protocol

package
v0.0.0-...-61b1583 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2020 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLog        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLog          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLog = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthProtocol        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtocol          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProtocol = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterClientServiceServer 

func RegisterClientServiceServer(s *grpc.Server, srv ClientServiceServer)

func RegisterReplicaServiceServer 

func RegisterReplicaServiceServer(s *grpc.Server, srv ReplicaServiceServer)

Types

type Checkpoint 

type Checkpoint struct {
	SlotNum  LogSlotID
	Data     []byte
	Checksum []byte
}

Checkpoint is a checkpoint of the state machine

func (*Checkpoint) Reader 

func (s *Checkpoint) Reader() io.ReadCloser

func (*Checkpoint) Writer 

func (s *Checkpoint) Writer() io.WriteCloser

type ClientMessage 

type ClientMessage struct {
	// Types that are valid to be assigned to Message:
	//	*ClientMessage_Command
	//	*ClientMessage_CommandReply
	//	*ClientMessage_CommandClose
	//	*ClientMessage_Query
	//	*ClientMessage_QueryReply
	//	*ClientMessage_QueryClose
	Message isClientMessage_Message `protobuf_oneof:"message"`
}

func NewPopulatedClientMessage 

func NewPopulatedClientMessage(r randyProtocol, easy bool) *ClientMessage

func (*ClientMessage) Descriptor 

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

func (*ClientMessage) Equal 

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

func (*ClientMessage) GetCommand 

func (m *ClientMessage) GetCommand() *CommandRequest

func (*ClientMessage) GetCommandClose 

func (m *ClientMessage) GetCommandClose() *CommandClose

func (*ClientMessage) GetCommandReply 

func (m *ClientMessage) GetCommandReply() *CommandReply

func (*ClientMessage) GetMessage 

func (m *ClientMessage) GetMessage() isClientMessage_Message

func (*ClientMessage) GetQuery 

func (m *ClientMessage) GetQuery() *QueryRequest

func (*ClientMessage) GetQueryClose 

func (m *ClientMessage) GetQueryClose() *QueryClose

func (*ClientMessage) GetQueryReply 

func (m *ClientMessage) GetQueryReply() *QueryReply

func (*ClientMessage) Marshal 

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

func (*ClientMessage) MarshalTo 

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

func (*ClientMessage) MarshalToSizedBuffer 

func (m *ClientMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientMessage) ProtoMessage 

func (*ClientMessage) ProtoMessage()

func (*ClientMessage) Reset 

func (m *ClientMessage) Reset()

func (*ClientMessage) Size 

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

func (*ClientMessage) String 

func (m *ClientMessage) String() string

func (*ClientMessage) Unmarshal 

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

func (*ClientMessage) XXX_DiscardUnknown 

func (m *ClientMessage) XXX_DiscardUnknown()

func (*ClientMessage) XXX_Marshal 

func (m *ClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientMessage) XXX_Merge 

func (m *ClientMessage) XXX_Merge(src proto.Message)

func (*ClientMessage) XXX_OneofWrappers 

func (*ClientMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientMessage) XXX_Size 

func (m *ClientMessage) XXX_Size() int

func (*ClientMessage) XXX_Unmarshal 

func (m *ClientMessage) XXX_Unmarshal(b []byte) error

type ClientMessage_Command 

type ClientMessage_Command struct {
	Command *CommandRequest `protobuf:"bytes,1,opt,name=command,proto3,oneof" json:"command,omitempty"`
}

func NewPopulatedClientMessage_Command 

func NewPopulatedClientMessage_Command(r randyProtocol, easy bool) *ClientMessage_Command

func (*ClientMessage_Command) Equal 

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

func (*ClientMessage_Command) MarshalTo 

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

func (*ClientMessage_Command) MarshalToSizedBuffer 

func (m *ClientMessage_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientMessage_Command) Size 

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

type ClientMessage_CommandClose 

type ClientMessage_CommandClose struct {
	CommandClose *CommandClose `protobuf:"bytes,3,opt,name=command_close,json=commandClose,proto3,oneof" json:"command_close,omitempty"`
}

func NewPopulatedClientMessage_CommandClose 

func NewPopulatedClientMessage_CommandClose(r randyProtocol, easy bool) *ClientMessage_CommandClose

func (*ClientMessage_CommandClose) Equal 

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

func (*ClientMessage_CommandClose) MarshalTo 

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

func (*ClientMessage_CommandClose) MarshalToSizedBuffer 

func (m *ClientMessage_CommandClose) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientMessage_CommandClose) Size 

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

type ClientMessage_CommandReply 

type ClientMessage_CommandReply struct {
	CommandReply *CommandReply `protobuf:"bytes,2,opt,name=command_reply,json=commandReply,proto3,oneof" json:"command_reply,omitempty"`
}

func NewPopulatedClientMessage_CommandReply 

func NewPopulatedClientMessage_CommandReply(r randyProtocol, easy bool) *ClientMessage_CommandReply

func (*ClientMessage_CommandReply) Equal 

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

func (*ClientMessage_CommandReply) MarshalTo 

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

func (*ClientMessage_CommandReply) MarshalToSizedBuffer 

func (m *ClientMessage_CommandReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientMessage_CommandReply) Size 

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

type ClientMessage_Query 

type ClientMessage_Query struct {
	Query *QueryRequest `protobuf:"bytes,4,opt,name=query,proto3,oneof" json:"query,omitempty"`
}

func NewPopulatedClientMessage_Query 

func NewPopulatedClientMessage_Query(r randyProtocol, easy bool) *ClientMessage_Query

func (*ClientMessage_Query) Equal 

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

func (*ClientMessage_Query) MarshalTo 

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

func (*ClientMessage_Query) MarshalToSizedBuffer 

func (m *ClientMessage_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientMessage_Query) Size 

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

type ClientMessage_QueryClose 

type ClientMessage_QueryClose struct {
	QueryClose *QueryClose `protobuf:"bytes,6,opt,name=query_close,json=queryClose,proto3,oneof" json:"query_close,omitempty"`
}

func NewPopulatedClientMessage_QueryClose 

func NewPopulatedClientMessage_QueryClose(r randyProtocol, easy bool) *ClientMessage_QueryClose

func (*ClientMessage_QueryClose) Equal 

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

func (*ClientMessage_QueryClose) MarshalTo 

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

func (*ClientMessage_QueryClose) MarshalToSizedBuffer 

func (m *ClientMessage_QueryClose) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientMessage_QueryClose) Size 

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

type ClientMessage_QueryReply 

type ClientMessage_QueryReply struct {
	QueryReply *QueryReply `protobuf:"bytes,5,opt,name=query_reply,json=queryReply,proto3,oneof" json:"query_reply,omitempty"`
}

func NewPopulatedClientMessage_QueryReply 

func NewPopulatedClientMessage_QueryReply(r randyProtocol, easy bool) *ClientMessage_QueryReply

func (*ClientMessage_QueryReply) Equal 

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

func (*ClientMessage_QueryReply) MarshalTo 

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

func (*ClientMessage_QueryReply) MarshalToSizedBuffer 

func (m *ClientMessage_QueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientMessage_QueryReply) Size 

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

type ClientServiceClient 

type ClientServiceClient interface {
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (ClientService_ClientStreamClient, error)
}

ClientServiceClient is the client API for ClientService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClientServiceClient 

func NewClientServiceClient(cc *grpc.ClientConn) ClientServiceClient

type ClientServiceServer 

type ClientServiceServer interface {
	ClientStream(ClientService_ClientStreamServer) error
}

ClientServiceServer is the server API for ClientService service.

type ClientService_ClientStreamClient 

type ClientService_ClientStreamClient interface {
	Send(*ClientMessage) error
	Recv() (*ClientMessage, error)
	grpc.ClientStream
}

type ClientService_ClientStreamServer 

