Documentation ¶
Overview ¶
Package protobuf is a generated protocol buffer package.
It is generated from these files:
message.proto
It has these top-level messages:
Ballot PreAccept PreAcceptOK PreAcceptReply Accept AcceptReply Prepare PrepareReply Commit
Index ¶
- Variables
- type Accept
- func (*Accept) Descriptor() ([]byte, []int)
- func (this *Accept) Equal(that interface{}) bool
- func (this *Accept) GoString() string
- func (m *Accept) Marshal() (data []byte, err error)
- func (m *Accept) MarshalTo(data []byte) (int, error)
- func (*Accept) ProtoMessage()
- func (m *Accept) Reset()
- func (m *Accept) Size() (n int)
- func (this *Accept) String() string
- func (m *Accept) Unmarshal(data []byte) error
- func (this *Accept) VerboseEqual(that interface{}) error
- type AcceptReply
- func (*AcceptReply) Descriptor() ([]byte, []int)
- func (this *AcceptReply) Equal(that interface{}) bool
- func (this *AcceptReply) GoString() string
- func (m *AcceptReply) Marshal() (data []byte, err error)
- func (m *AcceptReply) MarshalTo(data []byte) (int, error)
- func (*AcceptReply) ProtoMessage()
- func (m *AcceptReply) Reset()
- func (m *AcceptReply) Size() (n int)
- func (this *AcceptReply) String() string
- func (m *AcceptReply) Unmarshal(data []byte) error
- func (this *AcceptReply) VerboseEqual(that interface{}) error
- type Ballot
- func (*Ballot) Descriptor() ([]byte, []int)
- func (this *Ballot) Equal(that interface{}) bool
- func (this *Ballot) GoString() string
- func (m *Ballot) Marshal() (data []byte, err error)
- func (m *Ballot) MarshalTo(data []byte) (int, error)
- func (*Ballot) ProtoMessage()
- func (m *Ballot) Reset()
- func (m *Ballot) Size() (n int)
- func (this *Ballot) String() string
- func (m *Ballot) Unmarshal(data []byte) error
- func (this *Ballot) VerboseEqual(that interface{}) error
- type Commit
- func (*Commit) Descriptor() ([]byte, []int)
- func (this *Commit) Equal(that interface{}) bool
- func (this *Commit) GoString() string
- func (m *Commit) Marshal() (data []byte, err error)
- func (m *Commit) MarshalTo(data []byte) (int, error)
- func (*Commit) ProtoMessage()
- func (m *Commit) Reset()
- func (m *Commit) Size() (n int)
- func (this *Commit) String() string
- func (m *Commit) Unmarshal(data []byte) error
- func (this *Commit) VerboseEqual(that interface{}) error
- type PreAccept
- func (*PreAccept) Descriptor() ([]byte, []int)
- func (this *PreAccept) Equal(that interface{}) bool
- func (this *PreAccept) GoString() string
- func (m *PreAccept) Marshal() (data []byte, err error)
- func (m *PreAccept) MarshalTo(data []byte) (int, error)
- func (*PreAccept) ProtoMessage()
- func (m *PreAccept) Reset()
- func (m *PreAccept) Size() (n int)
- func (this *PreAccept) String() string
- func (m *PreAccept) Unmarshal(data []byte) error
- func (this *PreAccept) VerboseEqual(that interface{}) error
- type PreAcceptOK
- func (*PreAcceptOK) Descriptor() ([]byte, []int)
- func (this *PreAcceptOK) Equal(that interface{}) bool
- func (this *PreAcceptOK) GoString() string
- func (m *PreAcceptOK) Marshal() (data []byte, err error)
- func (m *PreAcceptOK) MarshalTo(data []byte) (int, error)
- func (*PreAcceptOK) ProtoMessage()
- func (m *PreAcceptOK) Reset()
- func (m *PreAcceptOK) Size() (n int)
- func (this *PreAcceptOK) String() string
- func (m *PreAcceptOK) Unmarshal(data []byte) error
- func (this *PreAcceptOK) VerboseEqual(that interface{}) error
- type PreAcceptReply
- func (*PreAcceptReply) Descriptor() ([]byte, []int)
- func (this *PreAcceptReply) Equal(that interface{}) bool
- func (this *PreAcceptReply) GoString() string
- func (m *PreAcceptReply) Marshal() (data []byte, err error)
- func (m *PreAcceptReply) MarshalTo(data []byte) (int, error)
- func (*PreAcceptReply) ProtoMessage()
- func (m *PreAcceptReply) Reset()
- func (m *PreAcceptReply) Size() (n int)
- func (this *PreAcceptReply) String() string
- func (m *PreAcceptReply) Unmarshal(data []byte) error
- func (this *PreAcceptReply) VerboseEqual(that interface{}) error
- type Prepare
- func (*Prepare) Descriptor() ([]byte, []int)
- func (this *Prepare) Equal(that interface{}) bool
- func (this *Prepare) GoString() string
- func (m *Prepare) Marshal() (data []byte, err error)
- func (m *Prepare) MarshalTo(data []byte) (int, error)
- func (*Prepare) ProtoMessage()
- func (m *Prepare) Reset()
- func (m *Prepare) Size() (n int)
- func (this *Prepare) String() string
- func (m *Prepare) Unmarshal(data []byte) error
- func (this *Prepare) VerboseEqual(that interface{}) error
- type PrepareReply
- func (*PrepareReply) Descriptor() ([]byte, []int)
- func (this *PrepareReply) Equal(that interface{}) bool
- func (this *PrepareReply) GoString() string
- func (m *PrepareReply) Marshal() (data []byte, err error)
- func (m *PrepareReply) MarshalTo(data []byte) (int, error)
- func (*PrepareReply) ProtoMessage()
- func (m *PrepareReply) Reset()
- func (m *PrepareReply) Size() (n int)
- func (this *PrepareReply) String() string
- func (m *PrepareReply) Unmarshal(data []byte) error
- func (this *PrepareReply) VerboseEqual(that interface{}) error
- type State
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") )
View Source
var State_name = map[int32]string{
1: "NilStatus",
2: "Preparing",
3: "PreAccepted",
4: "Accepted",
5: "Committed",
}
View Source
var State_value = map[string]int32{
"NilStatus": 1,
"Preparing": 2,
"PreAccepted": 3,
"Accepted": 4,
"Committed": 5,
}
Functions ¶
This section is empty.
Types ¶
type Accept ¶
type Accept struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstanceID *uint64 `protobuf:"varint,2,req,name=InstanceID,json=instanceID" json:"InstanceID,omitempty"` Cmds [][]byte `protobuf:"bytes,3,rep,name=Cmds,json=cmds" json:"Cmds,omitempty"` Deps []uint64 `protobuf:"varint,4,rep,name=Deps,json=deps" json:"Deps,omitempty"` Ballot *Ballot `protobuf:"bytes,5,req,name=Ballot,json=ballot" json:"Ballot,omitempty"` From *uint32 `protobuf:"varint,6,req,name=From,json=from" json:"From,omitempty"` }
func NewPopulatedAccept ¶
func (*Accept) Descriptor ¶
func (*Accept) ProtoMessage ¶
func (*Accept) ProtoMessage()
func (*Accept) VerboseEqual ¶
type AcceptReply ¶
type AcceptReply struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstanceID *uint64 `protobuf:"varint,2,req,name=InstanceID,json=instanceID" json:"InstanceID,omitempty"` Ballot *Ballot `protobuf:"bytes,3,req,name=Ballot,json=ballot" json:"Ballot,omitempty"` From *uint32 `protobuf:"varint,4,req,name=From,json=from" json:"From,omitempty"` }
func NewPopulatedAcceptReply ¶
func NewPopulatedAcceptReply(r randyMessage, easy bool) *AcceptReply
func (*AcceptReply) Descriptor ¶
func (*AcceptReply) Descriptor() ([]byte, []int)
func (*AcceptReply) Equal ¶
func (this *AcceptReply) Equal(that interface{}) bool
func (*AcceptReply) GoString ¶
func (this *AcceptReply) GoString() string
func (*AcceptReply) Marshal ¶
func (m *AcceptReply) Marshal() (data []byte, err error)
func (*AcceptReply) ProtoMessage ¶
func (*AcceptReply) ProtoMessage()
func (*AcceptReply) Reset ¶
func (m *AcceptReply) Reset()
func (*AcceptReply) Size ¶
func (m *AcceptReply) Size() (n int)
func (*AcceptReply) String ¶
func (this *AcceptReply) String() string
func (*AcceptReply) Unmarshal ¶
func (m *AcceptReply) Unmarshal(data []byte) error
func (*AcceptReply) VerboseEqual ¶
func (this *AcceptReply) VerboseEqual(that interface{}) error
type Ballot ¶
type Ballot struct { Epoch *uint32 `protobuf:"varint,1,req,name=Epoch,json=epoch" json:"Epoch,omitempty"` Number *uint64 `protobuf:"varint,2,req,name=Number,json=number" json:"Number,omitempty"` ReplicaID *uint32 `protobuf:"varint,3,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` }
Nested fields.
func NewPopulatedBallot ¶
func (*Ballot) Descriptor ¶
func (*Ballot) ProtoMessage ¶
func (*Ballot) ProtoMessage()
func (*Ballot) VerboseEqual ¶
type Commit ¶
type Commit struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstancdID *uint64 `protobuf:"varint,2,req,name=InstancdID,json=instancdID" json:"InstancdID,omitempty"` Cmds [][]byte `protobuf:"bytes,3,rep,name=Cmds,json=cmds" json:"Cmds,omitempty"` Deps []uint64 `protobuf:"varint,4,rep,name=Deps,json=deps" json:"Deps,omitempty"` From *uint32 `protobuf:"varint,5,req,name=From,json=from" json:"From,omitempty"` }
func NewPopulatedCommit ¶
func (*Commit) Descriptor ¶
func (*Commit) ProtoMessage ¶
func (*Commit) ProtoMessage()
func (*Commit) VerboseEqual ¶
type PreAccept ¶
type PreAccept struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstanceID *uint64 `protobuf:"varint,2,req,name=InstanceID,json=instanceID" json:"InstanceID,omitempty"` Cmds [][]byte `protobuf:"bytes,3,rep,name=Cmds,json=cmds" json:"Cmds,omitempty"` Deps []uint64 `protobuf:"varint,4,rep,name=Deps,json=deps" json:"Deps,omitempty"` Ballot *Ballot `protobuf:"bytes,5,req,name=Ballot,json=ballot" json:"Ballot,omitempty"` From *uint32 `protobuf:"varint,6,req,name=From,json=from" json:"From,omitempty"` }
EPaxos messages.
func NewPopulatedPreAccept ¶
func (*PreAccept) Descriptor ¶
func (*PreAccept) ProtoMessage ¶
func (*PreAccept) ProtoMessage()
func (*PreAccept) VerboseEqual ¶
type PreAcceptOK ¶
type PreAcceptOK struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstanceID *uint64 `protobuf:"varint,2,req,name=InstanceID,json=instanceID" json:"InstanceID,omitempty"` From *uint32 `protobuf:"varint,3,req,name=From,json=from" json:"From,omitempty"` }
func NewPopulatedPreAcceptOK ¶
func NewPopulatedPreAcceptOK(r randyMessage, easy bool) *PreAcceptOK
func (*PreAcceptOK) Descriptor ¶
func (*PreAcceptOK) Descriptor() ([]byte, []int)
func (*PreAcceptOK) Equal ¶
func (this *PreAcceptOK) Equal(that interface{}) bool
func (*PreAcceptOK) GoString ¶
func (this *PreAcceptOK) GoString() string
func (*PreAcceptOK) Marshal ¶
func (m *PreAcceptOK) Marshal() (data []byte, err error)
func (*PreAcceptOK) ProtoMessage ¶
func (*PreAcceptOK) ProtoMessage()
func (*PreAcceptOK) Reset ¶
func (m *PreAcceptOK) Reset()
func (*PreAcceptOK) Size ¶
func (m *PreAcceptOK) Size() (n int)
func (*PreAcceptOK) String ¶
func (this *PreAcceptOK) String() string
func (*PreAcceptOK) Unmarshal ¶
func (m *PreAcceptOK) Unmarshal(data []byte) error
func (*PreAcceptOK) VerboseEqual ¶
func (this *PreAcceptOK) VerboseEqual(that interface{}) error
type PreAcceptReply ¶
type PreAcceptReply struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstanceID *uint64 `protobuf:"varint,2,req,name=InstanceID,json=instanceID" json:"InstanceID,omitempty"` Deps []uint64 `protobuf:"varint,3,rep,name=Deps,json=deps" json:"Deps,omitempty"` Ballot *Ballot `protobuf:"bytes,4,req,name=Ballot,json=ballot" json:"Ballot,omitempty"` From *uint32 `protobuf:"varint,5,req,name=From,json=from" json:"From,omitempty"` }
func NewPopulatedPreAcceptReply ¶
func NewPopulatedPreAcceptReply(r randyMessage, easy bool) *PreAcceptReply
func (*PreAcceptReply) Descriptor ¶
func (*PreAcceptReply) Descriptor() ([]byte, []int)
func (*PreAcceptReply) Equal ¶
func (this *PreAcceptReply) Equal(that interface{}) bool
func (*PreAcceptReply) GoString ¶
func (this *PreAcceptReply) GoString() string
func (*PreAcceptReply) Marshal ¶
func (m *PreAcceptReply) Marshal() (data []byte, err error)
func (*PreAcceptReply) ProtoMessage ¶
func (*PreAcceptReply) ProtoMessage()
func (*PreAcceptReply) Reset ¶
func (m *PreAcceptReply) Reset()
func (*PreAcceptReply) Size ¶
func (m *PreAcceptReply) Size() (n int)
func (*PreAcceptReply) String ¶
func (this *PreAcceptReply) String() string
func (*PreAcceptReply) Unmarshal ¶
func (m *PreAcceptReply) Unmarshal(data []byte) error
func (*PreAcceptReply) VerboseEqual ¶
func (this *PreAcceptReply) VerboseEqual(that interface{}) error
type Prepare ¶
type Prepare struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstanceID *uint64 `protobuf:"varint,2,req,name=InstanceID,json=instanceID" json:"InstanceID,omitempty"` Ballot *Ballot `protobuf:"bytes,3,req,name=Ballot,json=ballot" json:"Ballot,omitempty"` From *uint32 `protobuf:"varint,4,req,name=From,json=from" json:"From,omitempty"` }
func NewPopulatedPrepare ¶
func (*Prepare) Descriptor ¶
func (*Prepare) ProtoMessage ¶
func (*Prepare) ProtoMessage()
func (*Prepare) VerboseEqual ¶
type PrepareReply ¶
type PrepareReply struct { ReplicaID *uint32 `protobuf:"varint,1,req,name=ReplicaID,json=replicaID" json:"ReplicaID,omitempty"` InstanceID *uint64 `protobuf:"varint,2,req,name=InstanceID,json=instanceID" json:"InstanceID,omitempty"` State *State `protobuf:"varint,3,req,name=State,json=state,enum=protobuf.State" json:"State,omitempty"` Cmds [][]byte `protobuf:"bytes,4,rep,name=Cmds,json=cmds" json:"Cmds,omitempty"` Deps []uint64 `protobuf:"varint,5,rep,name=Deps,json=deps" json:"Deps,omitempty"` Ballot *Ballot `protobuf:"bytes,6,req,name=Ballot,json=ballot" json:"Ballot,omitempty"` OriginalBallot *Ballot `protobuf:"bytes,7,req,name=OriginalBallot,json=originalBallot" json:"OriginalBallot,omitempty"` IsFromLeader *bool `protobuf:"varint,8,req,name=IsFromLeader,json=isFromLeader" json:"IsFromLeader,omitempty"` From *uint32 `protobuf:"varint,9,req,name=From,json=from" json:"From,omitempty"` }
func NewPopulatedPrepareReply ¶
func NewPopulatedPrepareReply(r randyMessage, easy bool) *PrepareReply
func (*PrepareReply) Descriptor ¶
func (*PrepareReply) Descriptor() ([]byte, []int)
func (*PrepareReply) Equal ¶
func (this *PrepareReply) Equal(that interface{}) bool
func (*PrepareReply) GoString ¶
func (this *PrepareReply) GoString() string
func (*PrepareReply) Marshal ¶
func (m *PrepareReply) Marshal() (data []byte, err error)
func (*PrepareReply) ProtoMessage ¶
func (*PrepareReply) ProtoMessage()
func (*PrepareReply) Reset ¶
func (m *PrepareReply) Reset()
func (*PrepareReply) Size ¶
func (m *PrepareReply) Size() (n int)
func (*PrepareReply) String ¶
func (this *PrepareReply) String() string
func (*PrepareReply) Unmarshal ¶
func (m *PrepareReply) Unmarshal(data []byte) error
func (*PrepareReply) VerboseEqual ¶
func (this *PrepareReply) VerboseEqual(that interface{}) error
Click to show internal directories.
Click to hide internal directories.