liiklus

package
v2.6.1 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

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

Functions

func RegisterLiiklusServiceService added in v2.5.0 

func RegisterLiiklusServiceService(s grpc.ServiceRegistrar, srv *LiiklusServiceService)

RegisterLiiklusServiceService registers a service implementation with a gRPC server.

Types

type AckRequest 

type AckRequest struct {

	// Deprecated: Do not use.
	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: Do not use.

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 LiiklusServiceService added in v2.5.0 

type LiiklusServiceService struct {
	Publish       func(context.Context, *PublishRequest) (*PublishReply, error)
	Subscribe     func(*SubscribeRequest, LiiklusService_SubscribeServer) error
	Receive       func(*ReceiveRequest, LiiklusService_ReceiveServer) error
	Ack           func(context.Context, *AckRequest) (*emptypb.Empty, error)
	GetOffsets    func(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error)
	GetEndOffsets func(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error)
}

LiiklusServiceService is the service API for LiiklusService service. Fields should be assigned to their respective handler implementations only before RegisterLiiklusServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.

func NewLiiklusServiceService added in v2.5.0 

func NewLiiklusServiceService(s interface{}) *LiiklusServiceService

NewLiiklusServiceService creates a new LiiklusServiceService containing the implemented methods of the LiiklusService service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.

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 UnstableLiiklusServiceService added in v2.5.0 

type UnstableLiiklusServiceService 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)
}

UnstableLiiklusServiceService is the service API for LiiklusService service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.

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.