liiklus

package
v2.0.2 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var SubscribeRequest_AutoOffsetReset_name = map[int32]string{
	0: "EARLIEST",
	1: "LATEST",
}
View Source 
var SubscribeRequest_AutoOffsetReset_value = map[string]int32{
	"EARLIEST": 0,
	"LATEST":   1,
}

Functions

func RegisterLiiklusServiceServer 

func RegisterLiiklusServiceServer(s *grpc.Server, srv LiiklusServiceServer)

Types

type AckRequest 

type AckRequest struct {
	Assignment           *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"` // Deprecated: Do not use.
	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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AckRequest) Descriptor 

func (*AckRequest) Descriptor() ([]byte, []int)

func (*AckRequest) GetAssignment deprecated 

func (m *AckRequest) GetAssignment() *Assignment

Deprecated: Do not use.

func (*AckRequest) GetGroup 

func (m *AckRequest) GetGroup() string

func (*AckRequest) GetGroupVersion 

func (m *AckRequest) GetGroupVersion() uint32

func (*AckRequest) GetOffset 

func (m *AckRequest) GetOffset() uint64

func (*AckRequest) GetPartition 

func (m *AckRequest) GetPartition() uint32

func (*AckRequest) GetTopic 

func (m *AckRequest) GetTopic() string

func (*AckRequest) ProtoMessage 

func (*AckRequest) ProtoMessage()

func (*AckRequest) Reset 

func (m *AckRequest) Reset()

func (*AckRequest) String 

func (m *AckRequest) String() string

func (*AckRequest) XXX_DiscardUnknown 

func (m *AckRequest) XXX_DiscardUnknown()

func (*AckRequest) XXX_Marshal 

func (m *AckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AckRequest) XXX_Merge 

func (m *AckRequest) XXX_Merge(src proto.Message)

func (*AckRequest) XXX_Size 

func (m *AckRequest) XXX_Size() int

func (*AckRequest) XXX_Unmarshal 

func (m *AckRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Assignment) Descriptor 

func (*Assignment) Descriptor() ([]byte, []int)

func (*Assignment) GetPartition 

func (m *Assignment) GetPartition() uint32

func (*Assignment) GetSessionId 

func (m *Assignment) GetSessionId() string

func (*Assignment) ProtoMessage 

func (*Assignment) ProtoMessage()

func (*Assignment) Reset 

func (m *Assignment) Reset()

func (*Assignment) String 

func (m *Assignment) String() string

func (*Assignment) XXX_DiscardUnknown 

func (m *Assignment) XXX_DiscardUnknown()

func (*Assignment) XXX_Marshal 

func (m *Assignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Assignment) XXX_Merge 

func (m *Assignment) XXX_Merge(src proto.Message)

func (*Assignment) XXX_Size 

func (m *Assignment) XXX_Size() int

func (*Assignment) XXX_Unmarshal 

func (m *Assignment) XXX_Unmarshal(b []byte) error

type GetEndOffsetsReply 

