isspb

package
v0.0.0-...-bd4e2c0 Latest Latest
Warning

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

Go to latest
Published: Sep 19, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_isspb_isspb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Checkpoint

type Checkpoint struct {
	Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Sn    uint64 `protobuf:"varint,2,opt,name=sn,proto3" json:"sn,omitempty"`
	// contains filtered or unexported fields
}

func (*Checkpoint) Descriptor deprecated

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

Deprecated: Use Checkpoint.ProtoReflect.Descriptor instead.

func (*Checkpoint) GetEpoch

func (x *Checkpoint) GetEpoch() uint64

func (*Checkpoint) GetSn

func (x *Checkpoint) GetSn() uint64

func (*Checkpoint) ProtoMessage

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoReflect

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

func (*Checkpoint) Reset

func (x *Checkpoint) Reset()

func (*Checkpoint) String

func (x *Checkpoint) String() string

type ISSEvent

type ISSEvent struct {

	// Types that are assignable to Type:
	//	*ISSEvent_PersistCheckpoint
	//	*ISSEvent_StableCheckpoint
	//	*ISSEvent_PersistStableCheckpoint
	//	*ISSEvent_Sb
	Type isISSEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ISSEvent) Descriptor deprecated

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

Deprecated: Use ISSEvent.ProtoReflect.Descriptor instead.

func (*ISSEvent) GetPersistCheckpoint

func (x *ISSEvent) GetPersistCheckpoint() *PersistCheckpoint

func (*ISSEvent) GetPersistStableCheckpoint

func (x *ISSEvent) GetPersistStableCheckpoint() *PersistStableCheckpoint

func (*ISSEvent) GetSb

func (x *ISSEvent) GetSb() *SBEvent

func (*ISSEvent) GetStableCheckpoint

func (x *ISSEvent) GetStableCheckpoint() *StableCheckpoint

func (*ISSEvent) GetType

func (m *ISSEvent) GetType() isISSEvent_Type

func (*ISSEvent) ProtoMessage

func (*ISSEvent) ProtoMessage()

func (*ISSEvent) ProtoReflect

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

func (*ISSEvent) Reset

func (x *ISSEvent) Reset()

func (*ISSEvent) String

func (x *ISSEvent) String() string

type ISSEvent_PersistCheckpoint

type ISSEvent_PersistCheckpoint struct {
	PersistCheckpoint *PersistCheckpoint `protobuf:"bytes,1,opt,name=persist_checkpoint,json=persistCheckpoint,proto3,oneof"`
}

type ISSEvent_PersistStableCheckpoint

type ISSEvent_PersistStableCheckpoint struct {
	PersistStableCheckpoint *PersistStableCheckpoint `protobuf:"bytes,3,opt,name=persist_stable_checkpoint,json=persistStableCheckpoint,proto3,oneof"`
}

type ISSEvent_Sb

type ISSEvent_Sb struct {
	Sb *SBEvent `protobuf:"bytes,4,opt,name=sb,proto3,oneof"`
}

type ISSEvent_StableCheckpoint

type ISSEvent_StableCheckpoint struct {
	StableCheckpoint *StableCheckpoint `protobuf:"bytes,2,opt,name=stable_checkpoint,json=stableCheckpoint,proto3,oneof"`
}

type ISSHashOrigin

type ISSHashOrigin struct {

	// Types that are assignable to Type:
	//	*ISSHashOrigin_Sb
	//	*ISSHashOrigin_LogEntrySn
	Type isISSHashOrigin_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ISSHashOrigin) Descriptor deprecated

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

Deprecated: Use ISSHashOrigin.ProtoReflect.Descriptor instead.

func (*ISSHashOrigin) GetLogEntrySn

func (x *ISSHashOrigin) GetLogEntrySn() uint64

func (*ISSHashOrigin) GetSb

func (x *ISSHashOrigin) GetSb() *SBHashOrigin

func (*ISSHashOrigin) GetType

func (m *ISSHashOrigin) GetType() isISSHashOrigin_Type

func (*ISSHashOrigin) ProtoMessage

func (*ISSHashOrigin) ProtoMessage()

func (*ISSHashOrigin) ProtoReflect

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

func (*ISSHashOrigin) Reset

