protocol

package

Go to main page

Versions in this module

v1

v1.9.0

Sep 9, 2022

Changes in this version

type LeaveConsumerGroupOp

+ Expired bool

+ func (m *LeaveConsumerGroupOp) GetExpired() bool

v1.8.0

Mar 11, 2022

Changes in this version

+ type ChangeConsumerGroupCoordinatorOp struct

+ Coordinator string

+ GroupId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChangeConsumerGroupCoordinatorOp) Descriptor() ([]byte, []int)

+ func (*ChangeConsumerGroupCoordinatorOp) ProtoMessage()

+ func (m *ChangeConsumerGroupCoordinatorOp) GetCoordinator() string

+ func (m *ChangeConsumerGroupCoordinatorOp) GetGroupId() string

+ func (m *ChangeConsumerGroupCoordinatorOp) Marshal() (dAtA []byte, err error)

+ func (m *ChangeConsumerGroupCoordinatorOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ChangeConsumerGroupCoordinatorOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ChangeConsumerGroupCoordinatorOp) Reset()

+ func (m *ChangeConsumerGroupCoordinatorOp) Size() (n int)

+ func (m *ChangeConsumerGroupCoordinatorOp) String() string

+ func (m *ChangeConsumerGroupCoordinatorOp) Unmarshal(dAtA []byte) error

+ func (m *ChangeConsumerGroupCoordinatorOp) XXX_DiscardUnknown()

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

+ func (m *ChangeConsumerGroupCoordinatorOp) XXX_Merge(src proto.Message)

+ func (m *ChangeConsumerGroupCoordinatorOp) XXX_Size() int

+ func (m *ChangeConsumerGroupCoordinatorOp) XXX_Unmarshal(b []byte) error

+ type Consumer struct

+ Id string

+ Streams []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Consumer) Descriptor() ([]byte, []int)

+ func (*Consumer) ProtoMessage()

+ func (m *Consumer) GetId() string

+ func (m *Consumer) GetStreams() []string

+ func (m *Consumer) Marshal() (dAtA []byte, err error)

+ func (m *Consumer) MarshalTo(dAtA []byte) (int, error)

+ func (m *Consumer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Consumer) Reset()

+ func (m *Consumer) Size() (n int)

+ func (m *Consumer) String() string

+ func (m *Consumer) Unmarshal(dAtA []byte) error

+ func (m *Consumer) XXX_DiscardUnknown()

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

+ func (m *Consumer) XXX_Merge(src proto.Message)

+ func (m *Consumer) XXX_Size() int

+ func (m *Consumer) XXX_Unmarshal(b []byte) error

+ type ConsumerGroup struct

+ Coordinator string

+ Epoch uint64

+ Id string

+ Members []*Consumer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConsumerGroup) Descriptor() ([]byte, []int)

+ func (*ConsumerGroup) ProtoMessage()

+ func (m *ConsumerGroup) GetCoordinator() string

+ func (m *ConsumerGroup) GetEpoch() uint64

+ func (m *ConsumerGroup) GetId() string

+ func (m *ConsumerGroup) GetMembers() []*Consumer

+ func (m *ConsumerGroup) Marshal() (dAtA []byte, err error)

+ func (m *ConsumerGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConsumerGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConsumerGroup) Reset()

+ func (m *ConsumerGroup) Size() (n int)

+ func (m *ConsumerGroup) String() string

+ func (m *ConsumerGroup) Unmarshal(dAtA []byte) error

+ func (m *ConsumerGroup) XXX_DiscardUnknown()

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

+ func (m *ConsumerGroup) XXX_Merge(src proto.Message)

+ func (m *ConsumerGroup) XXX_Size() int

+ func (m *ConsumerGroup) XXX_Unmarshal(b []byte) error

+ type CreateConsumerGroupOp struct

+ ConsumerGroup *ConsumerGroup

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateConsumerGroupOp) Descriptor() ([]byte, []int)

+ func (*CreateConsumerGroupOp) ProtoMessage()

+ func (m *CreateConsumerGroupOp) GetConsumerGroup() *ConsumerGroup

+ func (m *CreateConsumerGroupOp) Marshal() (dAtA []byte, err error)

+ func (m *CreateConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *CreateConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateConsumerGroupOp) Reset()

+ func (m *CreateConsumerGroupOp) Size() (n int)

+ func (m *CreateConsumerGroupOp) String() string

+ func (m *CreateConsumerGroupOp) Unmarshal(dAtA []byte) error

+ func (m *CreateConsumerGroupOp) XXX_DiscardUnknown()

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

+ func (m *CreateConsumerGroupOp) XXX_Merge(src proto.Message)

+ func (m *CreateConsumerGroupOp) XXX_Size() int

+ func (m *CreateConsumerGroupOp) XXX_Unmarshal(b []byte) error

+ type JoinConsumerGroupOp struct

+ ConsumerId string

+ GroupId string

+ Streams []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JoinConsumerGroupOp) Descriptor() ([]byte, []int)

+ func (*JoinConsumerGroupOp) ProtoMessage()

+ func (m *JoinConsumerGroupOp) GetConsumerId() string

+ func (m *JoinConsumerGroupOp) GetGroupId() string

+ func (m *JoinConsumerGroupOp) GetStreams() []string

+ func (m *JoinConsumerGroupOp) Marshal() (dAtA []byte, err error)

+ func (m *JoinConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *JoinConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *JoinConsumerGroupOp) Reset()

+ func (m *JoinConsumerGroupOp) Size() (n int)

+ func (m *JoinConsumerGroupOp) String() string

+ func (m *JoinConsumerGroupOp) Unmarshal(dAtA []byte) error

+ func (m *JoinConsumerGroupOp) XXX_DiscardUnknown()

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

+ func (m *JoinConsumerGroupOp) XXX_Merge(src proto.Message)

+ func (m *JoinConsumerGroupOp) XXX_Size() int

+ func (m *JoinConsumerGroupOp) XXX_Unmarshal(b []byte) error

+ type LeaveConsumerGroupOp struct

+ ConsumerId string

+ GroupId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LeaveConsumerGroupOp) Descriptor() ([]byte, []int)

+ func (*LeaveConsumerGroupOp) ProtoMessage()

+ func (m *LeaveConsumerGroupOp) GetConsumerId() string

+ func (m *LeaveConsumerGroupOp) GetGroupId() string

+ func (m *LeaveConsumerGroupOp) Marshal() (dAtA []byte, err error)

+ func (m *LeaveConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaveConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LeaveConsumerGroupOp) Reset()

+ func (m *LeaveConsumerGroupOp) Size() (n int)

+ func (m *LeaveConsumerGroupOp) String() string

