protobuf

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Feb 7, 2014 License: Apache-2.0, MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppendEntriesRequest added in v0.3.0

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 added in v0.3.0

func NewPopulatedAppendEntriesRequest(r randyAppendEntriesRequest, easy bool) *AppendEntriesRequest

func (*AppendEntriesRequest) Equal added in v0.3.0

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

func (*AppendEntriesRequest) GetCommitIndex added in v0.3.0

func (m *AppendEntriesRequest) GetCommitIndex() uint64

func (*AppendEntriesRequest) GetEntries added in v0.3.0

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

func (*AppendEntriesRequest) GetLeaderName added in v0.3.0

func (m *AppendEntriesRequest) GetLeaderName() string

func (*AppendEntriesRequest) GetPrevLogIndex added in v0.3.0

func (m *AppendEntriesRequest) GetPrevLogIndex() uint64

func (*AppendEntriesRequest) GetPrevLogTerm added in v0.3.0

func (m *AppendEntriesRequest) GetPrevLogTerm() uint64

func (*AppendEntriesRequest) GetTerm added in v0.3.0

func (m *AppendEntriesRequest) GetTerm() uint64

func (*AppendEntriesRequest) GoString added in v0.3.0

func (this *AppendEntriesRequest) GoString() string

func (*AppendEntriesRequest) Marshal added in v0.3.0

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

func (*AppendEntriesRequest) MarshalTo added in v0.3.0

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

func (*AppendEntriesRequest) ProtoMessage added in v0.3.0

func (*AppendEntriesRequest) ProtoMessage()

func (*AppendEntriesRequest) Reset added in v0.3.0

func (m *AppendEntriesRequest) Reset()

func (*AppendEntriesRequest) Size added in v0.3.0

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

func (*AppendEntriesRequest) String added in v0.3.0

func (this *AppendEntriesRequest) String() string

func (*AppendEntriesRequest) Unmarshal added in v0.3.0

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

func (*AppendEntriesRequest) VerboseEqual added in v0.3.0

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

type AppendEntriesResponse added in v0.3.0

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 added in v0.3.0

func NewPopulatedAppendEntriesResponse(r randyAppendEntriesResponses, easy bool) *AppendEntriesResponse

func (*AppendEntriesResponse) Equal added in v0.3.0

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

func (*AppendEntriesResponse) GetCommitIndex added in v0.3.0

func (m *AppendEntriesResponse) GetCommitIndex() uint64

func (*AppendEntriesResponse) GetIndex added in v0.3.0

func (m *AppendEntriesResponse) GetIndex() uint64

func (*AppendEntriesResponse) GetSuccess added in v0.3.0

func (m *AppendEntriesResponse) GetSuccess() bool

func (*AppendEntriesResponse) GetTerm added in v0.3.0

func (m *AppendEntriesResponse) GetTerm() uint64

func (*AppendEntriesResponse) GoString added in v0.3.0

func (this *AppendEntriesResponse) GoString() string

func (*AppendEntriesResponse) Marshal added in v0.3.0

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

func (*AppendEntriesResponse) MarshalTo added in v0.3.0

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

func (*AppendEntriesResponse) ProtoMessage added in v0.3.0

func (*AppendEntriesResponse) ProtoMessage()

func (*AppendEntriesResponse) Reset added in v0.3.0

func (m *AppendEntriesResponse) Reset()

func (*AppendEntriesResponse) Size added in v0.3.0

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

func (*AppendEntriesResponse) String added in v0.3.0

func (this *AppendEntriesResponse) String() string

func (*AppendEntriesResponse) Unmarshal added in v0.3.0

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

func (*AppendEntriesResponse) VerboseEqual added in v0.3.0

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

type LogEntry added in v0.3.0

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 added in v0.3.0

func NewPopulatedLogEntry(r randyLogEntry, easy bool) *LogEntry

func (*LogEntry) Equal added in v0.3.0

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

func (*LogEntry) GetCommand added in v0.3.0

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

