Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterLiiklusServiceServer(s grpc.ServiceRegistrar, srv LiiklusServiceServer)
- type AckRequest
- func (*AckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AckRequest) GetAssignment() *Assignmentdeprecated
- func (x *AckRequest) GetGroup() string
- func (x *AckRequest) GetGroupVersion() uint32
- func (x *AckRequest) GetOffset() uint64
- func (x *AckRequest) GetPartition() uint32
- func (x *AckRequest) GetTopic() string
- func (*AckRequest) ProtoMessage()
- func (x *AckRequest) ProtoReflect() protoreflect.Message
- func (x *AckRequest) Reset()
- func (x *AckRequest) String() string
- type Assignment
- func (*Assignment) Descriptor() ([]byte, []int)deprecated
- func (x *Assignment) GetPartition() uint32
- func (x *Assignment) GetSessionId() string
- func (*Assignment) ProtoMessage()
- func (x *Assignment) ProtoReflect() protoreflect.Message
- func (x *Assignment) Reset()
- func (x *Assignment) String() string
- type GetEndOffsetsReply
- func (*GetEndOffsetsReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetEndOffsetsReply) GetOffsets() map[uint32]uint64
- func (*GetEndOffsetsReply) ProtoMessage()
- func (x *GetEndOffsetsReply) ProtoReflect() protoreflect.Message
- func (x *GetEndOffsetsReply) Reset()
- func (x *GetEndOffsetsReply) String() string
- type GetEndOffsetsRequest
- func (*GetEndOffsetsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEndOffsetsRequest) GetTopic() string
- func (*GetEndOffsetsRequest) ProtoMessage()
- func (x *GetEndOffsetsRequest) ProtoReflect() protoreflect.Message
- func (x *GetEndOffsetsRequest) Reset()
- func (x *GetEndOffsetsRequest) String() string
- type GetOffsetsReply
- type GetOffsetsRequest
- func (*GetOffsetsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetOffsetsRequest) GetGroup() string
- func (x *GetOffsetsRequest) GetGroupVersion() uint32
- func (x *GetOffsetsRequest) GetTopic() string
- func (*GetOffsetsRequest) ProtoMessage()
- func (x *GetOffsetsRequest) ProtoReflect() protoreflect.Message
- func (x *GetOffsetsRequest) Reset()
- func (x *GetOffsetsRequest) String() string
- type LiiklusServiceClient
- type LiiklusServiceServer
- type LiiklusService_ReceiveClient
- type LiiklusService_ReceiveServer
- type LiiklusService_SubscribeClient
- type LiiklusService_SubscribeServer
- type PublishReply
- func (*PublishReply) Descriptor() ([]byte, []int)deprecated
- func (x *PublishReply) GetOffset() uint64
- func (x *PublishReply) GetPartition() uint32
- func (x *PublishReply) GetTopic() string
- func (*PublishReply) ProtoMessage()
- func (x *PublishReply) ProtoReflect() protoreflect.Message
- func (x *PublishReply) Reset()
- func (x *PublishReply) String() string
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishRequest) GetKey() []byte
- func (x *PublishRequest) GetTopic() string
- func (x *PublishRequest) GetValue() []byte
- func (*PublishRequest) ProtoMessage()
- func (x *PublishRequest) ProtoReflect() protoreflect.Message
- func (x *PublishRequest) Reset()
- func (x *PublishRequest) String() string
- type ReceiveReply
- func (*ReceiveReply) Descriptor() ([]byte, []int)deprecated
- func (x *ReceiveReply) GetRecord() *ReceiveReply_Record
- func (m *ReceiveReply) GetReply() isReceiveReply_Reply
- func (*ReceiveReply) ProtoMessage()
- func (x *ReceiveReply) ProtoReflect() protoreflect.Message
- func (x *ReceiveReply) Reset()
- func (x *ReceiveReply) String() string
- type ReceiveReply_Record
- func (*ReceiveReply_Record) Descriptor() ([]byte, []int)deprecated
- func (x *ReceiveReply_Record) GetKey() []byte
- func (x *ReceiveReply_Record) GetOffset() uint64
- func (x *ReceiveReply_Record) GetReplay() bool
- func (x *ReceiveReply_Record) GetTimestamp() *timestamppb.Timestamp
- func (x *ReceiveReply_Record) GetValue() []byte
- func (*ReceiveReply_Record) ProtoMessage()
- func (x *ReceiveReply_Record) ProtoReflect() protoreflect.Message
- func (x *ReceiveReply_Record) Reset()
- func (x *ReceiveReply_Record) String() string
- type ReceiveReply_Record_
- type ReceiveRequest
- func (*ReceiveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReceiveRequest) GetAssignment() *Assignment
- func (x *ReceiveRequest) GetLastKnownOffset() uint64
- func (*ReceiveRequest) ProtoMessage()
- func (x *ReceiveRequest) ProtoReflect() protoreflect.Message
- func (x *ReceiveRequest) Reset()
- func (x *ReceiveRequest) String() string
- type SubscribeReply
- func (*SubscribeReply) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeReply) GetAssignment() *Assignment
- func (m *SubscribeReply) GetReply() isSubscribeReply_Reply
- func (*SubscribeReply) ProtoMessage()
- func (x *SubscribeReply) ProtoReflect() protoreflect.Message
- func (x *SubscribeReply) Reset()
- func (x *SubscribeReply) String() string
- type SubscribeReply_Assignment
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeRequest) GetAutoOffsetReset() SubscribeRequest_AutoOffsetReset
- func (x *SubscribeRequest) GetGroup() string
- func (x *SubscribeRequest) GetGroupVersion() uint32
- func (x *SubscribeRequest) GetTopic() string
- func (*SubscribeRequest) ProtoMessage()
- func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeRequest) Reset()
- func (x *SubscribeRequest) String() string
- type SubscribeRequest_AutoOffsetReset
- func (SubscribeRequest_AutoOffsetReset) Descriptor() protoreflect.EnumDescriptor
- func (x SubscribeRequest_AutoOffsetReset) Enum() *SubscribeRequest_AutoOffsetReset
- func (SubscribeRequest_AutoOffsetReset) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscribeRequest_AutoOffsetReset) Number() protoreflect.EnumNumber
- func (x SubscribeRequest_AutoOffsetReset) String() string
- func (SubscribeRequest_AutoOffsetReset) Type() protoreflect.EnumType
- type UnimplementedLiiklusServiceServer
- func (UnimplementedLiiklusServiceServer) Ack(context.Context, *AckRequest) (*emptypb.Empty, error)
- func (UnimplementedLiiklusServiceServer) GetEndOffsets(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error)
- func (UnimplementedLiiklusServiceServer) GetOffsets(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error)
- func (UnimplementedLiiklusServiceServer) Publish(context.Context, *PublishRequest) (*PublishReply, error)
- func (UnimplementedLiiklusServiceServer) Receive(*ReceiveRequest, grpc.ServerStreamingServer[ReceiveReply]) error
- func (UnimplementedLiiklusServiceServer) Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[SubscribeReply]) error
- type UnsafeLiiklusServiceServer
Constants ¶
const ( LiiklusService_Publish_FullMethodName = "/com.github.bsideup.liiklus.LiiklusService/Publish" LiiklusService_Subscribe_FullMethodName = "/com.github.bsideup.liiklus.LiiklusService/Subscribe" LiiklusService_Receive_FullMethodName = "/com.github.bsideup.liiklus.LiiklusService/Receive" LiiklusService_Ack_FullMethodName = "/com.github.bsideup.liiklus.LiiklusService/Ack" LiiklusService_GetOffsets_FullMethodName = "/com.github.bsideup.liiklus.LiiklusService/GetOffsets" LiiklusService_GetEndOffsets_FullMethodName = "/com.github.bsideup.liiklus.LiiklusService/GetEndOffsets" )
Variables ¶
var ( SubscribeRequest_AutoOffsetReset_name = map[int32]string{ 0: "EARLIEST", 1: "LATEST", } SubscribeRequest_AutoOffsetReset_value = map[string]int32{ "EARLIEST": 0, "LATEST": 1, } )
Enum value maps for SubscribeRequest_AutoOffsetReset.
var File_LiiklusService_proto protoreflect.FileDescriptor
var LiiklusService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.github.bsideup.liiklus.LiiklusService", HandlerType: (*LiiklusServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Publish", Handler: _LiiklusService_Publish_Handler, }, { MethodName: "Ack", Handler: _LiiklusService_Ack_Handler, }, { MethodName: "GetOffsets", Handler: _LiiklusService_GetOffsets_Handler, }, { MethodName: "GetEndOffsets", Handler: _LiiklusService_GetEndOffsets_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Subscribe", Handler: _LiiklusService_Subscribe_Handler, ServerStreams: true, }, { StreamName: "Receive", Handler: _LiiklusService_Receive_Handler, ServerStreams: true, }, }, Metadata: "LiiklusService.proto", }
LiiklusService_ServiceDesc is the grpc.ServiceDesc for LiiklusService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLiiklusServiceServer ¶
func RegisterLiiklusServiceServer(s grpc.ServiceRegistrar, srv LiiklusServiceServer)
Types ¶
type AckRequest ¶
type AckRequest struct { // Deprecated: Marked as deprecated in LiiklusService.proto. Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"` Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` GroupVersion uint32 `protobuf:"varint,5,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` Partition uint32 `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*AckRequest) Descriptor
deprecated
func (*AckRequest) Descriptor() ([]byte, []int)
Deprecated: Use AckRequest.ProtoReflect.Descriptor instead.
func (*AckRequest) GetAssignment
deprecated
func (x *AckRequest) GetAssignment() *Assignment
Deprecated: Marked as deprecated in LiiklusService.proto.
func (*AckRequest) GetGroup ¶
func (x *AckRequest) GetGroup() string
func (*AckRequest) GetGroupVersion ¶
func (x *AckRequest) GetGroupVersion() uint32
func (*AckRequest) GetOffset ¶
func (x *AckRequest) GetOffset() uint64
func (*AckRequest) GetPartition ¶
func (x *AckRequest) GetPartition() uint32
func (*AckRequest) GetTopic ¶
func (x *AckRequest) GetTopic() string
func (*AckRequest) ProtoMessage ¶
func (*AckRequest) ProtoMessage()
func (*AckRequest) ProtoReflect ¶ added in v2.5.0
func (x *AckRequest) ProtoReflect() protoreflect.Message
func (*AckRequest) Reset ¶
func (x *AckRequest) Reset()
func (*AckRequest) String ¶
func (x *AckRequest) String() string
type Assignment ¶
type Assignment struct { SessionId string `protobuf:"bytes,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` Partition uint32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` // contains filtered or unexported fields }
func (*Assignment) Descriptor
deprecated
func (*Assignment) Descriptor() ([]byte, []int)
Deprecated: Use Assignment.ProtoReflect.Descriptor instead.
func (*Assignment) GetPartition ¶
func (x *Assignment) GetPartition() uint32
func (*Assignment) GetSessionId ¶
func (x *Assignment) GetSessionId() string
func (*Assignment) ProtoMessage ¶
func (*Assignment) ProtoMessage()
func (*Assignment) ProtoReflect ¶ added in v2.5.0
func (x *Assignment) ProtoReflect() protoreflect.Message
func (*Assignment) Reset ¶
func (x *Assignment) Reset()
func (*Assignment) String ¶
func (x *Assignment) String() string
type GetEndOffsetsReply ¶
type GetEndOffsetsReply struct { Offsets map[uint32]uint64 `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetEndOffsetsReply) Descriptor
deprecated
func (*GetEndOffsetsReply) Descriptor() ([]byte, []int)
Deprecated: Use GetEndOffsetsReply.ProtoReflect.Descriptor instead.
func (*GetEndOffsetsReply) GetOffsets ¶
func (x *GetEndOffsetsReply) GetOffsets() map[uint32]uint64
func (*GetEndOffsetsReply) ProtoMessage ¶
func (*GetEndOffsetsReply) ProtoMessage()
func (*GetEndOffsetsReply) ProtoReflect ¶ added in v2.5.0
func (x *GetEndOffsetsReply) ProtoReflect() protoreflect.Message
func (*GetEndOffsetsReply) Reset ¶
func (x *GetEndOffsetsReply) Reset()
func (*GetEndOffsetsReply) String ¶
func (x *GetEndOffsetsReply) String() string
type GetEndOffsetsRequest ¶
type GetEndOffsetsRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // contains filtered or unexported fields }
func (*GetEndOffsetsRequest) Descriptor
deprecated
func (*GetEndOffsetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEndOffsetsRequest.ProtoReflect.Descriptor instead.
func (*GetEndOffsetsRequest) GetTopic ¶
func (x *GetEndOffsetsRequest) GetTopic() string
func (*GetEndOffsetsRequest) ProtoMessage ¶
func (*GetEndOffsetsRequest) ProtoMessage()
func (*GetEndOffsetsRequest) ProtoReflect ¶ added in v2.5.0
func (x *GetEndOffsetsRequest) ProtoReflect() protoreflect.Message
func (*GetEndOffsetsRequest) Reset ¶
func (x *GetEndOffsetsRequest) Reset()
func (*GetEndOffsetsRequest) String ¶
func (x *GetEndOffsetsRequest) String() string
type GetOffsetsReply ¶
type GetOffsetsReply struct { Offsets map[uint32]uint64 `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetOffsetsReply) Descriptor
deprecated
func (*GetOffsetsReply) Descriptor() ([]byte, []int)
Deprecated: Use GetOffsetsReply.ProtoReflect.Descriptor instead.
func (*GetOffsetsReply) GetOffsets ¶
func (x *GetOffsetsReply) GetOffsets() map[uint32]uint64
func (*GetOffsetsReply) ProtoMessage ¶
func (*GetOffsetsReply) ProtoMessage()
func (*GetOffsetsReply) ProtoReflect ¶ added in v2.5.0
func (x *GetOffsetsReply) ProtoReflect() protoreflect.Message
func (*GetOffsetsReply) Reset ¶
func (x *GetOffsetsReply) Reset()
func (*GetOffsetsReply) String ¶
func (x *GetOffsetsReply) String() string
type GetOffsetsRequest ¶
type GetOffsetsRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` GroupVersion uint32 `protobuf:"varint,3,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` // contains filtered or unexported fields }
func (*GetOffsetsRequest) Descriptor
deprecated
func (*GetOffsetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetOffsetsRequest.ProtoReflect.Descriptor instead.
func (*GetOffsetsRequest) GetGroup ¶
func (x *GetOffsetsRequest) GetGroup() string
func (*GetOffsetsRequest) GetGroupVersion ¶
func (x *GetOffsetsRequest) GetGroupVersion() uint32
func (*GetOffsetsRequest) GetTopic ¶
func (x *GetOffsetsRequest) GetTopic() string
func (*GetOffsetsRequest) ProtoMessage ¶
func (*GetOffsetsRequest) ProtoMessage()
func (*GetOffsetsRequest) ProtoReflect ¶ added in v2.5.0
func (x *GetOffsetsRequest) ProtoReflect() protoreflect.Message
func (*GetOffsetsRequest) Reset ¶
func (x *GetOffsetsRequest) Reset()
func (*GetOffsetsRequest) String ¶
func (x *GetOffsetsRequest) String() string
type LiiklusServiceClient ¶
type LiiklusServiceClient interface { Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeReply], error) Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ReceiveReply], error) Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) GetOffsets(ctx context.Context, in *GetOffsetsRequest, opts ...grpc.CallOption) (*GetOffsetsReply, error) GetEndOffsets(ctx context.Context, in *GetEndOffsetsRequest, opts ...grpc.CallOption) (*GetEndOffsetsReply, error) }
LiiklusServiceClient is the client API for LiiklusService 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 NewLiiklusServiceClient ¶
func NewLiiklusServiceClient(cc grpc.ClientConnInterface) LiiklusServiceClient
type LiiklusServiceServer ¶
type LiiklusServiceServer interface { Publish(context.Context, *PublishRequest) (*PublishReply, error) Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[SubscribeReply]) error Receive(*ReceiveRequest, grpc.ServerStreamingServer[ReceiveReply]) error Ack(context.Context, *AckRequest) (*emptypb.Empty, error) GetOffsets(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error) GetEndOffsets(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error) // contains filtered or unexported methods }
LiiklusServiceServer is the server API for LiiklusService service. All implementations must embed UnimplementedLiiklusServiceServer for forward compatibility.
type LiiklusService_ReceiveClient ¶
type LiiklusService_ReceiveClient = grpc.ServerStreamingClient[ReceiveReply]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LiiklusService_ReceiveServer ¶
type LiiklusService_ReceiveServer = grpc.ServerStreamingServer[ReceiveReply]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LiiklusService_SubscribeClient ¶
type LiiklusService_SubscribeClient = grpc.ServerStreamingClient[SubscribeReply]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LiiklusService_SubscribeServer ¶
type LiiklusService_SubscribeServer = grpc.ServerStreamingServer[SubscribeReply]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type PublishReply ¶
type PublishReply struct { Partition uint32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` // contains filtered or unexported fields }
func (*PublishReply) Descriptor
deprecated
func (*PublishReply) Descriptor() ([]byte, []int)
Deprecated: Use PublishReply.ProtoReflect.Descriptor instead.
func (*PublishReply) GetOffset ¶
func (x *PublishReply) GetOffset() uint64
func (*PublishReply) GetPartition ¶
func (x *PublishReply) GetPartition() uint32
func (*PublishReply) GetTopic ¶
func (x *PublishReply) GetTopic() string
func (*PublishReply) ProtoMessage ¶
func (*PublishReply) ProtoMessage()
func (*PublishReply) ProtoReflect ¶ added in v2.5.0
func (x *PublishReply) ProtoReflect() protoreflect.Message
func (*PublishReply) Reset ¶
func (x *PublishReply) Reset()
func (*PublishReply) String ¶
func (x *PublishReply) String() string
type PublishRequest ¶
type PublishRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*PublishRequest) Descriptor
deprecated
func (*PublishRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.
func (*PublishRequest) GetKey ¶
func (x *PublishRequest) GetKey() []byte
func (*PublishRequest) GetTopic ¶
func (x *PublishRequest) GetTopic() string
func (*PublishRequest) GetValue ¶
func (x *PublishRequest) GetValue() []byte
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) ProtoReflect ¶ added in v2.5.0
func (x *PublishRequest) ProtoReflect() protoreflect.Message
func (*PublishRequest) Reset ¶
func (x *PublishRequest) Reset()
func (*PublishRequest) String ¶
func (x *PublishRequest) String() string
type ReceiveReply ¶
type ReceiveReply struct { // Types that are assignable to Reply: // // *ReceiveReply_Record_ Reply isReceiveReply_Reply `protobuf_oneof:"reply"` // contains filtered or unexported fields }
func (*ReceiveReply) Descriptor
deprecated
func (*ReceiveReply) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveReply.ProtoReflect.Descriptor instead.
func (*ReceiveReply) GetRecord ¶
func (x *ReceiveReply) GetRecord() *ReceiveReply_Record
func (*ReceiveReply) GetReply ¶
func (m *ReceiveReply) GetReply() isReceiveReply_Reply
func (*ReceiveReply) ProtoMessage ¶
func (*ReceiveReply) ProtoMessage()
func (*ReceiveReply) ProtoReflect ¶ added in v2.5.0
func (x *ReceiveReply) ProtoReflect() protoreflect.Message
func (*ReceiveReply) Reset ¶
func (x *ReceiveReply) Reset()
func (*ReceiveReply) String ¶
func (x *ReceiveReply) String() string
type ReceiveReply_Record ¶
type ReceiveReply_Record struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Replay bool `protobuf:"varint,5,opt,name=replay,proto3" json:"replay,omitempty"` // contains filtered or unexported fields }
func (*ReceiveReply_Record) Descriptor
deprecated
func (*ReceiveReply_Record) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveReply_Record.ProtoReflect.Descriptor instead.
func (*ReceiveReply_Record) GetKey ¶
func (x *ReceiveReply_Record) GetKey() []byte
func (*ReceiveReply_Record) GetOffset ¶
func (x *ReceiveReply_Record) GetOffset() uint64
func (*ReceiveReply_Record) GetReplay ¶
func (x *ReceiveReply_Record) GetReplay() bool
func (*ReceiveReply_Record) GetTimestamp ¶
func (x *ReceiveReply_Record) GetTimestamp() *timestamppb.Timestamp
func (*ReceiveReply_Record) GetValue ¶
func (x *ReceiveReply_Record) GetValue() []byte
func (*ReceiveReply_Record) ProtoMessage ¶
func (*ReceiveReply_Record) ProtoMessage()
func (*ReceiveReply_Record) ProtoReflect ¶ added in v2.5.0
func (x *ReceiveReply_Record) ProtoReflect() protoreflect.Message
func (*ReceiveReply_Record) Reset ¶
func (x *ReceiveReply_Record) Reset()
func (*ReceiveReply_Record) String ¶
func (x *ReceiveReply_Record) String() string
type ReceiveReply_Record_ ¶
type ReceiveReply_Record_ struct {
Record *ReceiveReply_Record `protobuf:"bytes,1,opt,name=record,proto3,oneof"`
}
type ReceiveRequest ¶
type ReceiveRequest struct { Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"` LastKnownOffset uint64 `protobuf:"varint,2,opt,name=lastKnownOffset,proto3" json:"lastKnownOffset,omitempty"` // contains filtered or unexported fields }
func (*ReceiveRequest) Descriptor
deprecated
func (*ReceiveRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveRequest.ProtoReflect.Descriptor instead.
func (*ReceiveRequest) GetAssignment ¶
func (x *ReceiveRequest) GetAssignment() *Assignment
func (*ReceiveRequest) GetLastKnownOffset ¶
func (x *ReceiveRequest) GetLastKnownOffset() uint64
func (*ReceiveRequest) ProtoMessage ¶
func (*ReceiveRequest) ProtoMessage()
func (*ReceiveRequest) ProtoReflect ¶ added in v2.5.0
func (x *ReceiveRequest) ProtoReflect() protoreflect.Message
func (*ReceiveRequest) Reset ¶
func (x *ReceiveRequest) Reset()
func (*ReceiveRequest) String ¶
func (x *ReceiveRequest) String() string
type SubscribeReply ¶
type SubscribeReply struct { // Types that are assignable to Reply: // // *SubscribeReply_Assignment Reply isSubscribeReply_Reply `protobuf_oneof:"reply"` // contains filtered or unexported fields }
func (*SubscribeReply) Descriptor
deprecated
func (*SubscribeReply) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeReply.ProtoReflect.Descriptor instead.
func (*SubscribeReply) GetAssignment ¶
func (x *SubscribeReply) GetAssignment() *Assignment
func (*SubscribeReply) GetReply ¶
func (m *SubscribeReply) GetReply() isSubscribeReply_Reply
func (*SubscribeReply) ProtoMessage ¶
func (*SubscribeReply) ProtoMessage()
func (*SubscribeReply) ProtoReflect ¶ added in v2.5.0
func (x *SubscribeReply) ProtoReflect() protoreflect.Message
func (*SubscribeReply) Reset ¶
func (x *SubscribeReply) Reset()
func (*SubscribeReply) String ¶
func (x *SubscribeReply) String() string
type SubscribeReply_Assignment ¶
type SubscribeReply_Assignment struct {
Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3,oneof"`
}
type SubscribeRequest ¶
type SubscribeRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` GroupVersion uint32 `protobuf:"varint,4,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"` AutoOffsetReset SubscribeRequest_AutoOffsetReset `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetAutoOffsetReset ¶
func (x *SubscribeRequest) GetAutoOffsetReset() SubscribeRequest_AutoOffsetReset
func (*SubscribeRequest) GetGroup ¶
func (x *SubscribeRequest) GetGroup() string
func (*SubscribeRequest) GetGroupVersion ¶
func (x *SubscribeRequest) GetGroupVersion() uint32
func (*SubscribeRequest) GetTopic ¶
func (x *SubscribeRequest) GetTopic() string
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶ added in v2.5.0
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SubscribeRequest_AutoOffsetReset ¶
type SubscribeRequest_AutoOffsetReset int32
const ( SubscribeRequest_EARLIEST SubscribeRequest_AutoOffsetReset = 0 SubscribeRequest_LATEST SubscribeRequest_AutoOffsetReset = 1 )
func (SubscribeRequest_AutoOffsetReset) Descriptor ¶ added in v2.5.0
func (SubscribeRequest_AutoOffsetReset) Descriptor() protoreflect.EnumDescriptor
func (SubscribeRequest_AutoOffsetReset) Enum ¶ added in v2.5.0
func (x SubscribeRequest_AutoOffsetReset) Enum() *SubscribeRequest_AutoOffsetReset
func (SubscribeRequest_AutoOffsetReset) EnumDescriptor
deprecated
func (SubscribeRequest_AutoOffsetReset) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest_AutoOffsetReset.Descriptor instead.
func (SubscribeRequest_AutoOffsetReset) Number ¶ added in v2.5.0
func (x SubscribeRequest_AutoOffsetReset) Number() protoreflect.EnumNumber
func (SubscribeRequest_AutoOffsetReset) String ¶
func (x SubscribeRequest_AutoOffsetReset) String() string
func (SubscribeRequest_AutoOffsetReset) Type ¶ added in v2.5.0
func (SubscribeRequest_AutoOffsetReset) Type() protoreflect.EnumType
type UnimplementedLiiklusServiceServer ¶ added in v2.8.1
type UnimplementedLiiklusServiceServer struct{}
UnimplementedLiiklusServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedLiiklusServiceServer) Ack ¶ added in v2.8.1
func (UnimplementedLiiklusServiceServer) Ack(context.Context, *AckRequest) (*emptypb.Empty, error)
func (UnimplementedLiiklusServiceServer) GetEndOffsets ¶ added in v2.8.1
func (UnimplementedLiiklusServiceServer) GetEndOffsets(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error)
func (UnimplementedLiiklusServiceServer) GetOffsets ¶ added in v2.8.1
func (UnimplementedLiiklusServiceServer) GetOffsets(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error)
func (UnimplementedLiiklusServiceServer) Publish ¶ added in v2.8.1
func (UnimplementedLiiklusServiceServer) Publish(context.Context, *PublishRequest) (*PublishReply, error)
func (UnimplementedLiiklusServiceServer) Receive ¶ added in v2.8.1
func (UnimplementedLiiklusServiceServer) Receive(*ReceiveRequest, grpc.ServerStreamingServer[ReceiveReply]) error
func (UnimplementedLiiklusServiceServer) Subscribe ¶ added in v2.8.1
func (UnimplementedLiiklusServiceServer) Subscribe(*SubscribeRequest, grpc.ServerStreamingServer[SubscribeReply]) error
type UnsafeLiiklusServiceServer ¶ added in v2.8.1
type UnsafeLiiklusServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLiiklusServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LiiklusServiceServer will result in compilation errors.