+ func (m *LeaveConsumerGroupOp) Unmarshal(dAtA []byte) error

+ func (m *LeaveConsumerGroupOp) XXX_DiscardUnknown()

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

+ func (m *LeaveConsumerGroupOp) XXX_Merge(src proto.Message)

+ func (m *LeaveConsumerGroupOp) XXX_Size() int

+ func (m *LeaveConsumerGroupOp) XXX_Unmarshal(b []byte) error

type MetadataSnapshot

+ Groups []*ConsumerGroup

+ func (m *MetadataSnapshot) GetGroups() []*ConsumerGroup

type Op

+ const Op_CHANGE_CONSUMER_GROUP_COORDINATOR

+ const Op_CREATE_CONSUMER_GROUP

+ const Op_JOIN_CONSUMER_GROUP

+ const Op_LEAVE_CONSUMER_GROUP

+ const Op_REPORT_CONSUMER_GROUP_COORDINATOR

type PropagatedRequest

+ JoinConsumerGroupOp *JoinConsumerGroupOp

+ LeaveConsumerGroupOp *LeaveConsumerGroupOp

+ ReportConsumerGroupCoordinatorOp *ReportConsumerGroupCoordinatorOp

+ func (m *PropagatedRequest) GetJoinConsumerGroupOp() *JoinConsumerGroupOp

+ func (m *PropagatedRequest) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp

+ func (m *PropagatedRequest) GetReportConsumerGroupCoordinatorOp() *ReportConsumerGroupCoordinatorOp

type PropagatedResponse

+ JoinConsumerGroupResp *PropagatedResponse_JoinConsumerGroupResponse

+ func (m *PropagatedResponse) GetJoinConsumerGroupResp() *PropagatedResponse_JoinConsumerGroupResponse

+ type PropagatedResponse_JoinConsumerGroupResponse struct

+ Coordinator string

+ Epoch uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PropagatedResponse_JoinConsumerGroupResponse) Descriptor() ([]byte, []int)

+ func (*PropagatedResponse_JoinConsumerGroupResponse) ProtoMessage()

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) GetCoordinator() string

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) GetEpoch() uint64

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) Marshal() (dAtA []byte, err error)

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) Reset()

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) Size() (n int)

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) String() string

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) Unmarshal(dAtA []byte) error

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_DiscardUnknown()

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

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_Merge(src proto.Message)

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_Size() int

+ func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_Unmarshal(b []byte) error

type RaftLog

+ ChangeConsumerGroupCoordinatorOp *ChangeConsumerGroupCoordinatorOp

+ CreateConsumerGroupOp *CreateConsumerGroupOp

+ JoinConsumerGroupOp *JoinConsumerGroupOp

+ LeaveConsumerGroupOp *LeaveConsumerGroupOp

+ ReportConsumerGroupCoordinatorOp *ReportConsumerGroupCoordinatorOp

+ func (m *RaftLog) GetChangeConsumerGroupCoordinatorOp() *ChangeConsumerGroupCoordinatorOp

+ func (m *RaftLog) GetCreateConsumerGroupOp() *CreateConsumerGroupOp

+ func (m *RaftLog) GetJoinConsumerGroupOp() *JoinConsumerGroupOp

+ func (m *RaftLog) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp

+ func (m *RaftLog) GetReportConsumerGroupCoordinatorOp() *ReportConsumerGroupCoordinatorOp

+ type ReportConsumerGroupCoordinatorOp struct

+ ConsumerId string

+ Coordinator string

+ Epoch uint64

+ GroupId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReportConsumerGroupCoordinatorOp) Descriptor() ([]byte, []int)

+ func (*ReportConsumerGroupCoordinatorOp) ProtoMessage()

+ func (m *ReportConsumerGroupCoordinatorOp) GetConsumerId() string

+ func (m *ReportConsumerGroupCoordinatorOp) GetCoordinator() string

+ func (m *ReportConsumerGroupCoordinatorOp) GetEpoch() uint64

+ func (m *ReportConsumerGroupCoordinatorOp) GetGroupId() string

+ func (m *ReportConsumerGroupCoordinatorOp) Marshal() (dAtA []byte, err error)

+ func (m *ReportConsumerGroupCoordinatorOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReportConsumerGroupCoordinatorOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReportConsumerGroupCoordinatorOp) Reset()

+ func (m *ReportConsumerGroupCoordinatorOp) Size() (n int)

+ func (m *ReportConsumerGroupCoordinatorOp) String() string

+ func (m *ReportConsumerGroupCoordinatorOp) Unmarshal(dAtA []byte) error

+ func (m *ReportConsumerGroupCoordinatorOp) XXX_DiscardUnknown()

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

+ func (m *ReportConsumerGroupCoordinatorOp) XXX_Merge(src proto.Message)

+ func (m *ReportConsumerGroupCoordinatorOp) XXX_Size() int

+ func (m *ReportConsumerGroupCoordinatorOp) XXX_Unmarshal(b []byte) error

v1.7.1

Jan 21, 2022

v1.7.0

Nov 8, 2021

v1.6.0

Jun 21, 2021

Changes in this version

type StreamConfig

+ Encryption *NullableBool

+ func (m *StreamConfig) GetEncryption() *NullableBool

v1.5.1

Feb 25, 2021

v1.5.0

Feb 12, 2021

Changes in this version

type StreamConfig

+ OptimisticConcurrencyControl *NullableBool

+ func (m *StreamConfig) GetOptimisticConcurrencyControl() *NullableBool

v1.4.1

Dec 22, 2020

v1.4.0

Dec 16, 2020

Changes in this version

type Partition

+ Readonly bool

+ func (m *Partition) GetReadonly() bool

type Stream

+ CreationTimestamp int64

+ func (m *Stream) GetCreationTimestamp() int64

v1.3.0

Oct 15, 2020

Changes in this version

+ type Cursor struct

+ CursorId string

+ Offset int64

+ Partition int32

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cursor) Descriptor() ([]byte, []int)

+ func (*Cursor) ProtoMessage()

+ func (m *Cursor) GetCursorId() string

+ func (m *Cursor) GetOffset() int64

+ func (m *Cursor) GetPartition() int32

+ func (m *Cursor) GetStream() string

+ func (m *Cursor) Marshal() (dAtA []byte, err error)

+ func (m *Cursor) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cursor) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Cursor) Reset()

+ func (m *Cursor) Size() (n int)

+ func (m *Cursor) String() string

+ func (m *Cursor) Unmarshal(dAtA []byte) error

+ func (m *Cursor) XXX_DiscardUnknown()

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

+ func (m *Cursor) XXX_Merge(src proto.Message)

+ func (m *Cursor) XXX_Size() int

+ func (m *Cursor) XXX_Unmarshal(b []byte) error

