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

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

        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

            Directories

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