type GetEndOffsetsReply struct {
	Offsets              map[uint32]uint64 `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetEndOffsetsReply) Descriptor 

func (*GetEndOffsetsReply) Descriptor() ([]byte, []int)

func (*GetEndOffsetsReply) GetOffsets 

func (m *GetEndOffsetsReply) GetOffsets() map[uint32]uint64

func (*GetEndOffsetsReply) ProtoMessage 

func (*GetEndOffsetsReply) ProtoMessage()

func (*GetEndOffsetsReply) Reset 

func (m *GetEndOffsetsReply) Reset()

func (*GetEndOffsetsReply) String 

func (m *GetEndOffsetsReply) String() string

func (*GetEndOffsetsReply) XXX_DiscardUnknown 

func (m *GetEndOffsetsReply) XXX_DiscardUnknown()

func (*GetEndOffsetsReply) XXX_Marshal 

func (m *GetEndOffsetsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetEndOffsetsReply) XXX_Merge 

func (m *GetEndOffsetsReply) XXX_Merge(src proto.Message)

func (*GetEndOffsetsReply) XXX_Size 

func (m *GetEndOffsetsReply) XXX_Size() int

func (*GetEndOffsetsReply) XXX_Unmarshal 

func (m *GetEndOffsetsReply) XXX_Unmarshal(b []byte) error

type GetEndOffsetsRequest 

type GetEndOffsetsRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetEndOffsetsRequest) Descriptor 

func (*GetEndOffsetsRequest) Descriptor() ([]byte, []int)

func (*GetEndOffsetsRequest) GetTopic 

func (m *GetEndOffsetsRequest) GetTopic() string

func (*GetEndOffsetsRequest) ProtoMessage 

func (*GetEndOffsetsRequest) ProtoMessage()

func (*GetEndOffsetsRequest) Reset 

func (m *GetEndOffsetsRequest) Reset()

func (*GetEndOffsetsRequest) String 

func (m *GetEndOffsetsRequest) String() string

func (*GetEndOffsetsRequest) XXX_DiscardUnknown 

func (m *GetEndOffsetsRequest) XXX_DiscardUnknown()

func (*GetEndOffsetsRequest) XXX_Marshal 

func (m *GetEndOffsetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetEndOffsetsRequest) XXX_Merge 

func (m *GetEndOffsetsRequest) XXX_Merge(src proto.Message)

func (*GetEndOffsetsRequest) XXX_Size 

func (m *GetEndOffsetsRequest) XXX_Size() int

func (*GetEndOffsetsRequest) XXX_Unmarshal 

func (m *GetEndOffsetsRequest) XXX_Unmarshal(b []byte) error

type GetOffsetsReply 

type GetOffsetsReply struct {
	Offsets              map[uint32]uint64 `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetOffsetsReply) Descriptor 

func (*GetOffsetsReply) Descriptor() ([]byte, []int)

func (*GetOffsetsReply) GetOffsets 

func (m *GetOffsetsReply) GetOffsets() map[uint32]uint64

func (*GetOffsetsReply) ProtoMessage 

func (*GetOffsetsReply) ProtoMessage()

func (*GetOffsetsReply) Reset 

func (m *GetOffsetsReply) Reset()

func (*GetOffsetsReply) String 

func (m *GetOffsetsReply) String() string

func (*GetOffsetsReply) XXX_DiscardUnknown 

func (m *GetOffsetsReply) XXX_DiscardUnknown()

func (*GetOffsetsReply) XXX_Marshal 

func (m *GetOffsetsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOffsetsReply) XXX_Merge 

func (m *GetOffsetsReply) XXX_Merge(src proto.Message)

func (*GetOffsetsReply) XXX_Size 

func (m *GetOffsetsReply) XXX_Size() int

func (*GetOffsetsReply) XXX_Unmarshal 

func (m *GetOffsetsReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetOffsetsRequest) Descriptor 

func (*GetOffsetsRequest) Descriptor() ([]byte, []int)

func (*GetOffsetsRequest) GetGroup 

func (m *GetOffsetsRequest) GetGroup() string

func (*GetOffsetsRequest) GetGroupVersion 

func (m *GetOffsetsRequest) GetGroupVersion() uint32

func (*GetOffsetsRequest) GetTopic 

func (m *GetOffsetsRequest) GetTopic() string

func (*GetOffsetsRequest) ProtoMessage 

func (*GetOffsetsRequest) ProtoMessage()

func (*GetOffsetsRequest) Reset 

func (m *GetOffsetsRequest) Reset()

func (*GetOffsetsRequest) String 

func (m *GetOffsetsRequest) String() string

func (*GetOffsetsRequest) XXX_DiscardUnknown 

func (m *GetOffsetsRequest) XXX_DiscardUnknown()

func (*GetOffsetsRequest) XXX_Marshal 

func (m *GetOffsetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOffsetsRequest) XXX_Merge 

func (m *GetOffsetsRequest) XXX_Merge(src proto.Message)

func (*GetOffsetsRequest) XXX_Size 

func (m *GetOffsetsRequest) XXX_Size() int

func (*GetOffsetsRequest) XXX_Unmarshal 

func (m *GetOffsetsRequest) XXX_Unmarshal(b []byte) error

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) (*empty.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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLiiklusServiceClient 

func NewLiiklusServiceClient(cc *grpc.ClientConn) 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) (*empty.Empty, error)
	GetOffsets(context.Context, *GetOffsetsRequest) (*GetOffsetsReply, error)
	GetEndOffsets(context.Context, *GetEndOffsetsRequest) (*GetEndOffsetsReply, error)
}

LiiklusServiceServer is the server API for LiiklusService service.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishReply) Descriptor 

