proto

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2019 License: Apache-2.0 Imports: 8 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
CreateStreamOp
ShrinkISROp
ExpandISROp
ReportLeaderOp
ChangeLeaderOp
Stream
RaftJoinRequest
RaftJoinResponse
MetadataSnapshot
ReplicationRequest
PropagatedRequest
Error
PropagatedResponse
ServerInfoRequest
ServerInfoResponse
StreamStatusRequest
StreamStatusResponse

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 = binary.BigEndian
View Source 
var ErrInsufficientData = errors.New("insufficient data to decode packet, more bytes expected")
View Source 
var ErrInvalidArrayLength = errors.New("invalid array length")
View Source 
var ErrInvalidByteSliceLength = errors.New("invalid byteslice length")
View Source 
var ErrInvalidStringLength = errors.New("invalid string length")
View Source 
var Op_name = map[int32]string{
	0: "CREATE_STREAM",
	1: "SHRINK_ISR",
	2: "REPORT_LEADER",
	3: "CHANGE_LEADER",
	4: "EXPAND_ISR",
}
View Source 
var Op_value = map[string]int32{
	"CREATE_STREAM": 0,
	"SHRINK_ISR":    1,
	"REPORT_LEADER": 2,
	"CHANGE_LEADER": 3,
	"EXPAND_ISR":    4,
}

Functions

func Decode 

func Decode(b []byte, in VersionedDecoder, version int16) error

func Encode 

func Encode(e Encoder) ([]byte, error)

Types

type ByteDecoder 

type ByteDecoder struct {
	// contains filtered or unexported fields
}

func NewDecoder 

func NewDecoder(b []byte) *ByteDecoder

func (*ByteDecoder) ArrayLength 

func (d *ByteDecoder) ArrayLength() (int, error)

func (*ByteDecoder) Bool 

func (d *ByteDecoder) Bool() (bool, error)

func (*ByteDecoder) Bytes 

func (d *ByteDecoder) Bytes() ([]byte, error)

func (*ByteDecoder) Int16 

func (d *ByteDecoder) Int16() (int16, error)

func (*ByteDecoder) Int32 

func (d *ByteDecoder) Int32() (int32, error)

func (*ByteDecoder) Int32Array 

func (d *ByteDecoder) Int32Array() ([]int32, error)

func (*ByteDecoder) Int64 

func (d *ByteDecoder) Int64() (int64, error)

func (*ByteDecoder) Int64Array 

func (d *ByteDecoder) Int64Array() ([]int64, error)

func (*ByteDecoder) Int8 

func (d *ByteDecoder) Int8() (int8, error)

func (*ByteDecoder) NullableString 

func (d *ByteDecoder) NullableString() (*string, error)

func (*ByteDecoder) Offset 

func (d *ByteDecoder) Offset() int

func (*ByteDecoder) Pop 

func (d *ByteDecoder) Pop() error

func (*ByteDecoder) Push 

func (d *ByteDecoder) Push(pd PushDecoder) error

func (*ByteDecoder) String 

func (d *ByteDecoder) String() (string, error)

func (*ByteDecoder) StringArray 

func (d *ByteDecoder) StringArray() ([]string, error)

type ByteEncoder 

type ByteEncoder struct {
	// contains filtered or unexported fields
}

func NewByteEncoder 

func NewByteEncoder(b []byte) *ByteEncoder

func (*ByteEncoder) Bytes 

func (b *ByteEncoder) Bytes() []byte

func (*ByteEncoder) Pop 

func (e *ByteEncoder) Pop()

func (*ByteEncoder) Push 

func (e *ByteEncoder) Push(pe PushEncoder)

func (*ByteEncoder) PutArrayLength 

func (e *ByteEncoder) PutArrayLength(in int) error

func (*ByteEncoder) PutBool 

func (e *ByteEncoder) PutBool(in bool)

func (*ByteEncoder) PutBytes 

func (e *ByteEncoder) PutBytes(in []byte) error

func (*ByteEncoder) PutInt16 

func (e *ByteEncoder) PutInt16(in int16)

func (*ByteEncoder) PutInt32 