type Op

+ const Op_SET_STREAM_READONLY

type PropagatedRequest

+ SetStreamReadonlyOp *SetStreamReadonlyOp

+ func (m *PropagatedRequest) GetSetStreamReadonlyOp() *SetStreamReadonlyOp

type RaftLog

+ SetStreamReadonlyOp *SetStreamReadonlyOp

+ func (m *RaftLog) GetSetStreamReadonlyOp() *SetStreamReadonlyOp

+ type SetStreamReadonlyOp struct

+ Partitions []int32

+ Readonly bool

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetStreamReadonlyOp) Descriptor() ([]byte, []int)

+ func (*SetStreamReadonlyOp) ProtoMessage()

+ func (m *SetStreamReadonlyOp) GetPartitions() []int32

+ func (m *SetStreamReadonlyOp) GetReadonly() bool

+ func (m *SetStreamReadonlyOp) GetStream() string

+ func (m *SetStreamReadonlyOp) Marshal() (dAtA []byte, err error)

+ func (m *SetStreamReadonlyOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetStreamReadonlyOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetStreamReadonlyOp) Reset()

+ func (m *SetStreamReadonlyOp) Size() (n int)

+ func (m *SetStreamReadonlyOp) String() string

+ func (m *SetStreamReadonlyOp) Unmarshal(dAtA []byte) error

+ func (m *SetStreamReadonlyOp) XXX_DiscardUnknown()

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

+ func (m *SetStreamReadonlyOp) XXX_Merge(src proto.Message)

+ func (m *SetStreamReadonlyOp) XXX_Size() int

+ func (m *SetStreamReadonlyOp) XXX_Unmarshal(b []byte) error

type StreamConfig

+ AutoPauseDisableIfSubscribers *NullableBool

+ AutoPauseTime *NullableInt64

+ MinIsr *NullableInt32

+ func (m *StreamConfig) GetAutoPauseDisableIfSubscribers() *NullableBool

+ func (m *StreamConfig) GetAutoPauseTime() *NullableInt64

+ func (m *StreamConfig) GetMinIsr() *NullableInt32

v1.2.0

Jul 16, 2020

Changes in this version

+ var ErrUnexpectedEndOfGroupInternal = fmt.Errorf("proto: unexpected end of group")

type ChangeLeaderOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ChangeLeaderOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ChangeLeaderOp) XXX_DiscardUnknown()

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

+ func (m *ChangeLeaderOp) XXX_Merge(src proto.Message)

+ func (m *ChangeLeaderOp) XXX_Size() int

+ func (m *ChangeLeaderOp) XXX_Unmarshal(b []byte) error

type CreateStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *CreateStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateStreamOp) XXX_DiscardUnknown()

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

+ func (m *CreateStreamOp) XXX_Merge(src proto.Message)

+ func (m *CreateStreamOp) XXX_Size() int

+ func (m *CreateStreamOp) XXX_Unmarshal(b []byte) error

type DeleteStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DeleteStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteStreamOp) XXX_DiscardUnknown()

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

+ func (m *DeleteStreamOp) XXX_Merge(src proto.Message)

+ func (m *DeleteStreamOp) XXX_Size() int

+ func (m *DeleteStreamOp) XXX_Unmarshal(b []byte) error

type Error

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Error) XXX_DiscardUnknown()

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

+ func (m *Error) XXX_Merge(src proto.Message)

+ func (m *Error) XXX_Size() int

+ func (m *Error) XXX_Unmarshal(b []byte) error

type ExpandISROp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ExpandISROp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ExpandISROp) XXX_DiscardUnknown()

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

+ func (m *ExpandISROp) XXX_Merge(src proto.Message)

+ func (m *ExpandISROp) XXX_Size() int

+ func (m *ExpandISROp) XXX_Unmarshal(b []byte) error

type LeaderEpochOffsetRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *LeaderEpochOffsetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LeaderEpochOffsetRequest) XXX_DiscardUnknown()

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

+ func (m *LeaderEpochOffsetRequest) XXX_Merge(src proto.Message)

+ func (m *LeaderEpochOffsetRequest) XXX_Size() int

+ func (m *LeaderEpochOffsetRequest) XXX_Unmarshal(b []byte) error

type LeaderEpochOffsetResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *LeaderEpochOffsetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LeaderEpochOffsetResponse) XXX_DiscardUnknown()

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

+ func (m *LeaderEpochOffsetResponse) XXX_Merge(src proto.Message)

+ func (m *LeaderEpochOffsetResponse) XXX_Size() int

+ func (m *LeaderEpochOffsetResponse) XXX_Unmarshal(b []byte) error

type MetadataSnapshot

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MetadataSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MetadataSnapshot) XXX_DiscardUnknown()

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

+ func (m *MetadataSnapshot) XXX_Merge(src proto.Message)

+ func (m *MetadataSnapshot) XXX_Size() int

+ func (m *MetadataSnapshot) XXX_Unmarshal(b []byte) error

+ type NullableBool struct

+ Value bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NullableBool) Descriptor() ([]byte, []int)

+ func (*NullableBool) ProtoMessage()

+ func (m *NullableBool) GetValue() bool

+ func (m *NullableBool) Marshal() (dAtA []byte, err error)

+ func (m *NullableBool) MarshalTo(dAtA []byte) (int, error)

+ func (m *NullableBool) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NullableBool) Reset()

+ func (m *NullableBool) Size() (n int)

+ func (m *NullableBool) String() string

+ func (m *NullableBool) Unmarshal(dAtA []byte) error

+ func (m *NullableBool) XXX_DiscardUnknown()

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

+ func (m *NullableBool) XXX_Merge(src proto.Message)

+ func (m *NullableBool) XXX_Size() int

+ func (m *NullableBool) XXX_Unmarshal(b []byte) error

+ type NullableInt32 struct

+ Value int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NullableInt32) Descriptor() ([]byte, []int)

+ func (*NullableInt32) ProtoMessage()

+ func (m *NullableInt32) GetValue() int32

+ func (m *NullableInt32) Marshal() (dAtA []byte, err error)

+ func (m *NullableInt32) MarshalTo(dAtA []byte) (int, error)

+ func (m *NullableInt32) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NullableInt32) Reset()

+ func (m *NullableInt32) Size() (n int)

+ func (m *NullableInt32) String() string

+ func (m *NullableInt32) Unmarshal(dAtA []byte) error

+ func (m *NullableInt32) XXX_DiscardUnknown()

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

+ func (m *NullableInt32) XXX_Merge(src proto.Message)

+ func (m *NullableInt32) XXX_Size() int

+ func (m *NullableInt32) XXX_Unmarshal(b []byte) error

+ type NullableInt64 struct

