liftbridge: github.com/liftbridge-io/liftbridge/server/protocol Index | Files

package protocol

import "github.com/liftbridge-io/liftbridge/server/protocol"

Index

Package Files

envelope.go internal.pb.go

Variables

var (
    ErrInvalidLengthInternal = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowInternal   = fmt.Errorf("proto: integer overflow")
)
var (
    // Encoding is the byte order to use for protocol serialization.
    Encoding = binary.BigEndian
)
var Op_name = map[int32]string{
    0:  "CREATE_STREAM",
    1:  "SHRINK_ISR",
    2:  "REPORT_LEADER",
    3:  "CHANGE_LEADER",
    4:  "EXPAND_ISR",
    5:  "DELETE_STREAM",
    6:  "PAUSE_STREAM",
    7:  "RESUME_STREAM",
    8:  "PUBLISH_ACTIVITY",
}
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,
}

func MarshalAck Uses

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

MarshalAck serializes a protobuf ack message into the Liftbridge envelope wire format.

func MarshalLeaderEpochOffsetRequest Uses

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

MarshalLeaderEpochOffsetRequest serializes a LeaderEpochOffsetRequest protobuf into the Liftbridge envelope wire format.

func MarshalLeaderEpochOffsetResponse Uses

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

MarshalLeaderEpochOffsetResponse serializes a LeaderEpochOffsetResponse protobuf into the Liftbridge envelope wire format.

func MarshalPartitionNotification Uses

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

MarshalPartitionNotification serializes a PartitionNotification protobuf into the Liftbridge envelope wire format.

func MarshalPartitionStatusRequest Uses

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

MarshalPartitionStatusRequest serializes a PartitionStatusRequest protobuf into the Liftbridge envelope wire format.

func MarshalPartitionStatusResponse Uses

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

MarshalPartitionStatusResponse serializes a PartitionStatusResponse protobuf into the Liftbridge envelope wire format.

func MarshalPropagatedRequest Uses

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

MarshalPropagatedRequest serializes a PropagatedRequest protobuf into the Liftbridge envelope wire format.

func MarshalPropagatedResponse Uses

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

MarshalPropagatedResponse serializes a PropagatedResponse protobuf into the Liftbridge envelope wire format.

func MarshalPublish Uses

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

MarshalPublish serializes a protobuf publish message into the Liftbridge envelope wire format.

func MarshalRaftJoinRequest Uses

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

MarshalRaftJoinRequest serializes a RaftJoinRequest protobuf into the Liftbridge envelope wire format.

func MarshalRaftJoinResponse Uses

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

MarshalRaftJoinResponse serializes a RaftJoinResponse protobuf into the Liftbridge envelope wire format.

func MarshalReplicationRequest Uses

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

MarshalReplicationRequest serializes a ReplicationRequest protobuf into the Liftbridge envelope wire format.

func MarshalServerInfoRequest Uses

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

MarshalServerInfoRequest serializes a ServerInfoRequest protobuf into the Liftbridge envelope wire format.

func MarshalServerInfoResponse Uses

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

MarshalServerInfoResponse serializes a ServerInfoResponse protobuf into the Liftbridge envelope wire format.

func UnmarshalAck Uses

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

UnmarshalAck deserializes a Liftbridge ack envelope into a protobuf message.

func UnmarshalPublish Uses

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

UnmarshalPublish deserializes a Liftbridge publish envelope into a protobuf message.

func UnmarshalReplicationResponse Uses

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 Uses

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.

type ChangeLeaderOp Uses

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 Uses

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

func (*ChangeLeaderOp) GetLeader Uses

func (m *ChangeLeaderOp) GetLeader() string

func (*ChangeLeaderOp) GetPartition Uses

func (m *ChangeLeaderOp) GetPartition() int32

func (*ChangeLeaderOp) GetStream Uses

func (m *ChangeLeaderOp) GetStream() string

func (*ChangeLeaderOp) Marshal Uses

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

func (*ChangeLeaderOp) MarshalTo Uses

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

func (*ChangeLeaderOp) MarshalToSizedBuffer Uses

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

func (*ChangeLeaderOp) ProtoMessage Uses

func (*ChangeLeaderOp) ProtoMessage()

func (*ChangeLeaderOp) Reset Uses

func (m *ChangeLeaderOp) Reset()

func (*ChangeLeaderOp) Size Uses

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

func (*ChangeLeaderOp) String Uses

func (m *ChangeLeaderOp) String() string

func (*ChangeLeaderOp) Unmarshal Uses

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

func (*ChangeLeaderOp) XXX_DiscardUnknown Uses

func (m *ChangeLeaderOp) XXX_DiscardUnknown()

func (*ChangeLeaderOp) XXX_Marshal Uses

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

func (*ChangeLeaderOp) XXX_Merge Uses

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

func (*ChangeLeaderOp) XXX_Size Uses

func (m *ChangeLeaderOp) XXX_Size() int

func (*ChangeLeaderOp) XXX_Unmarshal Uses

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

type CreateStreamOp Uses

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 Uses

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

func (*CreateStreamOp) GetStream Uses

func (m *CreateStreamOp) GetStream() *Stream

func (*CreateStreamOp) Marshal Uses

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

func (*CreateStreamOp) MarshalTo Uses

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

func (*CreateStreamOp) MarshalToSizedBuffer Uses

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

func (*CreateStreamOp) ProtoMessage Uses

func (*CreateStreamOp) ProtoMessage()

func (*CreateStreamOp) Reset Uses

func (m *CreateStreamOp) Reset()

func (*CreateStreamOp) Size Uses

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

func (*CreateStreamOp) String Uses

func (m *CreateStreamOp) String() string

func (*CreateStreamOp) Unmarshal Uses

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

func (*CreateStreamOp) XXX_DiscardUnknown Uses

func (m *CreateStreamOp) XXX_DiscardUnknown()

func (*CreateStreamOp) XXX_Marshal Uses

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

func (*CreateStreamOp) XXX_Merge Uses

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

func (*CreateStreamOp) XXX_Size Uses

func (m *CreateStreamOp) XXX_Size() int

func (*CreateStreamOp) XXX_Unmarshal Uses

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

type DeleteStreamOp Uses

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 Uses

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

