package
0.0.0-20240428152024-68d93cbc010c
Repository: https://github.com/ayoyu/comlog.git
Documentation: pkg.go.dev
# Functions
No description provided by the author
No description provided by the author
# Constants
No description provided by the author
No description provided by the author
# Variables
ComLogRpc_ServiceDesc is the grpc.ServiceDesc for ComLogRpc service.
No description provided by the author
Enum value maps for IndexFlushSyncType_Type.
Enum value maps for IndexFlushSyncType_Type.
# Structs
AppendRecordResp represents the server response from appending a record.
BatchAppendResp represents the server response from appending a batch of records in the same rpc call.
No description provided by the author
BatchRecords represents a batch of `Record` to send.
CollectOffset represents the integer offset with which we can trigger the segments collection operation which will delete segements containing records older than the given collect offset.
IndexFlushSyncType specifies wheter flushing should be done synchronously or asynchronously regarding the index mmap linked to the active segment.
LogMetaData holds informations about the state of the log regarding the `segmentsSize` which is the actual number of segments, the `oldestOffset` and `lastOffset` which represents the first and the last registred offsets.
Offset represents the integer offset with which we can read a record from the log server.
ReadRecordResp represents the server response from reading a record.
Record represents the record data in bytes to send to the log server to be appended.
StreamAppendRecordResp represents the server stream response from appending a record from a batch append operation when using the `client.Send` api.
UnimplementedComLogRpcServer must be embedded to have forward compatible implementations.
# Interfaces
No description provided by the author
No description provided by the author
ComLogRpcClient is the client API for ComLogRpc service.
ComLogRpcServer is the server API for ComLogRpc service.
UnsafeComLogRpcServer may be embedded to opt out of forward compatibility for this service.
# Type aliases
No description provided by the author