func (*PublishReply) Descriptor() ([]byte, []int)

func (*PublishReply) GetOffset 

func (m *PublishReply) GetOffset() uint64

func (*PublishReply) GetPartition 

func (m *PublishReply) GetPartition() uint32

func (*PublishReply) GetTopic 

func (m *PublishReply) GetTopic() string

func (*PublishReply) ProtoMessage 

func (*PublishReply) ProtoMessage()

func (*PublishReply) Reset 

func (m *PublishReply) Reset()

func (*PublishReply) String 

func (m *PublishReply) String() string

func (*PublishReply) XXX_DiscardUnknown 

func (m *PublishReply) XXX_DiscardUnknown()

func (*PublishReply) XXX_Marshal 

func (m *PublishReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishReply) XXX_Merge 

func (m *PublishReply) XXX_Merge(src proto.Message)

func (*PublishReply) XXX_Size 

func (m *PublishReply) XXX_Size() int

func (*PublishReply) XXX_Unmarshal 

func (m *PublishReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishRequest) Descriptor 

func (*PublishRequest) Descriptor() ([]byte, []int)

func (*PublishRequest) GetKey 

func (m *PublishRequest) GetKey() []byte

func (*PublishRequest) GetTopic 

func (m *PublishRequest) GetTopic() string

func (*PublishRequest) GetValue 

func (m *PublishRequest) GetValue() []byte

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRequest) XXX_Merge 