+ Value int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NullableInt64) Descriptor() ([]byte, []int)

+ func (*NullableInt64) ProtoMessage()

+ func (m *NullableInt64) GetValue() int64

+ func (m *NullableInt64) Marshal() (dAtA []byte, err error)

+ func (m *NullableInt64) MarshalTo(dAtA []byte) (int, error)

+ func (m *NullableInt64) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NullableInt64) Reset()

+ func (m *NullableInt64) Size() (n int)

+ func (m *NullableInt64) String() string

+ func (m *NullableInt64) Unmarshal(dAtA []byte) error

+ func (m *NullableInt64) XXX_DiscardUnknown()

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

+ func (m *NullableInt64) XXX_Merge(src proto.Message)

+ func (m *NullableInt64) XXX_Size() int

+ func (m *NullableInt64) XXX_Unmarshal(b []byte) error

type Partition

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Partition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Partition) XXX_DiscardUnknown()

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

+ func (m *Partition) XXX_Merge(src proto.Message)

+ func (m *Partition) XXX_Size() int

+ func (m *Partition) XXX_Unmarshal(b []byte) error

type PartitionNotification

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PartitionNotification) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PartitionNotification) XXX_DiscardUnknown()

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

+ func (m *PartitionNotification) XXX_Merge(src proto.Message)

+ func (m *PartitionNotification) XXX_Size() int

+ func (m *PartitionNotification) XXX_Unmarshal(b []byte) error

type PartitionStatusRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PartitionStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PartitionStatusRequest) XXX_DiscardUnknown()

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

+ func (m *PartitionStatusRequest) XXX_Merge(src proto.Message)

+ func (m *PartitionStatusRequest) XXX_Size() int

+ func (m *PartitionStatusRequest) XXX_Unmarshal(b []byte) error

type PartitionStatusResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PartitionStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PartitionStatusResponse) XXX_DiscardUnknown()

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

+ func (m *PartitionStatusResponse) XXX_Merge(src proto.Message)

+ func (m *PartitionStatusResponse) XXX_Size() int

+ func (m *PartitionStatusResponse) XXX_Unmarshal(b []byte) error

type PauseStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PauseStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PauseStreamOp) XXX_DiscardUnknown()

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

+ func (m *PauseStreamOp) XXX_Merge(src proto.Message)

+ func (m *PauseStreamOp) XXX_Size() int

+ func (m *PauseStreamOp) XXX_Unmarshal(b []byte) error

type PropagatedRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PropagatedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PropagatedRequest) XXX_DiscardUnknown()

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

+ func (m *PropagatedRequest) XXX_Merge(src proto.Message)

+ func (m *PropagatedRequest) XXX_Size() int

+ func (m *PropagatedRequest) XXX_Unmarshal(b []byte) error

type PropagatedResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PropagatedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PropagatedResponse) XXX_DiscardUnknown()

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

+ func (m *PropagatedResponse) XXX_Merge(src proto.Message)

+ func (m *PropagatedResponse) XXX_Size() int

+ func (m *PropagatedResponse) XXX_Unmarshal(b []byte) error

type PublishActivityOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *PublishActivityOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishActivityOp) XXX_DiscardUnknown()

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

+ func (m *PublishActivityOp) XXX_Merge(src proto.Message)

+ func (m *PublishActivityOp) XXX_Size() int

+ func (m *PublishActivityOp) XXX_Unmarshal(b []byte) error

type RaftJoinRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RaftJoinRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RaftJoinRequest) XXX_DiscardUnknown()

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

+ func (m *RaftJoinRequest) XXX_Merge(src proto.Message)

+ func (m *RaftJoinRequest) XXX_Size() int

+ func (m *RaftJoinRequest) XXX_Unmarshal(b []byte) error

type RaftJoinResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RaftJoinResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RaftJoinResponse) XXX_DiscardUnknown()

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

+ func (m *RaftJoinResponse) XXX_Merge(src proto.Message)

+ func (m *RaftJoinResponse) XXX_Size() int

+ func (m *RaftJoinResponse) XXX_Unmarshal(b []byte) error

type RaftLog

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RaftLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RaftLog) XXX_DiscardUnknown()

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

+ func (m *RaftLog) XXX_Merge(src proto.Message)

+ func (m *RaftLog) XXX_Size() int

+ func (m *RaftLog) XXX_Unmarshal(b []byte) error

type ReplicationRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ReplicationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicationRequest) XXX_DiscardUnknown()

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

+ func (m *ReplicationRequest) XXX_Merge(src proto.Message)

+ func (m *ReplicationRequest) XXX_Size() int

+ func (m *ReplicationRequest) XXX_Unmarshal(b []byte) error

type ReportLeaderOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ReportLeaderOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReportLeaderOp) XXX_DiscardUnknown()

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

+ func (m *ReportLeaderOp) XXX_Merge(src proto.Message)

+ func (m *ReportLeaderOp) XXX_Size() int

+ func (m *ReportLeaderOp) XXX_Unmarshal(b []byte) error

type ResumeStreamOp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ResumeStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResumeStreamOp) XXX_DiscardUnknown()

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

+ func (m *ResumeStreamOp) XXX_Merge(src proto.Message)

+ func (m *ResumeStreamOp) XXX_Size() int

+ func (m *ResumeStreamOp) XXX_Unmarshal(b []byte) error

type ServerInfoRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ServerInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServerInfoRequest) XXX_DiscardUnknown()

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

+ func (m *ServerInfoRequest) XXX_Merge(src proto.Message)

+ func (m *ServerInfoRequest) XXX_Size() int

+ func (m *ServerInfoRequest) XXX_Unmarshal(b []byte) error

type ServerInfoResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ServerInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServerInfoResponse) XXX_DiscardUnknown()

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

+ func (m *ServerInfoResponse) XXX_Merge(src proto.Message)

+ func (m *ServerInfoResponse) XXX_Size() int

+ func (m *ServerInfoResponse) XXX_Unmarshal(b []byte) error

type ServerState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ServerState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServerState) XXX_DiscardUnknown()

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

+ func (m *ServerState) XXX_Merge(src proto.Message)

+ func (m *ServerState) XXX_Size() int

+ func (m *ServerState) XXX_Unmarshal(b []byte) error

type ShrinkISROp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ShrinkISROp) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShrinkISROp) XXX_DiscardUnknown()

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

+ func (m *ShrinkISROp) XXX_Merge(src proto.Message)

+ func (m *ShrinkISROp) XXX_Size() int

+ func (m *ShrinkISROp) XXX_Unmarshal(b []byte) error

type Stream

+ Config *StreamConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Stream) GetConfig() *StreamConfig