func (e *ByteEncoder) PutInt32(in int32)

func (*ByteEncoder) PutInt32Array 

func (e *ByteEncoder) PutInt32Array(in []int32) error

func (*ByteEncoder) PutInt64 

func (e *ByteEncoder) PutInt64(in int64)

func (*ByteEncoder) PutInt64Array 

func (e *ByteEncoder) PutInt64Array(in []int64) error

func (*ByteEncoder) PutInt8 

func (e *ByteEncoder) PutInt8(in int8)

func (*ByteEncoder) PutNullableString 

func (e *ByteEncoder) PutNullableString(in *string) error

func (*ByteEncoder) PutRawBytes 

func (e *ByteEncoder) PutRawBytes(in []byte) error

func (*ByteEncoder) PutString 

func (e *ByteEncoder) PutString(in string) error

func (*ByteEncoder) PutStringArray 

func (e *ByteEncoder) PutStringArray(in []string) error

type CRCField 

type CRCField struct {
	StartOffset int
}

func (*CRCField) Check 

func (f *CRCField) Check(curOffset int, buf []byte) error

func (*CRCField) Fill 

func (f *CRCField) Fill(curOffset int, buf []byte) error

func (*CRCField) ReserveSize 

func (f *CRCField) ReserveSize() int

func (*CRCField) SaveOffset 

func (f *CRCField) SaveOffset(in int)

type ChangeLeaderOp 

type ChangeLeaderOp struct {
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,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) GetName 

func (m *ChangeLeaderOp) GetName() string

func (*ChangeLeaderOp) GetSubject 

func (m *ChangeLeaderOp) GetSubject() 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 CreateStreamOp 

type CreateStreamOp struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream" json:"stream,omitempty"`
}

func (*CreateStreamOp) Descriptor 

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

func (*CreateStreamOp) GetStream 

func (m *CreateStreamOp) GetStream() *Stream

func (*CreateStreamOp) Marshal 

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

func (*CreateStreamOp) MarshalTo 

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

func (*CreateStreamOp) ProtoMessage 

func (*CreateStreamOp) ProtoMessage()

func (*CreateStreamOp) Reset 

func (m *CreateStreamOp) Reset()

func (*CreateStreamOp) Size 

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

func (*CreateStreamOp) String 

func (m *CreateStreamOp) String() string

func (*CreateStreamOp) Unmarshal 

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

type Decoder 

type Decoder interface {
	Decode(d PacketDecoder) error
}

type Encoder 

type Encoder interface {
	Encode(e PacketEncoder) 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 {
	Subject      string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,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) GetName 

func (m *ExpandISROp) GetName() string

func (*ExpandISROp) GetReplicaToAdd 

func (m *ExpandISROp) GetReplicaToAdd() string

func (*ExpandISROp) GetSubject 

func (m *ExpandISROp) GetSubject() 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 LenEncoder 

type LenEncoder struct {
	Length int
}

func (*LenEncoder) Pop 

func (e *LenEncoder) Pop()

func (*LenEncoder) Push 

func (e *LenEncoder) Push(pe PushEncoder)

func (*LenEncoder) PutArrayLength 

func (e *LenEncoder) PutArrayLength(in int) error

func (*LenEncoder) PutBool 

func (e *LenEncoder) PutBool(in bool)

func (*LenEncoder) PutBytes 

func (e *LenEncoder) PutBytes(in []byte) error

func (*LenEncoder) PutInt16 

func (e *LenEncoder) PutInt16(in int16)

func (*LenEncoder) PutInt32 

func (e *LenEncoder) PutInt32(in int32)

func (*LenEncoder) PutInt32Array 

func (e *LenEncoder) PutInt32Array(in []int32) error

func (*LenEncoder) PutInt64 

func (e *LenEncoder) PutInt64(in int64)

func (*LenEncoder) PutInt64Array 

func (e *LenEncoder) PutInt64Array(in []int64) error

func (*LenEncoder) PutInt8 

func (e *LenEncoder) PutInt8(in int8)

func (*LenEncoder) PutNullableString 

func (e *LenEncoder) PutNullableString(in *string) error

func (*LenEncoder) PutRawBytes 

func (e *LenEncoder) PutRawBytes(in []byte) error

func (*LenEncoder) PutString 

func (e *LenEncoder) PutString(in string) error

func (*LenEncoder) PutStringArray 

func (e *LenEncoder) PutStringArray(in []string) error

type Message 

type Message struct {
	Crc        int32
	MagicByte  int8
	Attributes int8
	Key        []byte
	Value      []byte
	Headers    map[string][]byte

	// Transient fields
	Timestamp     int64
	AckInbox      string
	CorrelationID string
	AckPolicy     client.AckPolicy
}

func (*Message) Decode 

func (m *Message) Decode(d PacketDecoder) error

func (*Message) Encode 

func (m *Message) Encode(e PacketEncoder) error

type MetadataSnapshot 

type MetadataSnapshot struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
}

