protocol

package
v1.9.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthInternal        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInternal          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupInternal = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// Encoding is the byte order to use for protocol serialization.
	Encoding = binary.BigEndian
)
View Source 
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",
}
View Source 
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 

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

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 

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

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 

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

UnmarshalAck deserializes a Liftbridge ack envelope into a protobuf message.

func UnmarshalPublish 

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

UnmarshalPublish deserializes a Liftbridge publish envelope into a protobuf message.

func UnmarshalReplicationResponse 

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

UnmarshalReplicationResponse deserializes a Liftbridge replication response envelope and returns the leader epoch, HW, and message data.

func WriteReplicationResponseHeader 

func WriteReplicationResponseHeader(buf *bytes.Buffer) int

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) MarshalTo 

func (m *ChangeLeaderOp) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Consumer) GetId added in v1.8.0 

func (m *Consumer) GetId() string

func (*Consumer) GetStreams added in v1.8.0 

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

func (*Consumer) Marshal added in v1.8.0 

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

func (*Consumer) MarshalTo added in v1.8.0 

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

func (*Consumer) MarshalToSizedBuffer added in v1.8.0 

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

func (*Consumer) ProtoMessage added in v1.8.0 

func (*Consumer) ProtoMessage()

func (*Consumer) Reset added in v1.8.0 

func (m *Consumer) Reset()

func (*Consumer) Size added in v1.8.0 

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

func (*Consumer) String added in v1.8.0 

func (m *Consumer) String() string

func (*Consumer) Unmarshal added in v1.8.0 

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

func (*Consumer) XXX_DiscardUnknown added in v1.8.0 

func (m *Consumer) XXX_DiscardUnknown()

func (*Consumer) XXX_Marshal added in v1.8.0 

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

func (*Consumer) XXX_Merge added in v1.8.0 

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

func (*Consumer) XXX_Size added in v1.8.0 

func (m *Consumer) XXX_Size() int

func (*Consumer) XXX_Unmarshal added in v1.8.0 

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

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) MarshalTo 

func (m *CreateStreamOp) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Cursor) GetCursorId added in v1.3.0 

func (m *Cursor) GetCursorId() string

func (*Cursor) GetOffset added in v1.3.0 

func (m *Cursor) GetOffset() int64

func (*Cursor) GetPartition added in v1.3.0 

func (m *Cursor) GetPartition() int32

func (*Cursor) GetStream added in v1.3.0 

func (m *Cursor) GetStream() string

func (*Cursor) Marshal added in v1.3.0 

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

func (*Cursor) MarshalTo added in v1.3.0 

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

func (*Cursor) MarshalToSizedBuffer added in v1.3.0 

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

func (*Cursor) ProtoMessage added in v1.3.0 

func (*Cursor) ProtoMessage()

func (*Cursor) Reset added in v1.3.0 

func (m *Cursor) Reset()

func (*Cursor) Size added in v1.3.0 

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

func (*Cursor) String added in v1.3.0 

func (m *Cursor) String() string

func (*Cursor) Unmarshal added in v1.3.0 

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

func (*Cursor) XXX_DiscardUnknown added in v1.3.0 

func (m *Cursor) XXX_DiscardUnknown()

func (*Cursor) XXX_Marshal added in v1.3.0 

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

func (*Cursor) XXX_Merge added in v1.3.0 

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

func (*Cursor) XXX_Size added in v1.3.0 

func (m *Cursor) XXX_Size() int

func (*Cursor) XXX_Unmarshal added in v1.3.0 

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

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) MarshalTo 

func (m *DeleteStreamOp) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Error) GetCode 

func (m *Error) GetCode() uint32

func (*Error) GetMsg 

func (m *Error) GetMsg() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer added in v1.2.0 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown added in v1.2.0 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal added in v1.2.0 

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

func (*Error) XXX_Merge added in v1.2.0 

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

func (*Error) XXX_Size added in v1.2.0 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal added in v1.2.0 

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

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) MarshalTo 