func (*DeleteStreamOp) GetStream Uses

func (m *DeleteStreamOp) GetStream() string

func (*DeleteStreamOp) Marshal Uses

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

func (*DeleteStreamOp) MarshalTo Uses

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

func (*DeleteStreamOp) MarshalToSizedBuffer Uses

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

func (*DeleteStreamOp) ProtoMessage Uses

func (*DeleteStreamOp) ProtoMessage()

func (*DeleteStreamOp) Reset Uses

func (m *DeleteStreamOp) Reset()

func (*DeleteStreamOp) Size Uses

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

func (*DeleteStreamOp) String Uses

func (m *DeleteStreamOp) String() string

func (*DeleteStreamOp) Unmarshal Uses

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

func (*DeleteStreamOp) XXX_DiscardUnknown Uses

func (m *DeleteStreamOp) XXX_DiscardUnknown()

func (*DeleteStreamOp) XXX_Marshal Uses

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

func (*DeleteStreamOp) XXX_Merge Uses

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

func (*DeleteStreamOp) XXX_Size Uses

func (m *DeleteStreamOp) XXX_Size() int

func (*DeleteStreamOp) XXX_Unmarshal Uses

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

type Error Uses

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 Uses

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

func (*Error) GetCode Uses

func (m *Error) GetCode() uint32

func (*Error) GetMsg Uses

func (m *Error) GetMsg() string

func (*Error) Marshal Uses

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

func (*Error) MarshalTo Uses

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

func (*Error) MarshalToSizedBuffer Uses

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

func (*Error) ProtoMessage Uses

func (*Error) ProtoMessage()

func (*Error) Reset Uses

func (m *Error) Reset()

func (*Error) Size Uses

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

func (*Error) String Uses

func (m *Error) String() string

func (*Error) Unmarshal Uses

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

func (*Error) XXX_DiscardUnknown Uses

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal Uses

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

func (*Error) XXX_Merge Uses

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

func (*Error) XXX_Size Uses

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal Uses

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

type ExpandISROp Uses

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 Uses

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

func (*ExpandISROp) GetLeader Uses

func (m *ExpandISROp) GetLeader() string

func (*ExpandISROp) GetLeaderEpoch Uses

func (m *ExpandISROp) GetLeaderEpoch() uint64

func (*ExpandISROp) GetPartition Uses

func (m *ExpandISROp) GetPartition() int32

func (*ExpandISROp) GetReplicaToAdd Uses

func (m *ExpandISROp) GetReplicaToAdd() string

func (*ExpandISROp) GetStream Uses

func (m *ExpandISROp) GetStream() string

func (*ExpandISROp) Marshal Uses

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

func (*ExpandISROp) MarshalTo Uses

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

func (*ExpandISROp) MarshalToSizedBuffer Uses

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

func (*ExpandISROp) ProtoMessage Uses

func (*ExpandISROp) ProtoMessage()

func (*ExpandISROp) Reset Uses

func (m *ExpandISROp) Reset()

func (*ExpandISROp) Size Uses

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

func (*ExpandISROp) String Uses

func (m *ExpandISROp) String() string

func (*ExpandISROp) Unmarshal Uses

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

func (*ExpandISROp) XXX_DiscardUnknown Uses

func (m *ExpandISROp) XXX_DiscardUnknown()

func (*ExpandISROp) XXX_Marshal Uses

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

func (*ExpandISROp) XXX_Merge Uses

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

func (*ExpandISROp) XXX_Size Uses

func (m *ExpandISROp) XXX_Size() int

func (*ExpandISROp) XXX_Unmarshal Uses

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

type LeaderEpochOffsetRequest Uses

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 Uses

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

UnmarshalLeaderEpochOffsetRequest deserializes a Liftbridge LeaderEpochOffsetRequest envelope into a protobuf message.

func (*LeaderEpochOffsetRequest) Descriptor Uses

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

func (*LeaderEpochOffsetRequest) GetLeaderEpoch Uses

func (m *LeaderEpochOffsetRequest) GetLeaderEpoch() uint64

func (*LeaderEpochOffsetRequest) Marshal Uses

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

func (*LeaderEpochOffsetRequest) MarshalTo Uses

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

func (*LeaderEpochOffsetRequest) MarshalToSizedBuffer Uses

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

func (*LeaderEpochOffsetRequest) ProtoMessage Uses

func (*LeaderEpochOffsetRequest) ProtoMessage()

func (*LeaderEpochOffsetRequest) Reset Uses

func (m *LeaderEpochOffsetRequest) Reset()

func (*LeaderEpochOffsetRequest) Size Uses

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

func (*LeaderEpochOffsetRequest) String Uses

func (m *LeaderEpochOffsetRequest) String() string

func (*LeaderEpochOffsetRequest) Unmarshal Uses

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

func (*LeaderEpochOffsetRequest) XXX_DiscardUnknown Uses

func (m *LeaderEpochOffsetRequest) XXX_DiscardUnknown()

func (*LeaderEpochOffsetRequest) XXX_Marshal Uses

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

func (*LeaderEpochOffsetRequest) XXX_Merge Uses

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

func (*LeaderEpochOffsetRequest) XXX_Size Uses

func (m *LeaderEpochOffsetRequest) XXX_Size() int

func (*LeaderEpochOffsetRequest) XXX_Unmarshal Uses

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

type LeaderEpochOffsetResponse Uses

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 Uses

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

UnmarshalLeaderEpochOffsetResponse deserializes a Liftbridge LeaderEpochOffsetResponse envelope into a protobuf message.

func (*LeaderEpochOffsetResponse) Descriptor Uses

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

func (*LeaderEpochOffsetResponse) GetEndOffset Uses

func (m *LeaderEpochOffsetResponse) GetEndOffset() int64

func (*LeaderEpochOffsetResponse) Marshal Uses

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

func (*LeaderEpochOffsetResponse) MarshalTo Uses

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

func (*LeaderEpochOffsetResponse) MarshalToSizedBuffer Uses

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

func (*LeaderEpochOffsetResponse) ProtoMessage Uses

func (*LeaderEpochOffsetResponse) ProtoMessage()

func (*LeaderEpochOffsetResponse) Reset Uses