type ClientService_ClientStreamServer interface {
	Send(*ClientMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type Cluster 

type Cluster interface {
	// Member returns the local member ID
	Member() MemberID

	// Members returns a list of all members in the NOPaxos cluster
	Members() []MemberID

	// QuorumSize returns the cluster quorum size
	QuorumSize() int

	// GetStream gets a NOPaxosService_StreamClient connection for the given member
	GetStream(memberID MemberID) (ReplicaService_ReplicaStreamClient, error)
}

Cluster provides cluster information for the NOPaxos protocol

func NewCluster 

func NewCluster(config node.Cluster) Cluster

NewCluster returns a new Cluster with the given configuration

type CommandClose 

type CommandClose struct {
	MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Sender     MemberID  `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId   `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
}

func NewPopulatedCommandClose 

func NewPopulatedCommandClose(r randyProtocol, easy bool) *CommandClose

func (*CommandClose) Descriptor 

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

func (*CommandClose) Equal 

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

func (*CommandClose) GetMessageNum 

func (m *CommandClose) GetMessageNum() MessageID

func (*CommandClose) GetSender 

func (m *CommandClose) GetSender() MemberID

func (*CommandClose) GetViewID 

func (m *CommandClose) GetViewID() *ViewId

func (*CommandClose) Marshal 

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

func (*CommandClose) MarshalTo 

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

func (*CommandClose) MarshalToSizedBuffer 

func (m *CommandClose) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandClose) ProtoMessage 

func (*CommandClose) ProtoMessage()

func (*CommandClose) Reset 

func (m *CommandClose) Reset()

func (*CommandClose) Size 

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

func (*CommandClose) String 

func (m *CommandClose) String() string

func (*CommandClose) Unmarshal 

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

func (*CommandClose) XXX_DiscardUnknown 

func (m *CommandClose) XXX_DiscardUnknown()

func (*CommandClose) XXX_Marshal 

func (m *CommandClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandClose) XXX_Merge 

func (m *CommandClose) XXX_Merge(src proto.Message)

func (*CommandClose) XXX_Size 

func (m *CommandClose) XXX_Size() int

func (*CommandClose) XXX_Unmarshal 

func (m *CommandClose) XXX_Unmarshal(b []byte) error

type CommandReply 

type CommandReply struct {
	MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Sender     MemberID  `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId   `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	SlotNum    LogSlotID `protobuf:"varint,4,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"`
	Value      []byte    `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
}

func NewPopulatedCommandReply 

func NewPopulatedCommandReply(r randyProtocol, easy bool) *CommandReply

func (*CommandReply) Descriptor 

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

func (*CommandReply) Equal 

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

func (*CommandReply) GetMessageNum 

func (m *CommandReply) GetMessageNum() MessageID

func (*CommandReply) GetSender 

func (m *CommandReply) GetSender() MemberID

func (*CommandReply) GetSlotNum 

func (m *CommandReply) GetSlotNum() LogSlotID

func (*CommandReply) GetValue 

func (m *CommandReply) GetValue() []byte

func (*CommandReply) GetViewID 

func (m *CommandReply) GetViewID() *ViewId

func (*CommandReply) Marshal 

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

func (*CommandReply) MarshalTo 

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

func (*CommandReply) MarshalToSizedBuffer 

func (m *CommandReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandReply) ProtoMessage 

func (*CommandReply) ProtoMessage()

func (*CommandReply) Reset 

func (m *CommandReply) Reset()

func (*CommandReply) Size 

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

func (*CommandReply) String 

func (m *CommandReply) String() string

func (*CommandReply) Unmarshal 

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

func (*CommandReply) XXX_DiscardUnknown 

func (m *CommandReply) XXX_DiscardUnknown()

func (*CommandReply) XXX_Marshal 

func (m *CommandReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandReply) XXX_Merge 

func (m *CommandReply) XXX_Merge(src proto.Message)

func (*CommandReply) XXX_Size 

func (m *CommandReply) XXX_Size() int

func (*CommandReply) XXX_Unmarshal 

func (m *CommandReply) XXX_Unmarshal(b []byte) error

type CommandRequest 

type CommandRequest struct {
	SessionNum SessionID `protobuf:"varint,1,opt,name=session_num,json=sessionNum,proto3,casttype=SessionID" json:"session_num,omitempty"`
	MessageNum MessageID `protobuf:"varint,2,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Timestamp  time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	Value      []byte    `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func NewPopulatedCommandRequest 

func NewPopulatedCommandRequest(r randyProtocol, easy bool) *CommandRequest

func (*CommandRequest) Descriptor 

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

func (*CommandRequest) Equal 

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

func (*CommandRequest) GetMessageNum 

func (m *CommandRequest) GetMessageNum() MessageID

func (*CommandRequest) GetSessionNum 

func (m *CommandRequest) GetSessionNum() SessionID

func (*CommandRequest) GetTimestamp 

func (m *CommandRequest) GetTimestamp() time.Time

func (*CommandRequest) GetValue 

func (m *CommandRequest) GetValue() []byte

func (*CommandRequest) Marshal 

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

func (*CommandRequest) MarshalTo 

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

func (*CommandRequest) MarshalToSizedBuffer 

func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandRequest) ProtoMessage 

func (*CommandRequest) ProtoMessage()

func (*CommandRequest) Reset 

func (m *CommandRequest) Reset()

func (*CommandRequest) Size 

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

func (*CommandRequest) String 

func (m *CommandRequest) String() string

func (*CommandRequest) Unmarshal 

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

func (*CommandRequest) XXX_DiscardUnknown 

func (m *CommandRequest) XXX_DiscardUnknown()

func (*CommandRequest) XXX_Marshal 

func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandRequest) XXX_Merge 

func (m *CommandRequest) XXX_Merge(src proto.Message)

func (*CommandRequest) XXX_Size 

func (m *CommandRequest) XXX_Size() int

func (*CommandRequest) XXX_Unmarshal 

func (m *CommandRequest) XXX_Unmarshal(b []byte) error

type GapCommitReply 

type GapCommitReply struct {
	Sender  MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID  *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	SlotNum LogSlotID `protobuf:"varint,3,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"`
}

func NewPopulatedGapCommitReply 

func NewPopulatedGapCommitReply(r randyProtocol, easy bool) *GapCommitReply

func (*GapCommitReply) Descriptor 

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

func (*GapCommitReply) Equal 

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

func (*GapCommitReply) GetSender 

func (m *GapCommitReply) GetSender() MemberID

func (*GapCommitReply) GetSlotNum 

func (m *GapCommitReply) GetSlotNum() LogSlotID

func (*GapCommitReply) GetViewID 

func (m *GapCommitReply) GetViewID() *ViewId

func (*GapCommitReply) Marshal 

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

func (*GapCommitReply) MarshalTo 

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

func (*GapCommitReply) MarshalToSizedBuffer 

func (m *GapCommitReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GapCommitReply) ProtoMessage 

func (*GapCommitReply) ProtoMessage()

func (*GapCommitReply) Reset 

func (m *GapCommitReply) Reset()

func (*GapCommitReply) Size 

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

func (*GapCommitReply) String 

func (m *GapCommitReply) String() string

func (*GapCommitReply) Unmarshal 

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

func (*GapCommitReply) XXX_DiscardUnknown 

func (m *GapCommitReply) XXX_DiscardUnknown()

func (*GapCommitReply) XXX_Marshal 

func (m *GapCommitReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GapCommitReply) XXX_Merge 

func (m *GapCommitReply) XXX_Merge(src proto.Message)

func (*GapCommitReply) XXX_Size 

func (m *GapCommitReply) XXX_Size() int

func (*GapCommitReply) XXX_Unmarshal 

func (m *GapCommitReply) XXX_Unmarshal(b []byte) error

type GapCommitRequest 

type GapCommitRequest struct {
	Sender  MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID  *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	SlotNum LogSlotID `protobuf:"varint,3,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"`
}

func NewPopulatedGapCommitRequest 

func NewPopulatedGapCommitRequest(r randyProtocol, easy bool) *GapCommitRequest

func (*GapCommitRequest) Descriptor 

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

func (*GapCommitRequest) Equal 

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

func (*GapCommitRequest) GetSender 

func (m *GapCommitRequest) GetSender() MemberID

func (*GapCommitRequest) GetSlotNum 

func (m *GapCommitRequest) GetSlotNum() LogSlotID

func (*GapCommitRequest) GetViewID 

func (m *GapCommitRequest) GetViewID() *ViewId

func (*GapCommitRequest) Marshal 

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

func (*GapCommitRequest) MarshalTo 

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

func (*GapCommitRequest) MarshalToSizedBuffer 

func (m *GapCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GapCommitRequest) ProtoMessage 

func (*GapCommitRequest) ProtoMessage()

func (*GapCommitRequest) Reset 

func (m *GapCommitRequest) Reset()

func (*GapCommitRequest) Size 

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

func (*GapCommitRequest) String 

func (m *GapCommitRequest) String() string

func (*GapCommitRequest) Unmarshal 

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

func (*GapCommitRequest) XXX_DiscardUnknown 

func (m *GapCommitRequest) XXX_DiscardUnknown()

func (*GapCommitRequest) XXX_Marshal 

func (m *GapCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GapCommitRequest) XXX_Merge 

func (m *GapCommitRequest) XXX_Merge(src proto.Message)

func (*GapCommitRequest) XXX_Size 

func (m *GapCommitRequest) XXX_Size() int

func (*GapCommitRequest) XXX_Unmarshal 

func (m *GapCommitRequest) XXX_Unmarshal(b []byte) error

type Indexed 

type Indexed struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func NewPopulatedIndexed 

func NewPopulatedIndexed(r randyProtocol, easy bool) *Indexed

func (*Indexed) Descriptor 

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

func (*Indexed) Equal 

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

func (*Indexed) GetIndex 

func (m *Indexed) GetIndex() uint64

func (*Indexed) GetValue 

func (m *Indexed) GetValue() []byte

func (*Indexed) Marshal 

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

func (*Indexed) MarshalTo 

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

func (*Indexed) MarshalToSizedBuffer 

func (m *Indexed) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Indexed) ProtoMessage 

func (*Indexed) ProtoMessage()

func (*Indexed) Reset 

func (m *Indexed) Reset()

func (*Indexed) Size 

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

func (*Indexed) String 

func (m *Indexed) String() string

func (*Indexed) Unmarshal 

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

func (*Indexed) XXX_DiscardUnknown 

func (m *Indexed) XXX_DiscardUnknown()

func (*Indexed) XXX_Marshal 

func (m *Indexed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Indexed) XXX_Merge 

func (m *Indexed) XXX_Merge(src proto.Message)

func (*Indexed) XXX_Size 

func (m *Indexed) XXX_Size() int

func (*Indexed) XXX_Unmarshal 

func (m *Indexed) XXX_Unmarshal(b []byte) error

type LeaderID 

type LeaderID uint64

LeaderID is the leader identifier

type Log 

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

Log is a NOPaxos log

func (*Log) Delete 

func (l *Log) Delete(slotNum LogSlotID)

Delete deletes a log entry

func (*Log) Extend 

func (l *Log) Extend(slotNum LogSlotID)

Extend extends the tail of the log

func (*Log) FirstSlot 

func (l *Log) FirstSlot() LogSlotID

FirstSlot returns the first slot in the log

func (*Log) Get 

func (l *Log) Get(slotNum LogSlotID) *LogEntry

Get gets a log entry

func (*Log) LastSlot 

func (l *Log) LastSlot() LogSlotID

LastSlot returns the last slot in the log

func (*Log) Len 

func (l *Log) Len() int

Len returns the length of the log

func (*Log) Set 

func (l *Log) Set(entry *LogEntry)

Set sets a log entry

func (*Log) Truncate 

func (l *Log) Truncate(slotNum LogSlotID)

Truncate removes entries from the head of the log

type LogEntry 

type LogEntry struct {
	SlotNum    LogSlotID `protobuf:"varint,1,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"`
	Timestamp  time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Value      []byte    `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func NewPopulatedLogEntry 

func NewPopulatedLogEntry(r randyLog, easy bool) *LogEntry

func (*LogEntry) Descriptor 

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

func (*LogEntry) Equal 

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

func (*LogEntry) GetMessageNum 

func (m *LogEntry) GetMessageNum() MessageID

func (*LogEntry) GetSlotNum 

func (m *LogEntry) GetSlotNum() LogSlotID

func (*LogEntry) GetTimestamp 

func (m *LogEntry) GetTimestamp() time.Time

func (*LogEntry) GetValue 

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

func (*LogEntry) Marshal 

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

func (*LogEntry) MarshalTo 

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

func (*LogEntry) MarshalToSizedBuffer 

func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, 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 (m *LogEntry) String() string

func (*LogEntry) Unmarshal 

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

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEntry) XXX_Merge 

func (m *LogEntry) XXX_Merge(src proto.Message)

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

func (m *LogEntry) XXX_Unmarshal(b []byte) error

type LogSlotID 

type LogSlotID uint64

LogSlotID is a log slot number

type MemberID 

type MemberID string

MemberID is the ID of a NOPaxos cluster member

type MessageID 

type MessageID uint64

MessageID is a sequencer message ID

type NOPaxos 

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

NOPaxos is an interface for managing the state of the NOPaxos consensus protocol

func NewNOPaxos 

func NewNOPaxos(cluster Cluster, registry *node.Registry, config *config.ProtocolConfig) *NOPaxos

NewNOPaxos returns a new NOPaxos protocol state struct

func (*NOPaxos) ClientStream 

func (s *NOPaxos) ClientStream(stream ClientService_ClientStreamServer) error

func (*NOPaxos) ReplicaStream 

func (s *NOPaxos) ReplicaStream(stream ReplicaService_ReplicaStreamServer) error

func (*NOPaxos) Timeout 

func (s *NOPaxos) Timeout()

func (*NOPaxos) Watch 

func (s *NOPaxos) Watch(watcher func(Status))

type Ping 

type Ping struct {
	Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID *ViewId  `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
}