func (x *ISSHashOrigin) Reset()

func (*ISSHashOrigin) String

func (x *ISSHashOrigin) String() string

type ISSHashOrigin_LogEntrySn

type ISSHashOrigin_LogEntrySn struct {
	LogEntrySn uint64 `protobuf:"varint,2,opt,name=log_entry_sn,json=logEntrySn,proto3,oneof"`
}

type ISSHashOrigin_Sb

type ISSHashOrigin_Sb struct {
	Sb *SBHashOrigin `protobuf:"bytes,1,opt,name=sb,proto3,oneof"`
}

type ISSMessage

type ISSMessage struct {

	// Types that are assignable to Type:
	//	*ISSMessage_Sb
	//	*ISSMessage_Checkpoint
	//	*ISSMessage_RetransmitRequests
	Type isISSMessage_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ISSMessage) Descriptor deprecated

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

Deprecated: Use ISSMessage.ProtoReflect.Descriptor instead.

func (*ISSMessage) GetCheckpoint

func (x *ISSMessage) GetCheckpoint() *Checkpoint

func (*ISSMessage) GetRetransmitRequests

func (x *ISSMessage) GetRetransmitRequests() *RetransmitRequests

func (*ISSMessage) GetSb

func (x *ISSMessage) GetSb() *SBMessage

func (*ISSMessage) GetType

func (m *ISSMessage) GetType() isISSMessage_Type

func (*ISSMessage) ProtoMessage

func (*ISSMessage) ProtoMessage()

func (*ISSMessage) ProtoReflect

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

func (*ISSMessage) Reset

func (x *ISSMessage) Reset()

func (*ISSMessage) String

func (x *ISSMessage) String() string

type ISSMessage_Checkpoint

type ISSMessage_Checkpoint struct {
	Checkpoint *Checkpoint `protobuf:"bytes,2,opt,name=checkpoint,proto3,oneof"`
}

type ISSMessage_RetransmitRequests

type ISSMessage_RetransmitRequests struct {
	RetransmitRequests *RetransmitRequests `protobuf:"bytes,3,opt,name=retransmit_requests,json=retransmitRequests,proto3,oneof"`
}

type ISSMessage_Sb

type ISSMessage_Sb struct {
	Sb *SBMessage `protobuf:"bytes,1,opt,name=sb,proto3,oneof"`
}

type PersistCheckpoint