func (m *LeaderEpochOffsetResponse) Reset()

func (*LeaderEpochOffsetResponse) Size Uses

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

func (*LeaderEpochOffsetResponse) String Uses

func (m *LeaderEpochOffsetResponse) String() string

func (*LeaderEpochOffsetResponse) Unmarshal Uses

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

func (*LeaderEpochOffsetResponse) XXX_DiscardUnknown Uses

func (m *LeaderEpochOffsetResponse) XXX_DiscardUnknown()

func (*LeaderEpochOffsetResponse) XXX_Marshal Uses

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

func (*LeaderEpochOffsetResponse) XXX_Merge Uses

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

func (*LeaderEpochOffsetResponse) XXX_Size Uses

func (m *LeaderEpochOffsetResponse) XXX_Size() int

func (*LeaderEpochOffsetResponse) XXX_Unmarshal Uses

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

type MetadataSnapshot Uses

type MetadataSnapshot struct {
    Streams              []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*MetadataSnapshot) Descriptor Uses

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

func (*MetadataSnapshot) GetStreams Uses

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

func (*MetadataSnapshot) Marshal Uses

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

func (*MetadataSnapshot) MarshalTo Uses

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

func (*MetadataSnapshot) MarshalToSizedBuffer Uses

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

func (*MetadataSnapshot) ProtoMessage Uses

func (*MetadataSnapshot) ProtoMessage()

func (*MetadataSnapshot) Reset Uses

func (m *MetadataSnapshot) Reset()

func (*MetadataSnapshot) Size Uses

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

func (*MetadataSnapshot) String Uses

func (m *MetadataSnapshot) String() string

func (*MetadataSnapshot) Unmarshal Uses

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

func (*MetadataSnapshot) XXX_DiscardUnknown Uses

func (m *MetadataSnapshot) XXX_DiscardUnknown()

func (*MetadataSnapshot) XXX_Marshal Uses

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

func (*MetadataSnapshot) XXX_Merge Uses

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

func (*MetadataSnapshot) XXX_Size Uses

func (m *MetadataSnapshot) XXX_Size() int

func (*MetadataSnapshot) XXX_Unmarshal Uses

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

type NullableBool Uses

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 Uses

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

func (*NullableBool) GetValue Uses

func (m *NullableBool) GetValue() bool

func (*NullableBool) Marshal Uses

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

func (*NullableBool) MarshalTo Uses

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

func (*NullableBool) MarshalToSizedBuffer Uses

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

func (*NullableBool) ProtoMessage Uses

func (*NullableBool) ProtoMessage()

func (*NullableBool) Reset Uses

func (m *NullableBool) Reset()

func (*NullableBool) Size Uses

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

func (*NullableBool) String Uses

func (m *NullableBool) String() string

func (*NullableBool) Unmarshal Uses

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

func (*NullableBool) XXX_DiscardUnknown Uses

func (m *NullableBool) XXX_DiscardUnknown()

func (*NullableBool) XXX_Marshal Uses

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

func (*NullableBool) XXX_Merge Uses

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

func (*NullableBool) XXX_Size Uses

func (m *NullableBool) XXX_Size() int

func (*NullableBool) XXX_Unmarshal Uses

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

type NullableInt32 Uses

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 Uses

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

func (*NullableInt32) GetValue Uses

func (m *NullableInt32) GetValue() int32

func (*NullableInt32) Marshal Uses

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

func (*NullableInt32) MarshalTo Uses

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

func (*NullableInt32) MarshalToSizedBuffer Uses

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

func (*NullableInt32) ProtoMessage Uses

func (*NullableInt32) ProtoMessage()

func (*NullableInt32) Reset Uses

func (m *NullableInt32) Reset()

func (*NullableInt32) Size Uses

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

func (*NullableInt32) String Uses

func (m *NullableInt32) String() string

func (*NullableInt32) Unmarshal Uses

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

func (*NullableInt32) XXX_DiscardUnknown Uses

func (m *NullableInt32) XXX_DiscardUnknown()

func (*NullableInt32) XXX_Marshal Uses

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

func (*NullableInt32) XXX_Merge Uses

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

func (*NullableInt32) XXX_Size Uses

func (m *NullableInt32) XXX_Size() int

func (*NullableInt32) XXX_Unmarshal Uses

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

type NullableInt64 Uses

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 Uses

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

func (*NullableInt64) GetValue Uses

func (m *NullableInt64) GetValue() int64

func (*NullableInt64) Marshal Uses

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

func (*NullableInt64) MarshalTo Uses

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

func (*NullableInt64) MarshalToSizedBuffer Uses

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

func (*NullableInt64) ProtoMessage Uses

func (*NullableInt64) ProtoMessage()

func (*NullableInt64) Reset Uses

func (m *NullableInt64) Reset()

func (*NullableInt64) Size Uses

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

func (*NullableInt64) String Uses

func (m *NullableInt64) String() string

func (*NullableInt64) Unmarshal Uses

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

func (*NullableInt64) XXX_DiscardUnknown Uses

func (m *NullableInt64) XXX_DiscardUnknown()

func (*NullableInt64) XXX_Marshal Uses

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

func (*NullableInt64) XXX_Merge Uses

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

func (*NullableInt64) XXX_Size Uses

func (m *NullableInt64) XXX_Size() int

func (*NullableInt64) XXX_Unmarshal Uses

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

type Op Uses

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
)

func (Op) EnumDescriptor Uses

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

func (Op) String Uses

func (x Op) String() string

type Partition Uses

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

func (*Partition) Descriptor Uses

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

func (*Partition) GetEpoch Uses

func (m *Partition) GetEpoch() uint64

func (*Partition) GetGroup Uses

func (m *Partition) GetGroup() string

func (*Partition) GetId Uses

func (m *Partition) GetId() int32

func (*Partition) GetIsr Uses

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

func (*Partition) GetLeader Uses

func (m *Partition) GetLeader() string

func (*Partition) GetLeaderEpoch Uses

func (m *Partition) GetLeaderEpoch() uint64

func (*Partition) GetPaused Uses

func (m *Partition) GetPaused() bool

func (*Partition) GetReplicas Uses

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

func (*Partition) GetReplicationFactor Uses