func (*MetadataSnapshot) Descriptor 

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

func (*MetadataSnapshot) GetStreams 

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

func (*MetadataSnapshot) Marshal 

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

func (*MetadataSnapshot) MarshalTo 

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

func (*MetadataSnapshot) 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_STREAM 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 PacketDecoder 

type PacketDecoder interface {
	Bool() (bool, error)
	Int8() (int8, error)
	Int16() (int16, error)
	Int32() (int32, error)
	Int64() (int64, error)
	ArrayLength() (int, error)
	Bytes() ([]byte, error)
	String() (string, error)
	NullableString() (*string, error)
	Int32Array() ([]int32, error)
	Int64Array() ([]int64, error)
	StringArray() ([]string, error)
	Push(pd PushDecoder) error
	Pop() error
	// contains filtered or unexported methods
}

type PacketEncoder 

type PacketEncoder interface {
	PutBool(in bool)
	PutInt8(in int8)
	PutInt16(in int16)
	PutInt32(in int32)
	PutInt64(in int64)
	PutArrayLength(in int) error
	PutRawBytes(in []byte) error
	PutBytes(in []byte) error
	PutString(in string) error
	PutNullableString(in *string) error
	PutStringArray(in []string) error
	PutInt32Array(in []int32) error
	PutInt64Array(in []int64) error
	Push(pe PushEncoder)
	Pop()
}

type PropagatedRequest 

type PropagatedRequest struct {
	Op             Op                          `protobuf:"varint,1,opt,name=op,proto3,enum=proto.Op" json:"op,omitempty"`
	CreateStreamOp *proto2.CreateStreamRequest `protobuf:"bytes,2,opt,name=createStreamOp" json:"createStreamOp,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 (*PropagatedRequest) Descriptor 

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

func (*PropagatedRequest) GetCreateStreamOp 

func (m *PropagatedRequest) GetCreateStreamOp() *proto2.CreateStreamRequest

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"`
	CreateStreamResp *proto2.CreateStreamResponse `protobuf:"bytes,3,opt,name=createStreamResp" json:"createStreamResp,omitempty"`
}

func (*PropagatedResponse) Descriptor 

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

func (*PropagatedResponse) GetCreateStreamResp 

func (m *PropagatedResponse) GetCreateStreamResp() *proto2.CreateStreamResponse

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 PushDecoder 

type PushDecoder interface {
	SaveOffset(in int)
	ReserveSize() int
	Fill(curOffset int, buf []byte) error
	Check(curOffset int, buf []byte) error
}

type PushEncoder 

