Documentation
¶
Index ¶
- Variables
- func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)
- type ConsumeRequest
- type ConsumeResponse
- type ErrOffsetOutOfRange
- type LogClient
- type LogServer
- type Log_ConsumeStreamClient
- type Log_ConsumeStreamServer
- type Log_ProduceStreamClient
- type Log_ProduceStreamServer
- type ProduceRequest
- type ProduceResponse
- type Record
- 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 ¶
View Source
var File_api_v1_log_proto protoreflect.FileDescriptor
View Source
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"`
// 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,1,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 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"`
// 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"`
// 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 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.
Source Files
Click to show internal directories.
Click to hide internal directories.