func (m *Partition) GetReplicationFactor() int32

func (*Partition) GetStream Uses

func (m *Partition) GetStream() string

func (*Partition) GetSubject Uses

func (m *Partition) GetSubject() string

func (*Partition) Marshal Uses

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

func (*Partition) MarshalTo Uses

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

func (*Partition) MarshalToSizedBuffer Uses

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

func (*Partition) ProtoMessage Uses

func (*Partition) ProtoMessage()

func (*Partition) Reset Uses

func (m *Partition) Reset()

func (*Partition) Size Uses

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

func (*Partition) String Uses

func (m *Partition) String() string

func (*Partition) Unmarshal Uses

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

func (*Partition) XXX_DiscardUnknown Uses

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal Uses

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

func (*Partition) XXX_Merge Uses

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

func (*Partition) XXX_Size Uses

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal Uses

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

type PartitionNotification Uses

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 Uses

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

UnmarshalPartitionNotification deserializes a Liftbridge PartitionNotification envelope into a protobuf message.

func (*PartitionNotification) Descriptor Uses

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

func (*PartitionNotification) GetPartition Uses

func (m *PartitionNotification) GetPartition() int32

func (*PartitionNotification) GetStream Uses

func (m *PartitionNotification) GetStream() string

func (*PartitionNotification) Marshal Uses

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

func (*PartitionNotification) MarshalTo Uses

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

func (*PartitionNotification) MarshalToSizedBuffer Uses

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

func (*PartitionNotification) ProtoMessage Uses

func (*PartitionNotification) ProtoMessage()

func (*PartitionNotification) Reset Uses

func (m *PartitionNotification) Reset()

func (*PartitionNotification) Size Uses

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

func (*PartitionNotification) String Uses

func (m *PartitionNotification) String() string

func (*PartitionNotification) Unmarshal Uses

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

func (*PartitionNotification) XXX_DiscardUnknown Uses

func (m *PartitionNotification) XXX_DiscardUnknown()

func (*PartitionNotification) XXX_Marshal Uses

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

func (*PartitionNotification) XXX_Merge Uses

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

func (*PartitionNotification) XXX_Size Uses

func (m *PartitionNotification) XXX_Size() int

func (*PartitionNotification) XXX_Unmarshal Uses

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

type PartitionStatusRequest Uses

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 Uses

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

UnmarshalPartitionStatusRequest deserializes a Liftbridge PartitionStatusRequest envelope into a protobuf message.

func (*PartitionStatusRequest) Descriptor Uses

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

func (*PartitionStatusRequest) GetPartition Uses

func (m *PartitionStatusRequest) GetPartition() int32

func (*PartitionStatusRequest) GetStream Uses

func (m *PartitionStatusRequest) GetStream() string

func (*PartitionStatusRequest) Marshal Uses

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

func (*PartitionStatusRequest) MarshalTo Uses

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

func (*PartitionStatusRequest) MarshalToSizedBuffer Uses

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

func (*PartitionStatusRequest) ProtoMessage Uses

func (*PartitionStatusRequest) ProtoMessage()

func (*PartitionStatusRequest) Reset Uses

func (m *PartitionStatusRequest) Reset()

func (*PartitionStatusRequest) Size Uses

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

func (*PartitionStatusRequest) String Uses

func (m *PartitionStatusRequest) String() string

func (*PartitionStatusRequest) Unmarshal Uses

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

func (*PartitionStatusRequest) XXX_DiscardUnknown Uses

func (m *PartitionStatusRequest) XXX_DiscardUnknown()

func (*PartitionStatusRequest) XXX_Marshal Uses

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

func (*PartitionStatusRequest) XXX_Merge Uses

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

func (*PartitionStatusRequest) XXX_Size Uses

func (m *PartitionStatusRequest) XXX_Size() int

func (*PartitionStatusRequest) XXX_Unmarshal Uses

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

type PartitionStatusResponse Uses

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 Uses

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

UnmarshalPartitionStatusResponse deserializes a Liftbridge PartitionStatusResponse envelope into a protobuf message.

func (*PartitionStatusResponse) Descriptor Uses

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

func (*PartitionStatusResponse) GetExists Uses

func (m *PartitionStatusResponse) GetExists() bool

func (*PartitionStatusResponse) GetIsLeader Uses

func (m *PartitionStatusResponse) GetIsLeader() bool

func (*PartitionStatusResponse) Marshal Uses

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

func (*PartitionStatusResponse) MarshalTo Uses

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

func (*PartitionStatusResponse) MarshalToSizedBuffer Uses

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

func (*PartitionStatusResponse) ProtoMessage Uses

func (*PartitionStatusResponse) ProtoMessage()

func (*PartitionStatusResponse) Reset Uses

func (m *PartitionStatusResponse) Reset()

func (*PartitionStatusResponse) Size Uses

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

func (*PartitionStatusResponse) String Uses

func (m *PartitionStatusResponse) String() string

func (*PartitionStatusResponse) Unmarshal Uses

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

func (*PartitionStatusResponse) XXX_DiscardUnknown Uses

func (m *PartitionStatusResponse) XXX_DiscardUnknown()

func (*PartitionStatusResponse) XXX_Marshal Uses

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

func (*PartitionStatusResponse) XXX_Merge Uses

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

func (*PartitionStatusResponse) XXX_Size Uses

func (m *PartitionStatusResponse) XXX_Size() int

func (*PartitionStatusResponse) XXX_Unmarshal Uses

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

type PauseStreamOp Uses

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 Uses

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

func (*PauseStreamOp) GetPartitions Uses

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

func (*PauseStreamOp) GetResumeAll Uses

func (m *PauseStreamOp) GetResumeAll() bool

func (*PauseStreamOp) GetStream Uses

func (m *PauseStreamOp) GetStream() string

func (*PauseStreamOp) Marshal Uses

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

func (*PauseStreamOp) MarshalTo Uses

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

func (*PauseStreamOp) MarshalToSizedBuffer Uses

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

func (*PauseStreamOp) ProtoMessage Uses

func (*PauseStreamOp) ProtoMessage()

func (*PauseStreamOp) Reset Uses

func (m *PauseStreamOp) Reset()

func (*PauseStreamOp) Size Uses

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

func (*PauseStreamOp) String Uses

func (m *PauseStreamOp) String() string

func (*PauseStreamOp) Unmarshal Uses

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

func (*PauseStreamOp) XXX_DiscardUnknown Uses

func (m *PauseStreamOp) XXX_DiscardUnknown()

func (*PauseStreamOp) XXX_Marshal Uses

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

func (*PauseStreamOp) XXX_Merge Uses

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

func (*PauseStreamOp) XXX_Size Uses

func (m *PauseStreamOp) XXX_Size() int

func (*PauseStreamOp) XXX_Unmarshal Uses

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

type PropagatedRequest Uses

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

func UnmarshalPropagatedRequest Uses

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

UnmarshalPropagatedRequest deserializes a Liftbridge PropagatedRequest envelope into a protobuf message.

func (*PropagatedRequest) Descriptor Uses

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

func (*PropagatedRequest) GetCreateStreamOp Uses

func (m *PropagatedRequest) GetCreateStreamOp() *CreateStreamOp

func (*PropagatedRequest) GetDeleteStreamOp Uses

func (m *PropagatedRequest) GetDeleteStreamOp() *DeleteStreamOp

func (*PropagatedRequest) GetExpandISROp Uses

func (m *PropagatedRequest) GetExpandISROp() *ExpandISROp

func (*PropagatedRequest) GetOp Uses

func (m *PropagatedRequest) GetOp() Op

func (*PropagatedRequest) GetPauseStreamOp Uses

func (m *PropagatedRequest) GetPauseStreamOp() *PauseStreamOp

func (*PropagatedRequest) GetReportLeaderOp Uses

func (m *PropagatedRequest) GetReportLeaderOp() *ReportLeaderOp

func (*PropagatedRequest) GetResumeStreamOp Uses

func (m *PropagatedRequest) GetResumeStreamOp() *ResumeStreamOp

func (*PropagatedRequest) GetShrinkISROp Uses

func (m *PropagatedRequest) GetShrinkISROp() *ShrinkISROp

func (*PropagatedRequest) Marshal Uses

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

func (*PropagatedRequest) MarshalTo Uses

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

func (*PropagatedRequest) MarshalToSizedBuffer Uses

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

func (*PropagatedRequest) ProtoMessage Uses

func (*PropagatedRequest) ProtoMessage()

func (*PropagatedRequest) Reset Uses

func (m *PropagatedRequest) Reset()

func (*PropagatedRequest) Size Uses

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

func (*PropagatedRequest) String Uses

func (m *PropagatedRequest) String() string

func (*PropagatedRequest) Unmarshal Uses

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

func (*PropagatedRequest) XXX_DiscardUnknown Uses

func (m *PropagatedRequest) XXX_DiscardUnknown()

func (*PropagatedRequest) XXX_Marshal Uses

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

func (*PropagatedRequest) XXX_Merge Uses

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

func (*PropagatedRequest) XXX_Size Uses

func (m *PropagatedRequest) XXX_Size() int

func (*PropagatedRequest) XXX_Unmarshal Uses

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

type PropagatedResponse Uses

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

func UnmarshalPropagatedResponse Uses

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

UnmarshalPropagatedResponse deserializes a Liftbridge PropagatedResponse envelope into a protobuf message.

func (*PropagatedResponse) Descriptor Uses

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

func (*PropagatedResponse) GetError Uses

func (m *PropagatedResponse) GetError() *Error

func (*PropagatedResponse) GetOp Uses

func (m *PropagatedResponse) GetOp() Op

func (*PropagatedResponse) Marshal Uses

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

func (*PropagatedResponse) MarshalTo Uses

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

func (*PropagatedResponse) MarshalToSizedBuffer Uses

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

func (*PropagatedResponse) ProtoMessage Uses

func (*PropagatedResponse) ProtoMessage()

func (*PropagatedResponse) Reset Uses

func (m *PropagatedResponse) Reset()

func (*PropagatedResponse) Size Uses

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

func (*PropagatedResponse) String Uses

func (m *PropagatedResponse) String() string

func (*PropagatedResponse) Unmarshal Uses

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

func (*PropagatedResponse) XXX_DiscardUnknown Uses

func (m *PropagatedResponse) XXX_DiscardUnknown()

func (*PropagatedResponse) XXX_Marshal Uses

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

func (*PropagatedResponse) XXX_Merge Uses

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

func (*PropagatedResponse) XXX_Size Uses

func (m *PropagatedResponse) XXX_Size() int

func (*PropagatedResponse) XXX_Unmarshal Uses

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

type PublishActivityOp Uses

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 Uses

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

func (*PublishActivityOp) GetRaftIndex Uses

func (m *PublishActivityOp) GetRaftIndex() uint64

func (*PublishActivityOp) Marshal Uses

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

func (*PublishActivityOp) MarshalTo Uses

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

func (*PublishActivityOp) MarshalToSizedBuffer Uses

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

func (*PublishActivityOp) ProtoMessage Uses

func (*PublishActivityOp) ProtoMessage()

func (*PublishActivityOp) Reset Uses

func (m *PublishActivityOp) Reset()

func (*PublishActivityOp) Size Uses

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

func (*PublishActivityOp) String Uses

func (m *PublishActivityOp) String() string

func (*PublishActivityOp) Unmarshal Uses

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

func (*PublishActivityOp) XXX_DiscardUnknown Uses

func (m *PublishActivityOp) XXX_DiscardUnknown()

func (*PublishActivityOp) XXX_Marshal Uses

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

func (*PublishActivityOp) XXX_Merge Uses

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

func (*PublishActivityOp) XXX_Size Uses

func (m *PublishActivityOp) XXX_Size() int

func (*PublishActivityOp) XXX_Unmarshal Uses

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

type RaftJoinRequest Uses

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 Uses

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

UnmarshalRaftJoinRequest deserializes a Liftbridge RaftJoinRequest envelope into a protobuf message.

func (*RaftJoinRequest) Descriptor Uses

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

func (*RaftJoinRequest) GetNodeAddr Uses

func (m *RaftJoinRequest) GetNodeAddr() string

func (*RaftJoinRequest) GetNodeID Uses

