Documentation ¶
Index ¶
- Variables
- 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 ChangeConsumerGroupCoordinatorOp
- func (*ChangeConsumerGroupCoordinatorOp) Descriptor() ([]byte, []int)
- 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 (*ChangeConsumerGroupCoordinatorOp) ProtoMessage()
- 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 ChangeLeaderOp
- func (*ChangeLeaderOp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChangeLeaderOp) ProtoMessage()
- func (m *ChangeLeaderOp) Reset()
- func (m *ChangeLeaderOp) Size() (n int)
- func (m *ChangeLeaderOp) String() string
- func (m *ChangeLeaderOp) Unmarshal(dAtA []byte) 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 Consumer
- func (*Consumer) Descriptor() ([]byte, []int)
- 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 (*Consumer) ProtoMessage()
- 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
- func (*ConsumerGroup) Descriptor() ([]byte, []int)
- 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 (*ConsumerGroup) ProtoMessage()
- 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
- func (*CreateConsumerGroupOp) Descriptor() ([]byte, []int)
- 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 (*CreateConsumerGroupOp) ProtoMessage()
- 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 CreateStreamOp
- func (*CreateStreamOp) Descriptor() ([]byte, []int)
- func (m *CreateStreamOp) GetStream() *Stream
- func (m *CreateStreamOp) Marshal() (dAtA []byte, err error)
- func (m *CreateStreamOp) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateStreamOp) ProtoMessage()
- func (m *CreateStreamOp) Reset()
- func (m *CreateStreamOp) Size() (n int)
- func (m *CreateStreamOp) String() string
- func (m *CreateStreamOp) Unmarshal(dAtA []byte) 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 Cursor
- func (*Cursor) Descriptor() ([]byte, []int)
- 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 (*Cursor) ProtoMessage()
- 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 DeleteStreamOp
- func (*DeleteStreamOp) Descriptor() ([]byte, []int)
- func (m *DeleteStreamOp) GetStream() string
- func (m *DeleteStreamOp) Marshal() (dAtA []byte, err error)
- func (m *DeleteStreamOp) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteStreamOp) ProtoMessage()
- func (m *DeleteStreamOp) Reset()
- func (m *DeleteStreamOp) Size() (n int)
- func (m *DeleteStreamOp) String() string
- func (m *DeleteStreamOp) Unmarshal(dAtA []byte) 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
- func (*Error) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) 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
- func (*ExpandISROp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExpandISROp) ProtoMessage()
- func (m *ExpandISROp) Reset()
- func (m *ExpandISROp) Size() (n int)
- func (m *ExpandISROp) String() string
- func (m *ExpandISROp) Unmarshal(dAtA []byte) 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 JoinConsumerGroupOp
- func (*JoinConsumerGroupOp) Descriptor() ([]byte, []int)
- 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 (*JoinConsumerGroupOp) ProtoMessage()
- 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 LeaderEpochOffsetRequest
- func (*LeaderEpochOffsetRequest) Descriptor() ([]byte, []int)
- func (m *LeaderEpochOffsetRequest) GetLeaderEpoch() uint64
- func (m *LeaderEpochOffsetRequest) Marshal() (dAtA []byte, err error)
- func (m *LeaderEpochOffsetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaderEpochOffsetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaderEpochOffsetRequest) ProtoMessage()
- func (m *LeaderEpochOffsetRequest) Reset()
- func (m *LeaderEpochOffsetRequest) Size() (n int)
- func (m *LeaderEpochOffsetRequest) String() string
- func (m *LeaderEpochOffsetRequest) Unmarshal(dAtA []byte) 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
- func (*LeaderEpochOffsetResponse) Descriptor() ([]byte, []int)
- func (m *LeaderEpochOffsetResponse) GetEndOffset() int64
- func (m *LeaderEpochOffsetResponse) Marshal() (dAtA []byte, err error)
- func (m *LeaderEpochOffsetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaderEpochOffsetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaderEpochOffsetResponse) ProtoMessage()
- func (m *LeaderEpochOffsetResponse) Reset()
- func (m *LeaderEpochOffsetResponse) Size() (n int)
- func (m *LeaderEpochOffsetResponse) String() string
- func (m *LeaderEpochOffsetResponse) Unmarshal(dAtA []byte) 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 LeaveConsumerGroupOp
- func (*LeaveConsumerGroupOp) Descriptor() ([]byte, []int)
- func (m *LeaveConsumerGroupOp) GetConsumerId() string
- func (m *LeaveConsumerGroupOp) GetExpired() bool
- 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 (*LeaveConsumerGroupOp) ProtoMessage()
- 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
- func (*MetadataSnapshot) Descriptor() ([]byte, []int)
- func (m *MetadataSnapshot) GetGroups() []*ConsumerGroup
- func (m *MetadataSnapshot) GetStreams() []*Stream
- func (m *MetadataSnapshot) Marshal() (dAtA []byte, err error)
- func (m *MetadataSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *MetadataSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MetadataSnapshot) ProtoMessage()
- func (m *MetadataSnapshot) Reset()
- func (m *MetadataSnapshot) Size() (n int)
- func (m *MetadataSnapshot) String() string
- func (m *MetadataSnapshot) Unmarshal(dAtA []byte) 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
- func (*NullableBool) Descriptor() ([]byte, []int)
- 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 (*NullableBool) ProtoMessage()
- 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
- func (*NullableInt32) Descriptor() ([]byte, []int)
- 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 (*NullableInt32) ProtoMessage()
- 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
- func (*NullableInt64) Descriptor() ([]byte, []int)
- 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 (*NullableInt64) ProtoMessage()
- 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 Op
- type Partition
- func (*Partition) Descriptor() ([]byte, []int)
- 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) GetReadonly() 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Partition) ProtoMessage()
- func (m *Partition) Reset()
- func (m *Partition) Size() (n int)
- func (m *Partition) String() string
- func (m *Partition) Unmarshal(dAtA []byte) 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
- func (*PartitionNotification) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionNotification) ProtoMessage()
- func (m *PartitionNotification) Reset()
- func (m *PartitionNotification) Size() (n int)
- func (m *PartitionNotification) String() string
- func (m *PartitionNotification) Unmarshal(dAtA []byte) 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
- func (*PartitionStatusRequest) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionStatusRequest) ProtoMessage()
- func (m *PartitionStatusRequest) Reset()
- func (m *PartitionStatusRequest) Size() (n int)
- func (m *PartitionStatusRequest) String() string
- func (m *PartitionStatusRequest) Unmarshal(dAtA []byte) 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
- func (*PartitionStatusResponse) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionStatusResponse) ProtoMessage()
- func (m *PartitionStatusResponse) Reset()
- func (m *PartitionStatusResponse) Size() (n int)
- func (m *PartitionStatusResponse) String() string
- func (m *PartitionStatusResponse) Unmarshal(dAtA []byte) 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
- func (*PauseStreamOp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PauseStreamOp) ProtoMessage()
- func (m *PauseStreamOp) Reset()
- func (m *PauseStreamOp) Size() (n int)
- func (m *PauseStreamOp) String() string
- func (m *PauseStreamOp) Unmarshal(dAtA []byte) 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
- func (*PropagatedRequest) Descriptor() ([]byte, []int)
- func (m *PropagatedRequest) GetCreateStreamOp() *CreateStreamOp
- func (m *PropagatedRequest) GetDeleteStreamOp() *DeleteStreamOp
- func (m *PropagatedRequest) GetExpandISROp() *ExpandISROp
- func (m *PropagatedRequest) GetJoinConsumerGroupOp() *JoinConsumerGroupOp
- func (m *PropagatedRequest) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp
- func (m *PropagatedRequest) GetOp() Op
- func (m *PropagatedRequest) GetPauseStreamOp() *PauseStreamOp
- func (m *PropagatedRequest) GetReportConsumerGroupCoordinatorOp() *ReportConsumerGroupCoordinatorOp
- func (m *PropagatedRequest) GetReportLeaderOp() *ReportLeaderOp
- func (m *PropagatedRequest) GetResumeStreamOp() *ResumeStreamOp
- func (m *PropagatedRequest) GetSetStreamReadonlyOp() *SetStreamReadonlyOp
- func (m *PropagatedRequest) GetShrinkISROp() *ShrinkISROp
- func (m *PropagatedRequest) Marshal() (dAtA []byte, err error)
- func (m *PropagatedRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PropagatedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PropagatedRequest) ProtoMessage()
- func (m *PropagatedRequest) Reset()
- func (m *PropagatedRequest) Size() (n int)
- func (m *PropagatedRequest) String() string
- func (m *PropagatedRequest) Unmarshal(dAtA []byte) 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
- func (*PropagatedResponse) Descriptor() ([]byte, []int)
- func (m *PropagatedResponse) GetError() *Error
- func (m *PropagatedResponse) GetJoinConsumerGroupResp() *PropagatedResponse_JoinConsumerGroupResponse
- func (m *PropagatedResponse) GetOp() Op
- func (m *PropagatedResponse) Marshal() (dAtA []byte, err error)
- func (m *PropagatedResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PropagatedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PropagatedResponse) ProtoMessage()
- func (m *PropagatedResponse) Reset()
- func (m *PropagatedResponse) Size() (n int)
- func (m *PropagatedResponse) String() string
- func (m *PropagatedResponse) Unmarshal(dAtA []byte) 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 PropagatedResponse_JoinConsumerGroupResponse
- func (*PropagatedResponse_JoinConsumerGroupResponse) Descriptor() ([]byte, []int)
- 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 (*PropagatedResponse_JoinConsumerGroupResponse) ProtoMessage()
- 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 PublishActivityOp
- func (*PublishActivityOp) Descriptor() ([]byte, []int)
- func (m *PublishActivityOp) GetRaftIndex() uint64
- func (m *PublishActivityOp) Marshal() (dAtA []byte, err error)
- func (m *PublishActivityOp) MarshalTo(dAtA []byte) (int, error)
- func (m *PublishActivityOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PublishActivityOp) ProtoMessage()
- func (m *PublishActivityOp) Reset()
- func (m *PublishActivityOp) Size() (n int)
- func (m *PublishActivityOp) String() string
- func (m *PublishActivityOp) Unmarshal(dAtA []byte) 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
- func (*RaftJoinRequest) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RaftJoinRequest) ProtoMessage()
- func (m *RaftJoinRequest) Reset()
- func (m *RaftJoinRequest) Size() (n int)
- func (m *RaftJoinRequest) String() string
- func (m *RaftJoinRequest) Unmarshal(dAtA []byte) 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
- func (*RaftJoinResponse) Descriptor() ([]byte, []int)
- func (m *RaftJoinResponse) GetError() string
- func (m *RaftJoinResponse) Marshal() (dAtA []byte, err error)
- func (m *RaftJoinResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RaftJoinResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RaftJoinResponse) ProtoMessage()
- func (m *RaftJoinResponse) Reset()
- func (m *RaftJoinResponse) Size() (n int)
- func (m *RaftJoinResponse) String() string
- func (m *RaftJoinResponse) Unmarshal(dAtA []byte) 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
- func (*RaftLog) Descriptor() ([]byte, []int)
- func (m *RaftLog) GetChangeConsumerGroupCoordinatorOp() *ChangeConsumerGroupCoordinatorOp
- func (m *RaftLog) GetChangeLeaderOp() *ChangeLeaderOp
- func (m *RaftLog) GetCreateConsumerGroupOp() *CreateConsumerGroupOp
- func (m *RaftLog) GetCreateStreamOp() *CreateStreamOp
- func (m *RaftLog) GetDeleteStreamOp() *DeleteStreamOp
- func (m *RaftLog) GetExpandISROp() *ExpandISROp
- func (m *RaftLog) GetJoinConsumerGroupOp() *JoinConsumerGroupOp
- func (m *RaftLog) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp
- func (m *RaftLog) GetOp() Op
- func (m *RaftLog) GetPauseStreamOp() *PauseStreamOp
- func (m *RaftLog) GetPublishActivityOp() *PublishActivityOp
- func (m *RaftLog) GetResumeStreamOp() *ResumeStreamOp
- func (m *RaftLog) GetSetStreamReadonlyOp() *SetStreamReadonlyOp
- func (m *RaftLog) GetShrinkISROp() *ShrinkISROp
- func (m *RaftLog) Marshal() (dAtA []byte, err error)
- func (m *RaftLog) MarshalTo(dAtA []byte) (int, error)
- func (m *RaftLog) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RaftLog) ProtoMessage()
- func (m *RaftLog) Reset()
- func (m *RaftLog) Size() (n int)
- func (m *RaftLog) String() string
- func (m *RaftLog) Unmarshal(dAtA []byte) 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
- func (*ReplicationRequest) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplicationRequest) ProtoMessage()
- func (m *ReplicationRequest) Reset()
- func (m *ReplicationRequest) Size() (n int)
- func (m *ReplicationRequest) String() string
- func (m *ReplicationRequest) Unmarshal(dAtA []byte) 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 ReportConsumerGroupCoordinatorOp
- func (*ReportConsumerGroupCoordinatorOp) Descriptor() ([]byte, []int)
- 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 (*ReportConsumerGroupCoordinatorOp) ProtoMessage()
- 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
- type ReportLeaderOp
- func (*ReportLeaderOp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportLeaderOp) ProtoMessage()
- func (m *ReportLeaderOp) Reset()
- func (m *ReportLeaderOp) Size() (n int)
- func (m *ReportLeaderOp) String() string
- func (m *ReportLeaderOp) Unmarshal(dAtA []byte) 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
- func (*ResumeStreamOp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResumeStreamOp) ProtoMessage()
- func (m *ResumeStreamOp) Reset()
- func (m *ResumeStreamOp) Size() (n int)
- func (m *ResumeStreamOp) String() string
- func (m *ResumeStreamOp) Unmarshal(dAtA []byte) 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
- func (*ServerInfoRequest) Descriptor() ([]byte, []int)
- func (m *ServerInfoRequest) GetId() string
- func (m *ServerInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *ServerInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServerInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServerInfoRequest) ProtoMessage()
- func (m *ServerInfoRequest) Reset()
- func (m *ServerInfoRequest) Size() (n int)
- func (m *ServerInfoRequest) String() string
- func (m *ServerInfoRequest) Unmarshal(dAtA []byte) 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
- func (*ServerInfoResponse) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServerInfoResponse) ProtoMessage()
- func (m *ServerInfoResponse) Reset()
- func (m *ServerInfoResponse) Size() (n int)
- func (m *ServerInfoResponse) String() string
- func (m *ServerInfoResponse) Unmarshal(dAtA []byte) 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
- func (*ServerState) Descriptor() ([]byte, []int)
- func (m *ServerState) GetServerID() string
- func (m *ServerState) Marshal() (dAtA []byte, err error)
- func (m *ServerState) MarshalTo(dAtA []byte) (int, error)
- func (m *ServerState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServerState) ProtoMessage()
- func (m *ServerState) Reset()
- func (m *ServerState) Size() (n int)
- func (m *ServerState) String() string
- func (m *ServerState) Unmarshal(dAtA []byte) 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 SetStreamReadonlyOp
- func (*SetStreamReadonlyOp) Descriptor() ([]byte, []int)
- 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 (*SetStreamReadonlyOp) ProtoMessage()
- 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 ShrinkISROp
- func (*ShrinkISROp) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShrinkISROp) ProtoMessage()
- func (m *ShrinkISROp) Reset()
- func (m *ShrinkISROp) Size() (n int)
- func (m *ShrinkISROp) String() string
- func (m *ShrinkISROp) Unmarshal(dAtA []byte) 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
- func (*Stream) Descriptor() ([]byte, []int)
- func (m *Stream) GetConfig() *StreamConfig
- func (m *Stream) GetCreationTimestamp() int64
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Stream) ProtoMessage()
- func (m *Stream) Reset()
- func (m *Stream) Size() (n int)
- func (m *Stream) String() string
- func (m *Stream) Unmarshal(dAtA []byte) 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
- func (*StreamConfig) Descriptor() ([]byte, []int)
- func (m *StreamConfig) GetAutoPauseDisableIfSubscribers() *NullableBool
- func (m *StreamConfig) GetAutoPauseTime() *NullableInt64
- func (m *StreamConfig) GetCleanerInterval() *NullableInt64
- func (m *StreamConfig) GetCompactEnabled() *NullableBool
- func (m *StreamConfig) GetCompactMaxGoroutines() *NullableInt32
- func (m *StreamConfig) GetEncryption() *NullableBool
- func (m *StreamConfig) GetMinIsr() *NullableInt32
- func (m *StreamConfig) GetOptimisticConcurrencyControl() *NullableBool
- 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 (*StreamConfig) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowInternal = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupInternal = fmt.Errorf("proto: unexpected end of group") )
var ( // Encoding is the byte order to use for protocol serialization. Encoding = binary.BigEndian )
var Op_name = map[int32]string{
0: "CREATE_STREAM",
1: "SHRINK_ISR",
2: "REPORT_LEADER",
3: "CHANGE_LEADER",
4: "EXPAND_ISR",
5: "DELETE_STREAM",
6: "PAUSE_STREAM",
7: "RESUME_STREAM",
8: "PUBLISH_ACTIVITY",
9: "SET_STREAM_READONLY",
10: "CREATE_CONSUMER_GROUP",
11: "JOIN_CONSUMER_GROUP",
12: "LEAVE_CONSUMER_GROUP",
13: "REPORT_CONSUMER_GROUP_COORDINATOR",
14: "CHANGE_CONSUMER_GROUP_COORDINATOR",
}
var Op_value = map[string]int32{
"CREATE_STREAM": 0,
"SHRINK_ISR": 1,
"REPORT_LEADER": 2,
"CHANGE_LEADER": 3,
"EXPAND_ISR": 4,
"DELETE_STREAM": 5,
"PAUSE_STREAM": 6,
"RESUME_STREAM": 7,
"PUBLISH_ACTIVITY": 8,
"SET_STREAM_READONLY": 9,
"CREATE_CONSUMER_GROUP": 10,
"JOIN_CONSUMER_GROUP": 11,
"LEAVE_CONSUMER_GROUP": 12,
"REPORT_CONSUMER_GROUP_COORDINATOR": 13,
"CHANGE_CONSUMER_GROUP_COORDINATOR": 14,
}
Functions ¶
func MarshalAck ¶
MarshalAck serializes a protobuf ack message into the Liftbridge envelope wire format.
func MarshalLeaderEpochOffsetRequest ¶
func MarshalLeaderEpochOffsetRequest(req *LeaderEpochOffsetRequest) ([]byte, error)
MarshalLeaderEpochOffsetRequest serializes a LeaderEpochOffsetRequest protobuf into the Liftbridge envelope wire format.
func MarshalLeaderEpochOffsetResponse ¶
func MarshalLeaderEpochOffsetResponse(req *LeaderEpochOffsetResponse) ([]byte, error)
MarshalLeaderEpochOffsetResponse serializes a LeaderEpochOffsetResponse protobuf into the Liftbridge envelope wire format.
func MarshalPartitionNotification ¶
func MarshalPartitionNotification(req *PartitionNotification) ([]byte, error)
MarshalPartitionNotification serializes a PartitionNotification protobuf into the Liftbridge envelope wire format.
func MarshalPartitionStatusRequest ¶
func MarshalPartitionStatusRequest(req *PartitionStatusRequest) ([]byte, error)
MarshalPartitionStatusRequest serializes a PartitionStatusRequest protobuf into the Liftbridge envelope wire format.
func MarshalPartitionStatusResponse ¶
func MarshalPartitionStatusResponse(resp *PartitionStatusResponse) ([]byte, error)
MarshalPartitionStatusResponse serializes a PartitionStatusResponse protobuf into the Liftbridge envelope wire format.
func MarshalPropagatedRequest ¶
func MarshalPropagatedRequest(req *PropagatedRequest) ([]byte, error)
MarshalPropagatedRequest serializes a PropagatedRequest protobuf into the Liftbridge envelope wire format.
func MarshalPropagatedResponse ¶
func MarshalPropagatedResponse(req *PropagatedResponse) ([]byte, error)
MarshalPropagatedResponse serializes a PropagatedResponse protobuf into the Liftbridge envelope wire format.
func MarshalPublish ¶
MarshalPublish serializes a protobuf publish message into the Liftbridge envelope wire format.
func MarshalRaftJoinRequest ¶
func MarshalRaftJoinRequest(req *RaftJoinRequest) ([]byte, error)
MarshalRaftJoinRequest serializes a RaftJoinRequest protobuf into the Liftbridge envelope wire format.
func MarshalRaftJoinResponse ¶
func MarshalRaftJoinResponse(req *RaftJoinResponse) ([]byte, error)
MarshalRaftJoinResponse serializes a RaftJoinResponse protobuf into the Liftbridge envelope wire format.
func MarshalReplicationRequest ¶
func MarshalReplicationRequest(req *ReplicationRequest) ([]byte, error)
MarshalReplicationRequest serializes a ReplicationRequest protobuf into the Liftbridge envelope wire format.
func MarshalServerInfoRequest ¶
func MarshalServerInfoRequest(req *ServerInfoRequest) ([]byte, error)
MarshalServerInfoRequest serializes a ServerInfoRequest protobuf into the Liftbridge envelope wire format.
func MarshalServerInfoResponse ¶
func MarshalServerInfoResponse(req *ServerInfoResponse) ([]byte, error)
MarshalServerInfoResponse serializes a ServerInfoResponse protobuf into the Liftbridge envelope wire format.
func UnmarshalAck ¶
UnmarshalAck deserializes a Liftbridge ack envelope into a protobuf message.
func UnmarshalPublish ¶
UnmarshalPublish deserializes a Liftbridge publish envelope into a protobuf message.
func UnmarshalReplicationResponse ¶
UnmarshalReplicationResponse deserializes a Liftbridge replication response envelope and returns the leader epoch, HW, and message data.
func WriteReplicationResponseHeader ¶
WriteReplicationResponseHeader writes the envelope protocol header for replication messages to the buffer and returns the number of bytes written.
Types ¶
type ChangeConsumerGroupCoordinatorOp ¶ added in v1.8.0
type ChangeConsumerGroupCoordinatorOp struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` Coordinator string `protobuf:"bytes,2,opt,name=coordinator,proto3" json:"coordinator,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChangeConsumerGroupCoordinatorOp) Descriptor ¶ added in v1.8.0
func (*ChangeConsumerGroupCoordinatorOp) Descriptor() ([]byte, []int)
func (*ChangeConsumerGroupCoordinatorOp) GetCoordinator ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) GetCoordinator() string
func (*ChangeConsumerGroupCoordinatorOp) GetGroupId ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) GetGroupId() string
func (*ChangeConsumerGroupCoordinatorOp) Marshal ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) Marshal() (dAtA []byte, err error)
func (*ChangeConsumerGroupCoordinatorOp) MarshalTo ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) MarshalTo(dAtA []byte) (int, error)
func (*ChangeConsumerGroupCoordinatorOp) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangeConsumerGroupCoordinatorOp) ProtoMessage ¶ added in v1.8.0
func (*ChangeConsumerGroupCoordinatorOp) ProtoMessage()
func (*ChangeConsumerGroupCoordinatorOp) Reset ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) Reset()
func (*ChangeConsumerGroupCoordinatorOp) Size ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) Size() (n int)
func (*ChangeConsumerGroupCoordinatorOp) String ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) String() string
func (*ChangeConsumerGroupCoordinatorOp) Unmarshal ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) Unmarshal(dAtA []byte) error
func (*ChangeConsumerGroupCoordinatorOp) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) XXX_DiscardUnknown()
func (*ChangeConsumerGroupCoordinatorOp) XXX_Marshal ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangeConsumerGroupCoordinatorOp) XXX_Merge ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) XXX_Merge(src proto.Message)
func (*ChangeConsumerGroupCoordinatorOp) XXX_Size ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) XXX_Size() int
func (*ChangeConsumerGroupCoordinatorOp) XXX_Unmarshal ¶ added in v1.8.0
func (m *ChangeConsumerGroupCoordinatorOp) XXX_Unmarshal(b []byte) error
type ChangeLeaderOp ¶
type ChangeLeaderOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` Leader string `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChangeLeaderOp) Descriptor ¶
func (*ChangeLeaderOp) Descriptor() ([]byte, []int)
func (*ChangeLeaderOp) GetLeader ¶
func (m *ChangeLeaderOp) GetLeader() string
func (*ChangeLeaderOp) GetPartition ¶
func (m *ChangeLeaderOp) GetPartition() int32
func (*ChangeLeaderOp) GetStream ¶
func (m *ChangeLeaderOp) GetStream() string
func (*ChangeLeaderOp) Marshal ¶
func (m *ChangeLeaderOp) Marshal() (dAtA []byte, err error)
func (*ChangeLeaderOp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ChangeLeaderOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangeLeaderOp) ProtoMessage ¶
func (*ChangeLeaderOp) ProtoMessage()
func (*ChangeLeaderOp) Reset ¶
func (m *ChangeLeaderOp) Reset()
func (*ChangeLeaderOp) Size ¶
func (m *ChangeLeaderOp) Size() (n int)
func (*ChangeLeaderOp) String ¶
func (m *ChangeLeaderOp) String() string
func (*ChangeLeaderOp) Unmarshal ¶
func (m *ChangeLeaderOp) Unmarshal(dAtA []byte) error
func (*ChangeLeaderOp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ChangeLeaderOp) XXX_DiscardUnknown()
func (*ChangeLeaderOp) XXX_Marshal ¶ added in v1.2.0
func (m *ChangeLeaderOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangeLeaderOp) XXX_Merge ¶ added in v1.2.0
func (m *ChangeLeaderOp) XXX_Merge(src proto.Message)
func (*ChangeLeaderOp) XXX_Size ¶ added in v1.2.0
func (m *ChangeLeaderOp) XXX_Size() int
func (*ChangeLeaderOp) XXX_Unmarshal ¶ added in v1.2.0
func (m *ChangeLeaderOp) XXX_Unmarshal(b []byte) error
type Consumer ¶ added in v1.8.0
type Consumer struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Streams []string `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Consumer) Descriptor ¶ added in v1.8.0
func (*Consumer) GetStreams ¶ added in v1.8.0
func (*Consumer) MarshalToSizedBuffer ¶ added in v1.8.0
func (*Consumer) ProtoMessage ¶ added in v1.8.0
func (*Consumer) ProtoMessage()
func (*Consumer) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *Consumer) XXX_DiscardUnknown()
func (*Consumer) XXX_Marshal ¶ added in v1.8.0
func (*Consumer) XXX_Unmarshal ¶ added in v1.8.0
type ConsumerGroup ¶ added in v1.8.0
type ConsumerGroup struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Members []*Consumer `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"` Coordinator string `protobuf:"bytes,3,opt,name=coordinator,proto3" json:"coordinator,omitempty"` Epoch uint64 `protobuf:"varint,4,opt,name=epoch,proto3" json:"epoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConsumerGroup) Descriptor ¶ added in v1.8.0
func (*ConsumerGroup) Descriptor() ([]byte, []int)
func (*ConsumerGroup) GetCoordinator ¶ added in v1.8.0
func (m *ConsumerGroup) GetCoordinator() string
func (*ConsumerGroup) GetEpoch ¶ added in v1.8.0
func (m *ConsumerGroup) GetEpoch() uint64
func (*ConsumerGroup) GetId ¶ added in v1.8.0
func (m *ConsumerGroup) GetId() string
func (*ConsumerGroup) GetMembers ¶ added in v1.8.0
func (m *ConsumerGroup) GetMembers() []*Consumer
func (*ConsumerGroup) Marshal ¶ added in v1.8.0
func (m *ConsumerGroup) Marshal() (dAtA []byte, err error)
func (*ConsumerGroup) MarshalTo ¶ added in v1.8.0
func (m *ConsumerGroup) MarshalTo(dAtA []byte) (int, error)
func (*ConsumerGroup) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *ConsumerGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConsumerGroup) ProtoMessage ¶ added in v1.8.0
func (*ConsumerGroup) ProtoMessage()
func (*ConsumerGroup) Reset ¶ added in v1.8.0
func (m *ConsumerGroup) Reset()
func (*ConsumerGroup) Size ¶ added in v1.8.0
func (m *ConsumerGroup) Size() (n int)
func (*ConsumerGroup) String ¶ added in v1.8.0
func (m *ConsumerGroup) String() string
func (*ConsumerGroup) Unmarshal ¶ added in v1.8.0
func (m *ConsumerGroup) Unmarshal(dAtA []byte) error
func (*ConsumerGroup) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *ConsumerGroup) XXX_DiscardUnknown()
func (*ConsumerGroup) XXX_Marshal ¶ added in v1.8.0
func (m *ConsumerGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConsumerGroup) XXX_Merge ¶ added in v1.8.0
func (m *ConsumerGroup) XXX_Merge(src proto.Message)
func (*ConsumerGroup) XXX_Size ¶ added in v1.8.0
func (m *ConsumerGroup) XXX_Size() int
func (*ConsumerGroup) XXX_Unmarshal ¶ added in v1.8.0
func (m *ConsumerGroup) XXX_Unmarshal(b []byte) error
type CreateConsumerGroupOp ¶ added in v1.8.0
type CreateConsumerGroupOp struct { ConsumerGroup *ConsumerGroup `protobuf:"bytes,1,opt,name=consumerGroup,proto3" json:"consumerGroup,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateConsumerGroupOp) Descriptor ¶ added in v1.8.0
func (*CreateConsumerGroupOp) Descriptor() ([]byte, []int)
func (*CreateConsumerGroupOp) GetConsumerGroup ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) GetConsumerGroup() *ConsumerGroup
func (*CreateConsumerGroupOp) Marshal ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) Marshal() (dAtA []byte, err error)
func (*CreateConsumerGroupOp) MarshalTo ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)
func (*CreateConsumerGroupOp) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateConsumerGroupOp) ProtoMessage ¶ added in v1.8.0
func (*CreateConsumerGroupOp) ProtoMessage()
func (*CreateConsumerGroupOp) Reset ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) Reset()
func (*CreateConsumerGroupOp) Size ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) Size() (n int)
func (*CreateConsumerGroupOp) String ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) String() string
func (*CreateConsumerGroupOp) Unmarshal ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) Unmarshal(dAtA []byte) error
func (*CreateConsumerGroupOp) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) XXX_DiscardUnknown()
func (*CreateConsumerGroupOp) XXX_Marshal ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateConsumerGroupOp) XXX_Merge ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) XXX_Merge(src proto.Message)
func (*CreateConsumerGroupOp) XXX_Size ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) XXX_Size() int
func (*CreateConsumerGroupOp) XXX_Unmarshal ¶ added in v1.8.0
func (m *CreateConsumerGroupOp) XXX_Unmarshal(b []byte) error
type CreateStreamOp ¶
type CreateStreamOp struct { Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateStreamOp) Descriptor ¶
func (*CreateStreamOp) Descriptor() ([]byte, []int)
func (*CreateStreamOp) GetStream ¶
func (m *CreateStreamOp) GetStream() *Stream
func (*CreateStreamOp) Marshal ¶
func (m *CreateStreamOp) Marshal() (dAtA []byte, err error)
func (*CreateStreamOp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *CreateStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateStreamOp) ProtoMessage ¶
func (*CreateStreamOp) ProtoMessage()
func (*CreateStreamOp) Reset ¶
func (m *CreateStreamOp) Reset()
func (*CreateStreamOp) Size ¶
func (m *CreateStreamOp) Size() (n int)
func (*CreateStreamOp) String ¶
func (m *CreateStreamOp) String() string
func (*CreateStreamOp) Unmarshal ¶
func (m *CreateStreamOp) Unmarshal(dAtA []byte) error
func (*CreateStreamOp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *CreateStreamOp) XXX_DiscardUnknown()
func (*CreateStreamOp) XXX_Marshal ¶ added in v1.2.0
func (m *CreateStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateStreamOp) XXX_Merge ¶ added in v1.2.0
func (m *CreateStreamOp) XXX_Merge(src proto.Message)
func (*CreateStreamOp) XXX_Size ¶ added in v1.2.0
func (m *CreateStreamOp) XXX_Size() int
func (*CreateStreamOp) XXX_Unmarshal ¶ added in v1.2.0
func (m *CreateStreamOp) XXX_Unmarshal(b []byte) error
type Cursor ¶ added in v1.3.0
type Cursor struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` CursorId string `protobuf:"bytes,3,opt,name=cursorId,proto3" json:"cursorId,omitempty"` Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Cursor) Descriptor ¶ added in v1.3.0
func (*Cursor) GetCursorId ¶ added in v1.3.0
func (*Cursor) GetPartition ¶ added in v1.3.0
func (*Cursor) MarshalToSizedBuffer ¶ added in v1.3.0
func (*Cursor) ProtoMessage ¶ added in v1.3.0
func (*Cursor) ProtoMessage()
func (*Cursor) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *Cursor) XXX_DiscardUnknown()
func (*Cursor) XXX_Marshal ¶ added in v1.3.0
func (*Cursor) XXX_Unmarshal ¶ added in v1.3.0
type DeleteStreamOp ¶
type DeleteStreamOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteStreamOp) Descriptor ¶
func (*DeleteStreamOp) Descriptor() ([]byte, []int)
func (*DeleteStreamOp) GetStream ¶
func (m *DeleteStreamOp) GetStream() string
func (*DeleteStreamOp) Marshal ¶
func (m *DeleteStreamOp) Marshal() (dAtA []byte, err error)
func (*DeleteStreamOp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *DeleteStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteStreamOp) ProtoMessage ¶
func (*DeleteStreamOp) ProtoMessage()
func (*DeleteStreamOp) Reset ¶
func (m *DeleteStreamOp) Reset()
func (*DeleteStreamOp) Size ¶
func (m *DeleteStreamOp) Size() (n int)
func (*DeleteStreamOp) String ¶
func (m *DeleteStreamOp) String() string
func (*DeleteStreamOp) Unmarshal ¶
func (m *DeleteStreamOp) Unmarshal(dAtA []byte) error
func (*DeleteStreamOp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *DeleteStreamOp) XXX_DiscardUnknown()
func (*DeleteStreamOp) XXX_Marshal ¶ added in v1.2.0
func (m *DeleteStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteStreamOp) XXX_Merge ¶ added in v1.2.0
func (m *DeleteStreamOp) XXX_Merge(src proto.Message)
func (*DeleteStreamOp) XXX_Size ¶ added in v1.2.0
func (m *DeleteStreamOp) XXX_Size() int
func (*DeleteStreamOp) XXX_Unmarshal ¶ added in v1.2.0
func (m *DeleteStreamOp) XXX_Unmarshal(b []byte) error
type Error ¶
type Error struct { Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Error) Descriptor ¶
func (*Error) MarshalToSizedBuffer ¶ added in v1.2.0
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶ added in v1.2.0
func (*Error) XXX_Unmarshal ¶ added in v1.2.0
type ExpandISROp ¶
type ExpandISROp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` ReplicaToAdd string `protobuf:"bytes,3,opt,name=replicaToAdd,proto3" json:"replicaToAdd,omitempty"` Leader string `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"` LeaderEpoch uint64 `protobuf:"varint,5,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExpandISROp) Descriptor ¶
func (*ExpandISROp) Descriptor() ([]byte, []int)
func (*ExpandISROp) GetLeader ¶
func (m *ExpandISROp) GetLeader() string
func (*ExpandISROp) GetLeaderEpoch ¶
func (m *ExpandISROp) GetLeaderEpoch() uint64
func (*ExpandISROp) GetPartition ¶
func (m *ExpandISROp) GetPartition() int32
func (*ExpandISROp) GetReplicaToAdd ¶
func (m *ExpandISROp) GetReplicaToAdd() string
func (*ExpandISROp) GetStream ¶
func (m *ExpandISROp) GetStream() string
func (*ExpandISROp) Marshal ¶
func (m *ExpandISROp) Marshal() (dAtA []byte, err error)
func (*ExpandISROp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ExpandISROp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExpandISROp) ProtoMessage ¶
func (*ExpandISROp) ProtoMessage()
func (*ExpandISROp) Reset ¶
func (m *ExpandISROp) Reset()
func (*ExpandISROp) Size ¶
func (m *ExpandISROp) Size() (n int)
func (*ExpandISROp) String ¶
func (m *ExpandISROp) String() string
func (*ExpandISROp) Unmarshal ¶
func (m *ExpandISROp) Unmarshal(dAtA []byte) error
func (*ExpandISROp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ExpandISROp) XXX_DiscardUnknown()
func (*ExpandISROp) XXX_Marshal ¶ added in v1.2.0
func (m *ExpandISROp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExpandISROp) XXX_Merge ¶ added in v1.2.0
func (m *ExpandISROp) XXX_Merge(src proto.Message)
func (*ExpandISROp) XXX_Size ¶ added in v1.2.0
func (m *ExpandISROp) XXX_Size() int
func (*ExpandISROp) XXX_Unmarshal ¶ added in v1.2.0
func (m *ExpandISROp) XXX_Unmarshal(b []byte) error
type JoinConsumerGroupOp ¶ added in v1.8.0
type JoinConsumerGroupOp struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Streams []string `protobuf:"bytes,3,rep,name=streams,proto3" json:"streams,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JoinConsumerGroupOp) Descriptor ¶ added in v1.8.0
func (*JoinConsumerGroupOp) Descriptor() ([]byte, []int)
func (*JoinConsumerGroupOp) GetConsumerId ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) GetConsumerId() string
func (*JoinConsumerGroupOp) GetGroupId ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) GetGroupId() string
func (*JoinConsumerGroupOp) GetStreams ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) GetStreams() []string
func (*JoinConsumerGroupOp) Marshal ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) Marshal() (dAtA []byte, err error)
func (*JoinConsumerGroupOp) MarshalTo ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)
func (*JoinConsumerGroupOp) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JoinConsumerGroupOp) ProtoMessage ¶ added in v1.8.0
func (*JoinConsumerGroupOp) ProtoMessage()
func (*JoinConsumerGroupOp) Reset ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) Reset()
func (*JoinConsumerGroupOp) Size ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) Size() (n int)
func (*JoinConsumerGroupOp) String ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) String() string
func (*JoinConsumerGroupOp) Unmarshal ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) Unmarshal(dAtA []byte) error
func (*JoinConsumerGroupOp) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) XXX_DiscardUnknown()
func (*JoinConsumerGroupOp) XXX_Marshal ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinConsumerGroupOp) XXX_Merge ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) XXX_Merge(src proto.Message)
func (*JoinConsumerGroupOp) XXX_Size ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) XXX_Size() int
func (*JoinConsumerGroupOp) XXX_Unmarshal ¶ added in v1.8.0
func (m *JoinConsumerGroupOp) XXX_Unmarshal(b []byte) error
type LeaderEpochOffsetRequest ¶
type LeaderEpochOffsetRequest struct { LeaderEpoch uint64 `protobuf:"varint,1,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalLeaderEpochOffsetRequest ¶
func UnmarshalLeaderEpochOffsetRequest(data []byte) (*LeaderEpochOffsetRequest, error)
UnmarshalLeaderEpochOffsetRequest deserializes a Liftbridge LeaderEpochOffsetRequest envelope into a protobuf message.
func (*LeaderEpochOffsetRequest) Descriptor ¶
func (*LeaderEpochOffsetRequest) Descriptor() ([]byte, []int)
func (*LeaderEpochOffsetRequest) GetLeaderEpoch ¶
func (m *LeaderEpochOffsetRequest) GetLeaderEpoch() uint64
func (*LeaderEpochOffsetRequest) Marshal ¶
func (m *LeaderEpochOffsetRequest) Marshal() (dAtA []byte, err error)
func (*LeaderEpochOffsetRequest) MarshalTo ¶
func (m *LeaderEpochOffsetRequest) MarshalTo(dAtA []byte) (int, error)
func (*LeaderEpochOffsetRequest) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *LeaderEpochOffsetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaderEpochOffsetRequest) ProtoMessage ¶
func (*LeaderEpochOffsetRequest) ProtoMessage()
func (*LeaderEpochOffsetRequest) Reset ¶
func (m *LeaderEpochOffsetRequest) Reset()
func (*LeaderEpochOffsetRequest) Size ¶
func (m *LeaderEpochOffsetRequest) Size() (n int)
func (*LeaderEpochOffsetRequest) String ¶
func (m *LeaderEpochOffsetRequest) String() string
func (*LeaderEpochOffsetRequest) Unmarshal ¶
func (m *LeaderEpochOffsetRequest) Unmarshal(dAtA []byte) error
func (*LeaderEpochOffsetRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *LeaderEpochOffsetRequest) XXX_DiscardUnknown()
func (*LeaderEpochOffsetRequest) XXX_Marshal ¶ added in v1.2.0
func (m *LeaderEpochOffsetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaderEpochOffsetRequest) XXX_Merge ¶ added in v1.2.0
func (m *LeaderEpochOffsetRequest) XXX_Merge(src proto.Message)
func (*LeaderEpochOffsetRequest) XXX_Size ¶ added in v1.2.0
func (m *LeaderEpochOffsetRequest) XXX_Size() int
func (*LeaderEpochOffsetRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *LeaderEpochOffsetRequest) XXX_Unmarshal(b []byte) error
type LeaderEpochOffsetResponse ¶
type LeaderEpochOffsetResponse struct { EndOffset int64 `protobuf:"varint,1,opt,name=endOffset,proto3" json:"endOffset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalLeaderEpochOffsetResponse ¶
func UnmarshalLeaderEpochOffsetResponse(data []byte) (*LeaderEpochOffsetResponse, error)
UnmarshalLeaderEpochOffsetResponse deserializes a Liftbridge LeaderEpochOffsetResponse envelope into a protobuf message.
func (*LeaderEpochOffsetResponse) Descriptor ¶
func (*LeaderEpochOffsetResponse) Descriptor() ([]byte, []int)
func (*LeaderEpochOffsetResponse) GetEndOffset ¶
func (m *LeaderEpochOffsetResponse) GetEndOffset() int64
func (*LeaderEpochOffsetResponse) Marshal ¶
func (m *LeaderEpochOffsetResponse) Marshal() (dAtA []byte, err error)
func (*LeaderEpochOffsetResponse) MarshalTo ¶
func (m *LeaderEpochOffsetResponse) MarshalTo(dAtA []byte) (int, error)
func (*LeaderEpochOffsetResponse) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *LeaderEpochOffsetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaderEpochOffsetResponse) ProtoMessage ¶
func (*LeaderEpochOffsetResponse) ProtoMessage()
func (*LeaderEpochOffsetResponse) Reset ¶
func (m *LeaderEpochOffsetResponse) Reset()
func (*LeaderEpochOffsetResponse) Size ¶
func (m *LeaderEpochOffsetResponse) Size() (n int)
func (*LeaderEpochOffsetResponse) String ¶
func (m *LeaderEpochOffsetResponse) String() string
func (*LeaderEpochOffsetResponse) Unmarshal ¶
func (m *LeaderEpochOffsetResponse) Unmarshal(dAtA []byte) error
func (*LeaderEpochOffsetResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *LeaderEpochOffsetResponse) XXX_DiscardUnknown()
func (*LeaderEpochOffsetResponse) XXX_Marshal ¶ added in v1.2.0
func (m *LeaderEpochOffsetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaderEpochOffsetResponse) XXX_Merge ¶ added in v1.2.0
func (m *LeaderEpochOffsetResponse) XXX_Merge(src proto.Message)
func (*LeaderEpochOffsetResponse) XXX_Size ¶ added in v1.2.0
func (m *LeaderEpochOffsetResponse) XXX_Size() int
func (*LeaderEpochOffsetResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *LeaderEpochOffsetResponse) XXX_Unmarshal(b []byte) error
type LeaveConsumerGroupOp ¶ added in v1.8.0
type LeaveConsumerGroupOp struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Expired bool `protobuf:"varint,3,opt,name=expired,proto3" json:"expired,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LeaveConsumerGroupOp) Descriptor ¶ added in v1.8.0
func (*LeaveConsumerGroupOp) Descriptor() ([]byte, []int)
func (*LeaveConsumerGroupOp) GetConsumerId ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) GetConsumerId() string
func (*LeaveConsumerGroupOp) GetExpired ¶ added in v1.9.0
func (m *LeaveConsumerGroupOp) GetExpired() bool
func (*LeaveConsumerGroupOp) GetGroupId ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) GetGroupId() string
func (*LeaveConsumerGroupOp) Marshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) Marshal() (dAtA []byte, err error)
func (*LeaveConsumerGroupOp) MarshalTo ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) MarshalTo(dAtA []byte) (int, error)
func (*LeaveConsumerGroupOp) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaveConsumerGroupOp) ProtoMessage ¶ added in v1.8.0
func (*LeaveConsumerGroupOp) ProtoMessage()
func (*LeaveConsumerGroupOp) Reset ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) Reset()
func (*LeaveConsumerGroupOp) Size ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) Size() (n int)
func (*LeaveConsumerGroupOp) String ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) String() string
func (*LeaveConsumerGroupOp) Unmarshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) Unmarshal(dAtA []byte) error
func (*LeaveConsumerGroupOp) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) XXX_DiscardUnknown()
func (*LeaveConsumerGroupOp) XXX_Marshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaveConsumerGroupOp) XXX_Merge ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) XXX_Merge(src proto.Message)
func (*LeaveConsumerGroupOp) XXX_Size ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) XXX_Size() int
func (*LeaveConsumerGroupOp) XXX_Unmarshal ¶ added in v1.8.0
func (m *LeaveConsumerGroupOp) XXX_Unmarshal(b []byte) error
type MetadataSnapshot ¶
type MetadataSnapshot struct { Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"` Groups []*ConsumerGroup `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MetadataSnapshot) Descriptor ¶
func (*MetadataSnapshot) Descriptor() ([]byte, []int)
func (*MetadataSnapshot) GetGroups ¶ added in v1.8.0
func (m *MetadataSnapshot) GetGroups() []*ConsumerGroup
func (*MetadataSnapshot) GetStreams ¶
func (m *MetadataSnapshot) GetStreams() []*Stream
func (*MetadataSnapshot) Marshal ¶
func (m *MetadataSnapshot) Marshal() (dAtA []byte, err error)
func (*MetadataSnapshot) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *MetadataSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MetadataSnapshot) ProtoMessage ¶
func (*MetadataSnapshot) ProtoMessage()
func (*MetadataSnapshot) Reset ¶
func (m *MetadataSnapshot) Reset()
func (*MetadataSnapshot) Size ¶
func (m *MetadataSnapshot) Size() (n int)
func (*MetadataSnapshot) String ¶
func (m *MetadataSnapshot) String() string
func (*MetadataSnapshot) Unmarshal ¶
func (m *MetadataSnapshot) Unmarshal(dAtA []byte) error
func (*MetadataSnapshot) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *MetadataSnapshot) XXX_DiscardUnknown()
func (*MetadataSnapshot) XXX_Marshal ¶ added in v1.2.0
func (m *MetadataSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetadataSnapshot) XXX_Merge ¶ added in v1.2.0
func (m *MetadataSnapshot) XXX_Merge(src proto.Message)
func (*MetadataSnapshot) XXX_Size ¶ added in v1.2.0
func (m *MetadataSnapshot) XXX_Size() int
func (*MetadataSnapshot) XXX_Unmarshal ¶ added in v1.2.0
func (m *MetadataSnapshot) XXX_Unmarshal(b []byte) error
type NullableBool ¶ added in v1.2.0
type NullableBool struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NullableBool) Descriptor ¶ added in v1.2.0
func (*NullableBool) Descriptor() ([]byte, []int)
func (*NullableBool) GetValue ¶ added in v1.2.0
func (m *NullableBool) GetValue() bool
func (*NullableBool) Marshal ¶ added in v1.2.0
func (m *NullableBool) Marshal() (dAtA []byte, err error)
func (*NullableBool) MarshalTo ¶ added in v1.2.0
func (m *NullableBool) MarshalTo(dAtA []byte) (int, error)
func (*NullableBool) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *NullableBool) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NullableBool) ProtoMessage ¶ added in v1.2.0
func (*NullableBool) ProtoMessage()
func (*NullableBool) Reset ¶ added in v1.2.0
func (m *NullableBool) Reset()
func (*NullableBool) Size ¶ added in v1.2.0
func (m *NullableBool) Size() (n int)
func (*NullableBool) String ¶ added in v1.2.0
func (m *NullableBool) String() string
func (*NullableBool) Unmarshal ¶ added in v1.2.0
func (m *NullableBool) Unmarshal(dAtA []byte) error
func (*NullableBool) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *NullableBool) XXX_DiscardUnknown()
func (*NullableBool) XXX_Marshal ¶ added in v1.2.0
func (m *NullableBool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NullableBool) XXX_Merge ¶ added in v1.2.0
func (m *NullableBool) XXX_Merge(src proto.Message)
func (*NullableBool) XXX_Size ¶ added in v1.2.0
func (m *NullableBool) XXX_Size() int
func (*NullableBool) XXX_Unmarshal ¶ added in v1.2.0
func (m *NullableBool) XXX_Unmarshal(b []byte) error
type NullableInt32 ¶ added in v1.2.0
type NullableInt32 struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NullableInt32) Descriptor ¶ added in v1.2.0
func (*NullableInt32) Descriptor() ([]byte, []int)
func (*NullableInt32) GetValue ¶ added in v1.2.0
func (m *NullableInt32) GetValue() int32
func (*NullableInt32) Marshal ¶ added in v1.2.0
func (m *NullableInt32) Marshal() (dAtA []byte, err error)
func (*NullableInt32) MarshalTo ¶ added in v1.2.0
func (m *NullableInt32) MarshalTo(dAtA []byte) (int, error)
func (*NullableInt32) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *NullableInt32) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NullableInt32) ProtoMessage ¶ added in v1.2.0
func (*NullableInt32) ProtoMessage()
func (*NullableInt32) Reset ¶ added in v1.2.0
func (m *NullableInt32) Reset()
func (*NullableInt32) Size ¶ added in v1.2.0
func (m *NullableInt32) Size() (n int)
func (*NullableInt32) String ¶ added in v1.2.0
func (m *NullableInt32) String() string
func (*NullableInt32) Unmarshal ¶ added in v1.2.0
func (m *NullableInt32) Unmarshal(dAtA []byte) error
func (*NullableInt32) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *NullableInt32) XXX_DiscardUnknown()
func (*NullableInt32) XXX_Marshal ¶ added in v1.2.0
func (m *NullableInt32) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NullableInt32) XXX_Merge ¶ added in v1.2.0
func (m *NullableInt32) XXX_Merge(src proto.Message)
func (*NullableInt32) XXX_Size ¶ added in v1.2.0
func (m *NullableInt32) XXX_Size() int
func (*NullableInt32) XXX_Unmarshal ¶ added in v1.2.0
func (m *NullableInt32) XXX_Unmarshal(b []byte) error
type NullableInt64 ¶ added in v1.2.0
type NullableInt64 struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NullableInt64) Descriptor ¶ added in v1.2.0
func (*NullableInt64) Descriptor() ([]byte, []int)
func (*NullableInt64) GetValue ¶ added in v1.2.0
func (m *NullableInt64) GetValue() int64
func (*NullableInt64) Marshal ¶ added in v1.2.0
func (m *NullableInt64) Marshal() (dAtA []byte, err error)
func (*NullableInt64) MarshalTo ¶ added in v1.2.0
func (m *NullableInt64) MarshalTo(dAtA []byte) (int, error)
func (*NullableInt64) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *NullableInt64) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NullableInt64) ProtoMessage ¶ added in v1.2.0
func (*NullableInt64) ProtoMessage()
func (*NullableInt64) Reset ¶ added in v1.2.0
func (m *NullableInt64) Reset()
func (*NullableInt64) Size ¶ added in v1.2.0
func (m *NullableInt64) Size() (n int)
func (*NullableInt64) String ¶ added in v1.2.0
func (m *NullableInt64) String() string
func (*NullableInt64) Unmarshal ¶ added in v1.2.0
func (m *NullableInt64) Unmarshal(dAtA []byte) error
func (*NullableInt64) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *NullableInt64) XXX_DiscardUnknown()
func (*NullableInt64) XXX_Marshal ¶ added in v1.2.0
func (m *NullableInt64) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NullableInt64) XXX_Merge ¶ added in v1.2.0
func (m *NullableInt64) XXX_Merge(src proto.Message)
func (*NullableInt64) XXX_Size ¶ added in v1.2.0
func (m *NullableInt64) XXX_Size() int
func (*NullableInt64) XXX_Unmarshal ¶ added in v1.2.0
func (m *NullableInt64) XXX_Unmarshal(b []byte) error
type Op ¶
type Op int32
const ( Op_CREATE_STREAM Op = 0 Op_SHRINK_ISR Op = 1 Op_REPORT_LEADER Op = 2 Op_CHANGE_LEADER Op = 3 Op_EXPAND_ISR Op = 4 Op_DELETE_STREAM Op = 5 Op_PAUSE_STREAM Op = 6 Op_RESUME_STREAM Op = 7 Op_PUBLISH_ACTIVITY Op = 8 Op_SET_STREAM_READONLY Op = 9 Op_CREATE_CONSUMER_GROUP Op = 10 Op_JOIN_CONSUMER_GROUP Op = 11 Op_LEAVE_CONSUMER_GROUP Op = 12 Op_REPORT_CONSUMER_GROUP_COORDINATOR Op = 13 Op_CHANGE_CONSUMER_GROUP_COORDINATOR Op = 14 )
func (Op) EnumDescriptor ¶
type Partition ¶
type Partition struct { Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"` Stream string `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"` Id int32 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` ReplicationFactor int32 `protobuf:"varint,5,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"` Replicas []string `protobuf:"bytes,6,rep,name=replicas,proto3" json:"replicas,omitempty"` Leader string `protobuf:"bytes,7,opt,name=leader,proto3" json:"leader,omitempty"` Isr []string `protobuf:"bytes,8,rep,name=isr,proto3" json:"isr,omitempty"` LeaderEpoch uint64 `protobuf:"varint,9,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"` Epoch uint64 `protobuf:"varint,10,opt,name=epoch,proto3" json:"epoch,omitempty"` Paused bool `protobuf:"varint,11,opt,name=paused,proto3" json:"paused,omitempty"` Readonly bool `protobuf:"varint,12,opt,name=readonly,proto3" json:"readonly,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Partition) Descriptor ¶
func (*Partition) GetLeaderEpoch ¶
func (*Partition) GetReadonly ¶ added in v1.4.0
func (*Partition) GetReplicas ¶
func (*Partition) GetReplicationFactor ¶
func (*Partition) GetSubject ¶
func (*Partition) MarshalToSizedBuffer ¶ added in v1.2.0
func (*Partition) ProtoMessage ¶
func (*Partition) ProtoMessage()
func (*Partition) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Partition) XXX_DiscardUnknown()
func (*Partition) XXX_Marshal ¶ added in v1.2.0
func (*Partition) XXX_Unmarshal ¶ added in v1.2.0
type PartitionNotification ¶
type PartitionNotification struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalPartitionNotification ¶
func UnmarshalPartitionNotification(data []byte) (*PartitionNotification, error)
UnmarshalPartitionNotification deserializes a Liftbridge PartitionNotification envelope into a protobuf message.
func (*PartitionNotification) Descriptor ¶
func (*PartitionNotification) Descriptor() ([]byte, []int)
func (*PartitionNotification) GetPartition ¶
func (m *PartitionNotification) GetPartition() int32
func (*PartitionNotification) GetStream ¶
func (m *PartitionNotification) GetStream() string
func (*PartitionNotification) Marshal ¶
func (m *PartitionNotification) Marshal() (dAtA []byte, err error)
func (*PartitionNotification) MarshalTo ¶
func (m *PartitionNotification) MarshalTo(dAtA []byte) (int, error)
func (*PartitionNotification) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *PartitionNotification) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionNotification) ProtoMessage ¶
func (*PartitionNotification) ProtoMessage()
func (*PartitionNotification) Reset ¶
func (m *PartitionNotification) Reset()
func (*PartitionNotification) Size ¶
func (m *PartitionNotification) Size() (n int)
func (*PartitionNotification) String ¶
func (m *PartitionNotification) String() string
func (*PartitionNotification) Unmarshal ¶
func (m *PartitionNotification) Unmarshal(dAtA []byte) error
func (*PartitionNotification) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *PartitionNotification) XXX_DiscardUnknown()
func (*PartitionNotification) XXX_Marshal ¶ added in v1.2.0
func (m *PartitionNotification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionNotification) XXX_Merge ¶ added in v1.2.0
func (m *PartitionNotification) XXX_Merge(src proto.Message)
func (*PartitionNotification) XXX_Size ¶ added in v1.2.0
func (m *PartitionNotification) XXX_Size() int
func (*PartitionNotification) XXX_Unmarshal ¶ added in v1.2.0
func (m *PartitionNotification) XXX_Unmarshal(b []byte) error
type PartitionStatusRequest ¶
type PartitionStatusRequest struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalPartitionStatusRequest ¶
func UnmarshalPartitionStatusRequest(data []byte) (*PartitionStatusRequest, error)
UnmarshalPartitionStatusRequest deserializes a Liftbridge PartitionStatusRequest envelope into a protobuf message.
func (*PartitionStatusRequest) Descriptor ¶
func (*PartitionStatusRequest) Descriptor() ([]byte, []int)
func (*PartitionStatusRequest) GetPartition ¶
func (m *PartitionStatusRequest) GetPartition() int32
func (*PartitionStatusRequest) GetStream ¶
func (m *PartitionStatusRequest) GetStream() string
func (*PartitionStatusRequest) Marshal ¶
func (m *PartitionStatusRequest) Marshal() (dAtA []byte, err error)
func (*PartitionStatusRequest) MarshalTo ¶
func (m *PartitionStatusRequest) MarshalTo(dAtA []byte) (int, error)
func (*PartitionStatusRequest) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *PartitionStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionStatusRequest) ProtoMessage ¶
func (*PartitionStatusRequest) ProtoMessage()
func (*PartitionStatusRequest) Reset ¶
func (m *PartitionStatusRequest) Reset()
func (*PartitionStatusRequest) Size ¶
func (m *PartitionStatusRequest) Size() (n int)
func (*PartitionStatusRequest) String ¶
func (m *PartitionStatusRequest) String() string
func (*PartitionStatusRequest) Unmarshal ¶
func (m *PartitionStatusRequest) Unmarshal(dAtA []byte) error
func (*PartitionStatusRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *PartitionStatusRequest) XXX_DiscardUnknown()
func (*PartitionStatusRequest) XXX_Marshal ¶ added in v1.2.0
func (m *PartitionStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionStatusRequest) XXX_Merge ¶ added in v1.2.0
func (m *PartitionStatusRequest) XXX_Merge(src proto.Message)
func (*PartitionStatusRequest) XXX_Size ¶ added in v1.2.0
func (m *PartitionStatusRequest) XXX_Size() int
func (*PartitionStatusRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *PartitionStatusRequest) XXX_Unmarshal(b []byte) error
type PartitionStatusResponse ¶
type PartitionStatusResponse struct { Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"` IsLeader bool `protobuf:"varint,2,opt,name=isLeader,proto3" json:"isLeader,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalPartitionStatusResponse ¶
func UnmarshalPartitionStatusResponse(data []byte) (*PartitionStatusResponse, error)
UnmarshalPartitionStatusResponse deserializes a Liftbridge PartitionStatusResponse envelope into a protobuf message.
func (*PartitionStatusResponse) Descriptor ¶
func (*PartitionStatusResponse) Descriptor() ([]byte, []int)
func (*PartitionStatusResponse) GetExists ¶
func (m *PartitionStatusResponse) GetExists() bool
func (*PartitionStatusResponse) GetIsLeader ¶
func (m *PartitionStatusResponse) GetIsLeader() bool
func (*PartitionStatusResponse) Marshal ¶
func (m *PartitionStatusResponse) Marshal() (dAtA []byte, err error)
func (*PartitionStatusResponse) MarshalTo ¶
func (m *PartitionStatusResponse) MarshalTo(dAtA []byte) (int, error)
func (*PartitionStatusResponse) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *PartitionStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionStatusResponse) ProtoMessage ¶
func (*PartitionStatusResponse) ProtoMessage()
func (*PartitionStatusResponse) Reset ¶
func (m *PartitionStatusResponse) Reset()
func (*PartitionStatusResponse) Size ¶
func (m *PartitionStatusResponse) Size() (n int)
func (*PartitionStatusResponse) String ¶
func (m *PartitionStatusResponse) String() string
func (*PartitionStatusResponse) Unmarshal ¶
func (m *PartitionStatusResponse) Unmarshal(dAtA []byte) error
func (*PartitionStatusResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *PartitionStatusResponse) XXX_DiscardUnknown()
func (*PartitionStatusResponse) XXX_Marshal ¶ added in v1.2.0
func (m *PartitionStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionStatusResponse) XXX_Merge ¶ added in v1.2.0
func (m *PartitionStatusResponse) XXX_Merge(src proto.Message)
func (*PartitionStatusResponse) XXX_Size ¶ added in v1.2.0
func (m *PartitionStatusResponse) XXX_Size() int
func (*PartitionStatusResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *PartitionStatusResponse) XXX_Unmarshal(b []byte) error
type PauseStreamOp ¶
type PauseStreamOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` ResumeAll bool `protobuf:"varint,3,opt,name=resumeAll,proto3" json:"resumeAll,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PauseStreamOp) Descriptor ¶
func (*PauseStreamOp) Descriptor() ([]byte, []int)
func (*PauseStreamOp) GetPartitions ¶
func (m *PauseStreamOp) GetPartitions() []int32
func (*PauseStreamOp) GetResumeAll ¶
func (m *PauseStreamOp) GetResumeAll() bool
func (*PauseStreamOp) GetStream ¶
func (m *PauseStreamOp) GetStream() string
func (*PauseStreamOp) Marshal ¶
func (m *PauseStreamOp) Marshal() (dAtA []byte, err error)
func (*PauseStreamOp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *PauseStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PauseStreamOp) ProtoMessage ¶
func (*PauseStreamOp) ProtoMessage()
func (*PauseStreamOp) Reset ¶
func (m *PauseStreamOp) Reset()
func (*PauseStreamOp) Size ¶
func (m *PauseStreamOp) Size() (n int)
func (*PauseStreamOp) String ¶
func (m *PauseStreamOp) String() string
func (*PauseStreamOp) Unmarshal ¶
func (m *PauseStreamOp) Unmarshal(dAtA []byte) error
func (*PauseStreamOp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *PauseStreamOp) XXX_DiscardUnknown()
func (*PauseStreamOp) XXX_Marshal ¶ added in v1.2.0
func (m *PauseStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PauseStreamOp) XXX_Merge ¶ added in v1.2.0
func (m *PauseStreamOp) XXX_Merge(src proto.Message)
func (*PauseStreamOp) XXX_Size ¶ added in v1.2.0
func (m *PauseStreamOp) XXX_Size() int
func (*PauseStreamOp) XXX_Unmarshal ¶ added in v1.2.0
func (m *PauseStreamOp) XXX_Unmarshal(b []byte) error
type PropagatedRequest ¶
type PropagatedRequest struct { Op Op `protobuf:"varint,1,opt,name=op,proto3,enum=protocol.Op" json:"op,omitempty"` CreateStreamOp *CreateStreamOp `protobuf:"bytes,2,opt,name=createStreamOp,proto3" json:"createStreamOp,omitempty"` ShrinkISROp *ShrinkISROp `protobuf:"bytes,3,opt,name=shrinkISROp,proto3" json:"shrinkISROp,omitempty"` ReportLeaderOp *ReportLeaderOp `protobuf:"bytes,4,opt,name=reportLeaderOp,proto3" json:"reportLeaderOp,omitempty"` ExpandISROp *ExpandISROp `protobuf:"bytes,5,opt,name=expandISROp,proto3" json:"expandISROp,omitempty"` DeleteStreamOp *DeleteStreamOp `protobuf:"bytes,6,opt,name=deleteStreamOp,proto3" json:"deleteStreamOp,omitempty"` PauseStreamOp *PauseStreamOp `protobuf:"bytes,7,opt,name=pauseStreamOp,proto3" json:"pauseStreamOp,omitempty"` ResumeStreamOp *ResumeStreamOp `protobuf:"bytes,8,opt,name=resumeStreamOp,proto3" json:"resumeStreamOp,omitempty"` SetStreamReadonlyOp *SetStreamReadonlyOp `protobuf:"bytes,9,opt,name=setStreamReadonlyOp,proto3" json:"setStreamReadonlyOp,omitempty"` JoinConsumerGroupOp *JoinConsumerGroupOp `protobuf:"bytes,10,opt,name=joinConsumerGroupOp,proto3" json:"joinConsumerGroupOp,omitempty"` LeaveConsumerGroupOp *LeaveConsumerGroupOp `protobuf:"bytes,11,opt,name=leaveConsumerGroupOp,proto3" json:"leaveConsumerGroupOp,omitempty"` ReportConsumerGroupCoordinatorOp *ReportConsumerGroupCoordinatorOp `protobuf:"bytes,12,opt,name=reportConsumerGroupCoordinatorOp,proto3" json:"reportConsumerGroupCoordinatorOp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalPropagatedRequest ¶
func UnmarshalPropagatedRequest(data []byte) (*PropagatedRequest, error)
UnmarshalPropagatedRequest deserializes a Liftbridge PropagatedRequest envelope into a protobuf message.
func (*PropagatedRequest) Descriptor ¶
func (*PropagatedRequest) Descriptor() ([]byte, []int)
func (*PropagatedRequest) GetCreateStreamOp ¶
func (m *PropagatedRequest) GetCreateStreamOp() *CreateStreamOp
func (*PropagatedRequest) GetDeleteStreamOp ¶
func (m *PropagatedRequest) GetDeleteStreamOp() *DeleteStreamOp
func (*PropagatedRequest) GetExpandISROp ¶
func (m *PropagatedRequest) GetExpandISROp() *ExpandISROp
func (*PropagatedRequest) GetJoinConsumerGroupOp ¶ added in v1.8.0
func (m *PropagatedRequest) GetJoinConsumerGroupOp() *JoinConsumerGroupOp
func (*PropagatedRequest) GetLeaveConsumerGroupOp ¶ added in v1.8.0
func (m *PropagatedRequest) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp
func (*PropagatedRequest) GetOp ¶
func (m *PropagatedRequest) GetOp() Op
func (*PropagatedRequest) GetPauseStreamOp ¶
func (m *PropagatedRequest) GetPauseStreamOp() *PauseStreamOp
func (*PropagatedRequest) GetReportConsumerGroupCoordinatorOp ¶ added in v1.8.0
func (m *PropagatedRequest) GetReportConsumerGroupCoordinatorOp() *ReportConsumerGroupCoordinatorOp
func (*PropagatedRequest) GetReportLeaderOp ¶
func (m *PropagatedRequest) GetReportLeaderOp() *ReportLeaderOp
func (*PropagatedRequest) GetResumeStreamOp ¶
func (m *PropagatedRequest) GetResumeStreamOp() *ResumeStreamOp
func (*PropagatedRequest) GetSetStreamReadonlyOp ¶ added in v1.3.0
func (m *PropagatedRequest) GetSetStreamReadonlyOp() *SetStreamReadonlyOp
func (*PropagatedRequest) GetShrinkISROp ¶
func (m *PropagatedRequest) GetShrinkISROp() *ShrinkISROp
func (*PropagatedRequest) Marshal ¶
func (m *PropagatedRequest) Marshal() (dAtA []byte, err error)
func (*PropagatedRequest) MarshalTo ¶
func (m *PropagatedRequest) MarshalTo(dAtA []byte) (int, error)
func (*PropagatedRequest) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *PropagatedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PropagatedRequest) ProtoMessage ¶
func (*PropagatedRequest) ProtoMessage()
func (*PropagatedRequest) Reset ¶
func (m *PropagatedRequest) Reset()
func (*PropagatedRequest) Size ¶
func (m *PropagatedRequest) Size() (n int)
func (*PropagatedRequest) String ¶
func (m *PropagatedRequest) String() string
func (*PropagatedRequest) Unmarshal ¶
func (m *PropagatedRequest) Unmarshal(dAtA []byte) error
func (*PropagatedRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *PropagatedRequest) XXX_DiscardUnknown()
func (*PropagatedRequest) XXX_Marshal ¶ added in v1.2.0
func (m *PropagatedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PropagatedRequest) XXX_Merge ¶ added in v1.2.0
func (m *PropagatedRequest) XXX_Merge(src proto.Message)
func (*PropagatedRequest) XXX_Size ¶ added in v1.2.0
func (m *PropagatedRequest) XXX_Size() int
func (*PropagatedRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *PropagatedRequest) XXX_Unmarshal(b []byte) error
type PropagatedResponse ¶
type PropagatedResponse struct { Op Op `protobuf:"varint,1,opt,name=op,proto3,enum=protocol.Op" json:"op,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` JoinConsumerGroupResp *PropagatedResponse_JoinConsumerGroupResponse `protobuf:"bytes,11,opt,name=joinConsumerGroupResp,proto3" json:"joinConsumerGroupResp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalPropagatedResponse ¶
func UnmarshalPropagatedResponse(data []byte) (*PropagatedResponse, error)
UnmarshalPropagatedResponse deserializes a Liftbridge PropagatedResponse envelope into a protobuf message.
func (*PropagatedResponse) Descriptor ¶
func (*PropagatedResponse) Descriptor() ([]byte, []int)
func (*PropagatedResponse) GetError ¶
func (m *PropagatedResponse) GetError() *Error
func (*PropagatedResponse) GetJoinConsumerGroupResp ¶ added in v1.8.0
func (m *PropagatedResponse) GetJoinConsumerGroupResp() *PropagatedResponse_JoinConsumerGroupResponse
func (*PropagatedResponse) GetOp ¶
func (m *PropagatedResponse) GetOp() Op
func (*PropagatedResponse) Marshal ¶
func (m *PropagatedResponse) Marshal() (dAtA []byte, err error)
func (*PropagatedResponse) MarshalTo ¶
func (m *PropagatedResponse) MarshalTo(dAtA []byte) (int, error)
func (*PropagatedResponse) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *PropagatedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PropagatedResponse) ProtoMessage ¶
func (*PropagatedResponse) ProtoMessage()
func (*PropagatedResponse) Reset ¶
func (m *PropagatedResponse) Reset()
func (*PropagatedResponse) Size ¶
func (m *PropagatedResponse) Size() (n int)
func (*PropagatedResponse) String ¶
func (m *PropagatedResponse) String() string
func (*PropagatedResponse) Unmarshal ¶
func (m *PropagatedResponse) Unmarshal(dAtA []byte) error
func (*PropagatedResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *PropagatedResponse) XXX_DiscardUnknown()
func (*PropagatedResponse) XXX_Marshal ¶ added in v1.2.0
func (m *PropagatedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PropagatedResponse) XXX_Merge ¶ added in v1.2.0
func (m *PropagatedResponse) XXX_Merge(src proto.Message)
func (*PropagatedResponse) XXX_Size ¶ added in v1.2.0
func (m *PropagatedResponse) XXX_Size() int
func (*PropagatedResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *PropagatedResponse) XXX_Unmarshal(b []byte) error
type PropagatedResponse_JoinConsumerGroupResponse ¶ added in v1.8.0
type PropagatedResponse_JoinConsumerGroupResponse struct { Coordinator string `protobuf:"bytes,1,opt,name=coordinator,proto3" json:"coordinator,omitempty"` Epoch uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Reserving = 3 for createStreamResp if needed. Reserving = 4 for shrinkISRResp if needed. Reserving = 5 for reportLeaderResp if needed. Reserving = 6 for expandISRResp if needed. Reserving = 7 for deleteStreamResp if needed. Reserving = 8 for pauseStreamResp if needed. Reserving = 9 for resumeStreamResp if needed. Reserving = 10 for setStreamReadonlyResp if needed.
func (*PropagatedResponse_JoinConsumerGroupResponse) Descriptor ¶ added in v1.8.0
func (*PropagatedResponse_JoinConsumerGroupResponse) Descriptor() ([]byte, []int)
func (*PropagatedResponse_JoinConsumerGroupResponse) GetCoordinator ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) GetCoordinator() string
func (*PropagatedResponse_JoinConsumerGroupResponse) GetEpoch ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) GetEpoch() uint64
func (*PropagatedResponse_JoinConsumerGroupResponse) Marshal ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) Marshal() (dAtA []byte, err error)
func (*PropagatedResponse_JoinConsumerGroupResponse) MarshalTo ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) MarshalTo(dAtA []byte) (int, error)
func (*PropagatedResponse_JoinConsumerGroupResponse) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PropagatedResponse_JoinConsumerGroupResponse) ProtoMessage ¶ added in v1.8.0
func (*PropagatedResponse_JoinConsumerGroupResponse) ProtoMessage()
func (*PropagatedResponse_JoinConsumerGroupResponse) Reset ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) Reset()
func (*PropagatedResponse_JoinConsumerGroupResponse) Size ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) Size() (n int)
func (*PropagatedResponse_JoinConsumerGroupResponse) String ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) String() string
func (*PropagatedResponse_JoinConsumerGroupResponse) Unmarshal ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) Unmarshal(dAtA []byte) error
func (*PropagatedResponse_JoinConsumerGroupResponse) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_DiscardUnknown()
func (*PropagatedResponse_JoinConsumerGroupResponse) XXX_Marshal ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PropagatedResponse_JoinConsumerGroupResponse) XXX_Merge ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_Merge(src proto.Message)
func (*PropagatedResponse_JoinConsumerGroupResponse) XXX_Size ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_Size() int
func (*PropagatedResponse_JoinConsumerGroupResponse) XXX_Unmarshal ¶ added in v1.8.0
func (m *PropagatedResponse_JoinConsumerGroupResponse) XXX_Unmarshal(b []byte) error
type PublishActivityOp ¶
type PublishActivityOp struct { RaftIndex uint64 `protobuf:"varint,1,opt,name=raftIndex,proto3" json:"raftIndex,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PublishActivityOp) Descriptor ¶
func (*PublishActivityOp) Descriptor() ([]byte, []int)
func (*PublishActivityOp) GetRaftIndex ¶
func (m *PublishActivityOp) GetRaftIndex() uint64
func (*PublishActivityOp) Marshal ¶
func (m *PublishActivityOp) Marshal() (dAtA []byte, err error)
func (*PublishActivityOp) MarshalTo ¶
func (m *PublishActivityOp) MarshalTo(dAtA []byte) (int, error)
func (*PublishActivityOp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *PublishActivityOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PublishActivityOp) ProtoMessage ¶
func (*PublishActivityOp) ProtoMessage()
func (*PublishActivityOp) Reset ¶
func (m *PublishActivityOp) Reset()
func (*PublishActivityOp) Size ¶
func (m *PublishActivityOp) Size() (n int)
func (*PublishActivityOp) String ¶
func (m *PublishActivityOp) String() string
func (*PublishActivityOp) Unmarshal ¶
func (m *PublishActivityOp) Unmarshal(dAtA []byte) error
func (*PublishActivityOp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *PublishActivityOp) XXX_DiscardUnknown()
func (*PublishActivityOp) XXX_Marshal ¶ added in v1.2.0
func (m *PublishActivityOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishActivityOp) XXX_Merge ¶ added in v1.2.0
func (m *PublishActivityOp) XXX_Merge(src proto.Message)
func (*PublishActivityOp) XXX_Size ¶ added in v1.2.0
func (m *PublishActivityOp) XXX_Size() int
func (*PublishActivityOp) XXX_Unmarshal ¶ added in v1.2.0
func (m *PublishActivityOp) XXX_Unmarshal(b []byte) error
type RaftJoinRequest ¶
type RaftJoinRequest struct { NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"` NodeAddr string `protobuf:"bytes,2,opt,name=nodeAddr,proto3" json:"nodeAddr,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RaftJoinRequest is a request to join a Raft group.
func UnmarshalRaftJoinRequest ¶
func UnmarshalRaftJoinRequest(data []byte) (*RaftJoinRequest, error)
UnmarshalRaftJoinRequest deserializes a Liftbridge RaftJoinRequest envelope into a protobuf message.
func (*RaftJoinRequest) Descriptor ¶
func (*RaftJoinRequest) Descriptor() ([]byte, []int)
func (*RaftJoinRequest) GetNodeAddr ¶
func (m *RaftJoinRequest) GetNodeAddr() string
func (*RaftJoinRequest) GetNodeID ¶
func (m *RaftJoinRequest) GetNodeID() string
func (*RaftJoinRequest) Marshal ¶
func (m *RaftJoinRequest) Marshal() (dAtA []byte, err error)
func (*RaftJoinRequest) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *RaftJoinRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RaftJoinRequest) ProtoMessage ¶
func (*RaftJoinRequest) ProtoMessage()
func (*RaftJoinRequest) Reset ¶
func (m *RaftJoinRequest) Reset()
func (*RaftJoinRequest) Size ¶
func (m *RaftJoinRequest) Size() (n int)
func (*RaftJoinRequest) String ¶
func (m *RaftJoinRequest) String() string
func (*RaftJoinRequest) Unmarshal ¶
func (m *RaftJoinRequest) Unmarshal(dAtA []byte) error
func (*RaftJoinRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *RaftJoinRequest) XXX_DiscardUnknown()
func (*RaftJoinRequest) XXX_Marshal ¶ added in v1.2.0
func (m *RaftJoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RaftJoinRequest) XXX_Merge ¶ added in v1.2.0
func (m *RaftJoinRequest) XXX_Merge(src proto.Message)
func (*RaftJoinRequest) XXX_Size ¶ added in v1.2.0
func (m *RaftJoinRequest) XXX_Size() int
func (*RaftJoinRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *RaftJoinRequest) XXX_Unmarshal(b []byte) error
type RaftJoinResponse ¶
type RaftJoinResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RaftJoinResponse is a response to a RaftJoinRequest.
func UnmarshalRaftJoinResponse ¶
func UnmarshalRaftJoinResponse(data []byte) (*RaftJoinResponse, error)
UnmarshalRaftJoinResponse deserializes a Liftbridge RaftJoinResponse envelope into a protobuf message.
func (*RaftJoinResponse) Descriptor ¶
func (*RaftJoinResponse) Descriptor() ([]byte, []int)
func (*RaftJoinResponse) GetError ¶
func (m *RaftJoinResponse) GetError() string
func (*RaftJoinResponse) Marshal ¶
func (m *RaftJoinResponse) Marshal() (dAtA []byte, err error)
func (*RaftJoinResponse) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *RaftJoinResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RaftJoinResponse) ProtoMessage ¶
func (*RaftJoinResponse) ProtoMessage()
func (*RaftJoinResponse) Reset ¶
func (m *RaftJoinResponse) Reset()
func (*RaftJoinResponse) Size ¶
func (m *RaftJoinResponse) Size() (n int)
func (*RaftJoinResponse) String ¶
func (m *RaftJoinResponse) String() string
func (*RaftJoinResponse) Unmarshal ¶
func (m *RaftJoinResponse) Unmarshal(dAtA []byte) error
func (*RaftJoinResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *RaftJoinResponse) XXX_DiscardUnknown()
func (*RaftJoinResponse) XXX_Marshal ¶ added in v1.2.0
func (m *RaftJoinResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RaftJoinResponse) XXX_Merge ¶ added in v1.2.0
func (m *RaftJoinResponse) XXX_Merge(src proto.Message)
func (*RaftJoinResponse) XXX_Size ¶ added in v1.2.0
func (m *RaftJoinResponse) XXX_Size() int
func (*RaftJoinResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *RaftJoinResponse) XXX_Unmarshal(b []byte) error
type RaftLog ¶
type RaftLog struct { Op Op `protobuf:"varint,1,opt,name=op,proto3,enum=protocol.Op" json:"op,omitempty"` CreateStreamOp *CreateStreamOp `protobuf:"bytes,2,opt,name=createStreamOp,proto3" json:"createStreamOp,omitempty"` ShrinkISROp *ShrinkISROp `protobuf:"bytes,3,opt,name=shrinkISROp,proto3" json:"shrinkISROp,omitempty"` ChangeLeaderOp *ChangeLeaderOp `protobuf:"bytes,4,opt,name=changeLeaderOp,proto3" json:"changeLeaderOp,omitempty"` ExpandISROp *ExpandISROp `protobuf:"bytes,5,opt,name=expandISROp,proto3" json:"expandISROp,omitempty"` DeleteStreamOp *DeleteStreamOp `protobuf:"bytes,6,opt,name=deleteStreamOp,proto3" json:"deleteStreamOp,omitempty"` PauseStreamOp *PauseStreamOp `protobuf:"bytes,7,opt,name=pauseStreamOp,proto3" json:"pauseStreamOp,omitempty"` ResumeStreamOp *ResumeStreamOp `protobuf:"bytes,8,opt,name=resumeStreamOp,proto3" json:"resumeStreamOp,omitempty"` PublishActivityOp *PublishActivityOp `protobuf:"bytes,9,opt,name=publishActivityOp,proto3" json:"publishActivityOp,omitempty"` SetStreamReadonlyOp *SetStreamReadonlyOp `protobuf:"bytes,10,opt,name=setStreamReadonlyOp,proto3" json:"setStreamReadonlyOp,omitempty"` CreateConsumerGroupOp *CreateConsumerGroupOp `protobuf:"bytes,11,opt,name=createConsumerGroupOp,proto3" json:"createConsumerGroupOp,omitempty"` JoinConsumerGroupOp *JoinConsumerGroupOp `protobuf:"bytes,12,opt,name=joinConsumerGroupOp,proto3" json:"joinConsumerGroupOp,omitempty"` LeaveConsumerGroupOp *LeaveConsumerGroupOp `protobuf:"bytes,13,opt,name=leaveConsumerGroupOp,proto3" json:"leaveConsumerGroupOp,omitempty"` ChangeConsumerGroupCoordinatorOp *ChangeConsumerGroupCoordinatorOp `protobuf:"bytes,14,opt,name=changeConsumerGroupCoordinatorOp,proto3" json:"changeConsumerGroupCoordinatorOp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RaftLog) Descriptor ¶
func (*RaftLog) GetChangeConsumerGroupCoordinatorOp ¶ added in v1.8.0
func (m *RaftLog) GetChangeConsumerGroupCoordinatorOp() *ChangeConsumerGroupCoordinatorOp
func (*RaftLog) GetChangeLeaderOp ¶
func (m *RaftLog) GetChangeLeaderOp() *ChangeLeaderOp
func (*RaftLog) GetCreateConsumerGroupOp ¶ added in v1.8.0
func (m *RaftLog) GetCreateConsumerGroupOp() *CreateConsumerGroupOp
func (*RaftLog) GetCreateStreamOp ¶
func (m *RaftLog) GetCreateStreamOp() *CreateStreamOp
func (*RaftLog) GetDeleteStreamOp ¶
func (m *RaftLog) GetDeleteStreamOp() *DeleteStreamOp
func (*RaftLog) GetExpandISROp ¶
func (m *RaftLog) GetExpandISROp() *ExpandISROp
func (*RaftLog) GetJoinConsumerGroupOp ¶ added in v1.8.0
func (m *RaftLog) GetJoinConsumerGroupOp() *JoinConsumerGroupOp
func (*RaftLog) GetLeaveConsumerGroupOp ¶ added in v1.8.0
func (m *RaftLog) GetLeaveConsumerGroupOp() *LeaveConsumerGroupOp
func (*RaftLog) GetPauseStreamOp ¶
func (m *RaftLog) GetPauseStreamOp() *PauseStreamOp
func (*RaftLog) GetPublishActivityOp ¶
func (m *RaftLog) GetPublishActivityOp() *PublishActivityOp
func (*RaftLog) GetResumeStreamOp ¶
func (m *RaftLog) GetResumeStreamOp() *ResumeStreamOp
func (*RaftLog) GetSetStreamReadonlyOp ¶ added in v1.3.0
func (m *RaftLog) GetSetStreamReadonlyOp() *SetStreamReadonlyOp
func (*RaftLog) GetShrinkISROp ¶
func (m *RaftLog) GetShrinkISROp() *ShrinkISROp
func (*RaftLog) MarshalToSizedBuffer ¶ added in v1.2.0
func (*RaftLog) ProtoMessage ¶
func (*RaftLog) ProtoMessage()
func (*RaftLog) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *RaftLog) XXX_DiscardUnknown()
func (*RaftLog) XXX_Marshal ¶ added in v1.2.0
func (*RaftLog) XXX_Unmarshal ¶ added in v1.2.0
type ReplicationRequest ¶
type ReplicationRequest struct { ReplicaID string `protobuf:"bytes,1,opt,name=replicaID,proto3" json:"replicaID,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` LeaderEpoch uint64 `protobuf:"varint,3,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalReplicationRequest ¶
func UnmarshalReplicationRequest(data []byte) (*ReplicationRequest, error)
UnmarshalReplicationRequest deserializes a Liftbridge ReplicationRequest envelope into a protobuf message.
func (*ReplicationRequest) Descriptor ¶
func (*ReplicationRequest) Descriptor() ([]byte, []int)
func (*ReplicationRequest) GetLeaderEpoch ¶
func (m *ReplicationRequest) GetLeaderEpoch() uint64
func (*ReplicationRequest) GetOffset ¶
func (m *ReplicationRequest) GetOffset() int64
func (*ReplicationRequest) GetReplicaID ¶
func (m *ReplicationRequest) GetReplicaID() string
func (*ReplicationRequest) Marshal ¶
func (m *ReplicationRequest) Marshal() (dAtA []byte, err error)
func (*ReplicationRequest) MarshalTo ¶
func (m *ReplicationRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReplicationRequest) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ReplicationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicationRequest) ProtoMessage ¶
func (*ReplicationRequest) ProtoMessage()
func (*ReplicationRequest) Reset ¶
func (m *ReplicationRequest) Reset()
func (*ReplicationRequest) Size ¶
func (m *ReplicationRequest) Size() (n int)
func (*ReplicationRequest) String ¶
func (m *ReplicationRequest) String() string
func (*ReplicationRequest) Unmarshal ¶
func (m *ReplicationRequest) Unmarshal(dAtA []byte) error
func (*ReplicationRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ReplicationRequest) XXX_DiscardUnknown()
func (*ReplicationRequest) XXX_Marshal ¶ added in v1.2.0
func (m *ReplicationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationRequest) XXX_Merge ¶ added in v1.2.0
func (m *ReplicationRequest) XXX_Merge(src proto.Message)
func (*ReplicationRequest) XXX_Size ¶ added in v1.2.0
func (m *ReplicationRequest) XXX_Size() int
func (*ReplicationRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *ReplicationRequest) XXX_Unmarshal(b []byte) error
type ReportConsumerGroupCoordinatorOp ¶ added in v1.8.0
type ReportConsumerGroupCoordinatorOp struct { GroupId string `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"` ConsumerId string `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"` Coordinator string `protobuf:"bytes,3,opt,name=coordinator,proto3" json:"coordinator,omitempty"` Epoch uint64 `protobuf:"varint,4,opt,name=epoch,proto3" json:"epoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReportConsumerGroupCoordinatorOp) Descriptor ¶ added in v1.8.0
func (*ReportConsumerGroupCoordinatorOp) Descriptor() ([]byte, []int)
func (*ReportConsumerGroupCoordinatorOp) GetConsumerId ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) GetConsumerId() string
func (*ReportConsumerGroupCoordinatorOp) GetCoordinator ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) GetCoordinator() string
func (*ReportConsumerGroupCoordinatorOp) GetEpoch ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) GetEpoch() uint64
func (*ReportConsumerGroupCoordinatorOp) GetGroupId ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) GetGroupId() string
func (*ReportConsumerGroupCoordinatorOp) Marshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) Marshal() (dAtA []byte, err error)
func (*ReportConsumerGroupCoordinatorOp) MarshalTo ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) MarshalTo(dAtA []byte) (int, error)
func (*ReportConsumerGroupCoordinatorOp) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReportConsumerGroupCoordinatorOp) ProtoMessage ¶ added in v1.8.0
func (*ReportConsumerGroupCoordinatorOp) ProtoMessage()
func (*ReportConsumerGroupCoordinatorOp) Reset ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) Reset()
func (*ReportConsumerGroupCoordinatorOp) Size ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) Size() (n int)
func (*ReportConsumerGroupCoordinatorOp) String ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) String() string
func (*ReportConsumerGroupCoordinatorOp) Unmarshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) Unmarshal(dAtA []byte) error
func (*ReportConsumerGroupCoordinatorOp) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) XXX_DiscardUnknown()
func (*ReportConsumerGroupCoordinatorOp) XXX_Marshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportConsumerGroupCoordinatorOp) XXX_Merge ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) XXX_Merge(src proto.Message)
func (*ReportConsumerGroupCoordinatorOp) XXX_Size ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) XXX_Size() int
func (*ReportConsumerGroupCoordinatorOp) XXX_Unmarshal ¶ added in v1.8.0
func (m *ReportConsumerGroupCoordinatorOp) XXX_Unmarshal(b []byte) error
type ReportLeaderOp ¶
type ReportLeaderOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` Replica string `protobuf:"bytes,3,opt,name=replica,proto3" json:"replica,omitempty"` Leader string `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"` LeaderEpoch uint64 `protobuf:"varint,5,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReportLeaderOp) Descriptor ¶
func (*ReportLeaderOp) Descriptor() ([]byte, []int)
func (*ReportLeaderOp) GetLeader ¶
func (m *ReportLeaderOp) GetLeader() string
func (*ReportLeaderOp) GetLeaderEpoch ¶
func (m *ReportLeaderOp) GetLeaderEpoch() uint64
func (*ReportLeaderOp) GetPartition ¶
func (m *ReportLeaderOp) GetPartition() int32
func (*ReportLeaderOp) GetReplica ¶
func (m *ReportLeaderOp) GetReplica() string
func (*ReportLeaderOp) GetStream ¶
func (m *ReportLeaderOp) GetStream() string
func (*ReportLeaderOp) Marshal ¶
func (m *ReportLeaderOp) Marshal() (dAtA []byte, err error)
func (*ReportLeaderOp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ReportLeaderOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReportLeaderOp) ProtoMessage ¶
func (*ReportLeaderOp) ProtoMessage()
func (*ReportLeaderOp) Reset ¶
func (m *ReportLeaderOp) Reset()
func (*ReportLeaderOp) Size ¶
func (m *ReportLeaderOp) Size() (n int)
func (*ReportLeaderOp) String ¶
func (m *ReportLeaderOp) String() string
func (*ReportLeaderOp) Unmarshal ¶
func (m *ReportLeaderOp) Unmarshal(dAtA []byte) error
func (*ReportLeaderOp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ReportLeaderOp) XXX_DiscardUnknown()
func (*ReportLeaderOp) XXX_Marshal ¶ added in v1.2.0
func (m *ReportLeaderOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportLeaderOp) XXX_Merge ¶ added in v1.2.0
func (m *ReportLeaderOp) XXX_Merge(src proto.Message)
func (*ReportLeaderOp) XXX_Size ¶ added in v1.2.0
func (m *ReportLeaderOp) XXX_Size() int
func (*ReportLeaderOp) XXX_Unmarshal ¶ added in v1.2.0
func (m *ReportLeaderOp) XXX_Unmarshal(b []byte) error
type ResumeStreamOp ¶
type ResumeStreamOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResumeStreamOp) Descriptor ¶
func (*ResumeStreamOp) Descriptor() ([]byte, []int)
func (*ResumeStreamOp) GetPartitions ¶
func (m *ResumeStreamOp) GetPartitions() []int32
func (*ResumeStreamOp) GetStream ¶
func (m *ResumeStreamOp) GetStream() string
func (*ResumeStreamOp) Marshal ¶
func (m *ResumeStreamOp) Marshal() (dAtA []byte, err error)
func (*ResumeStreamOp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ResumeStreamOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResumeStreamOp) ProtoMessage ¶
func (*ResumeStreamOp) ProtoMessage()
func (*ResumeStreamOp) Reset ¶
func (m *ResumeStreamOp) Reset()
func (*ResumeStreamOp) Size ¶
func (m *ResumeStreamOp) Size() (n int)
func (*ResumeStreamOp) String ¶
func (m *ResumeStreamOp) String() string
func (*ResumeStreamOp) Unmarshal ¶
func (m *ResumeStreamOp) Unmarshal(dAtA []byte) error
func (*ResumeStreamOp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ResumeStreamOp) XXX_DiscardUnknown()
func (*ResumeStreamOp) XXX_Marshal ¶ added in v1.2.0
func (m *ResumeStreamOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResumeStreamOp) XXX_Merge ¶ added in v1.2.0
func (m *ResumeStreamOp) XXX_Merge(src proto.Message)
func (*ResumeStreamOp) XXX_Size ¶ added in v1.2.0
func (m *ResumeStreamOp) XXX_Size() int
func (*ResumeStreamOp) XXX_Unmarshal ¶ added in v1.2.0
func (m *ResumeStreamOp) XXX_Unmarshal(b []byte) error
type ServerInfoRequest ¶
type ServerInfoRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalServerInfoRequest ¶
func UnmarshalServerInfoRequest(data []byte) (*ServerInfoRequest, error)
UnmarshalServerInfoRequest deserializes a Liftbridge ServerInfoRequest envelope into a protobuf message.
func (*ServerInfoRequest) Descriptor ¶
func (*ServerInfoRequest) Descriptor() ([]byte, []int)
func (*ServerInfoRequest) GetId ¶
func (m *ServerInfoRequest) GetId() string
func (*ServerInfoRequest) Marshal ¶
func (m *ServerInfoRequest) Marshal() (dAtA []byte, err error)
func (*ServerInfoRequest) MarshalTo ¶
func (m *ServerInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServerInfoRequest) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ServerInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServerInfoRequest) ProtoMessage ¶
func (*ServerInfoRequest) ProtoMessage()
func (*ServerInfoRequest) Reset ¶
func (m *ServerInfoRequest) Reset()
func (*ServerInfoRequest) Size ¶
func (m *ServerInfoRequest) Size() (n int)
func (*ServerInfoRequest) String ¶
func (m *ServerInfoRequest) String() string
func (*ServerInfoRequest) Unmarshal ¶
func (m *ServerInfoRequest) Unmarshal(dAtA []byte) error
func (*ServerInfoRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ServerInfoRequest) XXX_DiscardUnknown()
func (*ServerInfoRequest) XXX_Marshal ¶ added in v1.2.0
func (m *ServerInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerInfoRequest) XXX_Merge ¶ added in v1.2.0
func (m *ServerInfoRequest) XXX_Merge(src proto.Message)
func (*ServerInfoRequest) XXX_Size ¶ added in v1.2.0
func (m *ServerInfoRequest) XXX_Size() int
func (*ServerInfoRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *ServerInfoRequest) XXX_Unmarshal(b []byte) error
type ServerInfoResponse ¶
type ServerInfoResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func UnmarshalServerInfoResponse ¶
func UnmarshalServerInfoResponse(data []byte) (*ServerInfoResponse, error)
UnmarshalServerInfoResponse deserializes a Liftbridge ServerInfoResponse envelope into a protobuf message.
func (*ServerInfoResponse) Descriptor ¶
func (*ServerInfoResponse) Descriptor() ([]byte, []int)
func (*ServerInfoResponse) GetHost ¶
func (m *ServerInfoResponse) GetHost() string
func (*ServerInfoResponse) GetId ¶
func (m *ServerInfoResponse) GetId() string
func (*ServerInfoResponse) GetPort ¶
func (m *ServerInfoResponse) GetPort() int32
func (*ServerInfoResponse) Marshal ¶
func (m *ServerInfoResponse) Marshal() (dAtA []byte, err error)
func (*ServerInfoResponse) MarshalTo ¶
func (m *ServerInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServerInfoResponse) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ServerInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServerInfoResponse) ProtoMessage ¶
func (*ServerInfoResponse) ProtoMessage()
func (*ServerInfoResponse) Reset ¶
func (m *ServerInfoResponse) Reset()
func (*ServerInfoResponse) Size ¶
func (m *ServerInfoResponse) Size() (n int)
func (*ServerInfoResponse) String ¶
func (m *ServerInfoResponse) String() string
func (*ServerInfoResponse) Unmarshal ¶
func (m *ServerInfoResponse) Unmarshal(dAtA []byte) error
func (*ServerInfoResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ServerInfoResponse) XXX_DiscardUnknown()
func (*ServerInfoResponse) XXX_Marshal ¶ added in v1.2.0
func (m *ServerInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerInfoResponse) XXX_Merge ¶ added in v1.2.0
func (m *ServerInfoResponse) XXX_Merge(src proto.Message)
func (*ServerInfoResponse) XXX_Size ¶ added in v1.2.0
func (m *ServerInfoResponse) XXX_Size() int
func (*ServerInfoResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *ServerInfoResponse) XXX_Unmarshal(b []byte) error
type ServerState ¶
type ServerState struct { ServerID string `protobuf:"bytes,1,opt,name=serverID,proto3" json:"serverID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServerState) Descriptor ¶
func (*ServerState) Descriptor() ([]byte, []int)
func (*ServerState) GetServerID ¶
func (m *ServerState) GetServerID() string
func (*ServerState) Marshal ¶
func (m *ServerState) Marshal() (dAtA []byte, err error)
func (*ServerState) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ServerState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServerState) ProtoMessage ¶
func (*ServerState) ProtoMessage()
func (*ServerState) Reset ¶
func (m *ServerState) Reset()
func (*ServerState) Size ¶
func (m *ServerState) Size() (n int)
func (*ServerState) String ¶
func (m *ServerState) String() string
func (*ServerState) Unmarshal ¶
func (m *ServerState) Unmarshal(dAtA []byte) error
func (*ServerState) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ServerState) XXX_DiscardUnknown()
func (*ServerState) XXX_Marshal ¶ added in v1.2.0
func (m *ServerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerState) XXX_Merge ¶ added in v1.2.0
func (m *ServerState) XXX_Merge(src proto.Message)
func (*ServerState) XXX_Size ¶ added in v1.2.0
func (m *ServerState) XXX_Size() int
func (*ServerState) XXX_Unmarshal ¶ added in v1.2.0
func (m *ServerState) XXX_Unmarshal(b []byte) error
type SetStreamReadonlyOp ¶ added in v1.3.0
type SetStreamReadonlyOp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` Readonly bool `protobuf:"varint,3,opt,name=readonly,proto3" json:"readonly,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetStreamReadonlyOp) Descriptor ¶ added in v1.3.0
func (*SetStreamReadonlyOp) Descriptor() ([]byte, []int)
func (*SetStreamReadonlyOp) GetPartitions ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) GetPartitions() []int32
func (*SetStreamReadonlyOp) GetReadonly ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) GetReadonly() bool
func (*SetStreamReadonlyOp) GetStream ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) GetStream() string
func (*SetStreamReadonlyOp) Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Marshal() (dAtA []byte, err error)
func (*SetStreamReadonlyOp) MarshalTo ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) MarshalTo(dAtA []byte) (int, error)
func (*SetStreamReadonlyOp) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetStreamReadonlyOp) ProtoMessage ¶ added in v1.3.0
func (*SetStreamReadonlyOp) ProtoMessage()
func (*SetStreamReadonlyOp) Reset ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Reset()
func (*SetStreamReadonlyOp) Size ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Size() (n int)
func (*SetStreamReadonlyOp) String ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) String() string
func (*SetStreamReadonlyOp) Unmarshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) Unmarshal(dAtA []byte) error
func (*SetStreamReadonlyOp) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_DiscardUnknown()
func (*SetStreamReadonlyOp) XXX_Marshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStreamReadonlyOp) XXX_Merge ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Merge(src proto.Message)
func (*SetStreamReadonlyOp) XXX_Size ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Size() int
func (*SetStreamReadonlyOp) XXX_Unmarshal ¶ added in v1.3.0
func (m *SetStreamReadonlyOp) XXX_Unmarshal(b []byte) error
type ShrinkISROp ¶
type ShrinkISROp struct { Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` Partition int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` ReplicaToRemove string `protobuf:"bytes,3,opt,name=replicaToRemove,proto3" json:"replicaToRemove,omitempty"` Leader string `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"` LeaderEpoch uint64 `protobuf:"varint,5,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShrinkISROp) Descriptor ¶
func (*ShrinkISROp) Descriptor() ([]byte, []int)
func (*ShrinkISROp) GetLeader ¶
func (m *ShrinkISROp) GetLeader() string
func (*ShrinkISROp) GetLeaderEpoch ¶
func (m *ShrinkISROp) GetLeaderEpoch() uint64
func (*ShrinkISROp) GetPartition ¶
func (m *ShrinkISROp) GetPartition() int32
func (*ShrinkISROp) GetReplicaToRemove ¶
func (m *ShrinkISROp) GetReplicaToRemove() string
func (*ShrinkISROp) GetStream ¶
func (m *ShrinkISROp) GetStream() string
func (*ShrinkISROp) Marshal ¶
func (m *ShrinkISROp) Marshal() (dAtA []byte, err error)
func (*ShrinkISROp) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *ShrinkISROp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShrinkISROp) ProtoMessage ¶
func (*ShrinkISROp) ProtoMessage()
func (*ShrinkISROp) Reset ¶
func (m *ShrinkISROp) Reset()
func (*ShrinkISROp) Size ¶
func (m *ShrinkISROp) Size() (n int)
func (*ShrinkISROp) String ¶
func (m *ShrinkISROp) String() string
func (*ShrinkISROp) Unmarshal ¶
func (m *ShrinkISROp) Unmarshal(dAtA []byte) error
func (*ShrinkISROp) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ShrinkISROp) XXX_DiscardUnknown()
func (*ShrinkISROp) XXX_Marshal ¶ added in v1.2.0
func (m *ShrinkISROp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShrinkISROp) XXX_Merge ¶ added in v1.2.0
func (m *ShrinkISROp) XXX_Merge(src proto.Message)
func (*ShrinkISROp) XXX_Size ¶ added in v1.2.0
func (m *ShrinkISROp) XXX_Size() int
func (*ShrinkISROp) XXX_Unmarshal ¶ added in v1.2.0
func (m *ShrinkISROp) XXX_Unmarshal(b []byte) error
type Stream ¶
type Stream struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"` Partitions []*Partition `protobuf:"bytes,3,rep,name=partitions,proto3" json:"partitions,omitempty"` Config *StreamConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` CreationTimestamp int64 `protobuf:"varint,5,opt,name=creationTimestamp,proto3" json:"creationTimestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Stream) Descriptor ¶
func (*Stream) GetConfig ¶ added in v1.2.0
func (m *Stream) GetConfig() *StreamConfig
func (*Stream) GetCreationTimestamp ¶ added in v1.4.0
func (*Stream) GetPartitions ¶
func (*Stream) GetSubject ¶
func (*Stream) MarshalToSizedBuffer ¶ added in v1.2.0
func (*Stream) ProtoMessage ¶
func (*Stream) ProtoMessage()
func (*Stream) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Stream) XXX_DiscardUnknown()
func (*Stream) XXX_Marshal ¶ added in v1.2.0
func (*Stream) XXX_Unmarshal ¶ added in v1.2.0
type StreamConfig ¶ added in v1.2.0
type StreamConfig struct { RetentionMaxBytes *NullableInt64 `protobuf:"bytes,1,opt,name=retentionMaxBytes,proto3" json:"retentionMaxBytes,omitempty"` RetentionMaxMessages *NullableInt64 `protobuf:"bytes,2,opt,name=retentionMaxMessages,proto3" json:"retentionMaxMessages,omitempty"` RetentionMaxAge *NullableInt64 `protobuf:"bytes,3,opt,name=retentionMaxAge,proto3" json:"retentionMaxAge,omitempty"` CleanerInterval *NullableInt64 `protobuf:"bytes,4,opt,name=cleanerInterval,proto3" json:"cleanerInterval,omitempty"` SegmentMaxBytes *NullableInt64 `protobuf:"bytes,5,opt,name=segmentMaxBytes,proto3" json:"segmentMaxBytes,omitempty"` SegmentMaxAge *NullableInt64 `protobuf:"bytes,6,opt,name=segmentMaxAge,proto3" json:"segmentMaxAge,omitempty"` CompactMaxGoroutines *NullableInt32 `protobuf:"bytes,7,opt,name=compactMaxGoroutines,proto3" json:"compactMaxGoroutines,omitempty"` CompactEnabled *NullableBool `protobuf:"bytes,8,opt,name=compactEnabled,proto3" json:"compactEnabled,omitempty"` AutoPauseTime *NullableInt64 `protobuf:"bytes,9,opt,name=autoPauseTime,proto3" json:"autoPauseTime,omitempty"` AutoPauseDisableIfSubscribers *NullableBool `protobuf:"bytes,10,opt,name=autoPauseDisableIfSubscribers,proto3" json:"autoPauseDisableIfSubscribers,omitempty"` MinIsr *NullableInt32 `protobuf:"bytes,11,opt,name=minIsr,proto3" json:"minIsr,omitempty"` OptimisticConcurrencyControl *NullableBool `protobuf:"bytes,12,opt,name=optimisticConcurrencyControl,proto3" json:"optimisticConcurrencyControl,omitempty"` Encryption *NullableBool `protobuf:"bytes,13,opt,name=encryption,proto3" json:"encryption,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StreamConfig) Descriptor ¶ added in v1.2.0
func (*StreamConfig) Descriptor() ([]byte, []int)
func (*StreamConfig) GetAutoPauseDisableIfSubscribers ¶ added in v1.3.0
func (m *StreamConfig) GetAutoPauseDisableIfSubscribers() *NullableBool
func (*StreamConfig) GetAutoPauseTime ¶ added in v1.3.0
func (m *StreamConfig) GetAutoPauseTime() *NullableInt64
func (*StreamConfig) GetCleanerInterval ¶ added in v1.2.0
func (m *StreamConfig) GetCleanerInterval() *NullableInt64
func (*StreamConfig) GetCompactEnabled ¶ added in v1.2.0
func (m *StreamConfig) GetCompactEnabled() *NullableBool
func (*StreamConfig) GetCompactMaxGoroutines ¶ added in v1.2.0
func (m *StreamConfig) GetCompactMaxGoroutines() *NullableInt32
func (*StreamConfig) GetEncryption ¶ added in v1.6.0
func (m *StreamConfig) GetEncryption() *NullableBool
func (*StreamConfig) GetMinIsr ¶ added in v1.3.0
func (m *StreamConfig) GetMinIsr() *NullableInt32
func (*StreamConfig) GetOptimisticConcurrencyControl ¶ added in v1.5.0
func (m *StreamConfig) GetOptimisticConcurrencyControl() *NullableBool
func (*StreamConfig) GetRetentionMaxAge ¶ added in v1.2.0
func (m *StreamConfig) GetRetentionMaxAge() *NullableInt64
func (*StreamConfig) GetRetentionMaxBytes ¶ added in v1.2.0
func (m *StreamConfig) GetRetentionMaxBytes() *NullableInt64
func (*StreamConfig) GetRetentionMaxMessages ¶ added in v1.2.0
func (m *StreamConfig) GetRetentionMaxMessages() *NullableInt64
func (*StreamConfig) GetSegmentMaxAge ¶ added in v1.2.0
func (m *StreamConfig) GetSegmentMaxAge() *NullableInt64
func (*StreamConfig) GetSegmentMaxBytes ¶ added in v1.2.0
func (m *StreamConfig) GetSegmentMaxBytes() *NullableInt64
func (*StreamConfig) Marshal ¶ added in v1.2.0
func (m *StreamConfig) Marshal() (dAtA []byte, err error)
func (*StreamConfig) MarshalTo ¶ added in v1.2.0
func (m *StreamConfig) MarshalTo(dAtA []byte) (int, error)
func (*StreamConfig) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *StreamConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamConfig) ProtoMessage ¶ added in v1.2.0
func (*StreamConfig) ProtoMessage()
func (*StreamConfig) Reset ¶ added in v1.2.0
func (m *StreamConfig) Reset()
func (*StreamConfig) Size ¶ added in v1.2.0
func (m *StreamConfig) Size() (n int)
func (*StreamConfig) String ¶ added in v1.2.0
func (m *StreamConfig) String() string
func (*StreamConfig) Unmarshal ¶ added in v1.2.0
func (m *StreamConfig) Unmarshal(dAtA []byte) error
func (*StreamConfig) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *StreamConfig) XXX_DiscardUnknown()
func (*StreamConfig) XXX_Marshal ¶ added in v1.2.0
func (m *StreamConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamConfig) XXX_Merge ¶ added in v1.2.0
func (m *StreamConfig) XXX_Merge(src proto.Message)
func (*StreamConfig) XXX_Size ¶ added in v1.2.0
func (m *StreamConfig) XXX_Size() int
func (*StreamConfig) XXX_Unmarshal ¶ added in v1.2.0
func (m *StreamConfig) XXX_Unmarshal(b []byte) error