+ func (m *Stream) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Stream) XXX_DiscardUnknown()

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

+ func (m *Stream) XXX_Merge(src proto.Message)

+ func (m *Stream) XXX_Size() int

+ func (m *Stream) XXX_Unmarshal(b []byte) error

+ type StreamConfig struct

+ CleanerInterval *NullableInt64

+ CompactEnabled *NullableBool

+ CompactMaxGoroutines *NullableInt32

+ RetentionMaxAge *NullableInt64

+ RetentionMaxBytes *NullableInt64

+ RetentionMaxMessages *NullableInt64

+ SegmentMaxAge *NullableInt64

+ SegmentMaxBytes *NullableInt64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamConfig) Descriptor() ([]byte, []int)

+ func (*StreamConfig) ProtoMessage()

+ func (m *StreamConfig) GetCleanerInterval() *NullableInt64

+ func (m *StreamConfig) GetCompactEnabled() *NullableBool

+ func (m *StreamConfig) GetCompactMaxGoroutines() *NullableInt32

+ func (m *StreamConfig) GetRetentionMaxAge() *NullableInt64

+ func (m *StreamConfig) GetRetentionMaxBytes() *NullableInt64

+ func (m *StreamConfig) GetRetentionMaxMessages() *NullableInt64

+ func (m *StreamConfig) GetSegmentMaxAge() *NullableInt64

+ func (m *StreamConfig) GetSegmentMaxBytes() *NullableInt64

+ func (m *StreamConfig) Marshal() (dAtA []byte, err error)

+ func (m *StreamConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamConfig) Reset()

+ func (m *StreamConfig) Size() (n int)

+ func (m *StreamConfig) String() string

+ func (m *StreamConfig) Unmarshal(dAtA []byte) error

+ func (m *StreamConfig) XXX_DiscardUnknown()

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

+ func (m *StreamConfig) XXX_Merge(src proto.Message)

+ func (m *StreamConfig) XXX_Size() int

+ func (m *StreamConfig) XXX_Unmarshal(b []byte) error

v1.1.0

May 29, 2020

v1.0.0

Apr 28, 2020

Changes in this version

+ var Encoding = binary.BigEndian

+ var ErrIntOverflowInternal = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling")

+ var Op_name = map[int32]string

+ var Op_value = map[string]int32

+ func MarshalAck(ack *client.Ack) ([]byte, error)

+ func MarshalLeaderEpochOffsetRequest(req *LeaderEpochOffsetRequest) ([]byte, error)

+ func MarshalLeaderEpochOffsetResponse(req *LeaderEpochOffsetResponse) ([]byte, error)

+ func MarshalPartitionNotification(req *PartitionNotification) ([]byte, error)

+ func MarshalPartitionStatusRequest(req *PartitionStatusRequest) ([]byte, error)

+ func MarshalPartitionStatusResponse(resp *PartitionStatusResponse) ([]byte, error)

+ func MarshalPropagatedRequest(req *PropagatedRequest) ([]byte, error)

+ func MarshalPropagatedResponse(req *PropagatedResponse) ([]byte, error)

+ func MarshalPublish(msg *client.Message) ([]byte, error)

+ func MarshalRaftJoinRequest(req *RaftJoinRequest) ([]byte, error)

+ func MarshalRaftJoinResponse(req *RaftJoinResponse) ([]byte, error)

+ func MarshalReplicationRequest(req *ReplicationRequest) ([]byte, error)

+ func MarshalServerInfoRequest(req *ServerInfoRequest) ([]byte, error)

+ func MarshalServerInfoResponse(req *ServerInfoResponse) ([]byte, error)

+ func UnmarshalAck(data []byte) (*client.Ack, error)

+ func UnmarshalPublish(data []byte) (*client.Message, error)

+ func UnmarshalReplicationResponse(data []byte) (uint64, int64, []byte, error)

+ func WriteReplicationResponseHeader(buf *bytes.Buffer) int

+ type ChangeLeaderOp struct

+ Leader string

+ Partition int32

+ Stream string

+ func (*ChangeLeaderOp) Descriptor() ([]byte, []int)

+ func (*ChangeLeaderOp) ProtoMessage()

+ func (m *ChangeLeaderOp) GetLeader() string

+ func (m *ChangeLeaderOp) GetPartition() int32

+ func (m *ChangeLeaderOp) GetStream() string

+ func (m *ChangeLeaderOp) Marshal() (dAtA []byte, err error)

+ func (m *ChangeLeaderOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ChangeLeaderOp) Reset()

+ func (m *ChangeLeaderOp) Size() (n int)

+ func (m *ChangeLeaderOp) String() string

+ func (m *ChangeLeaderOp) Unmarshal(dAtA []byte) error

+ type CreateStreamOp struct

+ Stream *Stream

+ func (*CreateStreamOp) Descriptor() ([]byte, []int)

+ func (*CreateStreamOp) ProtoMessage()

+ func (m *CreateStreamOp) GetStream() *Stream

+ func (m *CreateStreamOp) Marshal() (dAtA []byte, err error)

+ func (m *CreateStreamOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *CreateStreamOp) Reset()

+ func (m *CreateStreamOp) Size() (n int)

+ func (m *CreateStreamOp) String() string

+ func (m *CreateStreamOp) Unmarshal(dAtA []byte) error

+ type DeleteStreamOp struct

+ Stream string

+ func (*DeleteStreamOp) Descriptor() ([]byte, []int)

+ func (*DeleteStreamOp) ProtoMessage()

+ func (m *DeleteStreamOp) GetStream() string

+ func (m *DeleteStreamOp) Marshal() (dAtA []byte, err error)

+ func (m *DeleteStreamOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteStreamOp) Reset()

+ func (m *DeleteStreamOp) Size() (n int)

+ func (m *DeleteStreamOp) String() string

+ func (m *DeleteStreamOp) Unmarshal(dAtA []byte) error

+ type Error struct

+ Code uint32

+ Msg string

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (m *Error) GetCode() uint32

+ func (m *Error) GetMsg() string

+ func (m *Error) Marshal() (dAtA []byte, err error)

+ func (m *Error) MarshalTo(dAtA []byte) (int, error)

+ func (m *Error) Reset()

+ func (m *Error) Size() (n int)

+ func (m *Error) String() string

+ func (m *Error) Unmarshal(dAtA []byte) error

+ type ExpandISROp struct

+ Leader string

+ LeaderEpoch uint64

+ Partition int32

+ ReplicaToAdd string

+ Stream string

+ func (*ExpandISROp) Descriptor() ([]byte, []int)

+ func (*ExpandISROp) ProtoMessage()

+ func (m *ExpandISROp) GetLeader() string

+ func (m *ExpandISROp) GetLeaderEpoch() uint64

