protobuf

package
v0.0.0-...-7bb2cd3 Latest Latest
Warning

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

 Go to latest Published: May 20, 2016 License: Apache-2.0 Imports: 10 Imported by: 0

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

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 NewPopulatedAccept(r randyMessage, easy bool) *Accept

func (*Accept) Descriptor 

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

func (*Accept) Equal 

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

func (*Accept) GoString 

func (this *Accept) GoString() string

func (*Accept) Marshal 

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

func (*Accept) MarshalTo 

func (m *Accept) MarshalTo(data []byte) (int, error)

func (*Accept) ProtoMessage 

func (*Accept) ProtoMessage()

func (*Accept) Reset 

func (m *Accept) Reset()

func (*Accept) Size 

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

func (*Accept) String 

func (this *Accept) String() string

func (*Accept) Unmarshal 

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

func (*Accept) VerboseEqual 

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

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

func (m *AcceptReply) MarshalTo(data []byte) (int, 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 NewPopulatedBallot(r randyMessage, easy bool) *Ballot

func (*Ballot) Descriptor 

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

func (*Ballot) Equal 

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

func (*Ballot) GoString 

func (this *Ballot) GoString() string

func (*Ballot) Marshal 

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

func (*Ballot) MarshalTo 

func (m *Ballot) MarshalTo(data []byte) (int, error)

func (*Ballot) ProtoMessage 

func (*Ballot) ProtoMessage()

func (*Ballot) Reset 

func (m *Ballot) Reset()

func (*Ballot) Size 

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

func (*Ballot) String 

func (this *Ballot) String() string

func (*Ballot) Unmarshal 

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

func (*Ballot) VerboseEqual 

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

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 NewPopulatedCommit(r randyMessage, easy bool) *Commit

func (*Commit) Descriptor 

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

func (*Commit) Equal 

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

func (*Commit) GoString 

func (this *Commit) GoString() string

func (*Commit) Marshal 

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

func (*Commit) MarshalTo 

func (m *Commit) MarshalTo(data []byte) (int, error)

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) Size 

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

func (*Commit) String 

func (this *Commit) String() string

func (*Commit) Unmarshal 

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

func (*Commit) VerboseEqual 

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

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 NewPopulatedPreAccept(r randyMessage, easy bool) *PreAccept

func (*PreAccept) Descriptor 

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

func (*PreAccept) Equal 

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

func (*PreAccept) GoString 

func (this *PreAccept) GoString() string

func (*PreAccept) Marshal 

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

func (*PreAccept) MarshalTo 

func (m *PreAccept) MarshalTo(data []byte) (int, error)

func (*PreAccept) ProtoMessage 

func (*PreAccept) ProtoMessage()

func (*PreAccept) Reset 

func (m *PreAccept) Reset()

func (*PreAccept) Size 

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

func (*PreAccept) String 

func (this *PreAccept) String() string

func (*PreAccept) Unmarshal 

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

func (*PreAccept) VerboseEqual 

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

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

func (m *PreAcceptOK) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *PreAcceptReply) MarshalTo(data []byte) (int, 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 NewPopulatedPrepare(r randyMessage, easy bool) *Prepare

func (*Prepare) Descriptor 

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

func (*Prepare) Equal 

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

func (*Prepare) GoString 

func (this *Prepare) GoString() string

func (*Prepare) Marshal 

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

func (*Prepare) MarshalTo 

func (m *Prepare) MarshalTo(data []byte) (int, error)

func (*Prepare) ProtoMessage 

func (*Prepare) ProtoMessage()

func (*Prepare) Reset 

func (m *Prepare) Reset()

func (*Prepare) Size 

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

func (*Prepare) String 

func (this *Prepare) String() string

func (*Prepare) Unmarshal 

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

func (*Prepare) VerboseEqual 

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

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

func (m *PrepareReply) MarshalTo(data []byte) (int, 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

type State 

type State int32
const (
	State_NilStatus   State = 1
	State_Preparing   State = 2
	State_PreAccepted State = 3
	State_Accepted    State = 4
	State_Committed   State = 5
)

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor 

func (State) EnumDescriptor() ([]byte, []int)

func (State) String 

func (x State) String() string

func (*State) UnmarshalJSON 

func (x *State) UnmarshalJSON(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.