func NewPopulatedPing 

func NewPopulatedPing(r randyProtocol, easy bool) *Ping

func (*Ping) Descriptor 

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

func (*Ping) Equal 

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

func (*Ping) GetSender 

func (m *Ping) GetSender() MemberID

func (*Ping) GetViewID 

func (m *Ping) GetViewID() *ViewId

func (*Ping) Marshal 

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

func (*Ping) MarshalTo 

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

func (*Ping) MarshalToSizedBuffer 

func (m *Ping) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) Size 

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

func (*Ping) String 

func (m *Ping) String() string

func (*Ping) Unmarshal 

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

func (*Ping) XXX_DiscardUnknown 

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal 

func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping) XXX_Merge 

func (m *Ping) XXX_Merge(src proto.Message)

func (*Ping) XXX_Size 

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal 

func (m *Ping) XXX_Unmarshal(b []byte) error

type QueryClose 

type QueryClose struct {
	MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Sender     MemberID  `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId   `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
}

func NewPopulatedQueryClose 

func NewPopulatedQueryClose(r randyProtocol, easy bool) *QueryClose

func (*QueryClose) Descriptor 

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

func (*QueryClose) Equal 

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

func (*QueryClose) GetMessageNum 

func (m *QueryClose) GetMessageNum() MessageID

func (*QueryClose) GetSender 

func (m *QueryClose) GetSender() MemberID

func (*QueryClose) GetViewID 

func (m *QueryClose) GetViewID() *ViewId

func (*QueryClose) Marshal 

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

func (*QueryClose) MarshalTo 

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

func (*QueryClose) MarshalToSizedBuffer 

func (m *QueryClose) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryClose) ProtoMessage 

func (*QueryClose) ProtoMessage()

func (*QueryClose) Reset 

func (m *QueryClose) Reset()

func (*QueryClose) Size 

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

func (*QueryClose) String 

func (m *QueryClose) String() string

func (*QueryClose) Unmarshal 

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

func (*QueryClose) XXX_DiscardUnknown 

func (m *QueryClose) XXX_DiscardUnknown()

func (*QueryClose) XXX_Marshal 

func (m *QueryClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryClose) XXX_Merge 

func (m *QueryClose) XXX_Merge(src proto.Message)

func (*QueryClose) XXX_Size 

func (m *QueryClose) XXX_Size() int

func (*QueryClose) XXX_Unmarshal 

func (m *QueryClose) XXX_Unmarshal(b []byte) error

type QueryReply 

type QueryReply struct {
	MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Sender     MemberID  `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId   `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	Value      []byte    `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func NewPopulatedQueryReply 

func NewPopulatedQueryReply(r randyProtocol, easy bool) *QueryReply

func (*QueryReply) Descriptor 

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

func (*QueryReply) Equal 

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

func (*QueryReply) GetMessageNum 

func (m *QueryReply) GetMessageNum() MessageID

func (*QueryReply) GetSender 

func (m *QueryReply) GetSender() MemberID

func (*QueryReply) GetValue 

func (m *QueryReply) GetValue() []byte

func (*QueryReply) GetViewID 

func (m *QueryReply) GetViewID() *ViewId

func (*QueryReply) Marshal 

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

func (*QueryReply) MarshalTo 

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

func (*QueryReply) MarshalToSizedBuffer 

func (m *QueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryReply) ProtoMessage 

func (*QueryReply) ProtoMessage()

func (*QueryReply) Reset 

func (m *QueryReply) Reset()

func (*QueryReply) Size 

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

func (*QueryReply) String 

func (m *QueryReply) String() string

func (*QueryReply) Unmarshal 

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

func (*QueryReply) XXX_DiscardUnknown 

func (m *QueryReply) XXX_DiscardUnknown()

func (*QueryReply) XXX_Marshal 

func (m *QueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryReply) XXX_Merge 

func (m *QueryReply) XXX_Merge(src proto.Message)

func (*QueryReply) XXX_Size 

func (m *QueryReply) XXX_Size() int

func (*QueryReply) XXX_Unmarshal 

func (m *QueryReply) XXX_Unmarshal(b []byte) error

type QueryRequest 

type QueryRequest struct {
	SessionNum SessionID `protobuf:"varint,1,opt,name=session_num,json=sessionNum,proto3,casttype=SessionID" json:"session_num,omitempty"`
	MessageNum MessageID `protobuf:"varint,2,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Timestamp  time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	Value      []byte    `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func NewPopulatedQueryRequest 

func NewPopulatedQueryRequest(r randyProtocol, easy bool) *QueryRequest

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) Equal 

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

func (*QueryRequest) GetMessageNum 

func (m *QueryRequest) GetMessageNum() MessageID

func (*QueryRequest) GetSessionNum 

func (m *QueryRequest) GetSessionNum() SessionID

func (*QueryRequest) GetTimestamp 

func (m *QueryRequest) GetTimestamp() time.Time

func (*QueryRequest) GetValue 

func (m *QueryRequest) GetValue() []byte

func (*QueryRequest) Marshal 

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

func (*QueryRequest) MarshalTo 

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

func (*QueryRequest) MarshalToSizedBuffer 

func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

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

func (*QueryRequest) String 

func (m *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

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

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge 

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type Recover 

type Recover struct {
	Sender     MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	RecoveryID string   `protobuf:"bytes,2,opt,name=recovery_id,json=recoveryId,proto3" json:"recovery_id,omitempty"`
}

func NewPopulatedRecover 

func NewPopulatedRecover(r randyProtocol, easy bool) *Recover

func (*Recover) Descriptor 

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

func (*Recover) Equal 

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

func (*Recover) GetRecoveryID 

func (m *Recover) GetRecoveryID() string

func (*Recover) GetSender 

func (m *Recover) GetSender() MemberID

func (*Recover) Marshal 

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

func (*Recover) MarshalTo 

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

func (*Recover) MarshalToSizedBuffer 

func (m *Recover) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Recover) ProtoMessage 

func (*Recover) ProtoMessage()

func (*Recover) Reset 

func (m *Recover) Reset()

func (*Recover) Size 

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

func (*Recover) String 

func (m *Recover) String() string

func (*Recover) Unmarshal 

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

func (*Recover) XXX_DiscardUnknown 

func (m *Recover) XXX_DiscardUnknown()

func (*Recover) XXX_Marshal 

func (m *Recover) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Recover) XXX_Merge 

func (m *Recover) XXX_Merge(src proto.Message)

func (*Recover) XXX_Size 

func (m *Recover) XXX_Size() int

func (*Recover) XXX_Unmarshal 

func (m *Recover) XXX_Unmarshal(b []byte) error

type RecoverReply 

type RecoverReply struct {
	Sender            MemberID    `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	RecoveryID        string      `protobuf:"bytes,2,opt,name=recovery_id,json=recoveryId,proto3" json:"recovery_id,omitempty"`
	ViewID            *ViewId     `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum        MessageID   `protobuf:"varint,4,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	CheckpointSlotNum LogSlotID   `` /* 134-byte string literal not displayed */
	Checkpoint        []byte      `protobuf:"bytes,6,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Log               []*LogEntry `protobuf:"bytes,7,rep,name=log,proto3" json:"log,omitempty"`
}

func NewPopulatedRecoverReply 

func NewPopulatedRecoverReply(r randyProtocol, easy bool) *RecoverReply

func (*RecoverReply) Descriptor 

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

func (*RecoverReply) Equal 

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

func (*RecoverReply) GetCheckpoint 

func (m *RecoverReply) GetCheckpoint() []byte

func (*RecoverReply) GetCheckpointSlotNum 

func (m *RecoverReply) GetCheckpointSlotNum() LogSlotID

func (*RecoverReply) GetLog 

func (m *RecoverReply) GetLog() []*LogEntry

func (*RecoverReply) GetMessageNum 

func (m *RecoverReply) GetMessageNum() MessageID

func (*RecoverReply) GetRecoveryID 

func (m *RecoverReply) GetRecoveryID() string

func (*RecoverReply) GetSender 

func (m *RecoverReply) GetSender() MemberID

func (*RecoverReply) GetViewID 

func (m *RecoverReply) GetViewID() *ViewId

func (*RecoverReply) Marshal 

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

func (*RecoverReply) MarshalTo 

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

func (*RecoverReply) MarshalToSizedBuffer 

func (m *RecoverReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoverReply) ProtoMessage 

func (*RecoverReply) ProtoMessage()

func (*RecoverReply) Reset 

func (m *RecoverReply) Reset()

func (*RecoverReply) Size 

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

func (*RecoverReply) String 

func (m *RecoverReply) String() string

func (*RecoverReply) Unmarshal 

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

func (*RecoverReply) XXX_DiscardUnknown 

func (m *RecoverReply) XXX_DiscardUnknown()

func (*RecoverReply) XXX_Marshal 

func (m *RecoverReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecoverReply) XXX_Merge 

func (m *RecoverReply) XXX_Merge(src proto.Message)

func (*RecoverReply) XXX_Size 

func (m *RecoverReply) XXX_Size() int

func (*RecoverReply) XXX_Unmarshal 

func (m *RecoverReply) XXX_Unmarshal(b []byte) error

type ReplicaMessage 

type ReplicaMessage struct {
	// Types that are valid to be assigned to Message:
	//	*ReplicaMessage_Command
	//	*ReplicaMessage_CommandReply
	//	*ReplicaMessage_Query
	//	*ReplicaMessage_QueryReply
	//	*ReplicaMessage_SlotLookup
	//	*ReplicaMessage_GapCommit
	//	*ReplicaMessage_GapCommitReply
	//	*ReplicaMessage_ViewChangeRequest
	//	*ReplicaMessage_ViewChange
	//	*ReplicaMessage_ViewChangeRepair
	//	*ReplicaMessage_ViewChangeRepairReply
	//	*ReplicaMessage_StartView
	//	*ReplicaMessage_ViewRepair
	//	*ReplicaMessage_ViewRepairReply
	//	*ReplicaMessage_SyncPrepare
	//	*ReplicaMessage_SyncRepair
	//	*ReplicaMessage_SyncRepairReply
	//	*ReplicaMessage_SyncReply
	//	*ReplicaMessage_SyncCommit
	//	*ReplicaMessage_Recover
	//	*ReplicaMessage_RecoverReply
	//	*ReplicaMessage_Ping
	Message isReplicaMessage_Message `protobuf_oneof:"message"`
}

func NewPopulatedReplicaMessage 

func NewPopulatedReplicaMessage(r randyProtocol, easy bool) *ReplicaMessage

func (*ReplicaMessage) Descriptor 

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

func (*ReplicaMessage) Equal 

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

func (*ReplicaMessage) GetCommand 

func (m *ReplicaMessage) GetCommand() *CommandRequest

func (*ReplicaMessage) GetCommandReply 

func (m *ReplicaMessage) GetCommandReply() *CommandReply

func (*ReplicaMessage) GetGapCommit 

func (m *ReplicaMessage) GetGapCommit() *GapCommitRequest

func (*ReplicaMessage) GetGapCommitReply 

func (m *ReplicaMessage) GetGapCommitReply() *GapCommitReply

func (*ReplicaMessage) GetMessage 

func (m *ReplicaMessage) GetMessage() isReplicaMessage_Message

func (*ReplicaMessage) GetPing 

func (m *ReplicaMessage) GetPing() *Ping

func (*ReplicaMessage) GetQuery 

func (m *ReplicaMessage) GetQuery() *QueryRequest

func (*ReplicaMessage) GetQueryReply 

func (m *ReplicaMessage) GetQueryReply() *QueryReply

func (*ReplicaMessage) GetRecover 

func (m *ReplicaMessage) GetRecover() *Recover

func (*ReplicaMessage) GetRecoverReply 

func (m *ReplicaMessage) GetRecoverReply() *RecoverReply

func (*ReplicaMessage) GetSlotLookup 

func (m *ReplicaMessage) GetSlotLookup() *SlotLookup

func (*ReplicaMessage) GetStartView 

func (m *ReplicaMessage) GetStartView() *StartView

func (*ReplicaMessage) GetSyncCommit 

func (m *ReplicaMessage) GetSyncCommit() *SyncCommit

func (*ReplicaMessage) GetSyncPrepare 

func (m *ReplicaMessage) GetSyncPrepare() *SyncPrepare

func (*ReplicaMessage) GetSyncRepair 

func (m *ReplicaMessage) GetSyncRepair() *SyncRepair

func (*ReplicaMessage) GetSyncRepairReply 

func (m *ReplicaMessage) GetSyncRepairReply() *SyncRepairReply

func (*ReplicaMessage) GetSyncReply 

func (m *ReplicaMessage) GetSyncReply() *SyncReply

func (*ReplicaMessage) GetViewChange 

func (m *ReplicaMessage) GetViewChange() *ViewChange

func (*ReplicaMessage) GetViewChangeRepair 

func (m *ReplicaMessage) GetViewChangeRepair() *ViewChangeRepair

func (*ReplicaMessage) GetViewChangeRepairReply 

func (m *ReplicaMessage) GetViewChangeRepairReply() *ViewChangeRepairReply

func (*ReplicaMessage) GetViewChangeRequest 

func (m *ReplicaMessage) GetViewChangeRequest() *ViewChangeRequest

func (*ReplicaMessage) GetViewRepair 

func (m *ReplicaMessage) GetViewRepair() *ViewRepair

func (*ReplicaMessage) GetViewRepairReply 

func (m *ReplicaMessage) GetViewRepairReply() *ViewRepairReply

func (*ReplicaMessage) Marshal 

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

func (*ReplicaMessage) MarshalTo 

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

func (*ReplicaMessage) MarshalToSizedBuffer 

func (m *ReplicaMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage) ProtoMessage 

func (*ReplicaMessage) ProtoMessage()

func (*ReplicaMessage) Reset 

func (m *ReplicaMessage) Reset()

func (*ReplicaMessage) Size 

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

func (*ReplicaMessage) String 

func (m *ReplicaMessage) String() string

func (*ReplicaMessage) Unmarshal 

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

func (*ReplicaMessage) XXX_DiscardUnknown 

func (m *ReplicaMessage) XXX_DiscardUnknown()

func (*ReplicaMessage) XXX_Marshal 

func (m *ReplicaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaMessage) XXX_Merge 

func (m *ReplicaMessage) XXX_Merge(src proto.Message)

func (*ReplicaMessage) XXX_OneofWrappers 

func (*ReplicaMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReplicaMessage) XXX_Size 

func (m *ReplicaMessage) XXX_Size() int

func (*ReplicaMessage) XXX_Unmarshal 

func (m *ReplicaMessage) XXX_Unmarshal(b []byte) error

type ReplicaMessage_Command 

type ReplicaMessage_Command struct {
	Command *CommandRequest `protobuf:"bytes,1,opt,name=command,proto3,oneof" json:"command,omitempty"`
}

func NewPopulatedReplicaMessage_Command 

func NewPopulatedReplicaMessage_Command(r randyProtocol, easy bool) *ReplicaMessage_Command

func (*ReplicaMessage_Command) Equal 

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

func (*ReplicaMessage_Command) MarshalTo 

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

func (*ReplicaMessage_Command) MarshalToSizedBuffer 

func (m *ReplicaMessage_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_Command) Size 

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

type ReplicaMessage_CommandReply 

type ReplicaMessage_CommandReply struct {
	CommandReply *CommandReply `protobuf:"bytes,2,opt,name=command_reply,json=commandReply,proto3,oneof" json:"command_reply,omitempty"`
}

func NewPopulatedReplicaMessage_CommandReply 

func NewPopulatedReplicaMessage_CommandReply(r randyProtocol, easy bool) *ReplicaMessage_CommandReply

func (*ReplicaMessage_CommandReply) Equal 

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

func (*ReplicaMessage_CommandReply) MarshalTo 

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

func (*ReplicaMessage_CommandReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_CommandReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_CommandReply) Size 

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

type ReplicaMessage_GapCommit 

type ReplicaMessage_GapCommit struct {
	GapCommit *GapCommitRequest `protobuf:"bytes,6,opt,name=gap_commit,json=gapCommit,proto3,oneof" json:"gap_commit,omitempty"`
}

func NewPopulatedReplicaMessage_GapCommit 

func NewPopulatedReplicaMessage_GapCommit(r randyProtocol, easy bool) *ReplicaMessage_GapCommit

func (*ReplicaMessage_GapCommit) Equal 

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

func (*ReplicaMessage_GapCommit) MarshalTo 

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

func (*ReplicaMessage_GapCommit) MarshalToSizedBuffer 

func (m *ReplicaMessage_GapCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_GapCommit) Size 

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

type ReplicaMessage_GapCommitReply 

type ReplicaMessage_GapCommitReply struct {
	GapCommitReply *GapCommitReply `protobuf:"bytes,7,opt,name=gap_commit_reply,json=gapCommitReply,proto3,oneof" json:"gap_commit_reply,omitempty"`
}

func NewPopulatedReplicaMessage_GapCommitReply 

func NewPopulatedReplicaMessage_GapCommitReply(r randyProtocol, easy bool) *ReplicaMessage_GapCommitReply

func (*ReplicaMessage_GapCommitReply) Equal 

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

func (*ReplicaMessage_GapCommitReply) MarshalTo 

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

func (*ReplicaMessage_GapCommitReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_GapCommitReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_GapCommitReply) Size 

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

type ReplicaMessage_Ping 

type ReplicaMessage_Ping struct {
	Ping *Ping `protobuf:"bytes,22,opt,name=ping,proto3,oneof" json:"ping,omitempty"`
}

func NewPopulatedReplicaMessage_Ping 

func NewPopulatedReplicaMessage_Ping(r randyProtocol, easy bool) *ReplicaMessage_Ping

func (*ReplicaMessage_Ping) Equal 

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

func (*ReplicaMessage_Ping) MarshalTo 

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

func (*ReplicaMessage_Ping) MarshalToSizedBuffer 

func (m *ReplicaMessage_Ping) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_Ping) Size 

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

type ReplicaMessage_Query 

type ReplicaMessage_Query struct {
	Query *QueryRequest `protobuf:"bytes,3,opt,name=query,proto3,oneof" json:"query,omitempty"`
}

func NewPopulatedReplicaMessage_Query 

func NewPopulatedReplicaMessage_Query(r randyProtocol, easy bool) *ReplicaMessage_Query

func (*ReplicaMessage_Query) Equal 

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

func (*ReplicaMessage_Query) MarshalTo 

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

func (*ReplicaMessage_Query) MarshalToSizedBuffer 

func (m *ReplicaMessage_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_Query) Size 

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

type ReplicaMessage_QueryReply 

type ReplicaMessage_QueryReply struct {
	QueryReply *QueryReply `protobuf:"bytes,4,opt,name=query_reply,json=queryReply,proto3,oneof" json:"query_reply,omitempty"`
}

func NewPopulatedReplicaMessage_QueryReply 

func NewPopulatedReplicaMessage_QueryReply(r randyProtocol, easy bool) *ReplicaMessage_QueryReply

func (*ReplicaMessage_QueryReply) Equal 

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

func (*ReplicaMessage_QueryReply) MarshalTo 

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

func (*ReplicaMessage_QueryReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_QueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_QueryReply) Size 

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

type ReplicaMessage_Recover 

type ReplicaMessage_Recover struct {
	Recover *Recover `protobuf:"bytes,20,opt,name=recover,proto3,oneof" json:"recover,omitempty"`
}

func NewPopulatedReplicaMessage_Recover 

func NewPopulatedReplicaMessage_Recover(r randyProtocol, easy bool) *ReplicaMessage_Recover

func (*ReplicaMessage_Recover) Equal 

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

func (*ReplicaMessage_Recover) MarshalTo 

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

func (*ReplicaMessage_Recover) MarshalToSizedBuffer 

func (m *ReplicaMessage_Recover) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_Recover) Size 

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

type ReplicaMessage_RecoverReply 

type ReplicaMessage_RecoverReply struct {
	RecoverReply *RecoverReply `protobuf:"bytes,21,opt,name=recover_reply,json=recoverReply,proto3,oneof" json:"recover_reply,omitempty"`
}

func NewPopulatedReplicaMessage_RecoverReply 

func NewPopulatedReplicaMessage_RecoverReply(r randyProtocol, easy bool) *ReplicaMessage_RecoverReply

func (*ReplicaMessage_RecoverReply) Equal 

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

func (*ReplicaMessage_RecoverReply) MarshalTo 

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

func (*ReplicaMessage_RecoverReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_RecoverReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_RecoverReply) Size 

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

type ReplicaMessage_SlotLookup 

type ReplicaMessage_SlotLookup struct {
	SlotLookup *SlotLookup `protobuf:"bytes,5,opt,name=slot_lookup,json=slotLookup,proto3,oneof" json:"slot_lookup,omitempty"`
}

func NewPopulatedReplicaMessage_SlotLookup 

func NewPopulatedReplicaMessage_SlotLookup(r randyProtocol, easy bool) *ReplicaMessage_SlotLookup

func (*ReplicaMessage_SlotLookup) Equal 

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

func (*ReplicaMessage_SlotLookup) MarshalTo 

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

func (*ReplicaMessage_SlotLookup) MarshalToSizedBuffer 

func (m *ReplicaMessage_SlotLookup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_SlotLookup) Size 

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

type ReplicaMessage_StartView 

type ReplicaMessage_StartView struct {
	StartView *StartView `protobuf:"bytes,12,opt,name=start_view,json=startView,proto3,oneof" json:"start_view,omitempty"`
}

func NewPopulatedReplicaMessage_StartView 

func NewPopulatedReplicaMessage_StartView(r randyProtocol, easy bool) *ReplicaMessage_StartView

func (*ReplicaMessage_StartView) Equal 

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

func (*ReplicaMessage_StartView) MarshalTo 

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

func (*ReplicaMessage_StartView) MarshalToSizedBuffer 

func (m *ReplicaMessage_StartView) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_StartView) Size 

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

type ReplicaMessage_SyncCommit 

type ReplicaMessage_SyncCommit struct {
	SyncCommit *SyncCommit `protobuf:"bytes,19,opt,name=sync_commit,json=syncCommit,proto3,oneof" json:"sync_commit,omitempty"`
}

func NewPopulatedReplicaMessage_SyncCommit 

func NewPopulatedReplicaMessage_SyncCommit(r randyProtocol, easy bool) *ReplicaMessage_SyncCommit

func (*ReplicaMessage_SyncCommit) Equal 

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

func (*ReplicaMessage_SyncCommit) MarshalTo 

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

func (*ReplicaMessage_SyncCommit) MarshalToSizedBuffer 

func (m *ReplicaMessage_SyncCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_SyncCommit) Size 

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

type ReplicaMessage_SyncPrepare 

type ReplicaMessage_SyncPrepare struct {
	SyncPrepare *SyncPrepare `protobuf:"bytes,15,opt,name=sync_prepare,json=syncPrepare,proto3,oneof" json:"sync_prepare,omitempty"`
}

func NewPopulatedReplicaMessage_SyncPrepare 

func NewPopulatedReplicaMessage_SyncPrepare(r randyProtocol, easy bool) *ReplicaMessage_SyncPrepare

func (*ReplicaMessage_SyncPrepare) Equal 

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

func (*ReplicaMessage_SyncPrepare) MarshalTo 

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

func (*ReplicaMessage_SyncPrepare) MarshalToSizedBuffer 

func (m *ReplicaMessage_SyncPrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_SyncPrepare) Size 

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

type ReplicaMessage_SyncRepair 

type ReplicaMessage_SyncRepair struct {
	SyncRepair *SyncRepair `protobuf:"bytes,16,opt,name=sync_repair,json=syncRepair,proto3,oneof" json:"sync_repair,omitempty"`
}

func NewPopulatedReplicaMessage_SyncRepair 

func NewPopulatedReplicaMessage_SyncRepair(r randyProtocol, easy bool) *ReplicaMessage_SyncRepair

func (*ReplicaMessage_SyncRepair) Equal 

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

func (*ReplicaMessage_SyncRepair) MarshalTo 

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

func (*ReplicaMessage_SyncRepair) MarshalToSizedBuffer 

func (m *ReplicaMessage_SyncRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_SyncRepair) Size 

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

type ReplicaMessage_SyncRepairReply 

type ReplicaMessage_SyncRepairReply struct {
	SyncRepairReply *SyncRepairReply `protobuf:"bytes,17,opt,name=sync_repair_reply,json=syncRepairReply,proto3,oneof" json:"sync_repair_reply,omitempty"`
}

func NewPopulatedReplicaMessage_SyncRepairReply 

func NewPopulatedReplicaMessage_SyncRepairReply(r randyProtocol, easy bool) *ReplicaMessage_SyncRepairReply

func (*ReplicaMessage_SyncRepairReply) Equal 

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

func (*ReplicaMessage_SyncRepairReply) MarshalTo 

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

func (*ReplicaMessage_SyncRepairReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_SyncRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_SyncRepairReply) Size 

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

type ReplicaMessage_SyncReply 

type ReplicaMessage_SyncReply struct {
	SyncReply *SyncReply `protobuf:"bytes,18,opt,name=sync_reply,json=syncReply,proto3,oneof" json:"sync_reply,omitempty"`
}

func NewPopulatedReplicaMessage_SyncReply 

func NewPopulatedReplicaMessage_SyncReply(r randyProtocol, easy bool) *ReplicaMessage_SyncReply

func (*ReplicaMessage_SyncReply) Equal 

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

func (*ReplicaMessage_SyncReply) MarshalTo 

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

func (*ReplicaMessage_SyncReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_SyncReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_SyncReply) Size 

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

type ReplicaMessage_ViewChange 

type ReplicaMessage_ViewChange struct {
	ViewChange *ViewChange `protobuf:"bytes,9,opt,name=view_change,json=viewChange,proto3,oneof" json:"view_change,omitempty"`
}

func NewPopulatedReplicaMessage_ViewChange 

func NewPopulatedReplicaMessage_ViewChange(r randyProtocol, easy bool) *ReplicaMessage_ViewChange

func (*ReplicaMessage_ViewChange) Equal 

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

func (*ReplicaMessage_ViewChange) MarshalTo 

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

func (*ReplicaMessage_ViewChange) MarshalToSizedBuffer 

func (m *ReplicaMessage_ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_ViewChange) Size 

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

type ReplicaMessage_ViewChangeRepair 

type ReplicaMessage_ViewChangeRepair struct {
	ViewChangeRepair *ViewChangeRepair `protobuf:"bytes,10,opt,name=view_change_repair,json=viewChangeRepair,proto3,oneof" json:"view_change_repair,omitempty"`
}

func NewPopulatedReplicaMessage_ViewChangeRepair 

func NewPopulatedReplicaMessage_ViewChangeRepair(r randyProtocol, easy bool) *ReplicaMessage_ViewChangeRepair

func (*ReplicaMessage_ViewChangeRepair) Equal 

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

func (*ReplicaMessage_ViewChangeRepair) MarshalTo 

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

func (*ReplicaMessage_ViewChangeRepair) MarshalToSizedBuffer 

func (m *ReplicaMessage_ViewChangeRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_ViewChangeRepair) Size 

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

type ReplicaMessage_ViewChangeRepairReply 

type ReplicaMessage_ViewChangeRepairReply struct {
	ViewChangeRepairReply *ViewChangeRepairReply `` /* 135-byte string literal not displayed */
}

func NewPopulatedReplicaMessage_ViewChangeRepairReply 

func NewPopulatedReplicaMessage_ViewChangeRepairReply(r randyProtocol, easy bool) *ReplicaMessage_ViewChangeRepairReply

func (*ReplicaMessage_ViewChangeRepairReply) Equal 

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

func (*ReplicaMessage_ViewChangeRepairReply) MarshalTo 

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

func (*ReplicaMessage_ViewChangeRepairReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_ViewChangeRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_ViewChangeRepairReply) Size 

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

type ReplicaMessage_ViewChangeRequest 

type ReplicaMessage_ViewChangeRequest struct {
	ViewChangeRequest *ViewChangeRequest `protobuf:"bytes,8,opt,name=view_change_request,json=viewChangeRequest,proto3,oneof" json:"view_change_request,omitempty"`
}

func NewPopulatedReplicaMessage_ViewChangeRequest 

func NewPopulatedReplicaMessage_ViewChangeRequest(r randyProtocol, easy bool) *ReplicaMessage_ViewChangeRequest

func (*ReplicaMessage_ViewChangeRequest) Equal 

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

func (*ReplicaMessage_ViewChangeRequest) MarshalTo 

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

func (*ReplicaMessage_ViewChangeRequest) MarshalToSizedBuffer 

func (m *ReplicaMessage_ViewChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_ViewChangeRequest) Size 

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

type ReplicaMessage_ViewRepair 

type ReplicaMessage_ViewRepair struct {
	ViewRepair *ViewRepair `protobuf:"bytes,13,opt,name=view_repair,json=viewRepair,proto3,oneof" json:"view_repair,omitempty"`
}

func NewPopulatedReplicaMessage_ViewRepair 

func NewPopulatedReplicaMessage_ViewRepair(r randyProtocol, easy bool) *ReplicaMessage_ViewRepair

func (*ReplicaMessage_ViewRepair) Equal 

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

func (*ReplicaMessage_ViewRepair) MarshalTo 

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

func (*ReplicaMessage_ViewRepair) MarshalToSizedBuffer 

func (m *ReplicaMessage_ViewRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_ViewRepair) Size 

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

type ReplicaMessage_ViewRepairReply 

type ReplicaMessage_ViewRepairReply struct {
	ViewRepairReply *ViewRepairReply `protobuf:"bytes,14,opt,name=view_repair_reply,json=viewRepairReply,proto3,oneof" json:"view_repair_reply,omitempty"`
}

func NewPopulatedReplicaMessage_ViewRepairReply 

func NewPopulatedReplicaMessage_ViewRepairReply(r randyProtocol, easy bool) *ReplicaMessage_ViewRepairReply

func (*ReplicaMessage_ViewRepairReply) Equal 

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

func (*ReplicaMessage_ViewRepairReply) MarshalTo 

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

func (*ReplicaMessage_ViewRepairReply) MarshalToSizedBuffer 

func (m *ReplicaMessage_ViewRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaMessage_ViewRepairReply) Size 

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

type ReplicaServiceClient 

type ReplicaServiceClient interface {
	ReplicaStream(ctx context.Context, opts ...grpc.CallOption) (ReplicaService_ReplicaStreamClient, error)
}

ReplicaServiceClient is the client API for ReplicaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewReplicaServiceClient 

func NewReplicaServiceClient(cc *grpc.ClientConn) ReplicaServiceClient

type ReplicaServiceServer 

type ReplicaServiceServer interface {
	ReplicaStream(ReplicaService_ReplicaStreamServer) error
}

ReplicaServiceServer is the server API for ReplicaService service.

type ReplicaService_ReplicaStreamClient 

type ReplicaService_ReplicaStreamClient interface {
	Send(*ReplicaMessage) error
	Recv() (*ReplicaMessage, error)
	grpc.ClientStream
}

type ReplicaService_ReplicaStreamServer 

type ReplicaService_ReplicaStreamServer interface {
	Send(*ReplicaMessage) error
	Recv() (*ReplicaMessage, error)
	grpc.ServerStream
}

type SessionID 

type SessionID uint64

SessionID is a sequencer session ID

type SlotLookup 

type SlotLookup struct {
	Sender     MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
}

func NewPopulatedSlotLookup 

func NewPopulatedSlotLookup(r randyProtocol, easy bool) *SlotLookup

func (*SlotLookup) Descriptor 

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

func (*SlotLookup) Equal 

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

func (*SlotLookup) GetMessageNum 

func (m *SlotLookup) GetMessageNum() MessageID

func (*SlotLookup) GetSender 

func (m *SlotLookup) GetSender() MemberID

func (*SlotLookup) GetViewID 

func (m *SlotLookup) GetViewID() *ViewId

func (*SlotLookup) Marshal 

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

func (*SlotLookup) MarshalTo 

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

func (*SlotLookup) MarshalToSizedBuffer 

func (m *SlotLookup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SlotLookup) ProtoMessage 

func (*SlotLookup) ProtoMessage()

func (*SlotLookup) Reset 

func (m *SlotLookup) Reset()

func (*SlotLookup) Size 

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

func (*SlotLookup) String 

func (m *SlotLookup) String() string

func (*SlotLookup) Unmarshal 

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

func (*SlotLookup) XXX_DiscardUnknown 

func (m *SlotLookup) XXX_DiscardUnknown()

func (*SlotLookup) XXX_Marshal 

func (m *SlotLookup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlotLookup) XXX_Merge 

func (m *SlotLookup) XXX_Merge(src proto.Message)

func (*SlotLookup) XXX_Size 

func (m *SlotLookup) XXX_Size() int

func (*SlotLookup) XXX_Unmarshal 

func (m *SlotLookup) XXX_Unmarshal(b []byte) error

type StartView 

type StartView struct {
	Sender          MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID          *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum      MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	NoOpFilter      []byte    `protobuf:"bytes,4,opt,name=no_op_filter,json=noOpFilter,proto3" json:"no_op_filter,omitempty"`
	FirstLogSlotNum LogSlotID `` /* 130-byte string literal not displayed */
	LastLogSlotNum  LogSlotID `` /* 127-byte string literal not displayed */
}

func NewPopulatedStartView 

func NewPopulatedStartView(r randyProtocol, easy bool) *StartView

func (*StartView) Descriptor 

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

func (*StartView) Equal 

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

func (*StartView) GetFirstLogSlotNum 

func (m *StartView) GetFirstLogSlotNum() LogSlotID

func (*StartView) GetLastLogSlotNum 

func (m *StartView) GetLastLogSlotNum() LogSlotID

func (*StartView) GetMessageNum 

func (m *StartView) GetMessageNum() MessageID

func (*StartView) GetNoOpFilter 

func (m *StartView) GetNoOpFilter() []byte

func (*StartView) GetSender 

func (m *StartView) GetSender() MemberID

func (*StartView) GetViewID 

func (m *StartView) GetViewID() *ViewId

func (*StartView) Marshal 

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

func (*StartView) MarshalTo 

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

func (*StartView) MarshalToSizedBuffer 

func (m *StartView) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartView) ProtoMessage 

func (*StartView) ProtoMessage()

func (*StartView) Reset 

func (m *StartView) Reset()

func (*StartView) Size 

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

func (*StartView) String 

func (m *StartView) String() string

func (*StartView) Unmarshal 

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

func (*StartView) XXX_DiscardUnknown 

func (m *StartView) XXX_DiscardUnknown()

func (*StartView) XXX_Marshal 

func (m *StartView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartView) XXX_Merge 

func (m *StartView) XXX_Merge(src proto.Message)

func (*StartView) XXX_Size 

func (m *StartView) XXX_Size() int

func (*StartView) XXX_Unmarshal 

func (m *StartView) XXX_Unmarshal(b []byte) error

type Status 

type Status string

Status is the protocol status 

const (
	// StatusRecovering is used by a recovering replica to avoid operating on old state
	StatusRecovering Status = "Recovering"
	// StatusNormal is the normal status
	StatusNormal Status = "Normal"
	// StatusViewChange is used to ignore certain messages during view changes
	StatusViewChange Status = "ViewChange"
	// StatusGapCommit indicates the replica is undergoing a gap commit
	StatusGapCommit Status = "GapCommit"
)

type SyncCommit 

type SyncCommit struct {
	Sender     MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	SyncPoint  LogSlotID `protobuf:"varint,4,opt,name=sync_point,json=syncPoint,proto3,casttype=LogSlotID" json:"sync_point,omitempty"`
}

func NewPopulatedSyncCommit 

func NewPopulatedSyncCommit(r randyProtocol, easy bool) *SyncCommit

func (*SyncCommit) Descriptor 

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

func (*SyncCommit) Equal 

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

func (*SyncCommit) GetMessageNum 

func (m *SyncCommit) GetMessageNum() MessageID

func (*SyncCommit) GetSender 

func (m *SyncCommit) GetSender() MemberID

func (*SyncCommit) GetSyncPoint 

func (m *SyncCommit) GetSyncPoint() LogSlotID

func (*SyncCommit) GetViewID 

func (m *SyncCommit) GetViewID() *ViewId

func (*SyncCommit) Marshal 

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

func (*SyncCommit) MarshalTo 

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

func (*SyncCommit) MarshalToSizedBuffer 

func (m *SyncCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncCommit) ProtoMessage 

func (*SyncCommit) ProtoMessage()

func (*SyncCommit) Reset 

func (m *SyncCommit) Reset()

func (*SyncCommit) Size 

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

func (*SyncCommit) String 

func (m *SyncCommit) String() string

func (*SyncCommit) Unmarshal 

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

func (*SyncCommit) XXX_DiscardUnknown 

func (m *SyncCommit) XXX_DiscardUnknown()

func (*SyncCommit) XXX_Marshal 

func (m *SyncCommit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncCommit) XXX_Merge 

func (m *SyncCommit) XXX_Merge(src proto.Message)

func (*SyncCommit) XXX_Size 

func (m *SyncCommit) XXX_Size() int

func (*SyncCommit) XXX_Unmarshal 

func (m *SyncCommit) XXX_Unmarshal(b []byte) error

type SyncPrepare 

type SyncPrepare struct {
	Sender          MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID          *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum      MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	NoOpFilter      []byte    `protobuf:"bytes,4,opt,name=no_op_filter,json=noOpFilter,proto3" json:"no_op_filter,omitempty"`
	FirstLogSlotNum LogSlotID `` /* 130-byte string literal not displayed */
	LastLogSlotNum  LogSlotID `` /* 127-byte string literal not displayed */
}

func NewPopulatedSyncPrepare 

func NewPopulatedSyncPrepare(r randyProtocol, easy bool) *SyncPrepare

func (*SyncPrepare) Descriptor 

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

func (*SyncPrepare) Equal 

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

func (*SyncPrepare) GetFirstLogSlotNum 

func (m *SyncPrepare) GetFirstLogSlotNum() LogSlotID

func (*SyncPrepare) GetLastLogSlotNum 

func (m *SyncPrepare) GetLastLogSlotNum() LogSlotID

func (*SyncPrepare) GetMessageNum 

func (m *SyncPrepare) GetMessageNum() MessageID

func (*SyncPrepare) GetNoOpFilter 

func (m *SyncPrepare) GetNoOpFilter() []byte

func (*SyncPrepare) GetSender 

func (m *SyncPrepare) GetSender() MemberID

func (*SyncPrepare) GetViewID 

func (m *SyncPrepare) GetViewID() *ViewId

func (*SyncPrepare) Marshal 

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

func (*SyncPrepare) MarshalTo 

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

func (*SyncPrepare) MarshalToSizedBuffer 

func (m *SyncPrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncPrepare) ProtoMessage 

func (*SyncPrepare) ProtoMessage()

func (*SyncPrepare) Reset 

func (m *SyncPrepare) Reset()

func (*SyncPrepare) Size 

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

func (*SyncPrepare) String 

func (m *SyncPrepare) String() string

func (*SyncPrepare) Unmarshal 

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

func (*SyncPrepare) XXX_DiscardUnknown 

func (m *SyncPrepare) XXX_DiscardUnknown()

func (*SyncPrepare) XXX_Marshal 

func (m *SyncPrepare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncPrepare) XXX_Merge 

func (m *SyncPrepare) XXX_Merge(src proto.Message)

func (*SyncPrepare) XXX_Size 

func (m *SyncPrepare) XXX_Size() int

func (*SyncPrepare) XXX_Unmarshal 

func (m *SyncPrepare) XXX_Unmarshal(b []byte) error

type SyncRepair 

type SyncRepair struct {
	Sender     MemberID    `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId     `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	Checkpoint LogSlotID   `protobuf:"varint,3,opt,name=checkpoint,proto3,casttype=LogSlotID" json:"checkpoint,omitempty"`
	SlotNums   []LogSlotID `protobuf:"varint,4,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"`
}

func NewPopulatedSyncRepair 

func NewPopulatedSyncRepair(r randyProtocol, easy bool) *SyncRepair

func (*SyncRepair) Descriptor 

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

func (*SyncRepair) Equal 

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

func (*SyncRepair) GetCheckpoint 

func (m *SyncRepair) GetCheckpoint() LogSlotID

func (*SyncRepair) GetSender 

func (m *SyncRepair) GetSender() MemberID

func (*SyncRepair) GetSlotNums 