+ func (m *ExpandISROp) GetPartition() int32

+ func (m *ExpandISROp) GetReplicaToAdd() string

+ func (m *ExpandISROp) GetStream() string

+ func (m *ExpandISROp) Marshal() (dAtA []byte, err error)

+ func (m *ExpandISROp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExpandISROp) Reset()

+ func (m *ExpandISROp) Size() (n int)

+ func (m *ExpandISROp) String() string

+ func (m *ExpandISROp) Unmarshal(dAtA []byte) error

+ type LeaderEpochOffsetRequest struct

+ LeaderEpoch uint64

+ func UnmarshalLeaderEpochOffsetRequest(data []byte) (*LeaderEpochOffsetRequest, error)

+ func (*LeaderEpochOffsetRequest) Descriptor() ([]byte, []int)

+ func (*LeaderEpochOffsetRequest) ProtoMessage()

+ func (m *LeaderEpochOffsetRequest) GetLeaderEpoch() uint64

+ func (m *LeaderEpochOffsetRequest) Marshal() (dAtA []byte, err error)

+ func (m *LeaderEpochOffsetRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaderEpochOffsetRequest) Reset()

+ func (m *LeaderEpochOffsetRequest) Size() (n int)

+ func (m *LeaderEpochOffsetRequest) String() string

+ func (m *LeaderEpochOffsetRequest) Unmarshal(dAtA []byte) error

+ type LeaderEpochOffsetResponse struct

+ EndOffset int64

+ func UnmarshalLeaderEpochOffsetResponse(data []byte) (*LeaderEpochOffsetResponse, error)

+ func (*LeaderEpochOffsetResponse) Descriptor() ([]byte, []int)

+ func (*LeaderEpochOffsetResponse) ProtoMessage()

+ func (m *LeaderEpochOffsetResponse) GetEndOffset() int64

+ func (m *LeaderEpochOffsetResponse) Marshal() (dAtA []byte, err error)

+ func (m *LeaderEpochOffsetResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaderEpochOffsetResponse) Reset()

+ func (m *LeaderEpochOffsetResponse) Size() (n int)

+ func (m *LeaderEpochOffsetResponse) String() string

+ func (m *LeaderEpochOffsetResponse) Unmarshal(dAtA []byte) error

+ type MetadataSnapshot struct

+ Streams []*Stream

+ func (*MetadataSnapshot) Descriptor() ([]byte, []int)

+ func (*MetadataSnapshot) ProtoMessage()

+ func (m *MetadataSnapshot) GetStreams() []*Stream

+ func (m *MetadataSnapshot) Marshal() (dAtA []byte, err error)

+ func (m *MetadataSnapshot) MarshalTo(dAtA []byte) (int, error)

+ func (m *MetadataSnapshot) Reset()

+ func (m *MetadataSnapshot) Size() (n int)

+ func (m *MetadataSnapshot) String() string

+ func (m *MetadataSnapshot) Unmarshal(dAtA []byte) error

+ type Op int32

+ const Op_CHANGE_LEADER

+ const Op_CREATE_STREAM

+ const Op_DELETE_STREAM

+ const Op_EXPAND_ISR

+ const Op_PAUSE_STREAM

+ const Op_PUBLISH_ACTIVITY

+ const Op_REPORT_LEADER

+ const Op_RESUME_STREAM

+ const Op_SHRINK_ISR

+ func (Op) EnumDescriptor() ([]byte, []int)

+ func (x Op) String() string

+ type Partition struct

+ Epoch uint64

+ Group string

+ Id int32

+ Isr []string

+ Leader string

+ LeaderEpoch uint64

+ Paused bool

+ Replicas []string

+ ReplicationFactor int32

+ Stream string

+ Subject string

+ func (*Partition) Descriptor() ([]byte, []int)

+ func (*Partition) ProtoMessage()

+ func (m *Partition) GetEpoch() uint64

+ func (m *Partition) GetGroup() string

+ func (m *Partition) GetId() int32

+ func (m *Partition) GetIsr() []string

+ func (m *Partition) GetLeader() string

+ func (m *Partition) GetLeaderEpoch() uint64

+ func (m *Partition) GetPaused() bool

+ func (m *Partition) GetReplicas() []string

+ func (m *Partition) GetReplicationFactor() int32

+ func (m *Partition) GetStream() string

+ func (m *Partition) GetSubject() string

+ func (m *Partition) Marshal() (dAtA []byte, err error)

+ func (m *Partition) MarshalTo(dAtA []byte) (int, error)

+ func (m *Partition) Reset()

+ func (m *Partition) Size() (n int)

+ func (m *Partition) String() string

+ func (m *Partition) Unmarshal(dAtA []byte) error

+ type PartitionNotification struct

+ Partition int32

+ Stream string

+ func UnmarshalPartitionNotification(data []byte) (*PartitionNotification, error)

+ func (*PartitionNotification) Descriptor() ([]byte, []int)

+ func (*PartitionNotification) ProtoMessage()

+ func (m *PartitionNotification) GetPartition() int32

+ func (m *PartitionNotification) GetStream() string

+ func (m *PartitionNotification) Marshal() (dAtA []byte, err error)

+ func (m *PartitionNotification) MarshalTo(dAtA []byte) (int, error)

+ func (m *PartitionNotification) Reset()

+ func (m *PartitionNotification) Size() (n int)

+ func (m *PartitionNotification) String() string

+ func (m *PartitionNotification) Unmarshal(dAtA []byte) error

+ type PartitionStatusRequest struct

+ Partition int32

+ Stream string

+ func UnmarshalPartitionStatusRequest(data []byte) (*PartitionStatusRequest, error)

+ func (*PartitionStatusRequest) Descriptor() ([]byte, []int)

+ func (*PartitionStatusRequest) ProtoMessage()

+ func (m *PartitionStatusRequest) GetPartition() int32

+ func (m *PartitionStatusRequest) GetStream() string

+ func (m *PartitionStatusRequest) Marshal() (dAtA []byte, err error)

+ func (m *PartitionStatusRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PartitionStatusRequest) Reset()

+ func (m *PartitionStatusRequest) Size() (n int)

+ func (m *PartitionStatusRequest) String() string

+ func (m *PartitionStatusRequest) Unmarshal(dAtA []byte) error

+ type PartitionStatusResponse struct

+ Exists bool

+ IsLeader bool

+ func UnmarshalPartitionStatusResponse(data []byte) (*PartitionStatusResponse, error)

+ func (*PartitionStatusResponse) Descriptor() ([]byte, []int)

+ func (*PartitionStatusResponse) ProtoMessage()

+ func (m *PartitionStatusResponse) GetExists() bool

+ func (m *PartitionStatusResponse) GetIsLeader() bool

