Documentation

Overview

    Package protobuf is a generated protocol buffer package.

    It is generated from these files:

    append_entries_request.proto
    append_entries_responses.proto
    log_entry.proto
    request_vote_request.proto
    request_vote_responses.proto
    snapshot_recovery_request.proto
    snapshot_recovery_response.proto
    snapshot_request.proto
    snapshot_response.proto
    

    It has these top-level messages:

    AppendEntriesRequest
    

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    This section is empty.

    Types

    type AppendEntriesRequest

    type AppendEntriesRequest struct {
    	Term             *uint64     `protobuf:"varint,1,req" json:"Term,omitempty"`
    	PrevLogIndex     *uint64     `protobuf:"varint,2,req" json:"PrevLogIndex,omitempty"`
    	PrevLogTerm      *uint64     `protobuf:"varint,3,req" json:"PrevLogTerm,omitempty"`
    	CommitIndex      *uint64     `protobuf:"varint,4,req" json:"CommitIndex,omitempty"`
    	LeaderName       *string     `protobuf:"bytes,5,req" json:"LeaderName,omitempty"`
    	Entries          []*LogEntry `protobuf:"bytes,6,rep" json:"Entries,omitempty"`
    	XXX_unrecognized []byte      `json:"-"`
    }

    func NewPopulatedAppendEntriesRequest

    func NewPopulatedAppendEntriesRequest(r randyAppendEntriesRequest, easy bool) *AppendEntriesRequest

    func (*AppendEntriesRequest) Equal

    func (this *AppendEntriesRequest) Equal(that interface{}) bool

    func (*AppendEntriesRequest) GetCommitIndex

    func (m *AppendEntriesRequest) GetCommitIndex() uint64

    func (*AppendEntriesRequest) GetEntries

    func (m *AppendEntriesRequest) GetEntries() []*LogEntry

    func (*AppendEntriesRequest) GetLeaderName

    func (m *AppendEntriesRequest) GetLeaderName() string

    func (*AppendEntriesRequest) GetPrevLogIndex

    func (m *AppendEntriesRequest) GetPrevLogIndex() uint64

    func (*AppendEntriesRequest) GetPrevLogTerm

    func (m *AppendEntriesRequest) GetPrevLogTerm() uint64

    func (*AppendEntriesRequest) GetTerm

    func (m *AppendEntriesRequest) GetTerm() uint64

    func (*AppendEntriesRequest) GoString

    func (this *AppendEntriesRequest) GoString() string

    func (*AppendEntriesRequest) Marshal

    func (m *AppendEntriesRequest) Marshal() (data []byte, err error)

    func (*AppendEntriesRequest) MarshalTo

    func (m *AppendEntriesRequest) MarshalTo(data []byte) (n int, err error)

    func (*AppendEntriesRequest) ProtoMessage

    func (*AppendEntriesRequest) ProtoMessage()

    func (*AppendEntriesRequest) Reset

    func (m *AppendEntriesRequest) Reset()

    func (*AppendEntriesRequest) Size

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

    func (*AppendEntriesRequest) String

    func (this *AppendEntriesRequest) String() string

    func (*AppendEntriesRequest) Unmarshal

    func (m *AppendEntriesRequest) Unmarshal(data []byte) error

    func (*AppendEntriesRequest) VerboseEqual

    func (this *AppendEntriesRequest) VerboseEqual(that interface{}) error

    type AppendEntriesResponse

    type AppendEntriesResponse struct {
    	Term             *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"`
    	Index            *uint64 `protobuf:"varint,2,req" json:"Index,omitempty"`
    	CommitIndex      *uint64 `protobuf:"varint,3,req" json:"CommitIndex,omitempty"`
    	Success          *bool   `protobuf:"varint,4,req" json:"Success,omitempty"`
    	XXX_unrecognized []byte  `json:"-"`
    }

    func NewPopulatedAppendEntriesResponse

    func NewPopulatedAppendEntriesResponse(r randyAppendEntriesResponses, easy bool) *AppendEntriesResponse

    func (*AppendEntriesResponse) Equal

    func (this *AppendEntriesResponse) Equal(that interface{}) bool

    func (*AppendEntriesResponse) GetCommitIndex

    func (m *AppendEntriesResponse) GetCommitIndex() uint64

    func (*AppendEntriesResponse) GetIndex

    func (m *AppendEntriesResponse) GetIndex() uint64

    func (*AppendEntriesResponse) GetSuccess

    func (m *AppendEntriesResponse) GetSuccess() bool

    func (*AppendEntriesResponse) GetTerm

    func (m *AppendEntriesResponse) GetTerm() uint64

    func (*AppendEntriesResponse) GoString

    func (this *AppendEntriesResponse) GoString() string

    func (*AppendEntriesResponse) Marshal

    func (m *AppendEntriesResponse) Marshal() (data []byte, err error)

    func (*AppendEntriesResponse) MarshalTo

    func (m *AppendEntriesResponse) MarshalTo(data []byte) (n int, err error)

    func (*AppendEntriesResponse) ProtoMessage

    func (*AppendEntriesResponse) ProtoMessage()

    func (*AppendEntriesResponse) Reset

    func (m *AppendEntriesResponse) Reset()

    func (*AppendEntriesResponse) Size

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

    func (*AppendEntriesResponse) String

    func (this *AppendEntriesResponse) String() string

    func (*AppendEntriesResponse) Unmarshal

    func (m *AppendEntriesResponse) Unmarshal(data []byte) error

    func (*AppendEntriesResponse) VerboseEqual

    func (this *AppendEntriesResponse) VerboseEqual(that interface{}) error

    type LogEntry

    type LogEntry struct {
    	Index            *uint64 `protobuf:"varint,1,req" json:"Index,omitempty"`
    	Term             *uint64 `protobuf:"varint,2,req" json:"Term,omitempty"`
    	CommandName      *string `protobuf:"bytes,3,req" json:"CommandName,omitempty"`
    	Command          []byte  `protobuf:"bytes,4,opt" json:"Command,omitempty"`
    	XXX_unrecognized []byte  `json:"-"`
    }

    func NewPopulatedLogEntry

    func NewPopulatedLogEntry(r randyLogEntry, easy bool) *LogEntry

    func (*LogEntry) Equal

    func (this *LogEntry) Equal(that interface{}) bool

    func (*LogEntry) GetCommand

    func (m *LogEntry) GetCommand() []byte

    func (*LogEntry) GetCommandName

    func (m *LogEntry) GetCommandName() string

    func (*LogEntry) GetIndex

    func (m *LogEntry) GetIndex() uint64

    func (*LogEntry) GetTerm

    func (m *LogEntry) GetTerm() uint64

    func (*LogEntry) GoString

    func (this *LogEntry) GoString() string

    func (*LogEntry) Marshal

    func (m *LogEntry) Marshal() (data []byte, err error)

    func (*LogEntry) MarshalTo

    func (m *LogEntry) MarshalTo(data []byte) (n int, err error)

    func (*LogEntry) ProtoMessage

    func (*LogEntry) ProtoMessage()

    func (*LogEntry) Reset

    func (m *LogEntry) Reset()

    func (*LogEntry) Size

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

    func (*LogEntry) String

    func (this *LogEntry) String() string

    func (*LogEntry) Unmarshal

    func (m *LogEntry) Unmarshal(data []byte) error

    func (*LogEntry) VerboseEqual

    func (this *LogEntry) VerboseEqual(that interface{}) error

    type RequestVoteRequest

    type RequestVoteRequest struct {
    	Term             *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"`
    	LastLogIndex     *uint64 `protobuf:"varint,2,req" json:"LastLogIndex,omitempty"`
    	LastLogTerm      *uint64 `protobuf:"varint,3,req" json:"LastLogTerm,omitempty"`
    	CandidateName    *string `protobuf:"bytes,4,req" json:"CandidateName,omitempty"`
    	XXX_unrecognized []byte  `json:"-"`
    }

    func NewPopulatedRequestVoteRequest

    func NewPopulatedRequestVoteRequest(r randyRequestVoteRequest, easy bool) *RequestVoteRequest

    func (*RequestVoteRequest) Equal

    func (this *RequestVoteRequest) Equal(that interface{}) bool

    func (*RequestVoteRequest) GetCandidateName

    func (m *RequestVoteRequest) GetCandidateName() string

    func (*RequestVoteRequest) GetLastLogIndex

    func (m *RequestVoteRequest) GetLastLogIndex() uint64

    func (*RequestVoteRequest) GetLastLogTerm

    func (m *RequestVoteRequest) GetLastLogTerm() uint64

    func (*RequestVoteRequest) GetTerm

    func (m *RequestVoteRequest) GetTerm() uint64

    func (*RequestVoteRequest) GoString

    func (this *RequestVoteRequest) GoString() string

    func (*RequestVoteRequest) Marshal

    func (m *RequestVoteRequest) Marshal() (data []byte, err error)

    func (*RequestVoteRequest) MarshalTo

    func (m *RequestVoteRequest) MarshalTo(data []byte) (n int, err error)

    func (*RequestVoteRequest) ProtoMessage

    func (*RequestVoteRequest) ProtoMessage()

    func (*RequestVoteRequest) Reset

    func (m *RequestVoteRequest) Reset()

    func (*RequestVoteRequest) Size

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

    func (*RequestVoteRequest) String

    func (this *RequestVoteRequest) String() string

    func (*RequestVoteRequest) Unmarshal

    func (m *RequestVoteRequest) Unmarshal(data []byte) error

    func (*RequestVoteRequest) VerboseEqual

    func (this *RequestVoteRequest) VerboseEqual(that interface{}) error

    type RequestVoteResponse

    type RequestVoteResponse struct {
    	Term             *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"`
    	VoteGranted      *bool   `protobuf:"varint,2,req" json:"VoteGranted,omitempty"`
    	XXX_unrecognized []byte  `json:"-"`
    }

    func NewPopulatedRequestVoteResponse

    func NewPopulatedRequestVoteResponse(r randyRequestVoteResponses, easy bool) *RequestVoteResponse

    func (*RequestVoteResponse) Equal

    func (this *RequestVoteResponse) Equal(that interface{}) bool

    func (*RequestVoteResponse) GetTerm

    func (m *RequestVoteResponse) GetTerm() uint64

    func (*RequestVoteResponse) GetVoteGranted

    func (m *RequestVoteResponse) GetVoteGranted() bool

    func (*RequestVoteResponse) GoString

    func (this *RequestVoteResponse) GoString() string

    func (*RequestVoteResponse) Marshal

    func (m *RequestVoteResponse) Marshal() (data []byte, err error)

    func (*RequestVoteResponse) MarshalTo

    func (m *RequestVoteResponse) MarshalTo(data []byte) (n int, err error)

    func (*RequestVoteResponse) ProtoMessage

    func (*RequestVoteResponse) ProtoMessage()

    func (*RequestVoteResponse) Reset

    func (m *RequestVoteResponse) Reset()

    func (*RequestVoteResponse) Size

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

    func (*RequestVoteResponse) String

    func (this *RequestVoteResponse) String() string

    func (*RequestVoteResponse) Unmarshal

    func (m *RequestVoteResponse) Unmarshal(data []byte) error

    func (*RequestVoteResponse) VerboseEqual

    func (this *RequestVoteResponse) VerboseEqual(that interface{}) error

    type SnapshotRecoveryRequest

    type SnapshotRecoveryRequest struct {
    	LeaderName       *string                         `protobuf:"bytes,1,req" json:"LeaderName,omitempty"`
    	LastIndex        *uint64                         `protobuf:"varint,2,req" json:"LastIndex,omitempty"`
    	LastTerm         *uint64                         `protobuf:"varint,3,req" json:"LastTerm,omitempty"`
    	Peers            []*SnapshotRecoveryRequest_Peer `protobuf:"bytes,4,rep" json:"Peers,omitempty"`
    	State            []byte                          `protobuf:"bytes,5,req" json:"State,omitempty"`
    	XXX_unrecognized []byte                          `json:"-"`
    }

    func NewPopulatedSnapshotRecoveryRequest

    func NewPopulatedSnapshotRecoveryRequest(r randySnapshotRecoveryRequest, easy bool) *SnapshotRecoveryRequest

    func (*SnapshotRecoveryRequest) Equal

    func (this *SnapshotRecoveryRequest) Equal(that interface{}) bool

    func (*SnapshotRecoveryRequest) GetLastIndex

    func (m *SnapshotRecoveryRequest) GetLastIndex() uint64

    func (*SnapshotRecoveryRequest) GetLastTerm

    func (m *SnapshotRecoveryRequest) GetLastTerm() uint64

    func (*SnapshotRecoveryRequest) GetLeaderName

    func (m *SnapshotRecoveryRequest) GetLeaderName() string

    func (*SnapshotRecoveryRequest) GetPeers

    func (*SnapshotRecoveryRequest) GetState

    func (m *SnapshotRecoveryRequest) GetState() []byte

    func (*SnapshotRecoveryRequest) GoString

    func (this *SnapshotRecoveryRequest) GoString() string

    func (*SnapshotRecoveryRequest) Marshal

    func (m *SnapshotRecoveryRequest) Marshal() (data []byte, err error)

    func (*SnapshotRecoveryRequest) MarshalTo

    func (m *SnapshotRecoveryRequest) MarshalTo(data []byte) (n int, err error)

    func (*SnapshotRecoveryRequest) ProtoMessage

    func (*SnapshotRecoveryRequest) ProtoMessage()

    func (*SnapshotRecoveryRequest) Reset

    func (m *SnapshotRecoveryRequest) Reset()

    func (*SnapshotRecoveryRequest) Size

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

    func (*SnapshotRecoveryRequest) String

    func (this *SnapshotRecoveryRequest) String() string

    func (*SnapshotRecoveryRequest) Unmarshal

    func (m *SnapshotRecoveryRequest) Unmarshal(data []byte) error

    func (*SnapshotRecoveryRequest) VerboseEqual

    func (this *SnapshotRecoveryRequest) VerboseEqual(that interface{}) error

    type SnapshotRecoveryRequest_Peer

    type SnapshotRecoveryRequest_Peer struct {
    	Name             *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
    	ConnectionString *string `protobuf:"bytes,2,req" json:"ConnectionString,omitempty"`
    	XXX_unrecognized []byte  `json:"-"`
    }

    func NewPopulatedSnapshotRecoveryRequest_Peer

    func NewPopulatedSnapshotRecoveryRequest_Peer(r randySnapshotRecoveryRequest, easy bool) *SnapshotRecoveryRequest_Peer

    func (*SnapshotRecoveryRequest_Peer) Equal

    func (this *SnapshotRecoveryRequest_Peer) Equal(that interface{}) bool

    func (*SnapshotRecoveryRequest_Peer) GetConnectionString

    func (m *SnapshotRecoveryRequest_Peer) GetConnectionString() string

    func (*SnapshotRecoveryRequest_Peer) GetName

    func (m *SnapshotRecoveryRequest_Peer) GetName() string

    func (*SnapshotRecoveryRequest_Peer) GoString

    func (this *SnapshotRecoveryRequest_Peer) GoString() string

    func (*SnapshotRecoveryRequest_Peer) Marshal

    func (m *SnapshotRecoveryRequest_Peer) Marshal() (data []byte, err error)

    func (*SnapshotRecoveryRequest_Peer) MarshalTo

    func (m *SnapshotRecoveryRequest_Peer) MarshalTo(data []byte) (n int, err error)

    func (*SnapshotRecoveryRequest_Peer) ProtoMessage

    func (*SnapshotRecoveryRequest_Peer) ProtoMessage()

    func (*SnapshotRecoveryRequest_Peer) Reset

    func (m *SnapshotRecoveryRequest_Peer) Reset()

    func (*SnapshotRecoveryRequest_Peer) Size

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

    func (*SnapshotRecoveryRequest_Peer) String

    func (this *SnapshotRecoveryRequest_Peer) String() string

    func (*SnapshotRecoveryRequest_Peer) Unmarshal

    func (m *SnapshotRecoveryRequest_Peer) Unmarshal(data []byte) error

    func (*SnapshotRecoveryRequest_Peer) VerboseEqual

    func (this *SnapshotRecoveryRequest_Peer) VerboseEqual(that interface{}) error

    type SnapshotRecoveryResponse

    type SnapshotRecoveryResponse struct {
    	Term             *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"`
    	Success          *bool   `protobuf:"varint,2,req" json:"Success,omitempty"`
    	CommitIndex      *uint64 `protobuf:"varint,3,req" json:"CommitIndex,omitempty"`
    	XXX_unrecognized []byte  `json:"-"`
    }

    func NewPopulatedSnapshotRecoveryResponse

    func NewPopulatedSnapshotRecoveryResponse(r randySnapshotRecoveryResponse, easy bool) *SnapshotRecoveryResponse

    func (*SnapshotRecoveryResponse) Equal

    func (this *SnapshotRecoveryResponse) Equal(that interface{}) bool

    func (*SnapshotRecoveryResponse) GetCommitIndex

    func (m *SnapshotRecoveryResponse) GetCommitIndex() uint64

    func (*SnapshotRecoveryResponse) GetSuccess

    func (m *SnapshotRecoveryResponse) GetSuccess() bool

    func (*SnapshotRecoveryResponse) GetTerm

    func (m *SnapshotRecoveryResponse) GetTerm() uint64

    func (*SnapshotRecoveryResponse) GoString

    func (this *SnapshotRecoveryResponse) GoString() string

    func (*SnapshotRecoveryResponse) Marshal

    func (m *SnapshotRecoveryResponse) Marshal() (data []byte, err error)

    func (*SnapshotRecoveryResponse) MarshalTo

    func (m *SnapshotRecoveryResponse) MarshalTo(data []byte) (n int, err error)

    func (*SnapshotRecoveryResponse) ProtoMessage

    func (*SnapshotRecoveryResponse) ProtoMessage()

    func (*SnapshotRecoveryResponse) Reset

    func (m *SnapshotRecoveryResponse) Reset()

    func (*SnapshotRecoveryResponse) Size

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

    func (*SnapshotRecoveryResponse) String

    func (this *SnapshotRecoveryResponse) String() string

    func (*SnapshotRecoveryResponse) Unmarshal

    func (m *SnapshotRecoveryResponse) Unmarshal(data []byte) error

    func (*SnapshotRecoveryResponse) VerboseEqual

    func (this *SnapshotRecoveryResponse) VerboseEqual(that interface{}) error

    type SnapshotRequest

    type SnapshotRequest struct {
    	LeaderName       *string `protobuf:"bytes,1,req" json:"LeaderName,omitempty"`
    	LastIndex        *uint64 `protobuf:"varint,2,req" json:"LastIndex,omitempty"`
    	LastTerm         *uint64 `protobuf:"varint,3,req" json:"LastTerm,omitempty"`
    	XXX_unrecognized []byte  `json:"-"`
    }

    func NewPopulatedSnapshotRequest

    func NewPopulatedSnapshotRequest(r randySnapshotRequest, easy bool) *SnapshotRequest

    func (*SnapshotRequest) Equal

    func (this *SnapshotRequest) Equal(that interface{}) bool

    func (*SnapshotRequest) GetLastIndex

    func (m *SnapshotRequest) GetLastIndex() uint64

    func (*SnapshotRequest) GetLastTerm

    func (m *SnapshotRequest) GetLastTerm() uint64

    func (*SnapshotRequest) GetLeaderName

    func (m *SnapshotRequest) GetLeaderName() string

    func (*SnapshotRequest) GoString

    func (this *SnapshotRequest) GoString() string

    func (*SnapshotRequest) Marshal

    func (m *SnapshotRequest) Marshal() (data []byte, err error)

    func (*SnapshotRequest) MarshalTo

    func (m *SnapshotRequest) MarshalTo(data []byte) (n int, err error)

    func (*SnapshotRequest) ProtoMessage

    func (*SnapshotRequest) ProtoMessage()

    func (*SnapshotRequest) Reset

    func (m *SnapshotRequest) Reset()

    func (*SnapshotRequest) Size

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

    func (*SnapshotRequest) String

    func (this *SnapshotRequest) String() string

    func (*SnapshotRequest) Unmarshal

    func (m *SnapshotRequest) Unmarshal(data []byte) error

    func (*SnapshotRequest) VerboseEqual

    func (this *SnapshotRequest) VerboseEqual(that interface{}) error

    type SnapshotResponse

    type SnapshotResponse struct {
    	Success          *bool  `protobuf:"varint,1,req" json:"Success,omitempty"`
    	XXX_unrecognized []byte `json:"-"`
    }

    func NewPopulatedSnapshotResponse

    func NewPopulatedSnapshotResponse(r randySnapshotResponse, easy bool) *SnapshotResponse

    func (*SnapshotResponse) Equal

    func (this *SnapshotResponse) Equal(that interface{}) bool

    func (*SnapshotResponse) GetSuccess

    func (m *SnapshotResponse) GetSuccess() bool

    func (*SnapshotResponse) GoString

    func (this *SnapshotResponse) GoString() string

    func (*SnapshotResponse) Marshal

    func (m *SnapshotResponse) Marshal() (data []byte, err error)

    func (*SnapshotResponse) MarshalTo

    func (m *SnapshotResponse) MarshalTo(data []byte) (n int, err error)

    func (*SnapshotResponse) ProtoMessage

    func (*SnapshotResponse) ProtoMessage()

    func (*SnapshotResponse) Reset

    func (m *SnapshotResponse) Reset()

    func (*SnapshotResponse) Size

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

    func (*SnapshotResponse) String

    func (this *SnapshotResponse) String() string

    func (*SnapshotResponse) Unmarshal

    func (m *SnapshotResponse) Unmarshal(data []byte) error

    func (*SnapshotResponse) VerboseEqual

    func (this *SnapshotResponse) VerboseEqual(that interface{}) error