proto

package
v1.0.0-beta Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files: 

server/proto/internal.proto

It has these top-level messages: 

ServerState
RaftLog
CreatePartitionOp
ShrinkISROp
ExpandISROp
ReportLeaderOp
ChangeLeaderOp
Partition
RaftJoinRequest
RaftJoinResponse
MetadataSnapshot
ReplicationRequest
LeaderEpochOffsetRequest
LeaderEpochOffsetResponse
PropagatedRequest
Error
PropagatedResponse
ServerInfoRequest
ServerInfoResponse
PartitionStatusRequest
PartitionStatusResponse
PartitionNotification

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")
)
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_PARTITION",
	1: "SHRINK_ISR",
	2: "REPORT_LEADER",
	3: "CHANGE_LEADER",
	4: "EXPAND_ISR",
}
View Source 
var Op_value = map[string]int32{
	"CREATE_PARTITION": 0,
	"SHRINK_ISR":       1,
	"REPORT_LEADER":    2,
	"CHANGE_LEADER":    3,
	"EXPAND_ISR":       4,
}

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 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"`
}

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

type CreatePartitionOp 

type CreatePartitionOp struct {
	Partition *Partition `protobuf:"bytes,1,opt,name=partition" json:"partition,omitempty"`
}

func (*CreatePartitionOp) Descriptor 

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

func (*CreatePartitionOp) GetPartition 

func (m *CreatePartitionOp) GetPartition() *Partition

func (*CreatePartitionOp) Marshal 

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

func (*CreatePartitionOp) MarshalTo 

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

func (*CreatePartitionOp) ProtoMessage 

func (*CreatePartitionOp) ProtoMessage()

func (*CreatePartitionOp) Reset 

func (m *CreatePartitionOp) Reset()

func (*CreatePartitionOp) Size 

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

func (*CreatePartitionOp) String 

func (m *CreatePartitionOp) String() string

func (*CreatePartitionOp) Unmarshal 

func (m *CreatePartitionOp) Unmarshal(dAtA []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"`
}

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

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"`
}

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

type LeaderEpochOffsetRequest 

type LeaderEpochOffsetRequest struct {
	LeaderEpoch uint64 `protobuf:"varint,1,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"`
}

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

type LeaderEpochOffsetResponse 

type LeaderEpochOffsetResponse struct {
	EndOffset int64 `protobuf:"varint,1,opt,name=endOffset,proto3" json:"endOffset,omitempty"`
}

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

type MetadataSnapshot 

type MetadataSnapshot struct {
	Partitions []*Partition `protobuf:"bytes,1,rep,name=partitions" json:"partitions,omitempty"`
}

func (*MetadataSnapshot) Descriptor 

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

func (*MetadataSnapshot) GetPartitions 

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

func (*MetadataSnapshot) Marshal 

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

func (*MetadataSnapshot) MarshalTo 

func (m *MetadataSnapshot) MarshalTo(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

type Op 

type Op int32
const (
	Op_CREATE_PARTITION Op = 0
	Op_SHRINK_ISR       Op = 1
	Op_REPORT_LEADER    Op = 2
	Op_CHANGE_LEADER    Op = 3
	Op_EXPAND_ISR       Op = 4
)

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" json:"replicas,omitempty"`
	Leader            string   `protobuf:"bytes,7,opt,name=leader,proto3" json:"leader,omitempty"`
	Isr               []string `protobuf:"bytes,8,rep,name=isr" 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"`
}

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

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"`
}

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

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"`
}

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

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"`
}

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

type PropagatedRequest 

type PropagatedRequest struct {
	Op                Op                 `protobuf:"varint,1,opt,name=op,proto3,enum=proto.Op" json:"op,omitempty"`
	CreatePartitionOp *CreatePartitionOp `protobuf:"bytes,2,opt,name=createPartitionOp" json:"createPartitionOp,omitempty"`
	ShrinkISROp       *ShrinkISROp       `protobuf:"bytes,3,opt,name=shrinkISROp" json:"shrinkISROp,omitempty"`
	ReportLeaderOp    *ReportLeaderOp    `protobuf:"bytes,4,opt,name=reportLeaderOp" json:"reportLeaderOp,omitempty"`
	ExpandISROp       *ExpandISROp       `protobuf:"bytes,5,opt,name=expandISROp" json:"expandISROp,omitempty"`
}

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

func (m *PropagatedRequest) GetCreatePartitionOp() *CreatePartitionOp

func (*PropagatedRequest) GetExpandISROp 

func (m *PropagatedRequest) GetExpandISROp() *ExpandISROp

func (*PropagatedRequest) GetOp 

func (m *PropagatedRequest) GetOp() Op

func (*PropagatedRequest) GetReportLeaderOp 

func (m *PropagatedRequest) GetReportLeaderOp() *ReportLeaderOp

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

type PropagatedResponse 

type PropagatedResponse struct {
	Op    Op     `protobuf:"varint,1,opt,name=op,proto3,enum=proto.Op" json:"op,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

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

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"`
}

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

type RaftJoinResponse 

type RaftJoinResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

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

type RaftLog 

type RaftLog struct {
	Op                Op                 `protobuf:"varint,1,opt,name=op,proto3,enum=proto.Op" json:"op,omitempty"`
	CreatePartitionOp *CreatePartitionOp `protobuf:"bytes,2,opt,name=createPartitionOp" json:"createPartitionOp,omitempty"`
	ShrinkISROp       *ShrinkISROp       `protobuf:"bytes,3,opt,name=shrinkISROp" json:"shrinkISROp,omitempty"`
	ChangeLeaderOp    *ChangeLeaderOp    `protobuf:"bytes,4,opt,name=changeLeaderOp" json:"changeLeaderOp,omitempty"`
	ExpandISROp       *ExpandISROp       `protobuf:"bytes,5,opt,name=expandISROp" json:"expandISROp,omitempty"`
}

func (*RaftLog) Descriptor 

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

func (*RaftLog) GetChangeLeaderOp 

func (m *RaftLog) GetChangeLeaderOp() *ChangeLeaderOp

func (*RaftLog) GetCreatePartitionOp 

func (m *RaftLog) GetCreatePartitionOp() *CreatePartitionOp

func (*RaftLog) GetExpandISROp 

func (m *RaftLog) GetExpandISROp() *ExpandISROp

func (*RaftLog) GetOp 

func (m *RaftLog) GetOp() Op

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

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"`
}

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

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"`
}

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

type ServerInfoRequest 

type ServerInfoRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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

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"`
}

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

type ServerState 

type ServerState struct {
	ServerID string `protobuf:"bytes,1,opt,name=serverID,proto3" json:"serverID,omitempty"`
}

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

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"`
}

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

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.