+ func (m *PartitionStatusResponse) Marshal() (dAtA []byte, err error)

+ func (m *PartitionStatusResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PartitionStatusResponse) Reset()

+ func (m *PartitionStatusResponse) Size() (n int)

+ func (m *PartitionStatusResponse) String() string

+ func (m *PartitionStatusResponse) Unmarshal(dAtA []byte) error

+ type PauseStreamOp struct

+ Partitions []int32

+ ResumeAll bool

+ Stream string

+ func (*PauseStreamOp) Descriptor() ([]byte, []int)

+ func (*PauseStreamOp) ProtoMessage()

+ func (m *PauseStreamOp) GetPartitions() []int32

+ func (m *PauseStreamOp) GetResumeAll() bool

+ func (m *PauseStreamOp) GetStream() string

+ func (m *PauseStreamOp) Marshal() (dAtA []byte, err error)

+ func (m *PauseStreamOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *PauseStreamOp) Reset()

+ func (m *PauseStreamOp) Size() (n int)

+ func (m *PauseStreamOp) String() string

+ func (m *PauseStreamOp) Unmarshal(dAtA []byte) error

+ type PropagatedRequest struct

+ CreateStreamOp *CreateStreamOp

+ DeleteStreamOp *DeleteStreamOp

+ ExpandISROp *ExpandISROp

+ Op Op

+ PauseStreamOp *PauseStreamOp

+ ReportLeaderOp *ReportLeaderOp

+ ResumeStreamOp *ResumeStreamOp

+ ShrinkISROp *ShrinkISROp

+ func UnmarshalPropagatedRequest(data []byte) (*PropagatedRequest, error)

+ func (*PropagatedRequest) Descriptor() ([]byte, []int)

+ func (*PropagatedRequest) ProtoMessage()

+ func (m *PropagatedRequest) GetCreateStreamOp() *CreateStreamOp

+ func (m *PropagatedRequest) GetDeleteStreamOp() *DeleteStreamOp

+ func (m *PropagatedRequest) GetExpandISROp() *ExpandISROp

+ func (m *PropagatedRequest) GetOp() Op

+ func (m *PropagatedRequest) GetPauseStreamOp() *PauseStreamOp

+ func (m *PropagatedRequest) GetReportLeaderOp() *ReportLeaderOp

+ func (m *PropagatedRequest) GetResumeStreamOp() *ResumeStreamOp

+ func (m *PropagatedRequest) GetShrinkISROp() *ShrinkISROp

+ func (m *PropagatedRequest) Marshal() (dAtA []byte, err error)

+ func (m *PropagatedRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PropagatedRequest) Reset()

+ func (m *PropagatedRequest) Size() (n int)

+ func (m *PropagatedRequest) String() string

+ func (m *PropagatedRequest) Unmarshal(dAtA []byte) error

+ type PropagatedResponse struct

+ Error *Error

+ Op Op

+ func UnmarshalPropagatedResponse(data []byte) (*PropagatedResponse, error)

+ func (*PropagatedResponse) Descriptor() ([]byte, []int)

+ func (*PropagatedResponse) ProtoMessage()

+ func (m *PropagatedResponse) GetError() *Error

+ func (m *PropagatedResponse) GetOp() Op

+ func (m *PropagatedResponse) Marshal() (dAtA []byte, err error)

+ func (m *PropagatedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PropagatedResponse) Reset()

+ func (m *PropagatedResponse) Size() (n int)

+ func (m *PropagatedResponse) String() string

+ func (m *PropagatedResponse) Unmarshal(dAtA []byte) error

+ type PublishActivityOp struct

+ RaftIndex uint64

+ func (*PublishActivityOp) Descriptor() ([]byte, []int)

+ func (*PublishActivityOp) ProtoMessage()

+ func (m *PublishActivityOp) GetRaftIndex() uint64

+ func (m *PublishActivityOp) Marshal() (dAtA []byte, err error)

+ func (m *PublishActivityOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *PublishActivityOp) Reset()

+ func (m *PublishActivityOp) Size() (n int)

+ func (m *PublishActivityOp) String() string

+ func (m *PublishActivityOp) Unmarshal(dAtA []byte) error

+ type RaftJoinRequest struct

+ NodeAddr string

+ NodeID string

+ func UnmarshalRaftJoinRequest(data []byte) (*RaftJoinRequest, error)

+ func (*RaftJoinRequest) Descriptor() ([]byte, []int)

+ func (*RaftJoinRequest) ProtoMessage()

+ func (m *RaftJoinRequest) GetNodeAddr() string

+ func (m *RaftJoinRequest) GetNodeID() string

+ func (m *RaftJoinRequest) Marshal() (dAtA []byte, err error)

+ func (m *RaftJoinRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftJoinRequest) Reset()

+ func (m *RaftJoinRequest) Size() (n int)

+ func (m *RaftJoinRequest) String() string

+ func (m *RaftJoinRequest) Unmarshal(dAtA []byte) error

+ type RaftJoinResponse struct

+ Error string

+ func UnmarshalRaftJoinResponse(data []byte) (*RaftJoinResponse, error)

+ func (*RaftJoinResponse) Descriptor() ([]byte, []int)

+ func (*RaftJoinResponse) ProtoMessage()

+ func (m *RaftJoinResponse) GetError() string

+ func (m *RaftJoinResponse) Marshal() (dAtA []byte, err error)

+ func (m *RaftJoinResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftJoinResponse) Reset()

+ func (m *RaftJoinResponse) Size() (n int)

+ func (m *RaftJoinResponse) String() string

+ func (m *RaftJoinResponse) Unmarshal(dAtA []byte) error

+ type RaftLog struct

+ ChangeLeaderOp *ChangeLeaderOp

+ CreateStreamOp *CreateStreamOp

+ DeleteStreamOp *DeleteStreamOp

+ ExpandISROp *ExpandISROp

+ Op Op

+ PauseStreamOp *PauseStreamOp

+ PublishActivityOp *PublishActivityOp

+ ResumeStreamOp *ResumeStreamOp

+ ShrinkISROp *ShrinkISROp

+ func (*RaftLog) Descriptor() ([]byte, []int)

+ func (*RaftLog) ProtoMessage()

+ func (m *RaftLog) GetChangeLeaderOp() *ChangeLeaderOp

+ func (m *RaftLog) GetCreateStreamOp() *CreateStreamOp

+ func (m *RaftLog) GetDeleteStreamOp() *DeleteStreamOp

+ func (m *RaftLog) GetExpandISROp() *ExpandISROp

+ func (m *RaftLog) GetOp() Op

+ func (m *RaftLog) GetPauseStreamOp() *PauseStreamOp