func (m *RaftJoinRequest) GetNodeID() string

func (*RaftJoinRequest) Marshal Uses

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

func (*RaftJoinRequest) MarshalTo Uses

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

func (*RaftJoinRequest) MarshalToSizedBuffer Uses

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

func (*RaftJoinRequest) ProtoMessage Uses

func (*RaftJoinRequest) ProtoMessage()

func (*RaftJoinRequest) Reset Uses

func (m *RaftJoinRequest) Reset()

func (*RaftJoinRequest) Size Uses

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

func (*RaftJoinRequest) String Uses

func (m *RaftJoinRequest) String() string

func (*RaftJoinRequest) Unmarshal Uses

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

func (*RaftJoinRequest) XXX_DiscardUnknown Uses

func (m *RaftJoinRequest) XXX_DiscardUnknown()

func (*RaftJoinRequest) XXX_Marshal Uses

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

func (*RaftJoinRequest) XXX_Merge Uses

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

func (*RaftJoinRequest) XXX_Size Uses

func (m *RaftJoinRequest) XXX_Size() int

func (*RaftJoinRequest) XXX_Unmarshal Uses

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

type RaftJoinResponse Uses

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 Uses

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

UnmarshalRaftJoinResponse deserializes a Liftbridge RaftJoinResponse envelope into a protobuf message.

func (*RaftJoinResponse) Descriptor Uses

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

func (*RaftJoinResponse) GetError Uses

func (m *RaftJoinResponse) GetError() string

func (*RaftJoinResponse) Marshal Uses

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

func (*RaftJoinResponse) MarshalTo Uses

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

func (*RaftJoinResponse) MarshalToSizedBuffer Uses

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

func (*RaftJoinResponse) ProtoMessage Uses

func (*RaftJoinResponse) ProtoMessage()

func (*RaftJoinResponse) Reset Uses

func (m *RaftJoinResponse) Reset()

func (*RaftJoinResponse) Size Uses

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

func (*RaftJoinResponse) String Uses

func (m *RaftJoinResponse) String() string

func (*RaftJoinResponse) Unmarshal Uses

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

func (*RaftJoinResponse) XXX_DiscardUnknown Uses

func (m *RaftJoinResponse) XXX_DiscardUnknown()

func (*RaftJoinResponse) XXX_Marshal Uses

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

func (*RaftJoinResponse) XXX_Merge Uses

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

func (*RaftJoinResponse) XXX_Size Uses

func (m *RaftJoinResponse) XXX_Size() int

func (*RaftJoinResponse) XXX_Unmarshal Uses

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

type RaftLog Uses

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

func (*RaftLog) Descriptor Uses

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

func (*RaftLog) GetChangeLeaderOp Uses

func (m *RaftLog) GetChangeLeaderOp() *ChangeLeaderOp

func (*RaftLog) GetCreateStreamOp Uses

func (m *RaftLog) GetCreateStreamOp() *CreateStreamOp

func (*RaftLog) GetDeleteStreamOp Uses

func (m *RaftLog) GetDeleteStreamOp() *DeleteStreamOp

func (*RaftLog) GetExpandISROp Uses

func (m *RaftLog) GetExpandISROp() *ExpandISROp

func (*RaftLog) GetOp Uses

func (m *RaftLog) GetOp() Op

func (*RaftLog) GetPauseStreamOp Uses

func (m *RaftLog) GetPauseStreamOp() *PauseStreamOp

func (*RaftLog) GetPublishActivityOp Uses

func (m *RaftLog) GetPublishActivityOp() *PublishActivityOp

func (*RaftLog) GetResumeStreamOp Uses

func (m *RaftLog) GetResumeStreamOp() *ResumeStreamOp

func (*RaftLog) GetShrinkISROp Uses

func (m *RaftLog) GetShrinkISROp() *ShrinkISROp

func (*RaftLog) Marshal Uses

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

func (*RaftLog) MarshalTo Uses

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

func (*RaftLog) MarshalToSizedBuffer Uses

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

func (*RaftLog) ProtoMessage Uses

func (*RaftLog) ProtoMessage()

func (*RaftLog) Reset Uses

func (m *RaftLog) Reset()

func (*RaftLog) Size Uses

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

func (*RaftLog) String Uses

func (m *RaftLog) String() string

func (*RaftLog) Unmarshal Uses

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

func (*RaftLog) XXX_DiscardUnknown Uses

func (m *RaftLog) XXX_DiscardUnknown()

func (*RaftLog) XXX_Marshal Uses

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

func (*RaftLog) XXX_Merge Uses

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

func (*RaftLog) XXX_Size Uses

func (m *RaftLog) XXX_Size() int

func (*RaftLog) XXX_Unmarshal Uses

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

type ReplicationRequest Uses

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 Uses

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

UnmarshalReplicationRequest deserializes a Liftbridge ReplicationRequest envelope into a protobuf message.

func (*ReplicationRequest) Descriptor Uses

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

func (*ReplicationRequest) GetLeaderEpoch Uses

func (m *ReplicationRequest) GetLeaderEpoch() uint64

func (*ReplicationRequest) GetOffset Uses

func (m *ReplicationRequest) GetOffset() int64

func (*ReplicationRequest) GetReplicaID Uses

func (m *ReplicationRequest) GetReplicaID() string

func (*ReplicationRequest) Marshal Uses

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

func (*ReplicationRequest) MarshalTo Uses

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

func (*ReplicationRequest) MarshalToSizedBuffer Uses

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

func (*ReplicationRequest) ProtoMessage Uses

func (*ReplicationRequest) ProtoMessage()

func (*ReplicationRequest) Reset Uses

func (m *ReplicationRequest) Reset()

func (*ReplicationRequest) Size Uses

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

func (*ReplicationRequest) String Uses

func (m *ReplicationRequest) String() string

func (*ReplicationRequest) Unmarshal Uses

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

func (*ReplicationRequest) XXX_DiscardUnknown Uses

func (m *ReplicationRequest) XXX_DiscardUnknown()

func (*ReplicationRequest) XXX_Marshal Uses

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

func (*ReplicationRequest) XXX_Merge Uses

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

func (*ReplicationRequest) XXX_Size Uses

