state

package
v0.0.0-...-f247ec5 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_state_state_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Action 

type Action struct {

	// Types that are assignable to Type:
	//	*Action_Send
	//	*Action_Hash
	//	*Action_AppendWriteAhead
	//	*Action_TruncateWriteAhead
	//	*Action_Commit
	//	*Action_Checkpoint
	//	*Action_AllocatedRequest
	//	*Action_CorrectRequest
	//	*Action_ForwardRequest
	//	*Action_StateTransfer
	//	*Action_StateApplied
	Type isAction_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetAllocatedRequest 

func (x *Action) GetAllocatedRequest() *ActionRequestSlot

func (*Action) GetAppendWriteAhead 

func (x *Action) GetAppendWriteAhead() *ActionWrite

func (*Action) GetCheckpoint 

func (x *Action) GetCheckpoint() *ActionCheckpoint

func (*Action) GetCommit 

func (x *Action) GetCommit() *ActionCommit

func (*Action) GetCorrectRequest 

func (x *Action) GetCorrectRequest() *msgs.RequestAck

func (*Action) GetForwardRequest 

func (x *Action) GetForwardRequest() *ActionForward

func (*Action) GetHash 

func (x *Action) GetHash() *ActionHashRequest

func (*Action) GetSend 

func (x *Action) GetSend() *ActionSend

func (*Action) GetStateApplied 

func (x *Action) GetStateApplied() *ActionStateApplied

func (*Action) GetStateTransfer 

func (x *Action) GetStateTransfer() *ActionStateTarget

func (*Action) GetTruncateWriteAhead 

func (x *Action) GetTruncateWriteAhead() *ActionTruncate

func (*Action) GetType 

func (m *Action) GetType() isAction_Type

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

func (x *Action) ProtoReflect() protoreflect.Message

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type ActionCheckpoint 

type ActionCheckpoint struct {
	SeqNo         uint64                      `protobuf:"varint,2,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	NetworkConfig *msgs.NetworkState_Config   `protobuf:"bytes,3,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
	ClientStates  []*msgs.NetworkState_Client `protobuf:"bytes,4,rep,name=client_states,json=clientStates,proto3" json:"client_states,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionCheckpoint) Descriptor deprecated 

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

Deprecated: Use ActionCheckpoint.ProtoReflect.Descriptor instead.

func (*ActionCheckpoint) GetClientStates 

func (x *ActionCheckpoint) GetClientStates() []*msgs.NetworkState_Client

func (*ActionCheckpoint) GetNetworkConfig 

func (x *ActionCheckpoint) GetNetworkConfig() *msgs.NetworkState_Config

func (*ActionCheckpoint) GetSeqNo 

func (x *ActionCheckpoint) GetSeqNo() uint64

func (*ActionCheckpoint) ProtoMessage 

func (*ActionCheckpoint) ProtoMessage()

func (*ActionCheckpoint) ProtoReflect 

func (x *ActionCheckpoint) ProtoReflect() protoreflect.Message

func (*ActionCheckpoint) Reset 

func (x *ActionCheckpoint) Reset()

func (*ActionCheckpoint) String 

func (x *ActionCheckpoint) String() string

type ActionCommit 

type ActionCommit struct {
	Batch *msgs.QEntry `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionCommit) Descriptor deprecated 

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

Deprecated: Use ActionCommit.ProtoReflect.Descriptor instead.

func (*ActionCommit) GetBatch 

func (x *ActionCommit) GetBatch() *msgs.QEntry

func (*ActionCommit) ProtoMessage 

func (*ActionCommit) ProtoMessage()

func (*ActionCommit) ProtoReflect 

func (x *ActionCommit) ProtoReflect() protoreflect.Message

func (*ActionCommit) Reset 

func (x *ActionCommit) Reset()

func (*ActionCommit) String 

func (x *ActionCommit) String() string

type ActionForward 

type ActionForward struct {
	Targets []uint64         `protobuf:"varint,1,rep,packed,name=targets,proto3" json:"targets,omitempty"`
	Ack     *msgs.RequestAck `protobuf:"bytes,2,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionForward) Descriptor deprecated 

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

Deprecated: Use ActionForward.ProtoReflect.Descriptor instead.

func (*ActionForward) GetAck 

func (x *ActionForward) GetAck() *msgs.RequestAck

func (*ActionForward) GetTargets 

func (x *ActionForward) GetTargets() []uint64

func (*ActionForward) ProtoMessage 

func (*ActionForward) ProtoMessage()

func (*ActionForward) ProtoReflect 

func (x *ActionForward) ProtoReflect() protoreflect.Message

func (*ActionForward) Reset 

func (x *ActionForward) Reset()

func (*ActionForward) String 

func (x *ActionForward) String() string

type ActionHashRequest 

type ActionHashRequest struct {
	Data   [][]byte    `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Origin *HashOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionHashRequest) Descriptor deprecated 

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

Deprecated: Use ActionHashRequest.ProtoReflect.Descriptor instead.

func (*ActionHashRequest) GetData 

func (x *ActionHashRequest) GetData() [][]byte

func (*ActionHashRequest) GetOrigin 

func (x *ActionHashRequest) GetOrigin() *HashOrigin

func (*ActionHashRequest) ProtoMessage 

func (*ActionHashRequest) ProtoMessage()

func (*ActionHashRequest) ProtoReflect 

func (x *ActionHashRequest) ProtoReflect() protoreflect.Message

func (*ActionHashRequest) Reset 

func (x *ActionHashRequest) Reset()

func (*ActionHashRequest) String 

func (x *ActionHashRequest) String() string

type ActionRequestSlot 

type ActionRequestSlot struct {
	ClientId uint64 `protobuf:"varint,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	ReqNo    uint64 `protobuf:"varint,2,opt,name=req_no,json=reqNo,proto3" json:"req_no,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionRequestSlot) Descriptor deprecated 

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

Deprecated: Use ActionRequestSlot.ProtoReflect.Descriptor instead.

func (*ActionRequestSlot) GetClientId 

func (x *ActionRequestSlot) GetClientId() uint64

func (*ActionRequestSlot) GetReqNo 

func (x *ActionRequestSlot) GetReqNo() uint64

func (*ActionRequestSlot) ProtoMessage 

func (*ActionRequestSlot) ProtoMessage()

func (*ActionRequestSlot) ProtoReflect 

func (x *ActionRequestSlot) ProtoReflect() protoreflect.Message

func (*ActionRequestSlot) Reset 

func (x *ActionRequestSlot) Reset()

func (*ActionRequestSlot) String 

func (x *ActionRequestSlot) String() string

type ActionSend 

type ActionSend struct {
	Targets []uint64  `protobuf:"varint,1,rep,packed,name=targets,proto3" json:"targets,omitempty"`
	Msg     *msgs.Msg `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionSend) Descriptor deprecated 

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

Deprecated: Use ActionSend.ProtoReflect.Descriptor instead.

func (*ActionSend) GetMsg 

func (x *ActionSend) GetMsg() *msgs.Msg

func (*ActionSend) GetTargets 

func (x *ActionSend) GetTargets() []uint64

func (*ActionSend) ProtoMessage 

func (*ActionSend) ProtoMessage()

func (*ActionSend) ProtoReflect 

func (x *ActionSend) ProtoReflect() protoreflect.Message

func (*ActionSend) Reset 

func (x *ActionSend) Reset()

func (*ActionSend) String 

func (x *ActionSend) String() string

type ActionStateApplied 

type ActionStateApplied struct {
	SeqNo        uint64             `protobuf:"varint,1,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	NetworkState *msgs.NetworkState `protobuf:"bytes,2,opt,name=network_state,json=networkState,proto3" json:"network_state,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionStateApplied) Descriptor deprecated 

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

Deprecated: Use ActionStateApplied.ProtoReflect.Descriptor instead.

func (*ActionStateApplied) GetNetworkState 

func (x *ActionStateApplied) GetNetworkState() *msgs.NetworkState

func (*ActionStateApplied) GetSeqNo 

func (x *ActionStateApplied) GetSeqNo() uint64

func (*ActionStateApplied) ProtoMessage 

func (*ActionStateApplied) ProtoMessage()

func (*ActionStateApplied) ProtoReflect 

func (x *ActionStateApplied) ProtoReflect() protoreflect.Message

func (*ActionStateApplied) Reset 

func (x *ActionStateApplied) Reset()

func (*ActionStateApplied) String 

func (x *ActionStateApplied) String() string

type ActionStateTarget 

type ActionStateTarget struct {
	SeqNo uint64 `protobuf:"varint,1,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionStateTarget) Descriptor deprecated 

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

Deprecated: Use ActionStateTarget.ProtoReflect.Descriptor instead.

func (*ActionStateTarget) GetSeqNo 

func (x *ActionStateTarget) GetSeqNo() uint64

func (*ActionStateTarget) GetValue 

func (x *ActionStateTarget) GetValue() []byte

func (*ActionStateTarget) ProtoMessage 

func (*ActionStateTarget) ProtoMessage()

func (*ActionStateTarget) ProtoReflect 

func (x *ActionStateTarget) ProtoReflect() protoreflect.Message

func (*ActionStateTarget) Reset 

func (x *ActionStateTarget) Reset()

func (*ActionStateTarget) String 

func (x *ActionStateTarget) String() string

type ActionTruncate 

type ActionTruncate struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionTruncate) Descriptor deprecated 

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

Deprecated: Use ActionTruncate.ProtoReflect.Descriptor instead.

func (*ActionTruncate) GetIndex 

func (x *ActionTruncate) GetIndex() uint64

func (*ActionTruncate) ProtoMessage 

func (*ActionTruncate) ProtoMessage()

func (*ActionTruncate) ProtoReflect 

func (x *ActionTruncate) ProtoReflect() protoreflect.Message

func (*ActionTruncate) Reset 

func (x *ActionTruncate) Reset()

func (*ActionTruncate) String 

func (x *ActionTruncate) String() string

type ActionWrite 

type ActionWrite struct {
	Index uint64           `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Data  *msgs.Persistent `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionWrite) Descriptor deprecated 

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

Deprecated: Use ActionWrite.ProtoReflect.Descriptor instead.

func (*ActionWrite) GetData 

func (x *ActionWrite) GetData() *msgs.Persistent

func (*ActionWrite) GetIndex 

func (x *ActionWrite) GetIndex() uint64

func (*ActionWrite) ProtoMessage 

func (*ActionWrite) ProtoMessage()

func (*ActionWrite) ProtoReflect 

func (x *ActionWrite) ProtoReflect() protoreflect.Message

func (*ActionWrite) Reset 

func (x *ActionWrite) Reset()

func (*ActionWrite) String 

func (x *ActionWrite) String() string

type Action_AllocatedRequest 

type Action_AllocatedRequest struct {
	AllocatedRequest *ActionRequestSlot `protobuf:"bytes,7,opt,name=allocated_request,json=allocatedRequest,proto3,oneof"`
}

type Action_AppendWriteAhead 

type Action_AppendWriteAhead struct {
	AppendWriteAhead *ActionWrite `protobuf:"bytes,3,opt,name=append_write_ahead,json=appendWriteAhead,proto3,oneof"`
}

type Action_Checkpoint 

type Action_Checkpoint struct {
	Checkpoint *ActionCheckpoint `protobuf:"bytes,6,opt,name=checkpoint,proto3,oneof"`
}

type Action_Commit 

type Action_Commit struct {
	Commit *ActionCommit `protobuf:"bytes,5,opt,name=commit,proto3,oneof"`
}

type Action_CorrectRequest 

type Action_CorrectRequest struct {
	CorrectRequest *msgs.RequestAck `protobuf:"bytes,8,opt,name=correct_request,json=correctRequest,proto3,oneof"`
}

type Action_ForwardRequest 

type Action_ForwardRequest struct {
	ForwardRequest *ActionForward `protobuf:"bytes,9,opt,name=forward_request,json=forwardRequest,proto3,oneof"`
}

type Action_Hash 

type Action_Hash struct {
	Hash *ActionHashRequest `protobuf:"bytes,2,opt,name=hash,proto3,oneof"`
}

type Action_Send 

type Action_Send struct {
	Send *ActionSend `protobuf:"bytes,1,opt,name=send,proto3,oneof"`
}

type Action_StateApplied 

type Action_StateApplied struct {
	StateApplied *ActionStateApplied `protobuf:"bytes,11,opt,name=state_applied,json=stateApplied,proto3,oneof"`
}

type Action_StateTransfer 

type Action_StateTransfer struct {
	StateTransfer *ActionStateTarget `protobuf:"bytes,10,opt,name=state_transfer,json=stateTransfer,proto3,oneof"`
}

type Action_TruncateWriteAhead 

type Action_TruncateWriteAhead struct {
	TruncateWriteAhead *ActionTruncate `protobuf:"bytes,4,opt,name=truncate_write_ahead,json=truncateWriteAhead,proto3,oneof"`
}

type Event 

type Event struct {

	// TODO, normalize naming, for instance Complete/Completed
	//
	// Types that are assignable to Type:
	//	*Event_Initialize
	//	*Event_LoadPersistedEntry
	//	*Event_CompleteInitialization
	//	*Event_HashResult
	//	*Event_CheckpointResult
	//	*Event_RequestPersisted
	//	*Event_StateTransferComplete
	//	*Event_StateTransferFailed
	//	*Event_Step
	//	*Event_TickElapsed
	//	*Event_ActionsReceived
	Type isEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

Event represents a state event to be injected into the state machine

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetActionsReceived 

func (x *Event) GetActionsReceived() *EventActionsReceived

func (*Event) GetCheckpointResult 

func (x *Event) GetCheckpointResult() *EventCheckpointResult

func (*Event) GetCompleteInitialization 

func (x *Event) GetCompleteInitialization() *EventLoadCompleted

func (*Event) GetHashResult 

func (x *Event) GetHashResult() *EventHashResult

func (*Event) GetInitialize 

func (x *Event) GetInitialize() *EventInitialParameters

func (*Event) GetLoadPersistedEntry 

func (x *Event) GetLoadPersistedEntry() *EventLoadPersistedEntry

func (*Event) GetRequestPersisted 

func (x *Event) GetRequestPersisted() *EventRequestPersisted

func (*Event) GetStateTransferComplete 

func (x *Event) GetStateTransferComplete() *EventStateTransferComplete

func (*Event) GetStateTransferFailed 

func (x *Event) GetStateTransferFailed() *EventStateTransferFailed

func (*Event) GetStep 

func (x *Event) GetStep() *EventStep

func (*Event) GetTickElapsed 

func (x *Event) GetTickElapsed() *EventTickElapsed

func (*Event) GetType 

func (m *Event) GetType() isEvent_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventActionsReceived 

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

func (*EventActionsReceived) Descriptor deprecated 

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

Deprecated: Use EventActionsReceived.ProtoReflect.Descriptor instead.

func (*EventActionsReceived) ProtoMessage 

func (*EventActionsReceived) ProtoMessage()

func (*EventActionsReceived) ProtoReflect 

func (x *EventActionsReceived) ProtoReflect() protoreflect.Message

func (*EventActionsReceived) Reset 

func (x *EventActionsReceived) Reset()

func (*EventActionsReceived) String 

func (x *EventActionsReceived) String() string

type EventCheckpointResult 

type EventCheckpointResult struct {
	SeqNo        uint64             `protobuf:"varint,1,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	Value        []byte             `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	NetworkState *msgs.NetworkState `protobuf:"bytes,3,opt,name=network_state,json=networkState,proto3" json:"network_state,omitempty"`
	Reconfigured bool               `protobuf:"varint,4,opt,name=reconfigured,proto3" json:"reconfigured,omitempty"`
	// contains filtered or unexported fields
}

func (*EventCheckpointResult) Descriptor deprecated 

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

Deprecated: Use EventCheckpointResult.ProtoReflect.Descriptor instead.

func (*EventCheckpointResult) GetNetworkState 

func (x *EventCheckpointResult) GetNetworkState() *msgs.NetworkState

func (*EventCheckpointResult) GetReconfigured 

func (x *EventCheckpointResult) GetReconfigured() bool

func (*EventCheckpointResult) GetSeqNo 

func (x *EventCheckpointResult) GetSeqNo() uint64

func (*EventCheckpointResult) GetValue 

func (x *EventCheckpointResult) GetValue() []byte

func (*EventCheckpointResult) ProtoMessage 

func (*EventCheckpointResult) ProtoMessage()

func (*EventCheckpointResult) ProtoReflect 

func (x *EventCheckpointResult) ProtoReflect() protoreflect.Message

func (*EventCheckpointResult) Reset 

func (x *EventCheckpointResult) Reset()

func (*EventCheckpointResult) String 

func (x *EventCheckpointResult) String() string

type EventHashResult 

type EventHashResult struct {
	Digest []byte      `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	Origin *HashOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*EventHashResult) Descriptor deprecated 

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

Deprecated: Use EventHashResult.ProtoReflect.Descriptor instead.

func (*EventHashResult) GetDigest 

func (x *EventHashResult) GetDigest() []byte

func (*EventHashResult) GetOrigin 

func (x *EventHashResult) GetOrigin() *HashOrigin

func (*EventHashResult) ProtoMessage 

func (*EventHashResult) ProtoMessage()

func (*EventHashResult) ProtoReflect 

func (x *EventHashResult) ProtoReflect() protoreflect.Message

func (*EventHashResult) Reset 

func (x *EventHashResult) Reset()

func (*EventHashResult) String 

func (x *EventHashResult) String() string

type EventInitialParameters 

type EventInitialParameters struct {
	Id                   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	BatchSize            uint32 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	HeartbeatTicks       uint32 `protobuf:"varint,3,opt,name=heartbeat_ticks,json=heartbeatTicks,proto3" json:"heartbeat_ticks,omitempty"`
	SuspectTicks         uint32 `protobuf:"varint,4,opt,name=suspect_ticks,json=suspectTicks,proto3" json:"suspect_ticks,omitempty"`
	NewEpochTimeoutTicks uint32 `` /* 126-byte string literal not displayed */
	BufferSize           uint32 `protobuf:"varint,6,opt,name=buffer_size,json=bufferSize,proto3" json:"buffer_size,omitempty"`
	// contains filtered or unexported fields
}

func (*EventInitialParameters) Descriptor deprecated 

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

Deprecated: Use EventInitialParameters.ProtoReflect.Descriptor instead.

func (*EventInitialParameters) GetBatchSize 

func (x *EventInitialParameters) GetBatchSize() uint32

func (*EventInitialParameters) GetBufferSize 

func (x *EventInitialParameters) GetBufferSize() uint32

func (*EventInitialParameters) GetHeartbeatTicks 

func (x *EventInitialParameters) GetHeartbeatTicks() uint32

func (*EventInitialParameters) GetId 

func (x *EventInitialParameters) GetId() uint64

func (*EventInitialParameters) GetNewEpochTimeoutTicks 

func (x *EventInitialParameters) GetNewEpochTimeoutTicks() uint32

func (*EventInitialParameters) GetSuspectTicks 

func (x *EventInitialParameters) GetSuspectTicks() uint32

func (*EventInitialParameters) ProtoMessage 

func (*EventInitialParameters) ProtoMessage()

func (*EventInitialParameters) ProtoReflect 

func (x *EventInitialParameters) ProtoReflect() protoreflect.Message

func (*EventInitialParameters) Reset 

func (x *EventInitialParameters) Reset()

func (*EventInitialParameters) String 

func (x *EventInitialParameters) String() string

type EventLoadCompleted 

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

func (*EventLoadCompleted) Descriptor deprecated 

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

Deprecated: Use EventLoadCompleted.ProtoReflect.Descriptor instead.

func (*EventLoadCompleted) ProtoMessage 

func (*EventLoadCompleted) ProtoMessage()

func (*EventLoadCompleted) ProtoReflect 

func (x *EventLoadCompleted) ProtoReflect() protoreflect.Message

func (*EventLoadCompleted) Reset 

func (x *EventLoadCompleted) Reset()

func (*EventLoadCompleted) String 

func (x *EventLoadCompleted) String() string

type EventLoadPersistedEntry 

type EventLoadPersistedEntry struct {
	Index uint64           `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Entry *msgs.Persistent `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*EventLoadPersistedEntry) Descriptor deprecated 

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

Deprecated: Use EventLoadPersistedEntry.ProtoReflect.Descriptor instead.

func (*EventLoadPersistedEntry) GetEntry 

func (x *EventLoadPersistedEntry) GetEntry() *msgs.Persistent

func (*EventLoadPersistedEntry) GetIndex 

func (x *EventLoadPersistedEntry) GetIndex() uint64

func (*EventLoadPersistedEntry) ProtoMessage 

func (*EventLoadPersistedEntry) ProtoMessage()

func (*EventLoadPersistedEntry) ProtoReflect 

func (x *EventLoadPersistedEntry) ProtoReflect() protoreflect.Message

func (*EventLoadPersistedEntry) Reset 

func (x *EventLoadPersistedEntry) Reset()

func (*EventLoadPersistedEntry) String 

func (x *EventLoadPersistedEntry) String() string

type EventRequestPersisted 

type EventRequestPersisted struct {
	RequestAck *msgs.RequestAck `protobuf:"bytes,1,opt,name=request_ack,json=requestAck,proto3" json:"request_ack,omitempty"`
	// contains filtered or unexported fields
}

func (*EventRequestPersisted) Descriptor deprecated 

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

Deprecated: Use EventRequestPersisted.ProtoReflect.Descriptor instead.

func (*EventRequestPersisted) GetRequestAck 

func (x *EventRequestPersisted) GetRequestAck() *msgs.RequestAck

func (*EventRequestPersisted) ProtoMessage 

func (*EventRequestPersisted) ProtoMessage()

func (*EventRequestPersisted) ProtoReflect 

func (x *EventRequestPersisted) ProtoReflect() protoreflect.Message

func (*EventRequestPersisted) Reset 

func (x *EventRequestPersisted) Reset()

func (*EventRequestPersisted) String 

func (x *EventRequestPersisted) String() string

type EventStateTransferComplete 

type EventStateTransferComplete struct {
	SeqNo           uint64             `protobuf:"varint,1,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	CheckpointValue []byte             `protobuf:"bytes,2,opt,name=checkpoint_value,json=checkpointValue,proto3" json:"checkpoint_value,omitempty"`
	NetworkState    *msgs.NetworkState `protobuf:"bytes,3,opt,name=network_state,json=networkState,proto3" json:"network_state,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStateTransferComplete) Descriptor deprecated 

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

Deprecated: Use EventStateTransferComplete.ProtoReflect.Descriptor instead.

func (*EventStateTransferComplete) GetCheckpointValue 

func (x *EventStateTransferComplete) GetCheckpointValue() []byte

func (*EventStateTransferComplete) GetNetworkState 

func (x *EventStateTransferComplete) GetNetworkState() *msgs.NetworkState

func (*EventStateTransferComplete) GetSeqNo 

func (x *EventStateTransferComplete) GetSeqNo() uint64

func (*EventStateTransferComplete) ProtoMessage 

func (*EventStateTransferComplete) ProtoMessage()

func (*EventStateTransferComplete) ProtoReflect 

func (x *EventStateTransferComplete) ProtoReflect() protoreflect.Message

func (*EventStateTransferComplete) Reset 

func (x *EventStateTransferComplete) Reset()

func (*EventStateTransferComplete) String 

func (x *EventStateTransferComplete) String() string

type EventStateTransferFailed 

type EventStateTransferFailed struct {
	SeqNo           uint64 `protobuf:"varint,1,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	CheckpointValue []byte `protobuf:"bytes,2,opt,name=checkpoint_value,json=checkpointValue,proto3" json:"checkpoint_value,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStateTransferFailed) Descriptor deprecated 

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

Deprecated: Use EventStateTransferFailed.ProtoReflect.Descriptor instead.

func (*EventStateTransferFailed) GetCheckpointValue 

func (x *EventStateTransferFailed) GetCheckpointValue() []byte

func (*EventStateTransferFailed) GetSeqNo 

func (x *EventStateTransferFailed) GetSeqNo() uint64

func (*EventStateTransferFailed) ProtoMessage 

func (*EventStateTransferFailed) ProtoMessage()

func (*EventStateTransferFailed) ProtoReflect 

func (x *EventStateTransferFailed) ProtoReflect() protoreflect.Message

func (*EventStateTransferFailed) Reset 

func (x *EventStateTransferFailed) Reset()

func (*EventStateTransferFailed) String 

func (x *EventStateTransferFailed) String() string

type EventStep 

type EventStep struct {
	Source uint64    `protobuf:"varint,1,opt,name=source,proto3" json:"source,omitempty"`
	Msg    *msgs.Msg `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStep) Descriptor deprecated 

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

Deprecated: Use EventStep.ProtoReflect.Descriptor instead.

func (*EventStep) GetMsg 

func (x *EventStep) GetMsg() *msgs.Msg

func (*EventStep) GetSource 

func (x *EventStep) GetSource() uint64

func (*EventStep) ProtoMessage 

func (*EventStep) ProtoMessage()

func (*EventStep) ProtoReflect 

func (x *EventStep) ProtoReflect() protoreflect.Message

func (*EventStep) Reset 

func (x *EventStep) Reset()

func (*EventStep) String 

func (x *EventStep) String() string

type EventTickElapsed 

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

func (*EventTickElapsed) Descriptor deprecated 

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

Deprecated: Use EventTickElapsed.ProtoReflect.Descriptor instead.

func (*EventTickElapsed) ProtoMessage 

func (*EventTickElapsed) ProtoMessage()

func (*EventTickElapsed) ProtoReflect 

func (x *EventTickElapsed) ProtoReflect() protoreflect.Message

func (*EventTickElapsed) Reset 

func (x *EventTickElapsed) Reset()

func (*EventTickElapsed) String 

func (x *EventTickElapsed) String() string

type Event_ActionsReceived 

type Event_ActionsReceived struct {
	ActionsReceived *EventActionsReceived `protobuf:"bytes,11,opt,name=actions_received,json=actionsReceived,proto3,oneof"`
}

type Event_CheckpointResult 

type Event_CheckpointResult struct {
	CheckpointResult *EventCheckpointResult `protobuf:"bytes,5,opt,name=checkpoint_result,json=checkpointResult,proto3,oneof"`
}

type Event_CompleteInitialization 

type Event_CompleteInitialization struct {
	CompleteInitialization *EventLoadCompleted `protobuf:"bytes,3,opt,name=complete_initialization,json=completeInitialization,proto3,oneof"`
}

type Event_HashResult 

type Event_HashResult struct {
	HashResult *EventHashResult `protobuf:"bytes,4,opt,name=hash_result,json=hashResult,proto3,oneof"`
}

type Event_Initialize 

type Event_Initialize struct {
	Initialize *EventInitialParameters `protobuf:"bytes,1,opt,name=initialize,proto3,oneof"`
}

type Event_LoadPersistedEntry 

type Event_LoadPersistedEntry struct {
	LoadPersistedEntry *EventLoadPersistedEntry `protobuf:"bytes,2,opt,name=load_persisted_entry,json=loadPersistedEntry,proto3,oneof"`
}

type Event_RequestPersisted 

type Event_RequestPersisted struct {
	RequestPersisted *EventRequestPersisted `protobuf:"bytes,6,opt,name=request_persisted,json=requestPersisted,proto3,oneof"`
}

type Event_StateTransferComplete 

type Event_StateTransferComplete struct {
	StateTransferComplete *EventStateTransferComplete `protobuf:"bytes,7,opt,name=state_transfer_complete,json=stateTransferComplete,proto3,oneof"`
}

type Event_StateTransferFailed 

type Event_StateTransferFailed struct {
	StateTransferFailed *EventStateTransferFailed `protobuf:"bytes,8,opt,name=state_transfer_failed,json=stateTransferFailed,proto3,oneof"`
}

type Event_Step 

type Event_Step struct {
	Step *EventStep `protobuf:"bytes,9,opt,name=step,proto3,oneof"`
}

type Event_TickElapsed 

type Event_TickElapsed struct {
	TickElapsed *EventTickElapsed `protobuf:"bytes,10,opt,name=tick_elapsed,json=tickElapsed,proto3,oneof"`
}

type HashOrigin 

type HashOrigin struct {

	// Types that are assignable to Type:
	//	*HashOrigin_Batch_
	//	*HashOrigin_EpochChange_
	//	*HashOrigin_VerifyBatch_
	Type isHashOrigin_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*HashOrigin) Descriptor deprecated 

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

Deprecated: Use HashOrigin.ProtoReflect.Descriptor instead.

func (*HashOrigin) GetBatch 

func (x *HashOrigin) GetBatch() *HashOrigin_Batch

func (*HashOrigin) GetEpochChange 

func (x *HashOrigin) GetEpochChange() *HashOrigin_EpochChange

func (*HashOrigin) GetType 

func (m *HashOrigin) GetType() isHashOrigin_Type

func (*HashOrigin) GetVerifyBatch 

func (x *HashOrigin) GetVerifyBatch() *HashOrigin_VerifyBatch

func (*HashOrigin) ProtoMessage 

func (*HashOrigin) ProtoMessage()

func (*HashOrigin) ProtoReflect 

func (x *HashOrigin) ProtoReflect() protoreflect.Message

func (*HashOrigin) Reset 

func (x *HashOrigin) Reset()

func (*HashOrigin) String 

func (x *HashOrigin) String() string

type HashOrigin_Batch 

type HashOrigin_Batch struct {
	Source      uint64             `protobuf:"varint,1,opt,name=source,proto3" json:"source,omitempty"`
	Epoch       uint64             `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	SeqNo       uint64             `protobuf:"varint,3,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	RequestAcks []*msgs.RequestAck `protobuf:"bytes,5,rep,name=request_acks,json=requestAcks,proto3" json:"request_acks,omitempty"`
	// contains filtered or unexported fields
}

func (*HashOrigin_Batch) Descriptor deprecated 

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

Deprecated: Use HashOrigin_Batch.ProtoReflect.Descriptor instead.

func (*HashOrigin_Batch) GetEpoch 

func (x *HashOrigin_Batch) GetEpoch() uint64

func (*HashOrigin_Batch) GetRequestAcks 

func (x *HashOrigin_Batch) GetRequestAcks() []*msgs.RequestAck

func (*HashOrigin_Batch) GetSeqNo 

func (x *HashOrigin_Batch) GetSeqNo() uint64

func (*HashOrigin_Batch) GetSource 

func (x *HashOrigin_Batch) GetSource() uint64

func (*HashOrigin_Batch) ProtoMessage 

func (*HashOrigin_Batch) ProtoMessage()

func (*HashOrigin_Batch) ProtoReflect 

func (x *HashOrigin_Batch) ProtoReflect() protoreflect.Message

func (*HashOrigin_Batch) Reset 

func (x *HashOrigin_Batch) Reset()

func (*HashOrigin_Batch) String 

func (x *HashOrigin_Batch) String() string

type HashOrigin_Batch_ 

type HashOrigin_Batch_ struct {
	Batch *HashOrigin_Batch `protobuf:"bytes,1,opt,name=batch,proto3,oneof"`
}

type HashOrigin_EpochChange 

type HashOrigin_EpochChange struct {
	Source      uint64            `protobuf:"varint,1,opt,name=source,proto3" json:"source,omitempty"`
	Origin      uint64            `protobuf:"varint,2,opt,name=origin,proto3" json:"origin,omitempty"`
	EpochChange *msgs.EpochChange `protobuf:"bytes,3,opt,name=epoch_change,json=epochChange,proto3" json:"epoch_change,omitempty"`
	// contains filtered or unexported fields
}

func (*HashOrigin_EpochChange) Descriptor deprecated 

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

Deprecated: Use HashOrigin_EpochChange.ProtoReflect.Descriptor instead.

func (*HashOrigin_EpochChange) GetEpochChange 

func (x *HashOrigin_EpochChange) GetEpochChange() *msgs.EpochChange

func (*HashOrigin_EpochChange) GetOrigin 

func (x *HashOrigin_EpochChange) GetOrigin() uint64

func (*HashOrigin_EpochChange) GetSource 

func (x *HashOrigin_EpochChange) GetSource() uint64

func (*HashOrigin_EpochChange) ProtoMessage 

func (*HashOrigin_EpochChange) ProtoMessage()

func (*HashOrigin_EpochChange) ProtoReflect 

func (x *HashOrigin_EpochChange) ProtoReflect() protoreflect.Message

func (*HashOrigin_EpochChange) Reset 

func (x *HashOrigin_EpochChange) Reset()

func (*HashOrigin_EpochChange) String 

func (x *HashOrigin_EpochChange) String() string

type HashOrigin_EpochChange_ 

type HashOrigin_EpochChange_ struct {
	EpochChange *HashOrigin_EpochChange `protobuf:"bytes,2,opt,name=epoch_change,json=epochChange,proto3,oneof"`
}

type HashOrigin_VerifyBatch 

type HashOrigin_VerifyBatch struct {
	Source         uint64             `protobuf:"varint,1,opt,name=source,proto3" json:"source,omitempty"`
	SeqNo          uint64             `protobuf:"varint,2,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	RequestAcks    []*msgs.RequestAck `protobuf:"bytes,3,rep,name=request_acks,json=requestAcks,proto3" json:"request_acks,omitempty"`
	ExpectedDigest []byte             `protobuf:"bytes,4,opt,name=expected_digest,json=expectedDigest,proto3" json:"expected_digest,omitempty"`
	// contains filtered or unexported fields
}

func (*HashOrigin_VerifyBatch) Descriptor deprecated 

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

Deprecated: Use HashOrigin_VerifyBatch.ProtoReflect.Descriptor instead.

func (*HashOrigin_VerifyBatch) GetExpectedDigest 

func (x *HashOrigin_VerifyBatch) GetExpectedDigest() []byte

func (*HashOrigin_VerifyBatch) GetRequestAcks 

func (x *HashOrigin_VerifyBatch) GetRequestAcks() []*msgs.RequestAck

func (*HashOrigin_VerifyBatch) GetSeqNo 

func (x *HashOrigin_VerifyBatch) GetSeqNo() uint64

func (*HashOrigin_VerifyBatch) GetSource 

func (x *HashOrigin_VerifyBatch) GetSource() uint64

func (*HashOrigin_VerifyBatch) ProtoMessage 

func (*HashOrigin_VerifyBatch) ProtoMessage()

func (*HashOrigin_VerifyBatch) ProtoReflect 

func (x *HashOrigin_VerifyBatch) ProtoReflect() protoreflect.Message

func (*HashOrigin_VerifyBatch) Reset 

func (x *HashOrigin_VerifyBatch) Reset()

func (*HashOrigin_VerifyBatch) String 

func (x *HashOrigin_VerifyBatch) String() string

type HashOrigin_VerifyBatch_ 

type HashOrigin_VerifyBatch_ struct {
	VerifyBatch *HashOrigin_VerifyBatch `protobuf:"bytes,3,opt,name=verify_batch,json=verifyBatch,proto3,oneof"`
}

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.