+ func (m *RaftLog) GetPublishActivityOp() *PublishActivityOp

+ func (m *RaftLog) GetResumeStreamOp() *ResumeStreamOp

+ func (m *RaftLog) GetShrinkISROp() *ShrinkISROp

+ func (m *RaftLog) Marshal() (dAtA []byte, err error)

+ func (m *RaftLog) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftLog) Reset()

+ func (m *RaftLog) Size() (n int)

+ func (m *RaftLog) String() string

+ func (m *RaftLog) Unmarshal(dAtA []byte) error

+ type ReplicationRequest struct

+ LeaderEpoch uint64

+ Offset int64

+ ReplicaID string

+ func UnmarshalReplicationRequest(data []byte) (*ReplicationRequest, error)

+ func (*ReplicationRequest) Descriptor() ([]byte, []int)

+ func (*ReplicationRequest) ProtoMessage()

+ func (m *ReplicationRequest) GetLeaderEpoch() uint64

+ func (m *ReplicationRequest) GetOffset() int64

+ func (m *ReplicationRequest) GetReplicaID() string

+ func (m *ReplicationRequest) Marshal() (dAtA []byte, err error)

+ func (m *ReplicationRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicationRequest) Reset()

+ func (m *ReplicationRequest) Size() (n int)

+ func (m *ReplicationRequest) String() string

+ func (m *ReplicationRequest) Unmarshal(dAtA []byte) error

+ type ReportLeaderOp struct

+ Leader string

+ LeaderEpoch uint64

+ Partition int32

+ Replica string

+ Stream string

+ func (*ReportLeaderOp) Descriptor() ([]byte, []int)

+ func (*ReportLeaderOp) ProtoMessage()

+ func (m *ReportLeaderOp) GetLeader() string

+ func (m *ReportLeaderOp) GetLeaderEpoch() uint64

+ func (m *ReportLeaderOp) GetPartition() int32

+ func (m *ReportLeaderOp) GetReplica() string

+ func (m *ReportLeaderOp) GetStream() string

+ func (m *ReportLeaderOp) Marshal() (dAtA []byte, err error)

+ func (m *ReportLeaderOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReportLeaderOp) Reset()

+ func (m *ReportLeaderOp) Size() (n int)

+ func (m *ReportLeaderOp) String() string

+ func (m *ReportLeaderOp) Unmarshal(dAtA []byte) error

+ type ResumeStreamOp struct

+ Partitions []int32

+ Stream string

+ func (*ResumeStreamOp) Descriptor() ([]byte, []int)

+ func (*ResumeStreamOp) ProtoMessage()

+ func (m *ResumeStreamOp) GetPartitions() []int32

+ func (m *ResumeStreamOp) GetStream() string

+ func (m *ResumeStreamOp) Marshal() (dAtA []byte, err error)

+ func (m *ResumeStreamOp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResumeStreamOp) Reset()

+ func (m *ResumeStreamOp) Size() (n int)

+ func (m *ResumeStreamOp) String() string

+ func (m *ResumeStreamOp) Unmarshal(dAtA []byte) error

+ type ServerInfoRequest struct

+ Id string

+ func UnmarshalServerInfoRequest(data []byte) (*ServerInfoRequest, error)

+ func (*ServerInfoRequest) Descriptor() ([]byte, []int)

+ func (*ServerInfoRequest) ProtoMessage()

+ func (m *ServerInfoRequest) GetId() string

+ func (m *ServerInfoRequest) Marshal() (dAtA []byte, err error)

+ func (m *ServerInfoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServerInfoRequest) Reset()

+ func (m *ServerInfoRequest) Size() (n int)

+ func (m *ServerInfoRequest) String() string

+ func (m *ServerInfoRequest) Unmarshal(dAtA []byte) error

+ type ServerInfoResponse struct

+ Host string

+ Id string

+ Port int32

+ func UnmarshalServerInfoResponse(data []byte) (*ServerInfoResponse, error)

+ func (*ServerInfoResponse) Descriptor() ([]byte, []int)

+ func (*ServerInfoResponse) ProtoMessage()

+ func (m *ServerInfoResponse) GetHost() string

+ func (m *ServerInfoResponse) GetId() string

+ func (m *ServerInfoResponse) GetPort() int32

+ func (m *ServerInfoResponse) Marshal() (dAtA []byte, err error)

+ func (m *ServerInfoResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServerInfoResponse) Reset()

+ func (m *ServerInfoResponse) Size() (n int)

+ func (m *ServerInfoResponse) String() string

+ func (m *ServerInfoResponse) Unmarshal(dAtA []byte) error

+ type ServerState struct

+ ServerID string

+ func (*ServerState) Descriptor() ([]byte, []int)

+ func (*ServerState) ProtoMessage()

+ func (m *ServerState) GetServerID() string

+ func (m *ServerState) Marshal() (dAtA []byte, err error)

+ func (m *ServerState) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServerState) Reset()

+ func (m *ServerState) Size() (n int)

+ func (m *ServerState) String() string

+ func (m *ServerState) Unmarshal(dAtA []byte) error

+ type ShrinkISROp struct

+ Leader string

+ LeaderEpoch uint64

+ Partition int32

+ ReplicaToRemove string

+ Stream string

+ func (*ShrinkISROp) Descriptor() ([]byte, []int)

+ func (*ShrinkISROp) ProtoMessage()

+ func (m *ShrinkISROp) GetLeader() string

+ func (m *ShrinkISROp) GetLeaderEpoch() uint64

+ func (m *ShrinkISROp) GetPartition() int32

+ func (m *ShrinkISROp) GetReplicaToRemove() string

+ func (m *ShrinkISROp) GetStream() string

+ func (m *ShrinkISROp) Marshal() (dAtA []byte, err error)

+ func (m *ShrinkISROp) MarshalTo(dAtA []byte) (int, error)

+ func (m *ShrinkISROp) Reset()

+ func (m *ShrinkISROp) Size() (n int)

+ func (m *ShrinkISROp) String() string

+ func (m *ShrinkISROp) Unmarshal(dAtA []byte) error

+ type Stream struct

+ Name string

+ Partitions []*Partition

+ Subject string

+ func (*Stream) Descriptor() ([]byte, []int)

+ func (*Stream) ProtoMessage()

+ func (m *Stream) GetName() string

+ func (m *Stream) GetPartitions() []*Partition

+ func (m *Stream) GetSubject() string

+ func (m *Stream) Marshal() (dAtA []byte, err error)

+ func (m *Stream) MarshalTo(dAtA []byte) (int, error)

+ func (m *Stream) Reset()

+ func (m *Stream) Size() (n int)

+ func (m *Stream) String() string

+ func (m *Stream) Unmarshal(dAtA []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL