liiklus

package
v2.12.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 27, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
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

View Source 
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.

View Source 
var File_LiiklusService_proto protoreflect.FileDescriptor
View Source 
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) (LiiklusService_SubscribeClient, error)
	Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (LiiklusService_ReceiveClient, 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, LiiklusService_SubscribeServer) error
	Receive(*ReceiveRequest, LiiklusService_ReceiveServer) 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 interface {
	Recv() (*ReceiveReply, error)
	grpc.ClientStream
}

type LiiklusService_ReceiveServer 

type LiiklusService_ReceiveServer interface {
	Send(*ReceiveReply) error
	grpc.ServerStream
}

type LiiklusService_SubscribeClient 

type LiiklusService_SubscribeClient interface {
	Recv() (*SubscribeReply, error)
	grpc.ClientStream
}

type LiiklusService_SubscribeServer 

type LiiklusService_SubscribeServer interface {
	Send(*SubscribeReply) error
	grpc.ServerStream
}

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.

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, LiiklusService_ReceiveServer) error

func (UnimplementedLiiklusServiceServer) Subscribe added in v2.8.1 

func (UnimplementedLiiklusServiceServer) Subscribe(*SubscribeRequest, LiiklusService_SubscribeServer) 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.

Source Files

View all Source files

Directories

Path Synopsis
Package mock_liiklus is a generated GoMock package.
 Package mock_liiklus is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.