type PushEncoder interface {
	SaveOffset(in int)
	ReserveSize() int
	Fill(curOffset int, buf []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 (*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 (*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"`
	CreateStreamOp *CreateStreamOp `protobuf:"bytes,2,opt,name=createStreamOp" json:"createStreamOp,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) GetCreateStreamOp 

func (m *RaftLog) GetCreateStreamOp() *CreateStreamOp

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 (*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 {
	Subject     string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,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) GetName 

func (m *ReportLeaderOp) GetName() string

func (*ReportLeaderOp) GetReplica 

func (m *ReportLeaderOp) GetReplica() string

func (*ReportLeaderOp) GetSubject 

func (m *ReportLeaderOp) GetSubject() 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 (*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 (*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 {
	Subject         string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Name            string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,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) GetName 

func (m *ShrinkISROp) GetName() string

func (*ShrinkISROp) GetReplicaToRemove 

func (m *ShrinkISROp) GetReplicaToRemove() string

func (*ShrinkISROp) GetSubject 

func (m *ShrinkISROp) GetSubject() 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

type SizeField 

type SizeField struct {
	StartOffset int
}

func (*SizeField) Check 

func (s *SizeField) Check(curOffset int, buf []byte) error

func (*SizeField) Fill 

func (s *SizeField) Fill(curOffset int, buf []byte) error

func (*SizeField) ReserveSize 

func (s *SizeField) ReserveSize() int

func (*SizeField) SaveOffset 

func (s *SizeField) SaveOffset(in int)

type Stream 

type Stream struct {
	Subject           string   `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Name              string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group             string   `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	ReplicationFactor int32    `protobuf:"varint,4,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"`
	Replicas          []string `protobuf:"bytes,5,rep,name=replicas" json:"replicas,omitempty"`
	Leader            string   `protobuf:"bytes,6,opt,name=leader,proto3" json:"leader,omitempty"`
	Isr               []string `protobuf:"bytes,7,rep,name=isr" json:"isr,omitempty"`
	LeaderEpoch       uint64   `protobuf:"varint,8,opt,name=leaderEpoch,proto3" json:"leaderEpoch,omitempty"`
	Epoch             uint64   `protobuf:"varint,9,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

func (*Stream) Descriptor 

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

func (*Stream) GetEpoch 

func (m *Stream) GetEpoch() uint64

func (*Stream) GetGroup 

func (m *Stream) GetGroup() string

func (*Stream) GetIsr 

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

func (*Stream) GetLeader 

func (m *Stream) GetLeader() string

func (*Stream) GetLeaderEpoch 

func (m *Stream) GetLeaderEpoch() uint64

func (*Stream) GetName 

func (m *Stream) GetName() string

func (*Stream) GetReplicas 

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

func (*Stream) GetReplicationFactor 

func (m *Stream) GetReplicationFactor() int32

func (*Stream) GetSubject 

func (m *Stream) GetSubject() string

func (*Stream) Marshal 

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

func (*Stream) MarshalTo 

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

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) Size 

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

func (*Stream) String 

func (m *Stream) String() string

func (*Stream) Unmarshal 

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

type StreamStatusRequest 

type StreamStatusRequest struct {
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*StreamStatusRequest) Descriptor 

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

func (*StreamStatusRequest) GetName 

func (m *StreamStatusRequest) GetName() string

func (*StreamStatusRequest) GetSubject 

func (m *StreamStatusRequest) GetSubject() string

func (*StreamStatusRequest) Marshal 

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

func (*StreamStatusRequest) MarshalTo 

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

func (*StreamStatusRequest) ProtoMessage 

func (*StreamStatusRequest) ProtoMessage()

func (*StreamStatusRequest) Reset 

func (m *StreamStatusRequest) Reset()

func (*StreamStatusRequest) Size 

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

func (*StreamStatusRequest) String 

func (m *StreamStatusRequest) String() string

func (*StreamStatusRequest) Unmarshal 

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

type StreamStatusResponse 

type StreamStatusResponse 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 (*StreamStatusResponse) Descriptor 

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

func (*StreamStatusResponse) GetExists 

func (m *StreamStatusResponse) GetExists() bool

func (*StreamStatusResponse) GetIsLeader 

func (m *StreamStatusResponse) GetIsLeader() bool

func (*StreamStatusResponse) Marshal 

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

func (*StreamStatusResponse) MarshalTo 

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

func (*StreamStatusResponse) ProtoMessage 

func (*StreamStatusResponse) ProtoMessage()

func (*StreamStatusResponse) Reset 

func (m *StreamStatusResponse) Reset()

func (*StreamStatusResponse) Size 

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

func (*StreamStatusResponse) String 

func (m *StreamStatusResponse) String() string

func (*StreamStatusResponse) Unmarshal 

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

type VersionedDecoder 

type VersionedDecoder interface {
	Decode(d PacketDecoder, version int16) 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.