func (m *ReplicationRequest) XXX_Size() int

func (*ReplicationRequest) XXX_Unmarshal Uses

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

type ReportLeaderOp Uses

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 Uses

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

func (*ReportLeaderOp) GetLeader Uses

func (m *ReportLeaderOp) GetLeader() string

func (*ReportLeaderOp) GetLeaderEpoch Uses

func (m *ReportLeaderOp) GetLeaderEpoch() uint64

func (*ReportLeaderOp) GetPartition Uses

func (m *ReportLeaderOp) GetPartition() int32

func (*ReportLeaderOp) GetReplica Uses

func (m *ReportLeaderOp) GetReplica() string

func (*ReportLeaderOp) GetStream Uses

func (m *ReportLeaderOp) GetStream() string

func (*ReportLeaderOp) Marshal Uses

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

func (*ReportLeaderOp) MarshalTo Uses

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

func (*ReportLeaderOp) MarshalToSizedBuffer Uses

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

func (*ReportLeaderOp) ProtoMessage Uses

func (*ReportLeaderOp) ProtoMessage()

func (*ReportLeaderOp) Reset Uses

func (m *ReportLeaderOp) Reset()

func (*ReportLeaderOp) Size Uses

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

func (*ReportLeaderOp) String Uses

func (m *ReportLeaderOp) String() string

func (*ReportLeaderOp) Unmarshal Uses

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

func (*ReportLeaderOp) XXX_DiscardUnknown Uses

func (m *ReportLeaderOp) XXX_DiscardUnknown()

func (*ReportLeaderOp) XXX_Marshal Uses

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

func (*ReportLeaderOp) XXX_Merge Uses

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

func (*ReportLeaderOp) XXX_Size Uses

func (m *ReportLeaderOp) XXX_Size() int

func (*ReportLeaderOp) XXX_Unmarshal Uses

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

type ResumeStreamOp Uses

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 Uses

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

func (*ResumeStreamOp) GetPartitions Uses

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

func (*ResumeStreamOp) GetStream Uses

func (m *ResumeStreamOp) GetStream() string

func (*ResumeStreamOp) Marshal Uses

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

func (*ResumeStreamOp) MarshalTo Uses

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

func (*ResumeStreamOp) MarshalToSizedBuffer Uses

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

func (*ResumeStreamOp) ProtoMessage Uses

func (*ResumeStreamOp) ProtoMessage()

func (*ResumeStreamOp) Reset Uses

func (m *ResumeStreamOp) Reset()

func (*ResumeStreamOp) Size Uses

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

func (*ResumeStreamOp) String Uses

func (m *ResumeStreamOp) String() string

func (*ResumeStreamOp) Unmarshal Uses

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

func (*ResumeStreamOp) XXX_DiscardUnknown Uses

func (m *ResumeStreamOp) XXX_DiscardUnknown()

func (*ResumeStreamOp) XXX_Marshal Uses

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

func (*ResumeStreamOp) XXX_Merge Uses

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

func (*ResumeStreamOp) XXX_Size Uses

func (m *ResumeStreamOp) XXX_Size() int

func (*ResumeStreamOp) XXX_Unmarshal Uses

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

type ServerInfoRequest Uses

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 Uses

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

UnmarshalServerInfoRequest deserializes a Liftbridge ServerInfoRequest envelope into a protobuf message.

func (*ServerInfoRequest) Descriptor Uses

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

func (*ServerInfoRequest) GetId Uses

func (m *ServerInfoRequest) GetId() string

func (*ServerInfoRequest) Marshal Uses

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

func (*ServerInfoRequest) MarshalTo Uses

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

func (*ServerInfoRequest) MarshalToSizedBuffer Uses

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

func (*ServerInfoRequest) ProtoMessage Uses

func (*ServerInfoRequest) ProtoMessage()

func (*ServerInfoRequest) Reset Uses

func (m *ServerInfoRequest) Reset()

func (*ServerInfoRequest) Size Uses

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

func (*ServerInfoRequest) String Uses

func (m *ServerInfoRequest) String() string

func (*ServerInfoRequest) Unmarshal Uses

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

func (*ServerInfoRequest) XXX_DiscardUnknown Uses

func (m *ServerInfoRequest) XXX_DiscardUnknown()

func (*ServerInfoRequest) XXX_Marshal Uses

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

func (*ServerInfoRequest) XXX_Merge Uses

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

func (*ServerInfoRequest) XXX_Size Uses

func (m *ServerInfoRequest) XXX_Size() int

func (*ServerInfoRequest) XXX_Unmarshal Uses

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

type ServerInfoResponse Uses

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 Uses

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

UnmarshalServerInfoResponse deserializes a Liftbridge ServerInfoResponse envelope into a protobuf message.

func (*ServerInfoResponse) Descriptor Uses

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

func (*ServerInfoResponse) GetHost Uses

func (m *ServerInfoResponse) GetHost() string

func (*ServerInfoResponse) GetId Uses

func (m *ServerInfoResponse) GetId() string

func (*ServerInfoResponse) GetPort Uses

func (m *ServerInfoResponse) GetPort() int32

func (*ServerInfoResponse) Marshal Uses

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

func (*ServerInfoResponse) MarshalTo Uses

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

func (*ServerInfoResponse) MarshalToSizedBuffer Uses

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

func (*ServerInfoResponse) ProtoMessage Uses

func (*ServerInfoResponse) ProtoMessage()

func (*ServerInfoResponse) Reset Uses

func (m *ServerInfoResponse) Reset()

func (*ServerInfoResponse) Size Uses

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

func (*ServerInfoResponse) String Uses

func (m *ServerInfoResponse) String() string

func (*ServerInfoResponse) Unmarshal Uses

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

func (*ServerInfoResponse) XXX_DiscardUnknown Uses

func (m *ServerInfoResponse) XXX_DiscardUnknown()

func (*ServerInfoResponse) XXX_Marshal Uses

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

func (*ServerInfoResponse) XXX_Merge Uses

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

func (*ServerInfoResponse) XXX_Size Uses

func (m *ServerInfoResponse) XXX_Size() int

func (*ServerInfoResponse) XXX_Unmarshal Uses

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

type ServerState Uses

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 Uses

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