func (m *ExpandISROp) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *MetadataSnapshot) MarshalTo(dAtA []byte) (int, 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 

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

func (Op) String 

func (x Op) String() string

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) Descriptor() ([]byte, []int)

func (*Partition) GetEpoch 

func (m *Partition) GetEpoch() uint64

func (*Partition) GetGroup 

func (m *Partition) GetGroup() string

func (*Partition) GetId 

func (m *Partition) GetId() int32

func (*Partition) GetIsr 

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

func (*Partition) GetLeader 

func (m *Partition) GetLeader() string

func (*Partition) GetLeaderEpoch 

func (m *Partition) GetLeaderEpoch() uint64

func (*Partition) GetPaused 

func (m *Partition) GetPaused() bool

func (*Partition) GetReadonly added in v1.4.0 

func (m *Partition) GetReadonly() bool

func (*Partition) GetReplicas 

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

func (*Partition) GetReplicationFactor 

func (m *Partition) GetReplicationFactor() int32

func (*Partition) GetStream 

func (m *Partition) GetStream() string

func (*Partition) GetSubject 

func (m *Partition) GetSubject() string

func (*Partition) Marshal 

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

func (*Partition) MarshalTo 

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

func (*Partition) MarshalToSizedBuffer added in v1.2.0 

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

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) Reset 

func (m *Partition) Reset()

func (*Partition) Size 

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

func (*Partition) String 

func (m *Partition) String() string

func (*Partition) Unmarshal 

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

func (*Partition) XXX_DiscardUnknown added in v1.2.0 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal added in v1.2.0 

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

func (*Partition) XXX_Merge added in v1.2.0 

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

func (*Partition) XXX_Size added in v1.2.0 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal added in v1.2.0 

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

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) MarshalTo 

func (m *PauseStreamOp) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *RaftJoinRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *RaftJoinResponse) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

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) GetOp 

func (m *RaftLog) GetOp() Op

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) Marshal 

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

func (*RaftLog) MarshalTo 

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

func (*RaftLog) MarshalToSizedBuffer added in v1.2.0 

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

func (*RaftLog) ProtoMessage 

func (*RaftLog) ProtoMessage()

func (*RaftLog) Reset 

func (m *RaftLog) Reset()

func (*RaftLog) Size 

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

func (*RaftLog) String 

func (m *RaftLog) String() string

func (*RaftLog) Unmarshal 

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

func (*RaftLog) XXX_DiscardUnknown added in v1.2.0 

func (m *RaftLog) XXX_DiscardUnknown()

func (*RaftLog) XXX_Marshal added in v1.2.0 

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

func (*RaftLog) XXX_Merge added in v1.2.0 

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

func (*RaftLog) XXX_Size added in v1.2.0 

func (m *RaftLog) XXX_Size() int

func (*RaftLog) XXX_Unmarshal added in v1.2.0 

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

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) MarshalTo 

func (m *ReportLeaderOp) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ResumeStreamOp) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ServerState) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ShrinkISROp) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Stream) GetConfig added in v1.2.0 

func (m *Stream) GetConfig() *StreamConfig

func (*Stream) GetCreationTimestamp added in v1.4.0 

func (m *Stream) GetCreationTimestamp() int64

func (*Stream) GetName 

func (m *Stream) GetName() string

func (*Stream) GetPartitions 

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

func (*Stream) GetSubject 

func (m *Stream) GetSubject() string

func (*Stream) Marshal 

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

func (*Stream) MarshalTo 

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

func (*Stream) MarshalToSizedBuffer added in v1.2.0 

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

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) Size 

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

func (*Stream) String 

func (m *Stream) String() string

func (*Stream) Unmarshal 

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

func (*Stream) XXX_DiscardUnknown added in v1.2.0 

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal added in v1.2.0 

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

func (*Stream) XXX_Merge added in v1.2.0 

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

func (*Stream) XXX_Size added in v1.2.0 

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal added in v1.2.0 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.