Documentation ¶
Index ¶
- Variables
- func RegisterLogService(s grpc.ServiceRegistrar, srv *LogService)
- type ConsumeRequest
- type ConsumeResponse
- type ErrOffsetOutOfRange
- type GetServersRequest
- type GetServersResponse
- func (*GetServersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetServersResponse) GetServers() []*Server
- func (*GetServersResponse) ProtoMessage()
- func (x *GetServersResponse) ProtoReflect() protoreflect.Message
- func (x *GetServersResponse) Reset()
- func (x *GetServersResponse) String() string
- type LogClient
- type LogService
- type Log_ConsumeStreamClient
- type Log_ConsumeStreamServer
- type Log_ProduceStreamClient
- type Log_ProduceStreamServer
- type ProduceRequest
- type ProduceResponse
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetOffset() uint64
- func (x *Record) GetTerm() uint64
- func (x *Record) GetType() uint32
- func (x *Record) GetValue() []byte
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (x *Record) String() string
- type Server
Constants ¶
This section is empty.
Variables ¶
var File_api_v1_log_proto protoreflect.FileDescriptor
Functions ¶
func RegisterLogService ¶
func RegisterLogService(s grpc.ServiceRegistrar, srv *LogService)
RegisterLogService registers a service implementation with a gRPC server.
Types ¶
type ConsumeRequest ¶
type ConsumeRequest struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*ConsumeRequest) Descriptor
deprecated
func (*ConsumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.
func (*ConsumeRequest) GetOffset ¶
func (x *ConsumeRequest) GetOffset() uint64
func (*ConsumeRequest) ProtoMessage ¶
func (*ConsumeRequest) ProtoMessage()
func (*ConsumeRequest) ProtoReflect ¶
func (x *ConsumeRequest) ProtoReflect() protoreflect.Message
func (*ConsumeRequest) Reset ¶
func (x *ConsumeRequest) Reset()
func (*ConsumeRequest) String ¶
func (x *ConsumeRequest) String() string
type ConsumeResponse ¶
type ConsumeResponse struct { Record *Record `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"` // contains filtered or unexported fields }
func (*ConsumeResponse) Descriptor
deprecated
func (*ConsumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.
func (*ConsumeResponse) GetRecord ¶
func (x *ConsumeResponse) GetRecord() *Record
func (*ConsumeResponse) ProtoMessage ¶
func (*ConsumeResponse) ProtoMessage()
func (*ConsumeResponse) ProtoReflect ¶
func (x *ConsumeResponse) ProtoReflect() protoreflect.Message
func (*ConsumeResponse) Reset ¶
func (x *ConsumeResponse) Reset()
func (*ConsumeResponse) String ¶
func (x *ConsumeResponse) String() string
type ErrOffsetOutOfRange ¶
type ErrOffsetOutOfRange struct {
Offset uint64
}
func (ErrOffsetOutOfRange) Error ¶
func (e ErrOffsetOutOfRange) Error() string
func (ErrOffsetOutOfRange) GRPCStatus ¶
func (e ErrOffsetOutOfRange) GRPCStatus() *status.Status
type GetServersRequest ¶
type GetServersRequest struct {
// contains filtered or unexported fields
}
START: get_servers
func (*GetServersRequest) Descriptor
deprecated
func (*GetServersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServersRequest.ProtoReflect.Descriptor instead.
func (*GetServersRequest) ProtoMessage ¶
func (*GetServersRequest) ProtoMessage()
func (*GetServersRequest) ProtoReflect ¶
func (x *GetServersRequest) ProtoReflect() protoreflect.Message
func (*GetServersRequest) Reset ¶
func (x *GetServersRequest) Reset()
func (*GetServersRequest) String ¶
func (x *GetServersRequest) String() string
type GetServersResponse ¶
type GetServersResponse struct { Servers []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"` // contains filtered or unexported fields }
func (*GetServersResponse) Descriptor
deprecated
func (*GetServersResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServersResponse.ProtoReflect.Descriptor instead.
func (*GetServersResponse) GetServers ¶
func (x *GetServersResponse) GetServers() []*Server
func (*GetServersResponse) ProtoMessage ¶
func (*GetServersResponse) ProtoMessage()
func (*GetServersResponse) ProtoReflect ¶
func (x *GetServersResponse) ProtoReflect() protoreflect.Message
func (*GetServersResponse) Reset ¶
func (x *GetServersResponse) Reset()
func (*GetServersResponse) String ¶
func (x *GetServersResponse) String() string
type LogClient ¶
type LogClient interface { Produce(ctx context.Context, in *ProduceRequest, opts ...grpc.CallOption) (*ProduceResponse, error) Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error) ConsumeStream(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (Log_ConsumeStreamClient, error) ProduceStream(ctx context.Context, opts ...grpc.CallOption) (Log_ProduceStreamClient, error) GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error) }
LogClient is the client API for Log service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewLogClient ¶
func NewLogClient(cc grpc.ClientConnInterface) LogClient
type LogService ¶
type LogService struct { Produce func(context.Context, *ProduceRequest) (*ProduceResponse, error) Consume func(context.Context, *ConsumeRequest) (*ConsumeResponse, error) ConsumeStream func(*ConsumeRequest, Log_ConsumeStreamServer) error ProduceStream func(Log_ProduceStreamServer) error GetServers func(context.Context, *GetServersRequest) (*GetServersResponse, error) }
LogService is the service API for Log service. Fields should be assigned to their respective handler implementations only before RegisterLogService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.
type Log_ConsumeStreamClient ¶
type Log_ConsumeStreamClient interface { Recv() (*ConsumeResponse, error) grpc.ClientStream }
type Log_ConsumeStreamServer ¶
type Log_ConsumeStreamServer interface { Send(*ConsumeResponse) error grpc.ServerStream }
type Log_ProduceStreamClient ¶
type Log_ProduceStreamClient interface { Send(*ProduceRequest) error Recv() (*ProduceResponse, error) grpc.ClientStream }
type Log_ProduceStreamServer ¶
type Log_ProduceStreamServer interface { Send(*ProduceResponse) error Recv() (*ProduceRequest, error) grpc.ServerStream }
type ProduceRequest ¶
type ProduceRequest struct { Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // contains filtered or unexported fields }
func (*ProduceRequest) Descriptor
deprecated
func (*ProduceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProduceRequest.ProtoReflect.Descriptor instead.
func (*ProduceRequest) GetRecord ¶
func (x *ProduceRequest) GetRecord() *Record
func (*ProduceRequest) ProtoMessage ¶
func (*ProduceRequest) ProtoMessage()
func (*ProduceRequest) ProtoReflect ¶
func (x *ProduceRequest) ProtoReflect() protoreflect.Message
func (*ProduceRequest) Reset ¶
func (x *ProduceRequest) Reset()
func (*ProduceRequest) String ¶
func (x *ProduceRequest) String() string
type ProduceResponse ¶
type ProduceResponse struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*ProduceResponse) Descriptor
deprecated
func (*ProduceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProduceResponse.ProtoReflect.Descriptor instead.
func (*ProduceResponse) GetOffset ¶
func (x *ProduceResponse) GetOffset() uint64
func (*ProduceResponse) ProtoMessage ¶
func (*ProduceResponse) ProtoMessage()
func (*ProduceResponse) ProtoReflect ¶
func (x *ProduceResponse) ProtoReflect() protoreflect.Message
func (*ProduceResponse) Reset ¶
func (x *ProduceResponse) Reset()
func (*ProduceResponse) String ¶
func (x *ProduceResponse) String() string
type Record ¶
type Record struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Term uint64 `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"` Type uint32 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*Record) Descriptor
deprecated
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
type Server ¶
type Server struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` RpcAddr string `protobuf:"bytes,2,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"` IsLeader bool `protobuf:"varint,3,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"` // contains filtered or unexported fields }
func (*Server) Descriptor
deprecated
func (*Server) GetIsLeader ¶
func (*Server) GetRpcAddr ¶
func (*Server) ProtoMessage ¶
func (*Server) ProtoMessage()
func (*Server) ProtoReflect ¶
func (x *Server) ProtoReflect() protoreflect.Message