func (*ServerState) GetServerID Uses

func (m *ServerState) GetServerID() string

func (*ServerState) Marshal Uses

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

func (*ServerState) MarshalTo Uses

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

func (*ServerState) MarshalToSizedBuffer Uses

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

func (*ServerState) ProtoMessage Uses

func (*ServerState) ProtoMessage()

func (*ServerState) Reset Uses

func (m *ServerState) Reset()

func (*ServerState) Size Uses

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

func (*ServerState) String Uses

func (m *ServerState) String() string

func (*ServerState) Unmarshal Uses

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

func (*ServerState) XXX_DiscardUnknown Uses

func (m *ServerState) XXX_DiscardUnknown()

func (*ServerState) XXX_Marshal Uses

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

func (*ServerState) XXX_Merge Uses

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

func (*ServerState) XXX_Size Uses

func (m *ServerState) XXX_Size() int

func (*ServerState) XXX_Unmarshal Uses

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

type ShrinkISROp Uses

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 Uses

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

func (*ShrinkISROp) GetLeader Uses

func (m *ShrinkISROp) GetLeader() string

func (*ShrinkISROp) GetLeaderEpoch Uses

func (m *ShrinkISROp) GetLeaderEpoch() uint64

func (*ShrinkISROp) GetPartition Uses

func (m *ShrinkISROp) GetPartition() int32

func (*ShrinkISROp) GetReplicaToRemove Uses

func (m *ShrinkISROp) GetReplicaToRemove() string

func (*ShrinkISROp) GetStream Uses

func (m *ShrinkISROp) GetStream() string

func (*ShrinkISROp) Marshal Uses

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

func (*ShrinkISROp) MarshalTo Uses

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

func (*ShrinkISROp) MarshalToSizedBuffer Uses

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

func (*ShrinkISROp) ProtoMessage Uses

func (*ShrinkISROp) ProtoMessage()

func (*ShrinkISROp) Reset Uses

func (m *ShrinkISROp) Reset()

func (*ShrinkISROp) Size Uses

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

func (*ShrinkISROp) String Uses

func (m *ShrinkISROp) String() string

func (*ShrinkISROp) Unmarshal Uses

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

func (*ShrinkISROp) XXX_DiscardUnknown Uses

func (m *ShrinkISROp) XXX_DiscardUnknown()

func (*ShrinkISROp) XXX_Marshal Uses

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

func (*ShrinkISROp) XXX_Merge Uses

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

func (*ShrinkISROp) XXX_Size Uses

func (m *ShrinkISROp) XXX_Size() int

func (*ShrinkISROp) XXX_Unmarshal Uses

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

type Stream Uses

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

func (*Stream) Descriptor Uses

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

func (*Stream) GetConfig Uses

func (m *Stream) GetConfig() *StreamConfig

func (*Stream) GetName Uses

func (m *Stream) GetName() string

func (*Stream) GetPartitions Uses

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

func (*Stream) GetSubject Uses

func (m *Stream) GetSubject() string

func (*Stream) Marshal Uses

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

func (*Stream) MarshalTo Uses

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

func (*Stream) MarshalToSizedBuffer Uses

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

func (*Stream) ProtoMessage Uses

func (*Stream) ProtoMessage()

func (*Stream) Reset Uses

func (m *Stream) Reset()

func (*Stream) Size Uses

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

func (*Stream) String Uses

func (m *Stream) String() string

func (*Stream) Unmarshal Uses

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

func (*Stream) XXX_DiscardUnknown Uses

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal Uses

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

func (*Stream) XXX_Merge Uses

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

func (*Stream) XXX_Size Uses

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal Uses

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

type StreamConfig Uses

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

func (*StreamConfig) Descriptor Uses

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

func (*StreamConfig) GetAutoPauseDisableIfSubscribers Uses

func (m *StreamConfig) GetAutoPauseDisableIfSubscribers() *NullableBool

func (*StreamConfig) GetAutoPauseTime Uses

func (m *StreamConfig) GetAutoPauseTime() *NullableInt64

func (*StreamConfig) GetCleanerInterval Uses

func (m *StreamConfig) GetCleanerInterval() *NullableInt64

func (*StreamConfig) GetCompactEnabled Uses

func (m *StreamConfig) GetCompactEnabled() *NullableBool

func (*StreamConfig) GetCompactMaxGoroutines Uses

func (m *StreamConfig) GetCompactMaxGoroutines() *NullableInt32

func (*StreamConfig) GetRetentionMaxAge Uses

func (m *StreamConfig) GetRetentionMaxAge() *NullableInt64

func (*StreamConfig) GetRetentionMaxBytes Uses

func (m *StreamConfig) GetRetentionMaxBytes() *NullableInt64

func (*StreamConfig) GetRetentionMaxMessages Uses

func (m *StreamConfig) GetRetentionMaxMessages() *NullableInt64

func (*StreamConfig) GetSegmentMaxAge Uses

func (m *StreamConfig) GetSegmentMaxAge() *NullableInt64

func (*StreamConfig) GetSegmentMaxBytes Uses

func (m *StreamConfig) GetSegmentMaxBytes() *NullableInt64

func (*StreamConfig) Marshal Uses

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

func (*StreamConfig) MarshalTo Uses

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

func (*StreamConfig) MarshalToSizedBuffer Uses

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

func (*StreamConfig) ProtoMessage Uses

func (*StreamConfig) ProtoMessage()

func (*StreamConfig) Reset Uses

func (m *StreamConfig) Reset()

func (*StreamConfig) Size Uses

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

func (*StreamConfig) String Uses

func (m *StreamConfig) String() string

func (*StreamConfig) Unmarshal Uses

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

func (*StreamConfig) XXX_DiscardUnknown Uses

func (m *StreamConfig) XXX_DiscardUnknown()

func (*StreamConfig) XXX_Marshal Uses

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

func (*StreamConfig) XXX_Merge Uses

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

func (*StreamConfig) XXX_Size Uses

func (m *StreamConfig) XXX_Size() int

func (*StreamConfig) XXX_Unmarshal Uses

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

Package protocol imports 10 packages (graph) and is imported by 2 packages. Updated 2020-09-23. Refresh now. Tools for package owners.