func (m *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

func (m *PublishRequest) XXX_Unmarshal(b []byte) error

type ReceiveReply 

type ReceiveReply struct {
	// Types that are valid to be assigned to Reply:
	//	*ReceiveReply_Record_
	Reply                isReceiveReply_Reply `protobuf_oneof:"reply"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReceiveReply) Descriptor 

func (*ReceiveReply) Descriptor() ([]byte, []int)

func (*ReceiveReply) GetRecord 

func (m *ReceiveReply) GetRecord() *ReceiveReply_Record

func (*ReceiveReply) GetReply 

func (m *ReceiveReply) GetReply() isReceiveReply_Reply

func (*ReceiveReply) ProtoMessage 

func (*ReceiveReply) ProtoMessage()

func (*ReceiveReply) Reset 

func (m *ReceiveReply) Reset()

func (*ReceiveReply) String 

func (m *ReceiveReply) String() string

func (*ReceiveReply) XXX_DiscardUnknown 

func (m *ReceiveReply) XXX_DiscardUnknown()

func (*ReceiveReply) XXX_Marshal 

func (m *ReceiveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReceiveReply) XXX_Merge 

func (m *ReceiveReply) XXX_Merge(src proto.Message)

func (*ReceiveReply) XXX_OneofWrappers 

func (*ReceiveReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReceiveReply) XXX_Size 

func (m *ReceiveReply) XXX_Size() int

func (*ReceiveReply) XXX_Unmarshal 

func (m *ReceiveReply) XXX_Unmarshal(b []byte) error

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            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Replay               bool                 `protobuf:"varint,5,opt,name=replay,proto3" json:"replay,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReceiveReply_Record) Descriptor 

func (*ReceiveReply_Record) Descriptor() ([]byte, []int)

func (*ReceiveReply_Record) GetKey 

func (m *ReceiveReply_Record) GetKey() []byte

func (*ReceiveReply_Record) GetOffset 

func (m *ReceiveReply_Record) GetOffset() uint64

func (*ReceiveReply_Record) GetReplay 

func (m *ReceiveReply_Record) GetReplay() bool

func (*ReceiveReply_Record) GetTimestamp 

func (m *ReceiveReply_Record) GetTimestamp() *timestamp.Timestamp

func (*ReceiveReply_Record) GetValue 

func (m *ReceiveReply_Record) GetValue() []byte

func (*ReceiveReply_Record) ProtoMessage 

func (*ReceiveReply_Record) ProtoMessage()

func (*ReceiveReply_Record) Reset 

func (m *ReceiveReply_Record) Reset()

func (*ReceiveReply_Record) String 

func (m *ReceiveReply_Record) String() string

func (*ReceiveReply_Record) XXX_DiscardUnknown 

func (m *ReceiveReply_Record) XXX_DiscardUnknown()

func (*ReceiveReply_Record) XXX_Marshal 

func (m *ReceiveReply_Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReceiveReply_Record) XXX_Merge 

func (m *ReceiveReply_Record) XXX_Merge(src proto.Message)

func (*ReceiveReply_Record) XXX_Size 

func (m *ReceiveReply_Record) XXX_Size() int

func (*ReceiveReply_Record) XXX_Unmarshal 

func (m *ReceiveReply_Record) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ReceiveRequest) Descriptor 

func (*ReceiveRequest) Descriptor() ([]byte, []int)

func (*ReceiveRequest) GetAssignment 

func (m *ReceiveRequest) GetAssignment() *Assignment

func (*ReceiveRequest) GetLastKnownOffset 

func (m *ReceiveRequest) GetLastKnownOffset() uint64

func (*ReceiveRequest) ProtoMessage 

func (*ReceiveRequest) ProtoMessage()

func (*ReceiveRequest) Reset 

func (m *ReceiveRequest) Reset()

func (*ReceiveRequest) String 

func (m *ReceiveRequest) String() string

func (*ReceiveRequest) XXX_DiscardUnknown 

func (m *ReceiveRequest) XXX_DiscardUnknown()

func (*ReceiveRequest) XXX_Marshal 

func (m *ReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReceiveRequest) XXX_Merge 

func (m *ReceiveRequest) XXX_Merge(src proto.Message)

func (*ReceiveRequest) XXX_Size 

func (m *ReceiveRequest) XXX_Size() int

func (*ReceiveRequest) XXX_Unmarshal 

func (m *ReceiveRequest) XXX_Unmarshal(b []byte) error

type SubscribeReply 

type SubscribeReply struct {
	// Types that are valid to be assigned to Reply:
	//	*SubscribeReply_Assignment
	Reply                isSubscribeReply_Reply `protobuf_oneof:"reply"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*SubscribeReply) Descriptor 

func (*SubscribeReply) Descriptor() ([]byte, []int)

func (*SubscribeReply) GetAssignment 

func (m *SubscribeReply) GetAssignment() *Assignment

func (*SubscribeReply) GetReply 

func (m *SubscribeReply) GetReply() isSubscribeReply_Reply

func (*SubscribeReply) ProtoMessage 

func (*SubscribeReply) ProtoMessage()

func (*SubscribeReply) Reset 

func (m *SubscribeReply) Reset()

func (*SubscribeReply) String 

func (m *SubscribeReply) String() string

func (*SubscribeReply) XXX_DiscardUnknown 

func (m *SubscribeReply) XXX_DiscardUnknown()

func (*SubscribeReply) XXX_Marshal 

func (m *SubscribeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeReply) XXX_Merge 

func (m *SubscribeReply) XXX_Merge(src proto.Message)

func (*SubscribeReply) XXX_OneofWrappers 

func (*SubscribeReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubscribeReply) XXX_Size 

func (m *SubscribeReply) XXX_Size() int

func (*SubscribeReply) XXX_Unmarshal 

func (m *SubscribeReply) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*SubscribeRequest) Descriptor 

func (*SubscribeRequest) Descriptor() ([]byte, []int)

func (*SubscribeRequest) GetAutoOffsetReset 

func (m *SubscribeRequest) GetAutoOffsetReset() SubscribeRequest_AutoOffsetReset

func (*SubscribeRequest) GetGroup 

func (m *SubscribeRequest) GetGroup() string

func (*SubscribeRequest) GetGroupVersion 

func (m *SubscribeRequest) GetGroupVersion() uint32

func (*SubscribeRequest) GetTopic 

func (m *SubscribeRequest) GetTopic() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeRequest) XXX_Merge 

func (m *SubscribeRequest) XXX_Merge(src proto.Message)

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

type SubscribeRequest_AutoOffsetReset 

type SubscribeRequest_AutoOffsetReset int32
const (
	SubscribeRequest_EARLIEST SubscribeRequest_AutoOffsetReset = 0
	SubscribeRequest_LATEST   SubscribeRequest_AutoOffsetReset = 1
)

func (SubscribeRequest_AutoOffsetReset) EnumDescriptor 

func (SubscribeRequest_AutoOffsetReset) EnumDescriptor() ([]byte, []int)

func (SubscribeRequest_AutoOffsetReset) String 

func (x SubscribeRequest_AutoOffsetReset) String() string

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.