Documentation ¶
Index ¶
- Variables
- func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)
- type ConsumeRequest
- func (*ConsumeRequest) Descriptor() ([]byte, []int)
- func (m *ConsumeRequest) GetOffset() uint64
- func (*ConsumeRequest) ProtoMessage()
- func (m *ConsumeRequest) Reset()
- func (m *ConsumeRequest) String() string
- func (m *ConsumeRequest) XXX_DiscardUnknown()
- func (m *ConsumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConsumeRequest) XXX_Merge(src proto.Message)
- func (m *ConsumeRequest) XXX_Size() int
- func (m *ConsumeRequest) XXX_Unmarshal(b []byte) error
- type ConsumeResponse
- func (*ConsumeResponse) Descriptor() ([]byte, []int)
- func (m *ConsumeResponse) GetRecord() *Record
- func (*ConsumeResponse) ProtoMessage()
- func (m *ConsumeResponse) Reset()
- func (m *ConsumeResponse) String() string
- func (m *ConsumeResponse) XXX_DiscardUnknown()
- func (m *ConsumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConsumeResponse) XXX_Merge(src proto.Message)
- func (m *ConsumeResponse) XXX_Size() int
- func (m *ConsumeResponse) XXX_Unmarshal(b []byte) error
- type ErrOffsetOutOfRange
- type LogClient
- type LogServer
- type Log_ConsumeStreamClient
- type Log_ConsumeStreamServer
- type Log_ProduceStreamClient
- type Log_ProduceStreamServer
- type ProduceRequest
- func (*ProduceRequest) Descriptor() ([]byte, []int)
- func (m *ProduceRequest) GetRecord() *Record
- func (*ProduceRequest) ProtoMessage()
- func (m *ProduceRequest) Reset()
- func (m *ProduceRequest) String() string
- func (m *ProduceRequest) XXX_DiscardUnknown()
- func (m *ProduceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProduceRequest) XXX_Merge(src proto.Message)
- func (m *ProduceRequest) XXX_Size() int
- func (m *ProduceRequest) XXX_Unmarshal(b []byte) error
- type ProduceResponse
- func (*ProduceResponse) Descriptor() ([]byte, []int)
- func (m *ProduceResponse) GetOffset() uint64
- func (*ProduceResponse) ProtoMessage()
- func (m *ProduceResponse) Reset()
- func (m *ProduceResponse) String() string
- func (m *ProduceResponse) XXX_DiscardUnknown()
- func (m *ProduceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProduceResponse) XXX_Merge(src proto.Message)
- func (m *ProduceResponse) XXX_Size() int
- func (m *ProduceResponse) XXX_Unmarshal(b []byte) error
- type Record
- func (*Record) Descriptor() ([]byte, []int)
- func (m *Record) GetOffset() uint64
- func (m *Record) GetTerm() uint64
- func (m *Record) GetType() uint32
- func (m *Record) GetValue() []byte
- func (*Record) ProtoMessage()
- func (m *Record) Reset()
- func (m *Record) String() string
- func (m *Record) XXX_DiscardUnknown()
- func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Record) XXX_Merge(src proto.Message)
- func (m *Record) XXX_Size() int
- func (m *Record) XXX_Unmarshal(b []byte) error
- type UnimplementedLogServer
- func (UnimplementedLogServer) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
- func (UnimplementedLogServer) ConsumeStream(*ConsumeRequest, Log_ConsumeStreamServer) error
- func (UnimplementedLogServer) Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
- func (UnimplementedLogServer) ProduceStream(Log_ProduceStreamServer) error
- type UnsafeLogServer
Constants ¶
This section is empty.
Variables ¶
var Log_ServiceDesc = grpc.ServiceDesc{ ServiceName: "log.v1.Log", HandlerType: (*LogServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Produce", Handler: _Log_Produce_Handler, }, { MethodName: "Consume", Handler: _Log_Consume_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ConsumeStream", Handler: _Log_ConsumeStream_Handler, ServerStreams: true, }, { StreamName: "ProduceStream", Handler: _Log_ProduceStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "api/v1/log.proto", }
Log_ServiceDesc is the grpc.ServiceDesc for Log service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLogServer ¶
func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)
Types ¶
type ConsumeRequest ¶
type ConsumeRequest struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConsumeRequest) Descriptor ¶
func (*ConsumeRequest) Descriptor() ([]byte, []int)
func (*ConsumeRequest) GetOffset ¶
func (m *ConsumeRequest) GetOffset() uint64
func (*ConsumeRequest) ProtoMessage ¶
func (*ConsumeRequest) ProtoMessage()
func (*ConsumeRequest) Reset ¶
func (m *ConsumeRequest) Reset()
func (*ConsumeRequest) String ¶
func (m *ConsumeRequest) String() string
func (*ConsumeRequest) XXX_DiscardUnknown ¶
func (m *ConsumeRequest) XXX_DiscardUnknown()
func (*ConsumeRequest) XXX_Marshal ¶
func (m *ConsumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConsumeRequest) XXX_Merge ¶
func (m *ConsumeRequest) XXX_Merge(src proto.Message)
func (*ConsumeRequest) XXX_Size ¶
func (m *ConsumeRequest) XXX_Size() int
func (*ConsumeRequest) XXX_Unmarshal ¶
func (m *ConsumeRequest) XXX_Unmarshal(b []byte) error
type ConsumeResponse ¶
type ConsumeResponse struct { Record *Record `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConsumeResponse) Descriptor ¶
func (*ConsumeResponse) Descriptor() ([]byte, []int)
func (*ConsumeResponse) GetRecord ¶
func (m *ConsumeResponse) GetRecord() *Record
func (*ConsumeResponse) ProtoMessage ¶
func (*ConsumeResponse) ProtoMessage()
func (*ConsumeResponse) Reset ¶
func (m *ConsumeResponse) Reset()
func (*ConsumeResponse) String ¶
func (m *ConsumeResponse) String() string
func (*ConsumeResponse) XXX_DiscardUnknown ¶
func (m *ConsumeResponse) XXX_DiscardUnknown()
func (*ConsumeResponse) XXX_Marshal ¶
func (m *ConsumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConsumeResponse) XXX_Merge ¶
func (m *ConsumeResponse) XXX_Merge(src proto.Message)
func (*ConsumeResponse) XXX_Size ¶
func (m *ConsumeResponse) XXX_Size() int
func (*ConsumeResponse) XXX_Unmarshal ¶
func (m *ConsumeResponse) XXX_Unmarshal(b []byte) error
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 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) }
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 LogServer ¶
type LogServer interface { Produce(context.Context, *ProduceRequest) (*ProduceResponse, error) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error) ConsumeStream(*ConsumeRequest, Log_ConsumeStreamServer) error ProduceStream(Log_ProduceStreamServer) error // contains filtered or unexported methods }
LogServer is the server API for Log service. All implementations must embed UnimplementedLogServer for forward compatibility
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProduceRequest) Descriptor ¶
func (*ProduceRequest) Descriptor() ([]byte, []int)
func (*ProduceRequest) GetRecord ¶
func (m *ProduceRequest) GetRecord() *Record
func (*ProduceRequest) ProtoMessage ¶
func (*ProduceRequest) ProtoMessage()
func (*ProduceRequest) Reset ¶
func (m *ProduceRequest) Reset()
func (*ProduceRequest) String ¶
func (m *ProduceRequest) String() string
func (*ProduceRequest) XXX_DiscardUnknown ¶
func (m *ProduceRequest) XXX_DiscardUnknown()
func (*ProduceRequest) XXX_Marshal ¶
func (m *ProduceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProduceRequest) XXX_Merge ¶
func (m *ProduceRequest) XXX_Merge(src proto.Message)
func (*ProduceRequest) XXX_Size ¶
func (m *ProduceRequest) XXX_Size() int
func (*ProduceRequest) XXX_Unmarshal ¶
func (m *ProduceRequest) XXX_Unmarshal(b []byte) error
type ProduceResponse ¶
type ProduceResponse struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProduceResponse) Descriptor ¶
func (*ProduceResponse) Descriptor() ([]byte, []int)
func (*ProduceResponse) GetOffset ¶
func (m *ProduceResponse) GetOffset() uint64
func (*ProduceResponse) ProtoMessage ¶
func (*ProduceResponse) ProtoMessage()
func (*ProduceResponse) Reset ¶
func (m *ProduceResponse) Reset()
func (*ProduceResponse) String ¶
func (m *ProduceResponse) String() string
func (*ProduceResponse) XXX_DiscardUnknown ¶
func (m *ProduceResponse) XXX_DiscardUnknown()
func (*ProduceResponse) XXX_Marshal ¶
func (m *ProduceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProduceResponse) XXX_Merge ¶
func (m *ProduceResponse) XXX_Merge(src proto.Message)
func (*ProduceResponse) XXX_Size ¶
func (m *ProduceResponse) XXX_Size() int
func (*ProduceResponse) XXX_Unmarshal ¶
func (m *ProduceResponse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Record) Descriptor ¶
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) XXX_DiscardUnknown ¶
func (m *Record) XXX_DiscardUnknown()
func (*Record) XXX_Marshal ¶
func (*Record) XXX_Unmarshal ¶
type UnimplementedLogServer ¶
type UnimplementedLogServer struct { }
UnimplementedLogServer must be embedded to have forward compatible implementations.
func (UnimplementedLogServer) Consume ¶
func (UnimplementedLogServer) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
func (UnimplementedLogServer) ConsumeStream ¶
func (UnimplementedLogServer) ConsumeStream(*ConsumeRequest, Log_ConsumeStreamServer) error
func (UnimplementedLogServer) Produce ¶
func (UnimplementedLogServer) Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
func (UnimplementedLogServer) ProduceStream ¶
func (UnimplementedLogServer) ProduceStream(Log_ProduceStreamServer) error
type UnsafeLogServer ¶
type UnsafeLogServer interface {
// contains filtered or unexported methods
}
UnsafeLogServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogServer will result in compilation errors.