func (m *SyncRepair) GetSlotNums() []LogSlotID

func (*SyncRepair) GetViewID 

func (m *SyncRepair) GetViewID() *ViewId

func (*SyncRepair) Marshal 

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

func (*SyncRepair) MarshalTo 

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

func (*SyncRepair) MarshalToSizedBuffer 

func (m *SyncRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncRepair) ProtoMessage 

func (*SyncRepair) ProtoMessage()

func (*SyncRepair) Reset 

func (m *SyncRepair) Reset()

func (*SyncRepair) Size 

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

func (*SyncRepair) String 

func (m *SyncRepair) String() string

func (*SyncRepair) Unmarshal 

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

func (*SyncRepair) XXX_DiscardUnknown 

func (m *SyncRepair) XXX_DiscardUnknown()

func (*SyncRepair) XXX_Marshal 

func (m *SyncRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncRepair) XXX_Merge 

func (m *SyncRepair) XXX_Merge(src proto.Message)

func (*SyncRepair) XXX_Size 

func (m *SyncRepair) XXX_Size() int

func (*SyncRepair) XXX_Unmarshal 

func (m *SyncRepair) XXX_Unmarshal(b []byte) error

type SyncRepairReply 

type SyncRepairReply struct {
	Sender            MemberID    `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID            *ViewId     `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	CheckpointSlotNum LogSlotID   `` /* 134-byte string literal not displayed */
	Checkpoint        []byte      `protobuf:"bytes,4,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Entries           []*LogEntry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"`
}

func NewPopulatedSyncRepairReply 

func NewPopulatedSyncRepairReply(r randyProtocol, easy bool) *SyncRepairReply

func (*SyncRepairReply) Descriptor 

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

func (*SyncRepairReply) Equal 

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

func (*SyncRepairReply) GetCheckpoint 

func (m *SyncRepairReply) GetCheckpoint() []byte

func (*SyncRepairReply) GetCheckpointSlotNum 

func (m *SyncRepairReply) GetCheckpointSlotNum() LogSlotID

func (*SyncRepairReply) GetEntries 

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

func (*SyncRepairReply) GetSender 

func (m *SyncRepairReply) GetSender() MemberID

func (*SyncRepairReply) GetViewID 

func (m *SyncRepairReply) GetViewID() *ViewId

func (*SyncRepairReply) Marshal 

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

func (*SyncRepairReply) MarshalTo 

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

func (*SyncRepairReply) MarshalToSizedBuffer 

func (m *SyncRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncRepairReply) ProtoMessage 

func (*SyncRepairReply) ProtoMessage()

func (*SyncRepairReply) Reset 

func (m *SyncRepairReply) Reset()

func (*SyncRepairReply) Size 

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

func (*SyncRepairReply) String 

func (m *SyncRepairReply) String() string

func (*SyncRepairReply) Unmarshal 

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

func (*SyncRepairReply) XXX_DiscardUnknown 

func (m *SyncRepairReply) XXX_DiscardUnknown()

func (*SyncRepairReply) XXX_Marshal 

func (m *SyncRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncRepairReply) XXX_Merge 

func (m *SyncRepairReply) XXX_Merge(src proto.Message)

func (*SyncRepairReply) XXX_Size 

func (m *SyncRepairReply) XXX_Size() int

func (*SyncRepairReply) XXX_Unmarshal 

func (m *SyncRepairReply) XXX_Unmarshal(b []byte) error

type SyncReply 

type SyncReply struct {
	Sender  MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID  *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	SlotNum LogSlotID `protobuf:"varint,3,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"`
}

func NewPopulatedSyncReply 

func NewPopulatedSyncReply(r randyProtocol, easy bool) *SyncReply

func (*SyncReply) Descriptor 

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

func (*SyncReply) Equal 

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

func (*SyncReply) GetSender 

func (m *SyncReply) GetSender() MemberID

func (*SyncReply) GetSlotNum 

func (m *SyncReply) GetSlotNum() LogSlotID

func (*SyncReply) GetViewID 

func (m *SyncReply) GetViewID() *ViewId

func (*SyncReply) Marshal 

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

func (*SyncReply) MarshalTo 

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

func (*SyncReply) MarshalToSizedBuffer 

func (m *SyncReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncReply) ProtoMessage 

func (*SyncReply) ProtoMessage()

func (*SyncReply) Reset 

func (m *SyncReply) Reset()

func (*SyncReply) Size 

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

func (*SyncReply) String 

func (m *SyncReply) String() string

func (*SyncReply) Unmarshal 

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

func (*SyncReply) XXX_DiscardUnknown 

func (m *SyncReply) XXX_DiscardUnknown()

func (*SyncReply) XXX_Marshal 

func (m *SyncReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncReply) XXX_Merge 

func (m *SyncReply) XXX_Merge(src proto.Message)

func (*SyncReply) XXX_Size 

func (m *SyncReply) XXX_Size() int

func (*SyncReply) XXX_Unmarshal 

func (m *SyncReply) XXX_Unmarshal(b []byte) error

type UnimplementedClientServiceServer 

type UnimplementedClientServiceServer struct {
}

UnimplementedClientServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClientServiceServer) ClientStream 

func (*UnimplementedClientServiceServer) ClientStream(srv ClientService_ClientStreamServer) error

type UnimplementedReplicaServiceServer 

type UnimplementedReplicaServiceServer struct {
}

UnimplementedReplicaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicaServiceServer) ReplicaStream 

func (*UnimplementedReplicaServiceServer) ReplicaStream(srv ReplicaService_ReplicaStreamServer) error

type ViewChange 

type ViewChange struct {
	Sender          MemberID  `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID          *ViewId   `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	LastNormal      *ViewId   `protobuf:"bytes,3,opt,name=last_normal,json=lastNormal,proto3" json:"last_normal,omitempty"`
	MessageNum      MessageID `protobuf:"varint,4,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	NoOpFilter      []byte    `protobuf:"bytes,5,opt,name=no_op_filter,json=noOpFilter,proto3" json:"no_op_filter,omitempty"`
	FirstLogSlotNum LogSlotID `` /* 130-byte string literal not displayed */
	LastLogSlotNum  LogSlotID `` /* 127-byte string literal not displayed */
}

func NewPopulatedViewChange 

func NewPopulatedViewChange(r randyProtocol, easy bool) *ViewChange

func (*ViewChange) Descriptor 

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

func (*ViewChange) Equal 

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

func (*ViewChange) GetFirstLogSlotNum 

func (m *ViewChange) GetFirstLogSlotNum() LogSlotID

func (*ViewChange) GetLastLogSlotNum 

func (m *ViewChange) GetLastLogSlotNum() LogSlotID

func (*ViewChange) GetLastNormal 

func (m *ViewChange) GetLastNormal() *ViewId

func (*ViewChange) GetMessageNum 

func (m *ViewChange) GetMessageNum() MessageID

func (*ViewChange) GetNoOpFilter 

func (m *ViewChange) GetNoOpFilter() []byte

func (*ViewChange) GetSender 

func (m *ViewChange) GetSender() MemberID

func (*ViewChange) GetViewID 

func (m *ViewChange) GetViewID() *ViewId

func (*ViewChange) Marshal 

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

func (*ViewChange) MarshalTo 

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

func (*ViewChange) MarshalToSizedBuffer 

func (m *ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ViewChange) ProtoMessage 

func (*ViewChange) ProtoMessage()

func (*ViewChange) Reset 

func (m *ViewChange) Reset()

func (*ViewChange) Size 

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

func (*ViewChange) String 

func (m *ViewChange) String() string

func (*ViewChange) Unmarshal 

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

func (*ViewChange) XXX_DiscardUnknown 

func (m *ViewChange) XXX_DiscardUnknown()

func (*ViewChange) XXX_Marshal 

func (m *ViewChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ViewChange) XXX_Merge 

func (m *ViewChange) XXX_Merge(src proto.Message)

func (*ViewChange) XXX_Size 

func (m *ViewChange) XXX_Size() int

func (*ViewChange) XXX_Unmarshal 

func (m *ViewChange) XXX_Unmarshal(b []byte) error

type ViewChangeRepair 

type ViewChangeRepair struct {
	Sender     MemberID    `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId     `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum MessageID   `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Checkpoint LogSlotID   `protobuf:"varint,4,opt,name=checkpoint,proto3,casttype=LogSlotID" json:"checkpoint,omitempty"`
	SlotNums   []LogSlotID `protobuf:"varint,5,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"`
}

func NewPopulatedViewChangeRepair 

func NewPopulatedViewChangeRepair(r randyProtocol, easy bool) *ViewChangeRepair

func (*ViewChangeRepair) Descriptor 

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

func (*ViewChangeRepair) Equal 

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

func (*ViewChangeRepair) GetCheckpoint 

func (m *ViewChangeRepair) GetCheckpoint() LogSlotID

func (*ViewChangeRepair) GetMessageNum 

func (m *ViewChangeRepair) GetMessageNum() MessageID

func (*ViewChangeRepair) GetSender 

func (m *ViewChangeRepair) GetSender() MemberID

func (*ViewChangeRepair) GetSlotNums 

func (m *ViewChangeRepair) GetSlotNums() []LogSlotID

func (*ViewChangeRepair) GetViewID 

func (m *ViewChangeRepair) GetViewID() *ViewId

func (*ViewChangeRepair) Marshal 

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

func (*ViewChangeRepair) MarshalTo 

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

func (*ViewChangeRepair) MarshalToSizedBuffer 

func (m *ViewChangeRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ViewChangeRepair) ProtoMessage 

func (*ViewChangeRepair) ProtoMessage()

func (*ViewChangeRepair) Reset 

func (m *ViewChangeRepair) Reset()

func (*ViewChangeRepair) Size 

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

func (*ViewChangeRepair) String 

func (m *ViewChangeRepair) String() string

func (*ViewChangeRepair) Unmarshal 

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

func (*ViewChangeRepair) XXX_DiscardUnknown 

func (m *ViewChangeRepair) XXX_DiscardUnknown()

func (*ViewChangeRepair) XXX_Marshal 

func (m *ViewChangeRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ViewChangeRepair) XXX_Merge 

func (m *ViewChangeRepair) XXX_Merge(src proto.Message)

func (*ViewChangeRepair) XXX_Size 

func (m *ViewChangeRepair) XXX_Size() int

func (*ViewChangeRepair) XXX_Unmarshal 

func (m *ViewChangeRepair) XXX_Unmarshal(b []byte) error

type ViewChangeRepairReply 