type PersistCheckpoint struct {
	Sn          uint64 `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	AppSnapshot []byte `protobuf:"bytes,2,opt,name=app_snapshot,json=appSnapshot,proto3" json:"app_snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*PersistCheckpoint) Descriptor deprecated

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

Deprecated: Use PersistCheckpoint.ProtoReflect.Descriptor instead.

func (*PersistCheckpoint) GetAppSnapshot

func (x *PersistCheckpoint) GetAppSnapshot() []byte

func (*PersistCheckpoint) GetSn

func (x *PersistCheckpoint) GetSn() uint64

func (*PersistCheckpoint) ProtoMessage

func (*PersistCheckpoint) ProtoMessage()

func (*PersistCheckpoint) ProtoReflect

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

func (*PersistCheckpoint) Reset

func (x *PersistCheckpoint) Reset()

func (*PersistCheckpoint) String

func (x *PersistCheckpoint) String() string

type PersistStableCheckpoint

type PersistStableCheckpoint struct {
	StableCheckpoint *StableCheckpoint `protobuf:"bytes,1,opt,name=stable_checkpoint,json=stableCheckpoint,proto3" json:"stable_checkpoint,omitempty"`
	// contains filtered or unexported fields
}

PersistStableCheckpoint needs to be a separate Event from StableCheckpoint, since both are ISSEvents, but, the protocol must differentiate between them. While the former will be applied on recovery from the WAL, the latter serves as a notification to the ISS protocol when a stable checkpoint has been persisted.

func (*PersistStableCheckpoint) Descriptor deprecated

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

Deprecated: Use PersistStableCheckpoint.ProtoReflect.Descriptor instead.

func (*PersistStableCheckpoint) GetStableCheckpoint

func (x *PersistStableCheckpoint) GetStableCheckpoint() *StableCheckpoint

func (*PersistStableCheckpoint) ProtoMessage

func (*PersistStableCheckpoint) ProtoMessage()

func (*PersistStableCheckpoint) ProtoReflect

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

func (*PersistStableCheckpoint) Reset

func (x *PersistStableCheckpoint) Reset()

func (*PersistStableCheckpoint) String

func (x *PersistStableCheckpoint) String() string

type RetransmitRequests

type RetransmitRequests struct {
	Requests []*requestpb.RequestRef `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*RetransmitRequests) Descriptor deprecated

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

Deprecated: Use RetransmitRequests.ProtoReflect.Descriptor instead.

func (*RetransmitRequests) GetRequests

func (x *RetransmitRequests) GetRequests() []*requestpb.RequestRef

func (*RetransmitRequests) ProtoMessage

func (*RetransmitRequests) ProtoMessage()

func (*RetransmitRequests) ProtoReflect

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

func (*RetransmitRequests) Reset

func (x *RetransmitRequests) Reset()

func (*RetransmitRequests) String

func (x *RetransmitRequests) String() string

type SBBatchReady

type SBBatchReady struct {
	Batch               *requestpb.Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	PendingRequestsLeft uint64           `protobuf:"varint,2,opt,name=pending_requests_left,json=pendingRequestsLeft,proto3" json:"pending_requests_left,omitempty"`
	// contains filtered or unexported fields
}

func (*SBBatchReady) Descriptor deprecated

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

Deprecated: Use SBBatchReady.ProtoReflect.Descriptor instead.

func (*SBBatchReady) GetBatch

func (x *SBBatchReady) GetBatch() *requestpb.Batch

func (*SBBatchReady) GetPendingRequestsLeft

func (x *SBBatchReady) GetPendingRequestsLeft() uint64

func (*SBBatchReady) ProtoMessage

func (*SBBatchReady) ProtoMessage()

func (*SBBatchReady) ProtoReflect

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

func (*SBBatchReady) Reset

func (x *SBBatchReady) Reset()

func (*SBBatchReady) String

func (x *SBBatchReady) String() string

type SBCutBatch

type SBCutBatch struct {
	MaxSize uint64 `protobuf:"varint,1,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`
	// contains filtered or unexported fields
}

func (*SBCutBatch) Descriptor deprecated

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

Deprecated: Use SBCutBatch.ProtoReflect.Descriptor instead.

func (*SBCutBatch) GetMaxSize

func (x *SBCutBatch) GetMaxSize() uint64

func (*SBCutBatch) ProtoMessage

func (*SBCutBatch) ProtoMessage()

func (*SBCutBatch) ProtoReflect

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

func (*SBCutBatch) Reset

func (x *SBCutBatch) Reset()

func (*SBCutBatch) String

func (x *SBCutBatch) String() string

type SBDeliver

type SBDeliver struct {
	Sn      uint64           `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Batch   *requestpb.Batch `protobuf:"bytes,2,opt,name=batch,proto3" json:"batch,omitempty"`
	Aborted bool             `protobuf:"varint,3,opt,name=aborted,proto3" json:"aborted,omitempty"`
	// contains filtered or unexported fields
}

func (*SBDeliver) Descriptor deprecated

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

Deprecated: Use SBDeliver.ProtoReflect.Descriptor instead.

func (*SBDeliver) GetAborted

func (x *SBDeliver) GetAborted() bool

func (*SBDeliver) GetBatch

func (x *SBDeliver) GetBatch() *requestpb.Batch

func (*SBDeliver) GetSn

func (x *SBDeliver) GetSn() uint64

func (*SBDeliver) ProtoMessage

func (*SBDeliver) ProtoMessage()

func (*SBDeliver) ProtoReflect

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

func (*SBDeliver) Reset

func (x *SBDeliver) Reset()

func (*SBDeliver) String

func (x *SBDeliver) String() string

type SBEvent

type SBEvent struct {
	Epoch    uint64           `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Instance uint64           `protobuf:"varint,2,opt,name=instance,proto3" json:"instance,omitempty"`
	Event    *SBInstanceEvent `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*SBEvent) Descriptor deprecated

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

Deprecated: Use SBEvent.ProtoReflect.Descriptor instead.

func (*SBEvent) GetEpoch

func (x *SBEvent) GetEpoch() uint64

func (*SBEvent) GetEvent

func (x *SBEvent) GetEvent() *SBInstanceEvent

func (*SBEvent) GetInstance

func (x *SBEvent) GetInstance() uint64

func (*SBEvent) ProtoMessage

func (*SBEvent) ProtoMessage()

func (*SBEvent) ProtoReflect

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

func (*SBEvent) Reset

func (x *SBEvent) Reset()

func (*SBEvent) String

func (x *SBEvent) String() string

type SBHashOrigin

type SBHashOrigin struct {
	Epoch    uint64                `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Instance uint64                `protobuf:"varint,2,opt,name=instance,proto3" json:"instance,omitempty"`
	Origin   *SBInstanceHashOrigin `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*SBHashOrigin) Descriptor deprecated

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

Deprecated: Use SBHashOrigin.ProtoReflect.Descriptor instead.

func (*SBHashOrigin) GetEpoch

func (x *SBHashOrigin) GetEpoch() uint64

func (*SBHashOrigin) GetInstance

func (x *SBHashOrigin) GetInstance() uint64

func (*SBHashOrigin) GetOrigin

func (x *SBHashOrigin) GetOrigin() *SBInstanceHashOrigin

func (*SBHashOrigin) ProtoMessage

func (*SBHashOrigin) ProtoMessage()

func (*SBHashOrigin) ProtoReflect

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

func (*SBHashOrigin) Reset

func (x *SBHashOrigin) Reset()

func (*SBHashOrigin) String

func (x *SBHashOrigin) String() string

type SBHashRequest

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

func (*SBHashRequest) Descriptor deprecated

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

Deprecated: Use SBHashRequest.ProtoReflect.Descriptor instead.

func (*SBHashRequest) GetData

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

func (*SBHashRequest) GetOrigin

func (x *SBHashRequest) GetOrigin() *SBHashOrigin

func (*SBHashRequest) ProtoMessage

func (*SBHashRequest) ProtoMessage()

func (*SBHashRequest) ProtoReflect

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

func (*SBHashRequest) Reset

func (x *SBHashRequest) Reset()

func (*SBHashRequest) String

func (x *SBHashRequest) String() string

type SBHashResult

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

func (*SBHashResult) Descriptor deprecated

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

Deprecated: Use SBHashResult.ProtoReflect.Descriptor instead.

func (*SBHashResult) GetDigest

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

func (*SBHashResult) GetOrigin

func (x *SBHashResult) GetOrigin() *SBInstanceHashOrigin

func (*SBHashResult) ProtoMessage

func (*SBHashResult) ProtoMessage()

func (*SBHashResult) ProtoReflect

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

func (*SBHashResult) Reset

func (x *SBHashResult) Reset()

func (*SBHashResult) String

func (x *SBHashResult) String() string

type SBInit

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

func (*SBInit) Descriptor deprecated

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

Deprecated: Use SBInit.ProtoReflect.Descriptor instead.

func (*SBInit) ProtoMessage

func (*SBInit) ProtoMessage()

func (*SBInit) ProtoReflect

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

func (*SBInit) Reset

func (x *SBInit) Reset()

func (*SBInit) String

func (x *SBInit) String() string

type SBInstanceEvent

type SBInstanceEvent struct {

	// Types that are assignable to Type:
	//	*SBInstanceEvent_Init
	//	*SBInstanceEvent_Deliver
	//	*SBInstanceEvent_MessageReceived
	//	*SBInstanceEvent_PendingRequests
	//	*SBInstanceEvent_Tick
	//	*SBInstanceEvent_CutBatch
	//	*SBInstanceEvent_BatchReady
	//	*SBInstanceEvent_WaitForRequests
	//	*SBInstanceEvent_RequestsReady
	//	*SBInstanceEvent_HashRequest
	//	*SBInstanceEvent_HashResult
	//	*SBInstanceEvent_PbftPersistPreprepare
	//	*SBInstanceEvent_PbftPersistPrepare
	//	*SBInstanceEvent_PbftPersistCommit
	Type isSBInstanceEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*SBInstanceEvent) Descriptor deprecated

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

Deprecated: Use SBInstanceEvent.ProtoReflect.Descriptor instead.

func (*SBInstanceEvent) GetBatchReady

func (x *SBInstanceEvent) GetBatchReady() *SBBatchReady

func (*SBInstanceEvent) GetCutBatch

func (x *SBInstanceEvent) GetCutBatch() *SBCutBatch

func (*SBInstanceEvent) GetDeliver

func (x *SBInstanceEvent) GetDeliver() *SBDeliver

func (*SBInstanceEvent) GetHashRequest

func (x *SBInstanceEvent) GetHashRequest() *SBHashRequest

func (*SBInstanceEvent) GetHashResult

func (x *SBInstanceEvent) GetHashResult() *SBHashResult

func (*SBInstanceEvent) GetInit

func (x *SBInstanceEvent) GetInit() *SBInit

func (*SBInstanceEvent) GetMessageReceived

func (x *SBInstanceEvent) GetMessageReceived() *SBMessageReceived

func (*SBInstanceEvent) GetPbftPersistCommit

func (x *SBInstanceEvent) GetPbftPersistCommit() *isspbftpb.PersistCommit

func (*SBInstanceEvent) GetPbftPersistPrepare

func (x *SBInstanceEvent) GetPbftPersistPrepare() *isspbftpb.PersistPrepare

func (*SBInstanceEvent) GetPbftPersistPreprepare

func (x *SBInstanceEvent) GetPbftPersistPreprepare() *isspbftpb.PersistPreprepare

func (*SBInstanceEvent) GetPendingRequests

func (x *SBInstanceEvent) GetPendingRequests() *SBPendingRequests

func (*SBInstanceEvent) GetRequestsReady

func (x *SBInstanceEvent) GetRequestsReady() *SBRequestsReady

func (*SBInstanceEvent) GetTick

func (x *SBInstanceEvent) GetTick() *SBTick

func (*SBInstanceEvent) GetType

func (m *SBInstanceEvent) GetType() isSBInstanceEvent_Type

func (*SBInstanceEvent) GetWaitForRequests

func (x *SBInstanceEvent) GetWaitForRequests() *SBWaitForRequests

func (*SBInstanceEvent) ProtoMessage

func (*SBInstanceEvent) ProtoMessage()

func (*SBInstanceEvent) ProtoReflect

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

func (*SBInstanceEvent) Reset

func (x *SBInstanceEvent) Reset()

func (*SBInstanceEvent) String

func (x *SBInstanceEvent) String() string

type SBInstanceEvent_BatchReady

type SBInstanceEvent_BatchReady struct {
	BatchReady *SBBatchReady `protobuf:"bytes,7,opt,name=batch_ready,json=batchReady,proto3,oneof"`
}

type SBInstanceEvent_CutBatch

type SBInstanceEvent_CutBatch struct {
	CutBatch *SBCutBatch `protobuf:"bytes,6,opt,name=cut_batch,json=cutBatch,proto3,oneof"`
}

type SBInstanceEvent_Deliver

type SBInstanceEvent_Deliver struct {
	Deliver *SBDeliver `protobuf:"bytes,2,opt,name=deliver,proto3,oneof"`
}

type SBInstanceEvent_HashRequest

type SBInstanceEvent_HashRequest struct {
	HashRequest *SBHashRequest `protobuf:"bytes,10,opt,name=hash_request,json=hashRequest,proto3,oneof"`
}

type SBInstanceEvent_HashResult

type SBInstanceEvent_HashResult struct {
	HashResult *SBHashResult `protobuf:"bytes,11,opt,name=hash_result,json=hashResult,proto3,oneof"`
}

type SBInstanceEvent_Init

type SBInstanceEvent_Init struct {
	Init *SBInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type SBInstanceEvent_MessageReceived

type SBInstanceEvent_MessageReceived struct {
	MessageReceived *SBMessageReceived `protobuf:"bytes,3,opt,name=message_received,json=messageReceived,proto3,oneof"`
}

type SBInstanceEvent_PbftPersistCommit

type SBInstanceEvent_PbftPersistCommit struct {
	PbftPersistCommit *isspbftpb.PersistCommit `protobuf:"bytes,14,opt,name=pbft_persist_commit,json=pbftPersistCommit,proto3,oneof"` //isspbftpb.PreprepareHashResult pbft_hash_result        = 15;
}

type SBInstanceEvent_PbftPersistPrepare

type SBInstanceEvent_PbftPersistPrepare struct {
	PbftPersistPrepare *isspbftpb.PersistPrepare `protobuf:"bytes,13,opt,name=pbft_persist_prepare,json=pbftPersistPrepare,proto3,oneof"`
}

type SBInstanceEvent_PbftPersistPreprepare

type SBInstanceEvent_PbftPersistPreprepare struct {
	PbftPersistPreprepare *isspbftpb.PersistPreprepare `protobuf:"bytes,12,opt,name=pbft_persist_preprepare,json=pbftPersistPreprepare,proto3,oneof"`
}

type SBInstanceEvent_PendingRequests

type SBInstanceEvent_PendingRequests struct {
	PendingRequests *SBPendingRequests `protobuf:"bytes,4,opt,name=pending_requests,json=pendingRequests,proto3,oneof"`
}

type SBInstanceEvent_RequestsReady

type SBInstanceEvent_RequestsReady struct {
	RequestsReady *SBRequestsReady `protobuf:"bytes,9,opt,name=requests_ready,json=requestsReady,proto3,oneof"`
}

type SBInstanceEvent_Tick

type SBInstanceEvent_Tick struct {
	Tick *SBTick `protobuf:"bytes,5,opt,name=tick,proto3,oneof"`
}

type SBInstanceEvent_WaitForRequests

type SBInstanceEvent_WaitForRequests struct {
	WaitForRequests *SBWaitForRequests `protobuf:"bytes,8,opt,name=wait_for_requests,json=waitForRequests,proto3,oneof"`
}

type SBInstanceHashOrigin

type SBInstanceHashOrigin struct {

	// Types that are assignable to Type:
	//	*SBInstanceHashOrigin_PbftPreprepare
	Type isSBInstanceHashOrigin_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*SBInstanceHashOrigin) Descriptor deprecated

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

Deprecated: Use SBInstanceHashOrigin.ProtoReflect.Descriptor instead.

func (*SBInstanceHashOrigin) GetPbftPreprepare

func (x *SBInstanceHashOrigin) GetPbftPreprepare() *isspbftpb.PreprepareHashOrigin

func (*SBInstanceHashOrigin) GetType

func (m *SBInstanceHashOrigin) GetType() isSBInstanceHashOrigin_Type

func (*SBInstanceHashOrigin) ProtoMessage

func (*SBInstanceHashOrigin) ProtoMessage()

func (*SBInstanceHashOrigin) ProtoReflect

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

func (*SBInstanceHashOrigin) Reset

func (x *SBInstanceHashOrigin) Reset()

func (*SBInstanceHashOrigin) String

func (x *SBInstanceHashOrigin) String() string

type SBInstanceHashOrigin_PbftPreprepare

type SBInstanceHashOrigin_PbftPreprepare struct {
	PbftPreprepare *isspbftpb.PreprepareHashOrigin `protobuf:"bytes,1,opt,name=pbft_preprepare,json=pbftPreprepare,proto3,oneof"`
}

type SBInstanceMessage

type SBInstanceMessage struct {

	// Types that are assignable to Type:
	//	*SBInstanceMessage_PbftPreprepare
	//	*SBInstanceMessage_PbftPrepare
	//	*SBInstanceMessage_PbftCommit
	Type isSBInstanceMessage_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*SBInstanceMessage) Descriptor deprecated

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

Deprecated: Use SBInstanceMessage.ProtoReflect.Descriptor instead.

func (*SBInstanceMessage) GetPbftCommit

func (x *SBInstanceMessage) GetPbftCommit() *isspbftpb.Commit

func (*SBInstanceMessage) GetPbftPrepare

func (x *SBInstanceMessage) GetPbftPrepare() *isspbftpb.Prepare

func (*SBInstanceMessage) GetPbftPreprepare

func (x *SBInstanceMessage) GetPbftPreprepare() *isspbftpb.Preprepare

func (*SBInstanceMessage) GetType

func (m *SBInstanceMessage) GetType() isSBInstanceMessage_Type

func (*SBInstanceMessage) ProtoMessage

func (*SBInstanceMessage) ProtoMessage()

func (*SBInstanceMessage) ProtoReflect

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

func (*SBInstanceMessage) Reset

func (x *SBInstanceMessage) Reset()

func (*SBInstanceMessage) String

func (x *SBInstanceMessage) String() string

type SBInstanceMessage_PbftCommit

type SBInstanceMessage_PbftCommit struct {
	PbftCommit *isspbftpb.Commit `protobuf:"bytes,3,opt,name=pbft_commit,json=pbftCommit,proto3,oneof"`
}

type SBInstanceMessage_PbftPrepare

type SBInstanceMessage_PbftPrepare struct {
	PbftPrepare *isspbftpb.Prepare `protobuf:"bytes,2,opt,name=pbft_prepare,json=pbftPrepare,proto3,oneof"`
}

type SBInstanceMessage_PbftPreprepare

type SBInstanceMessage_PbftPreprepare struct {
	PbftPreprepare *isspbftpb.Preprepare `protobuf:"bytes,1,opt,name=pbft_preprepare,json=pbftPreprepare,proto3,oneof"`
}

type SBMessage

type SBMessage struct {
	Epoch    uint64             `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Instance uint64             `protobuf:"varint,2,opt,name=instance,proto3" json:"instance,omitempty"`
	Msg      *SBInstanceMessage `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SBMessage) Descriptor deprecated

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

Deprecated: Use SBMessage.ProtoReflect.Descriptor instead.

func (*SBMessage) GetEpoch

func (x *SBMessage) GetEpoch() uint64

func (*SBMessage) GetInstance

func (x *SBMessage) GetInstance() uint64

func (*SBMessage) GetMsg

func (x *SBMessage) GetMsg() *SBInstanceMessage

func (*SBMessage) ProtoMessage

func (*SBMessage) ProtoMessage()

func (*SBMessage) ProtoReflect

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

func (*SBMessage) Reset

func (x *SBMessage) Reset()

func (*SBMessage) String

func (x *SBMessage) String() string

type SBMessageReceived

type SBMessageReceived struct {
	From uint64             `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	Msg  *SBInstanceMessage `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SBMessageReceived) Descriptor deprecated

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

Deprecated: Use SBMessageReceived.ProtoReflect.Descriptor instead.

func (*SBMessageReceived) GetFrom

func (x *SBMessageReceived) GetFrom() uint64

func (*SBMessageReceived) GetMsg

func (x *SBMessageReceived) GetMsg() *SBInstanceMessage

func (*SBMessageReceived) ProtoMessage

func (*SBMessageReceived) ProtoMessage()

func (*SBMessageReceived) ProtoReflect

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

func (*SBMessageReceived) Reset

func (x *SBMessageReceived) Reset()

func (*SBMessageReceived) String

func (x *SBMessageReceived) String() string

type SBPendingRequests

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

func (*SBPendingRequests) Descriptor deprecated

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

Deprecated: Use SBPendingRequests.ProtoReflect.Descriptor instead.

func (*SBPendingRequests) GetNumRequests

func (x *SBPendingRequests) GetNumRequests() uint64

func (*SBPendingRequests) ProtoMessage

func (*SBPendingRequests) ProtoMessage()

func (*SBPendingRequests) ProtoReflect

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

func (*SBPendingRequests) Reset

func (x *SBPendingRequests) Reset()

func (*SBPendingRequests) String

func (x *SBPendingRequests) String() string

type SBReqWaitReference

type SBReqWaitReference struct {

	// Types that are assignable to Type:
	//	*SBReqWaitReference_Pbft
	Type isSBReqWaitReference_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*SBReqWaitReference) Descriptor deprecated

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

Deprecated: Use SBReqWaitReference.ProtoReflect.Descriptor instead.

func (*SBReqWaitReference) GetPbft

func (*SBReqWaitReference) GetType

func (m *SBReqWaitReference) GetType() isSBReqWaitReference_Type

func (*SBReqWaitReference) ProtoMessage

func (*SBReqWaitReference) ProtoMessage()

func (*SBReqWaitReference) ProtoReflect

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

func (*SBReqWaitReference) Reset

func (x *SBReqWaitReference) Reset()

func (*SBReqWaitReference) String

func (x *SBReqWaitReference) String() string

type SBReqWaitReference_Pbft

type SBReqWaitReference_Pbft struct {
	Pbft *isspbftpb.ReqWaitReference `protobuf:"bytes,1,opt,name=pbft,proto3,oneof"`
}

type SBRequestsReady

type SBRequestsReady struct {
	Ref *SBReqWaitReference `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*SBRequestsReady) Descriptor deprecated

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

Deprecated: Use SBRequestsReady.ProtoReflect.Descriptor instead.

func (*SBRequestsReady) GetRef

func (x *SBRequestsReady) GetRef() *SBReqWaitReference

func (*SBRequestsReady) ProtoMessage

func (*SBRequestsReady) ProtoMessage()

func (*SBRequestsReady) ProtoReflect

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

func (*SBRequestsReady) Reset

func (x *SBRequestsReady) Reset()

func (*SBRequestsReady) String

func (x *SBRequestsReady) String() string

type SBStatus

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

func (*SBStatus) Descriptor deprecated

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

Deprecated: Use SBStatus.ProtoReflect.Descriptor instead.

func (*SBStatus) GetLeader

func (x *SBStatus) GetLeader() uint64

func (*SBStatus) ProtoMessage

func (*SBStatus) ProtoMessage()

func (*SBStatus) ProtoReflect

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

func (*SBStatus) Reset

func (x *SBStatus) Reset()

func (*SBStatus) String

func (x *SBStatus) String() string

type SBTick

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

func (*SBTick) Descriptor deprecated

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

Deprecated: Use SBTick.ProtoReflect.Descriptor instead.

func (*SBTick) ProtoMessage

func (*SBTick) ProtoMessage()

func (*SBTick) ProtoReflect

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

func (*SBTick) Reset

func (x *SBTick) Reset()

func (*SBTick) String

func (x *SBTick) String() string

type SBWaitForRequests

type SBWaitForRequests struct {
	Reference *SBReqWaitReference     `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
	Requests  []*requestpb.RequestRef `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*SBWaitForRequests) Descriptor deprecated

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

Deprecated: Use SBWaitForRequests.ProtoReflect.Descriptor instead.

func (*SBWaitForRequests) GetReference

func (x *SBWaitForRequests) GetReference() *SBReqWaitReference

func (*SBWaitForRequests) GetRequests

func (x *SBWaitForRequests) GetRequests() []*requestpb.RequestRef

func (*SBWaitForRequests) ProtoMessage

func (*SBWaitForRequests) ProtoMessage()

func (*SBWaitForRequests) ProtoReflect

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

func (*SBWaitForRequests) Reset

func (x *SBWaitForRequests) Reset()

func (*SBWaitForRequests) String

func (x *SBWaitForRequests) String() string

type StableCheckpoint

type StableCheckpoint struct {
	Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Sn    uint64 `protobuf:"varint,2,opt,name=sn,proto3" json:"sn,omitempty"` // TODO: Some form of checkpoint certificate will need to go here.
	// contains filtered or unexported fields
}

func (*StableCheckpoint) Descriptor deprecated

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

Deprecated: Use StableCheckpoint.ProtoReflect.Descriptor instead.

func (*StableCheckpoint) GetEpoch

func (x *StableCheckpoint) GetEpoch() uint64

func (*StableCheckpoint) GetSn

func (x *StableCheckpoint) GetSn() uint64

func (*StableCheckpoint) ProtoMessage

func (*StableCheckpoint) ProtoMessage()

func (*StableCheckpoint) ProtoReflect

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

func (*StableCheckpoint) Reset

func (x *StableCheckpoint) Reset()

func (*StableCheckpoint) String

func (x *StableCheckpoint) String() string

type Status

type Status struct {
	Epoch    uint64      `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Orderers []*SBStatus `protobuf:"bytes,2,rep,name=orderers,proto3" json:"orderers,omitempty"` // TODO: Represent whole status here.
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetEpoch

func (x *Status) GetEpoch() uint64

func (*Status) GetOrderers

func (x *Status) GetOrderers() []*SBStatus

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

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

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

Jump to

Keyboard shortcuts

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