func (*LogEntry) GetCommandName added in v0.3.0

func (m *LogEntry) GetCommandName() string

func (*LogEntry) GetIndex added in v0.3.0

func (m *LogEntry) GetIndex() uint64

func (*LogEntry) GetTerm added in v0.3.0

func (m *LogEntry) GetTerm() uint64

func (*LogEntry) GoString added in v0.3.0

func (this *LogEntry) GoString() string

func (*LogEntry) Marshal added in v0.3.0

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

func (*LogEntry) MarshalTo added in v0.3.0

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

func (*LogEntry) ProtoMessage added in v0.3.0

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset added in v0.3.0

func (m *LogEntry) Reset()

func (*LogEntry) Size added in v0.3.0

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

func (*LogEntry) String added in v0.3.0

func (this *LogEntry) String() string

func (*LogEntry) Unmarshal added in v0.3.0

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

func (*LogEntry) VerboseEqual added in v0.3.0

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

type RequestVoteRequest added in v0.3.0

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 added in v0.3.0

func NewPopulatedRequestVoteRequest(r randyRequestVoteRequest, easy bool) *RequestVoteRequest

func (*RequestVoteRequest) Equal added in v0.3.0

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

func (*RequestVoteRequest) GetCandidateName added in v0.3.0

func (m *RequestVoteRequest) GetCandidateName() string

func (*RequestVoteRequest) GetLastLogIndex added in v0.3.0

func (m *RequestVoteRequest) GetLastLogIndex() uint64

func (*RequestVoteRequest) GetLastLogTerm added in v0.3.0

func (m *RequestVoteRequest) GetLastLogTerm() uint64

func (*RequestVoteRequest) GetTerm added in v0.3.0

func (m *RequestVoteRequest) GetTerm() uint64

func (*RequestVoteRequest) GoString added in v0.3.0

func (this *RequestVoteRequest) GoString() string

func (*RequestVoteRequest) Marshal added in v0.3.0

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

func (*RequestVoteRequest) MarshalTo added in v0.3.0

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

func (*RequestVoteRequest) ProtoMessage added in v0.3.0

func (*RequestVoteRequest) ProtoMessage()

func (*RequestVoteRequest) Reset added in v0.3.0

func (m *RequestVoteRequest) Reset()

func (*RequestVoteRequest) Size added in v0.3.0

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

func (*RequestVoteRequest) String added in v0.3.0

func (this *RequestVoteRequest) String() string

func (*RequestVoteRequest) Unmarshal added in v0.3.0

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

func (*RequestVoteRequest) VerboseEqual added in v0.3.0

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

type RequestVoteResponse added in v0.3.0

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 added in v0.3.0

func NewPopulatedRequestVoteResponse(r randyRequestVoteResponses, easy bool) *RequestVoteResponse

func (*RequestVoteResponse) Equal added in v0.3.0

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

func (*RequestVoteResponse) GetTerm added in v0.3.0

func (m *RequestVoteResponse) GetTerm() uint64

func (*RequestVoteResponse) GetVoteGranted added in v0.3.0

func (m *RequestVoteResponse) GetVoteGranted() bool

func (*RequestVoteResponse) GoString added in v0.3.0

func (this *RequestVoteResponse) GoString() string

func (*RequestVoteResponse) Marshal added in v0.3.0

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

func (*RequestVoteResponse) MarshalTo added in v0.3.0

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

func (*RequestVoteResponse) ProtoMessage added in v0.3.0

func (*RequestVoteResponse) ProtoMessage()

func (*RequestVoteResponse) Reset added in v0.3.0

func (m *RequestVoteResponse) Reset()

func (*RequestVoteResponse) Size added in v0.3.0

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

func (*RequestVoteResponse) String added in v0.3.0

func (this *RequestVoteResponse) String() string

func (*RequestVoteResponse) Unmarshal added in v0.3.0

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

func (*RequestVoteResponse) VerboseEqual added in v0.3.0

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