type ViewChangeRepairReply struct {
	Sender            MemberID    `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID            *ViewId     `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum        MessageID   `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	CheckpointSlotNum LogSlotID   `` /* 134-byte string literal not displayed */
	Checkpoint        []byte      `protobuf:"bytes,5,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	SlotNums          []LogSlotID `protobuf:"varint,6,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"`
}

func NewPopulatedViewChangeRepairReply 

func NewPopulatedViewChangeRepairReply(r randyProtocol, easy bool) *ViewChangeRepairReply

func (*ViewChangeRepairReply) Descriptor 

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

func (*ViewChangeRepairReply) Equal 

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

func (*ViewChangeRepairReply) GetCheckpoint 

func (m *ViewChangeRepairReply) GetCheckpoint() []byte

func (*ViewChangeRepairReply) GetCheckpointSlotNum 

func (m *ViewChangeRepairReply) GetCheckpointSlotNum() LogSlotID

func (*ViewChangeRepairReply) GetMessageNum 

func (m *ViewChangeRepairReply) GetMessageNum() MessageID

func (*ViewChangeRepairReply) GetSender 

func (m *ViewChangeRepairReply) GetSender() MemberID

func (*ViewChangeRepairReply) GetSlotNums 

func (m *ViewChangeRepairReply) GetSlotNums() []LogSlotID

func (*ViewChangeRepairReply) GetViewID 

func (m *ViewChangeRepairReply) GetViewID() *ViewId

func (*ViewChangeRepairReply) Marshal 

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

func (*ViewChangeRepairReply) MarshalTo 

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

func (*ViewChangeRepairReply) MarshalToSizedBuffer 

func (m *ViewChangeRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ViewChangeRepairReply) ProtoMessage 

func (*ViewChangeRepairReply) ProtoMessage()

func (*ViewChangeRepairReply) Reset 

func (m *ViewChangeRepairReply) Reset()

func (*ViewChangeRepairReply) Size 

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

func (*ViewChangeRepairReply) String 

func (m *ViewChangeRepairReply) String() string

func (*ViewChangeRepairReply) Unmarshal 

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

func (*ViewChangeRepairReply) XXX_DiscardUnknown 

func (m *ViewChangeRepairReply) XXX_DiscardUnknown()

func (*ViewChangeRepairReply) XXX_Marshal 

func (m *ViewChangeRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ViewChangeRepairReply) XXX_Merge 

func (m *ViewChangeRepairReply) XXX_Merge(src proto.Message)

func (*ViewChangeRepairReply) XXX_Size 

func (m *ViewChangeRepairReply) XXX_Size() int

func (*ViewChangeRepairReply) XXX_Unmarshal 

func (m *ViewChangeRepairReply) XXX_Unmarshal(b []byte) error

type ViewChangeRequest 

type ViewChangeRequest struct {
	Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID *ViewId  `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
}

func NewPopulatedViewChangeRequest 

func NewPopulatedViewChangeRequest(r randyProtocol, easy bool) *ViewChangeRequest

func (*ViewChangeRequest) Descriptor 

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

func (*ViewChangeRequest) Equal 

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

func (*ViewChangeRequest) GetSender 

func (m *ViewChangeRequest) GetSender() MemberID

func (*ViewChangeRequest) GetViewID 

func (m *ViewChangeRequest) GetViewID() *ViewId

func (*ViewChangeRequest) Marshal 

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

func (*ViewChangeRequest) MarshalTo 

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

func (*ViewChangeRequest) MarshalToSizedBuffer 

func (m *ViewChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ViewChangeRequest) ProtoMessage 

func (*ViewChangeRequest) ProtoMessage()

func (*ViewChangeRequest) Reset 

func (m *ViewChangeRequest) Reset()

func (*ViewChangeRequest) Size 

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

func (*ViewChangeRequest) String 

func (m *ViewChangeRequest) String() string

func (*ViewChangeRequest) Unmarshal 

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

func (*ViewChangeRequest) XXX_DiscardUnknown 

func (m *ViewChangeRequest) XXX_DiscardUnknown()

func (*ViewChangeRequest) XXX_Marshal 

func (m *ViewChangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ViewChangeRequest) XXX_Merge 

func (m *ViewChangeRequest) XXX_Merge(src proto.Message)

func (*ViewChangeRequest) XXX_Size 

func (m *ViewChangeRequest) XXX_Size() int

func (*ViewChangeRequest) XXX_Unmarshal 

func (m *ViewChangeRequest) XXX_Unmarshal(b []byte) error

type ViewId 

type ViewId struct {
	LeaderNum  LeaderID  `protobuf:"varint,1,opt,name=leader_num,json=leaderNum,proto3,casttype=LeaderID" json:"leader_num,omitempty"`
	SessionNum SessionID `protobuf:"varint,2,opt,name=session_num,json=sessionNum,proto3,casttype=SessionID" json:"session_num,omitempty"`
}

func NewPopulatedViewId 

func NewPopulatedViewId(r randyProtocol, easy bool) *ViewId

func (*ViewId) Descriptor 

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

func (*ViewId) Equal 

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

func (*ViewId) GetLeaderNum 

func (m *ViewId) GetLeaderNum() LeaderID

func (*ViewId) GetSessionNum 

func (m *ViewId) GetSessionNum() SessionID

func (*ViewId) Marshal 

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

func (*ViewId) MarshalTo 

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

func (*ViewId) MarshalToSizedBuffer 

func (m *ViewId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ViewId) ProtoMessage 

func (*ViewId) ProtoMessage()

func (*ViewId) Reset 

func (m *ViewId) Reset()

func (*ViewId) Size 

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

func (*ViewId) String 

func (m *ViewId) String() string

func (*ViewId) Unmarshal 

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

func (*ViewId) XXX_DiscardUnknown 

func (m *ViewId) XXX_DiscardUnknown()

func (*ViewId) XXX_Marshal 

func (m *ViewId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ViewId) XXX_Merge 

func (m *ViewId) XXX_Merge(src proto.Message)

func (*ViewId) XXX_Size 

func (m *ViewId) XXX_Size() int

func (*ViewId) XXX_Unmarshal 

func (m *ViewId) XXX_Unmarshal(b []byte) error

type ViewRepair 

type ViewRepair struct {
	Sender     MemberID    `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID     *ViewId     `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	MessageNum MessageID   `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"`
	Checkpoint LogSlotID   `protobuf:"varint,4,opt,name=checkpoint,proto3,casttype=LogSlotID" json:"checkpoint,omitempty"`
	SlotNums   []LogSlotID `protobuf:"varint,5,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"`
}

func NewPopulatedViewRepair 

func NewPopulatedViewRepair(r randyProtocol, easy bool) *ViewRepair

func (*ViewRepair) Descriptor 

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

func (*ViewRepair) Equal 

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

func (*ViewRepair) GetCheckpoint 

func (m *ViewRepair) GetCheckpoint() LogSlotID

func (*ViewRepair) GetMessageNum 

func (m *ViewRepair) GetMessageNum() MessageID

func (*ViewRepair) GetSender 

func (m *ViewRepair) GetSender() MemberID

func (*ViewRepair) GetSlotNums 

func (m *ViewRepair) GetSlotNums() []LogSlotID

func (*ViewRepair) GetViewID 

func (m *ViewRepair) GetViewID() *ViewId

func (*ViewRepair) Marshal 

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

func (*ViewRepair) MarshalTo 

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

func (*ViewRepair) MarshalToSizedBuffer 

func (m *ViewRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ViewRepair) ProtoMessage 

func (*ViewRepair) ProtoMessage()

func (*ViewRepair) Reset 

func (m *ViewRepair) Reset()

func (*ViewRepair) Size 

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

func (*ViewRepair) String 

func (m *ViewRepair) String() string

func (*ViewRepair) Unmarshal 

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

func (*ViewRepair) XXX_DiscardUnknown 

func (m *ViewRepair) XXX_DiscardUnknown()

func (*ViewRepair) XXX_Marshal 

func (m *ViewRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ViewRepair) XXX_Merge 

func (m *ViewRepair) XXX_Merge(src proto.Message)

func (*ViewRepair) XXX_Size 

func (m *ViewRepair) XXX_Size() int

func (*ViewRepair) XXX_Unmarshal 

func (m *ViewRepair) XXX_Unmarshal(b []byte) error

type ViewRepairReply 

type ViewRepairReply struct {
	Sender            MemberID    `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"`
	ViewID            *ViewId     `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"`
	CheckpointSlotNum LogSlotID   `` /* 134-byte string literal not displayed */
	Checkpoint        []byte      `protobuf:"bytes,4,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Entries           []*LogEntry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"`
}

func NewPopulatedViewRepairReply 

func NewPopulatedViewRepairReply(r randyProtocol, easy bool) *ViewRepairReply

func (*ViewRepairReply) Descriptor 

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

func (*ViewRepairReply) Equal 

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

func (*ViewRepairReply) GetCheckpoint 

func (m *ViewRepairReply) GetCheckpoint() []byte

func (*ViewRepairReply) GetCheckpointSlotNum 

func (m *ViewRepairReply) GetCheckpointSlotNum() LogSlotID

func (*ViewRepairReply) GetEntries 

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

func (*ViewRepairReply) GetSender 

func (m *ViewRepairReply) GetSender() MemberID

func (*ViewRepairReply) GetViewID 

func (m *ViewRepairReply) GetViewID() *ViewId

func (*ViewRepairReply) Marshal 

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

func (*ViewRepairReply) MarshalTo 

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

func (*ViewRepairReply) MarshalToSizedBuffer 

func (m *ViewRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ViewRepairReply) ProtoMessage 

func (*ViewRepairReply) ProtoMessage()

func (*ViewRepairReply) Reset 

func (m *ViewRepairReply) Reset()

func (*ViewRepairReply) Size 

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

func (*ViewRepairReply) String 

func (m *ViewRepairReply) String() string

func (*ViewRepairReply) Unmarshal 

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

func (*ViewRepairReply) XXX_DiscardUnknown 

func (m *ViewRepairReply) XXX_DiscardUnknown()

func (*ViewRepairReply) XXX_Marshal 

func (m *ViewRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ViewRepairReply) XXX_Merge 

func (m *ViewRepairReply) XXX_Merge(src proto.Message)

func (*ViewRepairReply) XXX_Size 

func (m *ViewRepairReply) XXX_Size() int

func (*ViewRepairReply) XXX_Unmarshal 

func (m *ViewRepairReply) XXX_Unmarshal(b []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.