type SnapshotRecoveryRequest added in v0.3.0

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 added in v0.3.0

func NewPopulatedSnapshotRecoveryRequest(r randySnapshotRecoveryRequest, easy bool) *SnapshotRecoveryRequest

func (*SnapshotRecoveryRequest) Equal added in v0.3.0

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

func (*SnapshotRecoveryRequest) GetLastIndex added in v0.3.0

func (m *SnapshotRecoveryRequest) GetLastIndex() uint64

func (*SnapshotRecoveryRequest) GetLastTerm added in v0.3.0

func (m *SnapshotRecoveryRequest) GetLastTerm() uint64

func (*SnapshotRecoveryRequest) GetLeaderName added in v0.3.0

func (m *SnapshotRecoveryRequest) GetLeaderName() string

func (*SnapshotRecoveryRequest) GetPeers added in v0.3.0

func (*SnapshotRecoveryRequest) GetState added in v0.3.0

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

func (*SnapshotRecoveryRequest) GoString added in v0.3.0

func (this *SnapshotRecoveryRequest) GoString() string

func (*SnapshotRecoveryRequest) Marshal added in v0.3.0

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

func (*SnapshotRecoveryRequest) MarshalTo added in v0.3.0

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

func (*SnapshotRecoveryRequest) ProtoMessage added in v0.3.0

func (*SnapshotRecoveryRequest) ProtoMessage()

func (*SnapshotRecoveryRequest) Reset added in v0.3.0

func (m *SnapshotRecoveryRequest) Reset()

func (*SnapshotRecoveryRequest) Size added in v0.3.0

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

func (*SnapshotRecoveryRequest) String added in v0.3.0

func (this *SnapshotRecoveryRequest) String() string

func (*SnapshotRecoveryRequest) Unmarshal added in v0.3.0

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

func (*SnapshotRecoveryRequest) VerboseEqual added in v0.3.0

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

type SnapshotRecoveryRequest_Peer added in v0.3.0

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 added in v0.3.0

func NewPopulatedSnapshotRecoveryRequest_Peer(r randySnapshotRecoveryRequest, easy bool) *SnapshotRecoveryRequest_Peer

func (*SnapshotRecoveryRequest_Peer) Equal added in v0.3.0

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

func (*SnapshotRecoveryRequest_Peer) GetConnectionString added in v0.3.0

func (m *SnapshotRecoveryRequest_Peer) GetConnectionString() string

func (*SnapshotRecoveryRequest_Peer) GetName added in v0.3.0

func (m *SnapshotRecoveryRequest_Peer) GetName() string

func (*SnapshotRecoveryRequest_Peer) GoString added in v0.3.0

func (this *SnapshotRecoveryRequest_Peer) GoString() string

func (*SnapshotRecoveryRequest_Peer) Marshal added in v0.3.0

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

func (*SnapshotRecoveryRequest_Peer) MarshalTo added in v0.3.0

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

func (*SnapshotRecoveryRequest_Peer) ProtoMessage added in v0.3.0

func (*SnapshotRecoveryRequest_Peer) ProtoMessage()

func (*SnapshotRecoveryRequest_Peer) Reset added in v0.3.0

func (m *SnapshotRecoveryRequest_Peer) Reset()

func (*SnapshotRecoveryRequest_Peer) Size added in v0.3.0

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

func (*SnapshotRecoveryRequest_Peer) String added in v0.3.0

func (this *SnapshotRecoveryRequest_Peer) String() string

func (*SnapshotRecoveryRequest_Peer) Unmarshal added in v0.3.0

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

func (*SnapshotRecoveryRequest_Peer) VerboseEqual added in v0.3.0

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

type SnapshotRecoveryResponse added in v0.3.0

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 added in v0.3.0

func NewPopulatedSnapshotRecoveryResponse(r randySnapshotRecoveryResponse, easy bool) *SnapshotRecoveryResponse

func (*SnapshotRecoveryResponse) Equal added in v0.3.0

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

func (*SnapshotRecoveryResponse) GetCommitIndex added in v0.3.0

func (m *SnapshotRecoveryResponse) GetCommitIndex() uint64

func (*SnapshotRecoveryResponse) GetSuccess added in v0.3.0

func (m *SnapshotRecoveryResponse) GetSuccess() bool

func (*SnapshotRecoveryResponse) GetTerm added in v0.3.0

func (m *SnapshotRecoveryResponse) GetTerm() uint64

func (*SnapshotRecoveryResponse) GoString added in v0.3.0

func (this *SnapshotRecoveryResponse) GoString() string

func (*SnapshotRecoveryResponse) Marshal added in v0.3.0

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

func (*SnapshotRecoveryResponse) MarshalTo added in v0.3.0

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

func (*SnapshotRecoveryResponse) ProtoMessage added in v0.3.0

func (*SnapshotRecoveryResponse) ProtoMessage()

func (*SnapshotRecoveryResponse) Reset added in v0.3.0

func (m *SnapshotRecoveryResponse) Reset()

func (*SnapshotRecoveryResponse) Size added in v0.3.0

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

func (*SnapshotRecoveryResponse) String added in v0.3.0

func (this *SnapshotRecoveryResponse) String() string

func (*SnapshotRecoveryResponse) Unmarshal added in v0.3.0

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

func (*SnapshotRecoveryResponse) VerboseEqual added in v0.3.0

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

type SnapshotRequest added in v0.3.0

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 added in v0.3.0

func NewPopulatedSnapshotRequest(r randySnapshotRequest, easy bool) *SnapshotRequest

func (*SnapshotRequest) Equal added in v0.3.0

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

func (*SnapshotRequest) GetLastIndex added in v0.3.0

func (m *SnapshotRequest) GetLastIndex() uint64

func (*SnapshotRequest) GetLastTerm added in v0.3.0

func (m *SnapshotRequest) GetLastTerm() uint64

func (*SnapshotRequest) GetLeaderName added in v0.3.0

func (m *SnapshotRequest) GetLeaderName() string

func (*SnapshotRequest) GoString added in v0.3.0

func (this *SnapshotRequest) GoString() string

func (*SnapshotRequest) Marshal added in v0.3.0

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

func (*SnapshotRequest) MarshalTo added in v0.3.0

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

func (*SnapshotRequest) ProtoMessage added in v0.3.0

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) Reset added in v0.3.0

func (m *SnapshotRequest) Reset()

func (*SnapshotRequest) Size added in v0.3.0

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

func (*SnapshotRequest) String added in v0.3.0

func (this *SnapshotRequest) String() string

func (*SnapshotRequest) Unmarshal added in v0.3.0

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

func (*SnapshotRequest) VerboseEqual added in v0.3.0

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

type SnapshotResponse added in v0.3.0

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

func NewPopulatedSnapshotResponse added in v0.3.0

func NewPopulatedSnapshotResponse(r randySnapshotResponse, easy bool) *SnapshotResponse

func (*SnapshotResponse) Equal added in v0.3.0

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

func (*SnapshotResponse) GetSuccess added in v0.3.0

func (m *SnapshotResponse) GetSuccess() bool

func (*SnapshotResponse) GoString added in v0.3.0

func (this *SnapshotResponse) GoString() string

func (*SnapshotResponse) Marshal added in v0.3.0

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

func (*SnapshotResponse) MarshalTo added in v0.3.0

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

func (*SnapshotResponse) ProtoMessage added in v0.3.0

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) Reset added in v0.3.0

func (m *SnapshotResponse) Reset()

func (*SnapshotResponse) Size added in v0.3.0

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

func (*SnapshotResponse) String added in v0.3.0

func (this *SnapshotResponse) String() string

func (*SnapshotResponse) Unmarshal added in v0.3.0

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

func (*SnapshotResponse) VerboseEqual added in v0.3.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL