Documentation
¶
Index ¶
- Variables
- type AppRestoreState
- func (*AppRestoreState) Descriptor() ([]byte, []int)deprecated
- func (x *AppRestoreState) GetCheckpoint() *checkpointpb.StableCheckpoint
- func (*AppRestoreState) ProtoMessage()
- func (x *AppRestoreState) ProtoReflect() protoreflect.Message
- func (x *AppRestoreState) Reset()
- func (x *AppRestoreState) String() string
- type AppSnapshot
- type AppSnapshotRequest
- func (*AppSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppSnapshotRequest) GetReplyTo() string
- func (*AppSnapshotRequest) ProtoMessage()
- func (x *AppSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *AppSnapshotRequest) Reset()
- func (x *AppSnapshotRequest) String() string
- type DeliverCert
- func (*DeliverCert) Descriptor() ([]byte, []int)deprecated
- func (x *DeliverCert) GetCert() *availabilitypb.Cert
- func (x *DeliverCert) GetSn() uint64
- func (*DeliverCert) ProtoMessage()
- func (x *DeliverCert) ProtoReflect() protoreflect.Message
- func (x *DeliverCert) Reset()
- func (x *DeliverCert) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (e *Event) FollowUp(next *Event) *Event
- func (e *Event) FollowUps(next []*Event)
- func (x *Event) GetAppRestoreState() *AppRestoreState
- func (x *Event) GetAppSnapshot() *AppSnapshot
- func (x *Event) GetAppSnapshotRequest() *AppSnapshotRequest
- func (x *Event) GetAvailability() *availabilitypb.Event
- func (x *Event) GetBatchDb() *batchdbpb.Event
- func (x *Event) GetBatchFetcher() *batchfetcherpb.Event
- func (x *Event) GetBcb() *bcbpb.Event
- func (x *Event) GetCheckpoint() *checkpointpb.Event
- func (x *Event) GetDeliverCert() *DeliverCert
- func (x *Event) GetDestModule() string
- func (x *Event) GetFactory() *factorymodulepb.Factory
- func (x *Event) GetHashRequest() *HashRequest
- func (x *Event) GetHashResult() *HashResult
- func (x *Event) GetInit() *Init
- func (x *Event) GetIss() *isspb.ISSEvent
- func (x *Event) GetMempool() *mempoolpb.Event
- func (x *Event) GetMessageReceived() *MessageReceived
- func (x *Event) GetNewConfig() *NewConfig
- func (x *Event) GetNewEpoch() *NewEpoch
- func (x *Event) GetNewRequests() *NewRequests
- func (x *Event) GetNext() []*Event
- func (x *Event) GetNodeSigsVerified() *NodeSigsVerified
- func (x *Event) GetPingPong() *pingpongpb.Event
- func (x *Event) GetRequestReady() *RequestReady
- func (x *Event) GetRequestSigVerified() *RequestSigVerified
- func (x *Event) GetSendMessage() *SendMessage
- func (x *Event) GetSignRequest() *SignRequest
- func (x *Event) GetSignResult() *SignResult
- func (x *Event) GetStoreVerifiedRequest() *StoreVerifiedRequest
- func (x *Event) GetTestingString() *wrapperspb.StringValue
- func (x *Event) GetTestingUint() *wrapperspb.UInt64Value
- func (x *Event) GetThreshCrypto() *threshcryptopb.Event
- func (x *Event) GetTick() *Tick
- func (x *Event) GetTimerDelay() *TimerDelay
- func (x *Event) GetTimerGarbageCollect() *TimerGarbageCollect
- func (x *Event) GetTimerRepeat() *TimerRepeat
- func (m *Event) GetType() isEvent_Type
- func (x *Event) GetVerifyNodeSigs() *VerifyNodeSigs
- func (x *Event) GetVerifyRequestSig() *VerifyRequestSig
- func (x *Event) GetWalAppend() *WALAppend
- func (x *Event) GetWalEntry() *WALEntry
- func (x *Event) GetWalTruncate() *WALTruncate
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type Event_AppRestoreState
- type Event_AppSnapshot
- type Event_AppSnapshotRequest
- type Event_Availability
- type Event_BatchDb
- type Event_BatchFetcher
- type Event_Bcb
- type Event_Checkpoint
- type Event_DeliverCert
- type Event_Factory
- type Event_HashRequest
- type Event_HashResult
- type Event_Init
- type Event_Iss
- type Event_Mempool
- type Event_MessageReceived
- type Event_NewConfig
- type Event_NewEpoch
- type Event_NewRequests
- type Event_NodeSigsVerified
- type Event_PingPong
- type Event_RequestReady
- type Event_RequestSigVerified
- type Event_SendMessage
- type Event_SignRequest
- type Event_SignResult
- type Event_StoreVerifiedRequest
- type Event_TestingString
- type Event_TestingUint
- type Event_ThreshCrypto
- type Event_Tick
- type Event_TimerDelay
- type Event_TimerGarbageCollect
- type Event_TimerRepeat
- type Event_Type
- type Event_TypeWrapper
- type Event_VerifyNodeSigs
- type Event_VerifyRequestSig
- type Event_WalAppend
- type Event_WalEntry
- type Event_WalTruncate
- type HashOrigin
- func (*HashOrigin) Descriptor() ([]byte, []int)deprecated
- func (x *HashOrigin) GetCheckpoint() *checkpointpb.HashOrigin
- func (x *HashOrigin) GetContextStore() *contextstorepb.Origin
- func (x *HashOrigin) GetDsl() *dslpb.Origin
- func (x *HashOrigin) GetIss() *isspb.ISSHashOrigin
- func (x *HashOrigin) GetModule() string
- func (x *HashOrigin) GetRequest() *requestpb.Request
- func (m *HashOrigin) GetType() isHashOrigin_Type
- func (*HashOrigin) ProtoMessage()
- func (x *HashOrigin) ProtoReflect() protoreflect.Message
- func (x *HashOrigin) Reset()
- func (x *HashOrigin) String() string
- type HashOrigin_Checkpoint
- type HashOrigin_ContextStore
- type HashOrigin_Dsl
- type HashOrigin_Iss
- type HashOrigin_Request
- type HashRequest
- func (*HashRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HashRequest) GetData() []*commonpb.HashData
- func (x *HashRequest) GetOrigin() *HashOrigin
- func (*HashRequest) ProtoMessage()
- func (x *HashRequest) ProtoReflect() protoreflect.Message
- func (x *HashRequest) Reset()
- func (x *HashRequest) String() string
- type HashResult
- func (*HashResult) Descriptor() ([]byte, []int)deprecated
- func (x *HashResult) GetDigests() [][]byte
- func (x *HashResult) GetOrigin() *HashOrigin
- func (*HashResult) ProtoMessage()
- func (x *HashResult) ProtoReflect() protoreflect.Message
- func (x *HashResult) Reset()
- func (x *HashResult) String() string
- type Init
- type MessageReceived
- func (*MessageReceived) Descriptor() ([]byte, []int)deprecated
- func (x *MessageReceived) GetFrom() string
- func (x *MessageReceived) GetMsg() *messagepb.Message
- func (*MessageReceived) ProtoMessage()
- func (x *MessageReceived) ProtoReflect() protoreflect.Message
- func (x *MessageReceived) Reset()
- func (x *MessageReceived) String() string
- type NewConfig
- type NewEpoch
- type NewRequests
- type NodeSigsVerified
- func (*NodeSigsVerified) Descriptor() ([]byte, []int)deprecated
- func (x *NodeSigsVerified) GetAllOk() bool
- func (x *NodeSigsVerified) GetErrors() []string
- func (x *NodeSigsVerified) GetNodeIds() []string
- func (x *NodeSigsVerified) GetOrigin() *SigVerOrigin
- func (x *NodeSigsVerified) GetValid() []bool
- func (*NodeSigsVerified) ProtoMessage()
- func (x *NodeSigsVerified) ProtoReflect() protoreflect.Message
- func (x *NodeSigsVerified) Reset()
- func (x *NodeSigsVerified) String() string
- type RequestReady
- type RequestSigVerified
- func (*RequestSigVerified) Descriptor() ([]byte, []int)deprecated
- func (x *RequestSigVerified) GetError() string
- func (x *RequestSigVerified) GetRequest() *requestpb.Request
- func (x *RequestSigVerified) GetValid() bool
- func (*RequestSigVerified) ProtoMessage()
- func (x *RequestSigVerified) ProtoReflect() protoreflect.Message
- func (x *RequestSigVerified) Reset()
- func (x *RequestSigVerified) String() string
- type SendMessage
- func (*SendMessage) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessage) GetDestinations() []string
- func (x *SendMessage) GetMsg() *messagepb.Message
- func (*SendMessage) ProtoMessage()
- func (x *SendMessage) ProtoReflect() protoreflect.Message
- func (x *SendMessage) Reset()
- func (x *SendMessage) String() string
- type SigVerData
- type SigVerOrigin
- func (*SigVerOrigin) Descriptor() ([]byte, []int)deprecated
- func (x *SigVerOrigin) GetCheckpoint() *checkpointpb.SigVerOrigin
- func (x *SigVerOrigin) GetContextStore() *contextstorepb.Origin
- func (x *SigVerOrigin) GetDsl() *dslpb.Origin
- func (x *SigVerOrigin) GetIss() *isspb.ISSSigVerOrigin
- func (x *SigVerOrigin) GetModule() string
- func (m *SigVerOrigin) GetType() isSigVerOrigin_Type
- func (*SigVerOrigin) ProtoMessage()
- func (x *SigVerOrigin) ProtoReflect() protoreflect.Message
- func (x *SigVerOrigin) Reset()
- func (x *SigVerOrigin) String() string
- type SigVerOrigin_Checkpoint
- type SigVerOrigin_ContextStore
- type SigVerOrigin_Dsl
- type SigVerOrigin_Iss
- type SignOrigin
- func (*SignOrigin) Descriptor() ([]byte, []int)deprecated
- func (x *SignOrigin) GetCheckpoint() *checkpointpb.SignOrigin
- func (x *SignOrigin) GetContextStore() *contextstorepb.Origin
- func (x *SignOrigin) GetDsl() *dslpb.Origin
- func (x *SignOrigin) GetIss() *isspb.ISSSignOrigin
- func (x *SignOrigin) GetModule() string
- func (m *SignOrigin) GetType() isSignOrigin_Type
- func (*SignOrigin) ProtoMessage()
- func (x *SignOrigin) ProtoReflect() protoreflect.Message
- func (x *SignOrigin) Reset()
- func (x *SignOrigin) String() string
- type SignOrigin_Checkpoint
- type SignOrigin_ContextStore
- type SignOrigin_Dsl
- type SignOrigin_Iss
- type SignRequest
- func (*SignRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SignRequest) GetData() [][]byte
- func (x *SignRequest) GetOrigin() *SignOrigin
- func (*SignRequest) ProtoMessage()
- func (x *SignRequest) ProtoReflect() protoreflect.Message
- func (x *SignRequest) Reset()
- func (x *SignRequest) String() string
- type SignResult
- func (*SignResult) Descriptor() ([]byte, []int)deprecated
- func (x *SignResult) GetOrigin() *SignOrigin
- func (x *SignResult) GetSignature() []byte
- func (*SignResult) ProtoMessage()
- func (x *SignResult) ProtoReflect() protoreflect.Message
- func (x *SignResult) Reset()
- func (x *SignResult) String() string
- type StoreVerifiedRequest
- func (*StoreVerifiedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreVerifiedRequest) GetAuthenticator() []byte
- func (x *StoreVerifiedRequest) GetData() []byte
- func (x *StoreVerifiedRequest) GetRequest() *requestpb.Request
- func (*StoreVerifiedRequest) ProtoMessage()
- func (x *StoreVerifiedRequest) ProtoReflect() protoreflect.Message
- func (x *StoreVerifiedRequest) Reset()
- func (x *StoreVerifiedRequest) String() string
- type Tick
- type TimerDelay
- type TimerGarbageCollect
- func (*TimerGarbageCollect) Descriptor() ([]byte, []int)deprecated
- func (x *TimerGarbageCollect) GetRetentionIndex() uint64
- func (*TimerGarbageCollect) ProtoMessage()
- func (x *TimerGarbageCollect) ProtoReflect() protoreflect.Message
- func (x *TimerGarbageCollect) Reset()
- func (x *TimerGarbageCollect) String() string
- type TimerRepeat
- func (*TimerRepeat) Descriptor() ([]byte, []int)deprecated
- func (x *TimerRepeat) GetDelay() uint64
- func (x *TimerRepeat) GetEvents() []*Event
- func (x *TimerRepeat) GetRetentionIndex() uint64
- func (*TimerRepeat) ProtoMessage()
- func (x *TimerRepeat) ProtoReflect() protoreflect.Message
- func (x *TimerRepeat) Reset()
- func (x *TimerRepeat) String() string
- type VerifyNodeSigs
- func (*VerifyNodeSigs) Descriptor() ([]byte, []int)deprecated
- func (x *VerifyNodeSigs) GetData() []*SigVerData
- func (x *VerifyNodeSigs) GetNodeIds() []string
- func (x *VerifyNodeSigs) GetOrigin() *SigVerOrigin
- func (x *VerifyNodeSigs) GetSignatures() [][]byte
- func (*VerifyNodeSigs) ProtoMessage()
- func (x *VerifyNodeSigs) ProtoReflect() protoreflect.Message
- func (x *VerifyNodeSigs) Reset()
- func (x *VerifyNodeSigs) String() string
- type VerifyRequestSig
- func (*VerifyRequestSig) Descriptor() ([]byte, []int)deprecated
- func (x *VerifyRequestSig) GetRequest() *requestpb.Request
- func (x *VerifyRequestSig) GetSignature() []byte
- func (*VerifyRequestSig) ProtoMessage()
- func (x *VerifyRequestSig) ProtoReflect() protoreflect.Message
- func (x *VerifyRequestSig) Reset()
- func (x *VerifyRequestSig) String() string
- type WALAppend
- type WALEntry
- type WALLoadAll
- type WALTruncate
Constants ¶
This section is empty.
Variables ¶
var File_eventpb_eventpb_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AppRestoreState ¶
type AppRestoreState struct {
Checkpoint *checkpointpb.StableCheckpoint `protobuf:"bytes,1,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
// contains filtered or unexported fields
}
func (*AppRestoreState) Descriptor
deprecated
func (*AppRestoreState) Descriptor() ([]byte, []int)
Deprecated: Use AppRestoreState.ProtoReflect.Descriptor instead.
func (*AppRestoreState) GetCheckpoint ¶
func (x *AppRestoreState) GetCheckpoint() *checkpointpb.StableCheckpoint
func (*AppRestoreState) ProtoMessage ¶
func (*AppRestoreState) ProtoMessage()
func (*AppRestoreState) ProtoReflect ¶
func (x *AppRestoreState) ProtoReflect() protoreflect.Message
func (*AppRestoreState) Reset ¶
func (x *AppRestoreState) Reset()
func (*AppRestoreState) String ¶
func (x *AppRestoreState) String() string
type AppSnapshot ¶
type AppSnapshot struct {
AppData []byte `protobuf:"bytes,1,opt,name=app_data,json=appData,proto3" json:"app_data,omitempty"`
// contains filtered or unexported fields
}
func (*AppSnapshot) Descriptor
deprecated
func (*AppSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use AppSnapshot.ProtoReflect.Descriptor instead.
func (*AppSnapshot) GetAppData ¶
func (x *AppSnapshot) GetAppData() []byte
func (*AppSnapshot) ProtoMessage ¶
func (*AppSnapshot) ProtoMessage()
func (*AppSnapshot) ProtoReflect ¶
func (x *AppSnapshot) ProtoReflect() protoreflect.Message
func (*AppSnapshot) Reset ¶
func (x *AppSnapshot) Reset()
func (*AppSnapshot) String ¶
func (x *AppSnapshot) String() string
type AppSnapshotRequest ¶
type AppSnapshotRequest struct {
ReplyTo string `protobuf:"bytes,1,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
// contains filtered or unexported fields
}
func (*AppSnapshotRequest) Descriptor
deprecated
func (*AppSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppSnapshotRequest.ProtoReflect.Descriptor instead.
func (*AppSnapshotRequest) GetReplyTo ¶
func (x *AppSnapshotRequest) GetReplyTo() string
func (*AppSnapshotRequest) ProtoMessage ¶
func (*AppSnapshotRequest) ProtoMessage()
func (*AppSnapshotRequest) ProtoReflect ¶
func (x *AppSnapshotRequest) ProtoReflect() protoreflect.Message
func (*AppSnapshotRequest) Reset ¶
func (x *AppSnapshotRequest) Reset()
func (*AppSnapshotRequest) String ¶
func (x *AppSnapshotRequest) String() string
type DeliverCert ¶
type DeliverCert struct {
Sn uint64 `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
Cert *availabilitypb.Cert `protobuf:"bytes,2,opt,name=cert,proto3" json:"cert,omitempty"`
// contains filtered or unexported fields
}
func (*DeliverCert) Descriptor
deprecated
func (*DeliverCert) Descriptor() ([]byte, []int)
Deprecated: Use DeliverCert.ProtoReflect.Descriptor instead.
func (*DeliverCert) GetCert ¶
func (x *DeliverCert) GetCert() *availabilitypb.Cert
func (*DeliverCert) GetSn ¶
func (x *DeliverCert) GetSn() uint64
func (*DeliverCert) ProtoMessage ¶
func (*DeliverCert) ProtoMessage()
func (*DeliverCert) ProtoReflect ¶
func (x *DeliverCert) ProtoReflect() protoreflect.Message
func (*DeliverCert) Reset ¶
func (x *DeliverCert) Reset()
func (*DeliverCert) String ¶
func (x *DeliverCert) String() string
type Event ¶
type Event struct {
// TODO, normalize naming, for instance Complete/Completed
//
// Types that are assignable to Type:
// *Event_Init
// *Event_Tick
// *Event_WalAppend
// *Event_WalEntry
// *Event_WalTruncate
// *Event_NewRequests
// *Event_HashRequest
// *Event_HashResult
// *Event_SignRequest
// *Event_SignResult
// *Event_VerifyNodeSigs
// *Event_NodeSigsVerified
// *Event_RequestReady
// *Event_SendMessage
// *Event_MessageReceived
// *Event_DeliverCert
// *Event_Iss
// *Event_VerifyRequestSig
// *Event_RequestSigVerified
// *Event_StoreVerifiedRequest
// *Event_AppSnapshotRequest
// *Event_AppSnapshot
// *Event_AppRestoreState
// *Event_TimerDelay
// *Event_TimerRepeat
// *Event_TimerGarbageCollect
// *Event_Bcb
// *Event_Mempool
// *Event_Availability
// *Event_NewEpoch
// *Event_NewConfig
// *Event_Factory
// *Event_BatchDb
// *Event_BatchFetcher
// *Event_ThreshCrypto
// *Event_PingPong
// *Event_Checkpoint
// *Event_TestingString
// *Event_TestingUint
Type isEvent_Type `protobuf_oneof:"type"`
// A list of follow-up events to process after this event has been processed.
// This field is used if events need to be processed in a particular order.
// For example, a message sending event must only be processed
// after the corresponding entry has been persisted in the write-ahead log (WAL).
// In this case, the WAL append event would be this event
// and the next field would contain the message sending event.
Next []*Event `protobuf:"bytes,100,rep,name=next,proto3" json:"next,omitempty"`
DestModule string `protobuf:"bytes,200,opt,name=dest_module,json=destModule,proto3" json:"dest_module,omitempty"`
// contains filtered or unexported fields
}
Event represents a state event to be injected into the state machine
func (*Event) Descriptor
deprecated
func (*Event) FollowUp ¶
FollowUp appends the Event next as a follow-up Event to this Event and returns the next Event (the argument). FollowUp can be called multiple times on the same Event and all the Events added this way will be guaranteed to be applied after this Event. The appended Events are, however, not guaranteed to be applied in any order relative to each other. Events (e.g., e1, e3, e3) that should be applied one after the other can be chained using chained calls to FollowUp: e1.FollowUp(e2).FollowUp(e3) guarantees application in this order. Note that the above expression evaluates to e3 and thus applying the whole expression will only evaluate e3. To process all three Events, e1 (and only e1) must be added to the Node's WorkItems.
func (*Event) FollowUps ¶
FollowUps is like FollowUp, but appends multiple Events and does not return anything (and thus cannot be chained). e.FollowUps([]*Event{e1, e2, e3}) is equivalent to e.FollowUp(e1); e.FollowUp(e2); e.FollowUp(e3)
func (*Event) GetAppRestoreState ¶
func (x *Event) GetAppRestoreState() *AppRestoreState
func (*Event) GetAppSnapshot ¶
func (x *Event) GetAppSnapshot() *AppSnapshot
func (*Event) GetAppSnapshotRequest ¶
func (x *Event) GetAppSnapshotRequest() *AppSnapshotRequest
func (*Event) GetAvailability ¶
func (x *Event) GetAvailability() *availabilitypb.Event
func (*Event) GetBatchDb ¶
func (*Event) GetBatchFetcher ¶
func (x *Event) GetBatchFetcher() *batchfetcherpb.Event
func (*Event) GetCheckpoint ¶
func (x *Event) GetCheckpoint() *checkpointpb.Event
func (*Event) GetDeliverCert ¶
func (x *Event) GetDeliverCert() *DeliverCert
func (*Event) GetDestModule ¶
func (*Event) GetFactory ¶
func (x *Event) GetFactory() *factorymodulepb.Factory
func (*Event) GetHashRequest ¶
func (x *Event) GetHashRequest() *HashRequest
func (*Event) GetHashResult ¶
func (x *Event) GetHashResult() *HashResult
func (*Event) GetMempool ¶
func (*Event) GetMessageReceived ¶
func (x *Event) GetMessageReceived() *MessageReceived
func (*Event) GetNewConfig ¶
func (*Event) GetNewEpoch ¶
func (*Event) GetNewRequests ¶
func (x *Event) GetNewRequests() *NewRequests
func (*Event) GetNodeSigsVerified ¶
func (x *Event) GetNodeSigsVerified() *NodeSigsVerified
func (*Event) GetPingPong ¶
func (x *Event) GetPingPong() *pingpongpb.Event
func (*Event) GetRequestReady ¶
func (x *Event) GetRequestReady() *RequestReady
func (*Event) GetRequestSigVerified ¶
func (x *Event) GetRequestSigVerified() *RequestSigVerified
func (*Event) GetSendMessage ¶
func (x *Event) GetSendMessage() *SendMessage
func (*Event) GetSignRequest ¶
func (x *Event) GetSignRequest() *SignRequest
func (*Event) GetSignResult ¶
func (x *Event) GetSignResult() *SignResult
func (*Event) GetStoreVerifiedRequest ¶
func (x *Event) GetStoreVerifiedRequest() *StoreVerifiedRequest
func (*Event) GetTestingString ¶
func (x *Event) GetTestingString() *wrapperspb.StringValue
func (*Event) GetTestingUint ¶
func (x *Event) GetTestingUint() *wrapperspb.UInt64Value
func (*Event) GetThreshCrypto ¶
func (x *Event) GetThreshCrypto() *threshcryptopb.Event
func (*Event) GetTimerDelay ¶
func (x *Event) GetTimerDelay() *TimerDelay
func (*Event) GetTimerGarbageCollect ¶
func (x *Event) GetTimerGarbageCollect() *TimerGarbageCollect
func (*Event) GetTimerRepeat ¶
func (x *Event) GetTimerRepeat() *TimerRepeat
func (*Event) GetVerifyNodeSigs ¶
func (x *Event) GetVerifyNodeSigs() *VerifyNodeSigs
func (*Event) GetVerifyRequestSig ¶
func (x *Event) GetVerifyRequestSig() *VerifyRequestSig
func (*Event) GetWalAppend ¶
func (*Event) GetWalEntry ¶
func (*Event) GetWalTruncate ¶
func (x *Event) GetWalTruncate() *WALTruncate
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type Event_AppRestoreState ¶
type Event_AppRestoreState struct {
AppRestoreState *AppRestoreState `protobuf:"bytes,24,opt,name=app_restore_state,json=appRestoreState,proto3,oneof"`
}
func (*Event_AppRestoreState) Unwrap ¶
func (p *Event_AppRestoreState) Unwrap() *AppRestoreState
type Event_AppSnapshot ¶
type Event_AppSnapshot struct {
AppSnapshot *AppSnapshot `protobuf:"bytes,23,opt,name=app_snapshot,json=appSnapshot,proto3,oneof"`
}
func (*Event_AppSnapshot) Unwrap ¶
func (p *Event_AppSnapshot) Unwrap() *AppSnapshot
type Event_AppSnapshotRequest ¶
type Event_AppSnapshotRequest struct {
AppSnapshotRequest *AppSnapshotRequest `protobuf:"bytes,22,opt,name=app_snapshot_request,json=appSnapshotRequest,proto3,oneof"`
}
func (*Event_AppSnapshotRequest) Unwrap ¶
func (p *Event_AppSnapshotRequest) Unwrap() *AppSnapshotRequest
type Event_Availability ¶
type Event_Availability struct {
Availability *availabilitypb.Event `protobuf:"bytes,30,opt,name=availability,proto3,oneof"`
}
func (*Event_Availability) Unwrap ¶
func (p *Event_Availability) Unwrap() *availabilitypb.Event
type Event_BatchDb ¶
type Event_BatchDb struct {
BatchDb *batchdbpb.Event `protobuf:"bytes,34,opt,name=batch_db,json=batchDb,proto3,oneof"`
}
func (*Event_BatchDb) Unwrap ¶
func (p *Event_BatchDb) Unwrap() *batchdbpb.Event
type Event_BatchFetcher ¶
type Event_BatchFetcher struct {
BatchFetcher *batchfetcherpb.Event `protobuf:"bytes,35,opt,name=batch_fetcher,json=batchFetcher,proto3,oneof"`
}
func (*Event_BatchFetcher) Unwrap ¶
func (p *Event_BatchFetcher) Unwrap() *batchfetcherpb.Event
type Event_Checkpoint ¶
type Event_Checkpoint struct {
Checkpoint *checkpointpb.Event `protobuf:"bytes,38,opt,name=checkpoint,proto3,oneof"`
}
func (*Event_Checkpoint) Unwrap ¶
func (p *Event_Checkpoint) Unwrap() *checkpointpb.Event
type Event_DeliverCert ¶
type Event_DeliverCert struct {
DeliverCert *DeliverCert `protobuf:"bytes,17,opt,name=deliver_cert,json=deliverCert,proto3,oneof"`
}
func (*Event_DeliverCert) Unwrap ¶
func (p *Event_DeliverCert) Unwrap() *DeliverCert
type Event_Factory ¶
type Event_Factory struct {
Factory *factorymodulepb.Factory `protobuf:"bytes,33,opt,name=factory,proto3,oneof"`
}
func (*Event_Factory) Unwrap ¶
func (p *Event_Factory) Unwrap() *factorymodulepb.Factory
type Event_HashRequest ¶
type Event_HashRequest struct {
HashRequest *HashRequest `protobuf:"bytes,8,opt,name=hash_request,json=hashRequest,proto3,oneof"`
}
func (*Event_HashRequest) Unwrap ¶
func (p *Event_HashRequest) Unwrap() *HashRequest
type Event_HashResult ¶
type Event_HashResult struct {
HashResult *HashResult `protobuf:"bytes,9,opt,name=hash_result,json=hashResult,proto3,oneof"`
}
func (*Event_HashResult) Unwrap ¶
func (p *Event_HashResult) Unwrap() *HashResult
type Event_Init ¶
type Event_Init struct {
Init *Init `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}
func (*Event_Init) Unwrap ¶
func (p *Event_Init) Unwrap() *Init
type Event_Mempool ¶
type Event_Mempool struct {
Mempool *mempoolpb.Event `protobuf:"bytes,29,opt,name=mempool,proto3,oneof"`
}
func (*Event_Mempool) Unwrap ¶
func (p *Event_Mempool) Unwrap() *mempoolpb.Event
type Event_MessageReceived ¶
type Event_MessageReceived struct {
MessageReceived *MessageReceived `protobuf:"bytes,16,opt,name=message_received,json=messageReceived,proto3,oneof"`
}
func (*Event_MessageReceived) Unwrap ¶
func (p *Event_MessageReceived) Unwrap() *MessageReceived
type Event_NewConfig ¶
type Event_NewConfig struct {
NewConfig *NewConfig `protobuf:"bytes,32,opt,name=new_config,json=newConfig,proto3,oneof"`
}
func (*Event_NewConfig) Unwrap ¶
func (p *Event_NewConfig) Unwrap() *NewConfig
type Event_NewEpoch ¶
type Event_NewEpoch struct {
NewEpoch *NewEpoch `protobuf:"bytes,31,opt,name=new_epoch,json=newEpoch,proto3,oneof"`
}
func (*Event_NewEpoch) Unwrap ¶
func (p *Event_NewEpoch) Unwrap() *NewEpoch
type Event_NewRequests ¶
type Event_NewRequests struct {
NewRequests *NewRequests `protobuf:"bytes,7,opt,name=new_requests,json=newRequests,proto3,oneof"`
}
func (*Event_NewRequests) Unwrap ¶
func (p *Event_NewRequests) Unwrap() *NewRequests
type Event_NodeSigsVerified ¶
type Event_NodeSigsVerified struct {
NodeSigsVerified *NodeSigsVerified `protobuf:"bytes,13,opt,name=node_sigs_verified,json=nodeSigsVerified,proto3,oneof"`
}
func (*Event_NodeSigsVerified) Unwrap ¶
func (p *Event_NodeSigsVerified) Unwrap() *NodeSigsVerified
type Event_PingPong ¶
type Event_PingPong struct {
PingPong *pingpongpb.Event `protobuf:"bytes,37,opt,name=ping_pong,json=pingPong,proto3,oneof"`
}
func (*Event_PingPong) Unwrap ¶
func (p *Event_PingPong) Unwrap() *pingpongpb.Event
type Event_RequestReady ¶
type Event_RequestReady struct {
RequestReady *RequestReady `protobuf:"bytes,14,opt,name=request_ready,json=requestReady,proto3,oneof"`
}
func (*Event_RequestReady) Unwrap ¶
func (p *Event_RequestReady) Unwrap() *RequestReady
type Event_RequestSigVerified ¶
type Event_RequestSigVerified struct {
RequestSigVerified *RequestSigVerified `protobuf:"bytes,20,opt,name=request_sig_verified,json=requestSigVerified,proto3,oneof"`
}
func (*Event_RequestSigVerified) Unwrap ¶
func (p *Event_RequestSigVerified) Unwrap() *RequestSigVerified
type Event_SendMessage ¶
type Event_SendMessage struct {
SendMessage *SendMessage `protobuf:"bytes,15,opt,name=send_message,json=sendMessage,proto3,oneof"`
}
func (*Event_SendMessage) Unwrap ¶
func (p *Event_SendMessage) Unwrap() *SendMessage
type Event_SignRequest ¶
type Event_SignRequest struct {
SignRequest *SignRequest `protobuf:"bytes,10,opt,name=sign_request,json=signRequest,proto3,oneof"`
}
func (*Event_SignRequest) Unwrap ¶
func (p *Event_SignRequest) Unwrap() *SignRequest
type Event_SignResult ¶
type Event_SignResult struct {
SignResult *SignResult `protobuf:"bytes,11,opt,name=sign_result,json=signResult,proto3,oneof"`
}
func (*Event_SignResult) Unwrap ¶
func (p *Event_SignResult) Unwrap() *SignResult
type Event_StoreVerifiedRequest ¶
type Event_StoreVerifiedRequest struct {
StoreVerifiedRequest *StoreVerifiedRequest `protobuf:"bytes,21,opt,name=store_verified_request,json=storeVerifiedRequest,proto3,oneof"`
}
func (*Event_StoreVerifiedRequest) Unwrap ¶
func (p *Event_StoreVerifiedRequest) Unwrap() *StoreVerifiedRequest
type Event_TestingString ¶
type Event_TestingString struct {
// for unit-tests
TestingString *wrapperspb.StringValue `protobuf:"bytes,301,opt,name=testingString,proto3,oneof"`
}
func (*Event_TestingString) Unwrap ¶
func (p *Event_TestingString) Unwrap() *wrapperspb.StringValue
type Event_TestingUint ¶
type Event_TestingUint struct {
TestingUint *wrapperspb.UInt64Value `protobuf:"bytes,302,opt,name=testingUint,proto3,oneof"`
}
func (*Event_TestingUint) Unwrap ¶
func (p *Event_TestingUint) Unwrap() *wrapperspb.UInt64Value
type Event_ThreshCrypto ¶
type Event_ThreshCrypto struct {
ThreshCrypto *threshcryptopb.Event `protobuf:"bytes,36,opt,name=thresh_crypto,json=threshCrypto,proto3,oneof"`
}
func (*Event_ThreshCrypto) Unwrap ¶
func (p *Event_ThreshCrypto) Unwrap() *threshcryptopb.Event
type Event_Tick ¶
type Event_Tick struct {
Tick *Tick `protobuf:"bytes,2,opt,name=tick,proto3,oneof"`
}
func (*Event_Tick) Unwrap ¶
func (p *Event_Tick) Unwrap() *Tick
type Event_TimerDelay ¶
type Event_TimerDelay struct {
TimerDelay *TimerDelay `protobuf:"bytes,25,opt,name=timer_delay,json=timerDelay,proto3,oneof"`
}
func (*Event_TimerDelay) Unwrap ¶
func (p *Event_TimerDelay) Unwrap() *TimerDelay
type Event_TimerGarbageCollect ¶
type Event_TimerGarbageCollect struct {
TimerGarbageCollect *TimerGarbageCollect `protobuf:"bytes,27,opt,name=timer_garbage_collect,json=timerGarbageCollect,proto3,oneof"`
}
func (*Event_TimerGarbageCollect) Unwrap ¶
func (p *Event_TimerGarbageCollect) Unwrap() *TimerGarbageCollect
type Event_TimerRepeat ¶
type Event_TimerRepeat struct {
TimerRepeat *TimerRepeat `protobuf:"bytes,26,opt,name=timer_repeat,json=timerRepeat,proto3,oneof"`
}
func (*Event_TimerRepeat) Unwrap ¶
func (p *Event_TimerRepeat) Unwrap() *TimerRepeat
type Event_Type ¶
type Event_Type = isEvent_Type
type Event_TypeWrapper ¶
type Event_TypeWrapper[Ev any] interface { Event_Type Unwrap() *Ev }
type Event_VerifyNodeSigs ¶
type Event_VerifyNodeSigs struct {
VerifyNodeSigs *VerifyNodeSigs `protobuf:"bytes,12,opt,name=verify_node_sigs,json=verifyNodeSigs,proto3,oneof"`
}
func (*Event_VerifyNodeSigs) Unwrap ¶
func (p *Event_VerifyNodeSigs) Unwrap() *VerifyNodeSigs
type Event_VerifyRequestSig ¶
type Event_VerifyRequestSig struct {
VerifyRequestSig *VerifyRequestSig `protobuf:"bytes,19,opt,name=verify_request_sig,json=verifyRequestSig,proto3,oneof"`
}
func (*Event_VerifyRequestSig) Unwrap ¶
func (p *Event_VerifyRequestSig) Unwrap() *VerifyRequestSig
type Event_WalAppend ¶
type Event_WalAppend struct {
WalAppend *WALAppend `protobuf:"bytes,3,opt,name=wal_append,json=walAppend,proto3,oneof"`
}
func (*Event_WalAppend) Unwrap ¶
func (p *Event_WalAppend) Unwrap() *WALAppend
type Event_WalEntry ¶
type Event_WalEntry struct {
WalEntry *WALEntry `protobuf:"bytes,4,opt,name=wal_entry,json=walEntry,proto3,oneof"`
}
func (*Event_WalEntry) Unwrap ¶
func (p *Event_WalEntry) Unwrap() *WALEntry
type Event_WalTruncate ¶
type Event_WalTruncate struct {
WalTruncate *WALTruncate `protobuf:"bytes,5,opt,name=wal_truncate,json=walTruncate,proto3,oneof"`
}
func (*Event_WalTruncate) Unwrap ¶
func (p *Event_WalTruncate) Unwrap() *WALTruncate
type HashOrigin ¶
type HashOrigin struct {
Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
// Types that are assignable to Type:
// *HashOrigin_ContextStore
// *HashOrigin_Request
// *HashOrigin_Iss
// *HashOrigin_Dsl
// *HashOrigin_Checkpoint
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) GetCheckpoint ¶
func (x *HashOrigin) GetCheckpoint() *checkpointpb.HashOrigin
func (*HashOrigin) GetContextStore ¶
func (x *HashOrigin) GetContextStore() *contextstorepb.Origin
func (*HashOrigin) GetDsl ¶
func (x *HashOrigin) GetDsl() *dslpb.Origin
func (*HashOrigin) GetIss ¶
func (x *HashOrigin) GetIss() *isspb.ISSHashOrigin
func (*HashOrigin) GetModule ¶
func (x *HashOrigin) GetModule() string
func (*HashOrigin) GetRequest ¶
func (x *HashOrigin) GetRequest() *requestpb.Request
func (*HashOrigin) GetType ¶
func (m *HashOrigin) GetType() isHashOrigin_Type
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_Checkpoint ¶
type HashOrigin_Checkpoint struct {
Checkpoint *checkpointpb.HashOrigin `protobuf:"bytes,6,opt,name=checkpoint,proto3,oneof"`
}
type HashOrigin_ContextStore ¶
type HashOrigin_ContextStore struct {
ContextStore *contextstorepb.Origin `protobuf:"bytes,2,opt,name=context_store,json=contextStore,proto3,oneof"`
}
type HashOrigin_Dsl ¶
type HashOrigin_Iss ¶
type HashOrigin_Iss struct {
Iss *isspb.ISSHashOrigin `protobuf:"bytes,4,opt,name=iss,proto3,oneof"`
}
type HashOrigin_Request ¶
type HashRequest ¶
type HashRequest struct {
Data []*commonpb.HashData `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 (*HashRequest) Descriptor
deprecated
func (*HashRequest) Descriptor() ([]byte, []int)
Deprecated: Use HashRequest.ProtoReflect.Descriptor instead.
func (*HashRequest) GetData ¶
func (x *HashRequest) GetData() []*commonpb.HashData
func (*HashRequest) GetOrigin ¶
func (x *HashRequest) GetOrigin() *HashOrigin
func (*HashRequest) ProtoMessage ¶
func (*HashRequest) ProtoMessage()
func (*HashRequest) ProtoReflect ¶
func (x *HashRequest) ProtoReflect() protoreflect.Message
func (*HashRequest) Reset ¶
func (x *HashRequest) Reset()
func (*HashRequest) String ¶
func (x *HashRequest) String() string
type HashResult ¶
type HashResult struct {
Digests [][]byte `protobuf:"bytes,1,rep,name=digests,proto3" json:"digests,omitempty"`
Origin *HashOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
// contains filtered or unexported fields
}
func (*HashResult) Descriptor
deprecated
func (*HashResult) Descriptor() ([]byte, []int)
Deprecated: Use HashResult.ProtoReflect.Descriptor instead.
func (*HashResult) GetDigests ¶
func (x *HashResult) GetDigests() [][]byte
func (*HashResult) GetOrigin ¶
func (x *HashResult) GetOrigin() *HashOrigin
func (*HashResult) ProtoMessage ¶
func (*HashResult) ProtoMessage()
func (*HashResult) ProtoReflect ¶
func (x *HashResult) ProtoReflect() protoreflect.Message
func (*HashResult) Reset ¶
func (x *HashResult) Reset()
func (*HashResult) String ¶
func (x *HashResult) String() string
type Init ¶
type Init struct {
// contains filtered or unexported fields
}
func (*Init) Descriptor
deprecated
func (*Init) ProtoMessage ¶
func (*Init) ProtoMessage()
func (*Init) ProtoReflect ¶
func (x *Init) ProtoReflect() protoreflect.Message
type MessageReceived ¶
type MessageReceived struct {
From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
Msg *messagepb.Message `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
// contains filtered or unexported fields
}
func (*MessageReceived) Descriptor
deprecated
func (*MessageReceived) Descriptor() ([]byte, []int)
Deprecated: Use MessageReceived.ProtoReflect.Descriptor instead.
func (*MessageReceived) GetFrom ¶
func (x *MessageReceived) GetFrom() string
func (*MessageReceived) GetMsg ¶
func (x *MessageReceived) GetMsg() *messagepb.Message
func (*MessageReceived) ProtoMessage ¶
func (*MessageReceived) ProtoMessage()
func (*MessageReceived) ProtoReflect ¶
func (x *MessageReceived) ProtoReflect() protoreflect.Message
func (*MessageReceived) Reset ¶
func (x *MessageReceived) Reset()
func (*MessageReceived) String ¶
func (x *MessageReceived) String() string
type NewConfig ¶
type NewConfig struct {
Membership *commonpb.Membership `protobuf:"bytes,1,opt,name=membership,proto3" json:"membership,omitempty"`
// contains filtered or unexported fields
}
func (*NewConfig) Descriptor
deprecated
func (*NewConfig) GetMembership ¶
func (x *NewConfig) GetMembership() *commonpb.Membership
func (*NewConfig) ProtoMessage ¶
func (*NewConfig) ProtoMessage()
func (*NewConfig) ProtoReflect ¶
func (x *NewConfig) ProtoReflect() protoreflect.Message
type NewEpoch ¶
type NewEpoch struct {
EpochNr uint64 `protobuf:"varint,1,opt,name=epoch_nr,json=epochNr,proto3" json:"epoch_nr,omitempty"`
// contains filtered or unexported fields
}
func (*NewEpoch) Descriptor
deprecated
func (*NewEpoch) GetEpochNr ¶
func (*NewEpoch) ProtoMessage ¶
func (*NewEpoch) ProtoMessage()
func (*NewEpoch) ProtoReflect ¶
func (x *NewEpoch) ProtoReflect() protoreflect.Message
type NewRequests ¶
type NewRequests struct {
Requests []*requestpb.Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
// contains filtered or unexported fields
}
func (*NewRequests) Descriptor
deprecated
func (*NewRequests) Descriptor() ([]byte, []int)
Deprecated: Use NewRequests.ProtoReflect.Descriptor instead.
func (*NewRequests) GetRequests ¶
func (x *NewRequests) GetRequests() []*requestpb.Request
func (*NewRequests) ProtoMessage ¶
func (*NewRequests) ProtoMessage()
func (*NewRequests) ProtoReflect ¶
func (x *NewRequests) ProtoReflect() protoreflect.Message
func (*NewRequests) Reset ¶
func (x *NewRequests) Reset()
func (*NewRequests) String ¶
func (x *NewRequests) String() string
type NodeSigsVerified ¶
type NodeSigsVerified struct {
Origin *SigVerOrigin `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
NodeIds []string `protobuf:"bytes,2,rep,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
Valid []bool `protobuf:"varint,3,rep,packed,name=valid,proto3" json:"valid,omitempty"`
Errors []string `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
AllOk bool `protobuf:"varint,5,opt,name=all_ok,json=allOk,proto3" json:"all_ok,omitempty"`
// contains filtered or unexported fields
}
func (*NodeSigsVerified) Descriptor
deprecated
func (*NodeSigsVerified) Descriptor() ([]byte, []int)
Deprecated: Use NodeSigsVerified.ProtoReflect.Descriptor instead.
func (*NodeSigsVerified) GetAllOk ¶
func (x *NodeSigsVerified) GetAllOk() bool
func (*NodeSigsVerified) GetErrors ¶
func (x *NodeSigsVerified) GetErrors() []string
func (*NodeSigsVerified) GetNodeIds ¶
func (x *NodeSigsVerified) GetNodeIds() []string
func (*NodeSigsVerified) GetOrigin ¶
func (x *NodeSigsVerified) GetOrigin() *SigVerOrigin
func (*NodeSigsVerified) GetValid ¶
func (x *NodeSigsVerified) GetValid() []bool
func (*NodeSigsVerified) ProtoMessage ¶
func (*NodeSigsVerified) ProtoMessage()
func (*NodeSigsVerified) ProtoReflect ¶
func (x *NodeSigsVerified) ProtoReflect() protoreflect.Message
func (*NodeSigsVerified) Reset ¶
func (x *NodeSigsVerified) Reset()
func (*NodeSigsVerified) String ¶
func (x *NodeSigsVerified) String() string
type RequestReady ¶
type RequestReady struct {
Request *requestpb.Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
// contains filtered or unexported fields
}
func (*RequestReady) Descriptor
deprecated
func (*RequestReady) Descriptor() ([]byte, []int)
Deprecated: Use RequestReady.ProtoReflect.Descriptor instead.
func (*RequestReady) GetRequest ¶
func (x *RequestReady) GetRequest() *requestpb.Request
func (*RequestReady) ProtoMessage ¶
func (*RequestReady) ProtoMessage()
func (*RequestReady) ProtoReflect ¶
func (x *RequestReady) ProtoReflect() protoreflect.Message
func (*RequestReady) Reset ¶
func (x *RequestReady) Reset()
func (*RequestReady) String ¶
func (x *RequestReady) String() string
type RequestSigVerified ¶
type RequestSigVerified struct {
Request *requestpb.Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
Valid bool `protobuf:"varint,2,opt,name=valid,proto3" json:"valid,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*RequestSigVerified) Descriptor
deprecated
func (*RequestSigVerified) Descriptor() ([]byte, []int)
Deprecated: Use RequestSigVerified.ProtoReflect.Descriptor instead.
func (*RequestSigVerified) GetError ¶
func (x *RequestSigVerified) GetError() string
func (*RequestSigVerified) GetRequest ¶
func (x *RequestSigVerified) GetRequest() *requestpb.Request
func (*RequestSigVerified) GetValid ¶
func (x *RequestSigVerified) GetValid() bool
func (*RequestSigVerified) ProtoMessage ¶
func (*RequestSigVerified) ProtoMessage()
func (*RequestSigVerified) ProtoReflect ¶
func (x *RequestSigVerified) ProtoReflect() protoreflect.Message
func (*RequestSigVerified) Reset ¶
func (x *RequestSigVerified) Reset()
func (*RequestSigVerified) String ¶
func (x *RequestSigVerified) String() string
type SendMessage ¶
type SendMessage struct {
Destinations []string `protobuf:"bytes,1,rep,name=destinations,proto3" json:"destinations,omitempty"`
Msg *messagepb.Message `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
// contains filtered or unexported fields
}
func (*SendMessage) Descriptor
deprecated
func (*SendMessage) Descriptor() ([]byte, []int)
Deprecated: Use SendMessage.ProtoReflect.Descriptor instead.
func (*SendMessage) GetDestinations ¶
func (x *SendMessage) GetDestinations() []string
func (*SendMessage) GetMsg ¶
func (x *SendMessage) GetMsg() *messagepb.Message
func (*SendMessage) ProtoMessage ¶
func (*SendMessage) ProtoMessage()
func (*SendMessage) ProtoReflect ¶
func (x *SendMessage) ProtoReflect() protoreflect.Message
func (*SendMessage) Reset ¶
func (x *SendMessage) Reset()
func (*SendMessage) String ¶
func (x *SendMessage) String() string
type SigVerData ¶
type SigVerData struct {
Data [][]byte `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*SigVerData) Descriptor
deprecated
func (*SigVerData) Descriptor() ([]byte, []int)
Deprecated: Use SigVerData.ProtoReflect.Descriptor instead.
func (*SigVerData) GetData ¶
func (x *SigVerData) GetData() [][]byte
func (*SigVerData) ProtoMessage ¶
func (*SigVerData) ProtoMessage()
func (*SigVerData) ProtoReflect ¶
func (x *SigVerData) ProtoReflect() protoreflect.Message
func (*SigVerData) Reset ¶
func (x *SigVerData) Reset()
func (*SigVerData) String ¶
func (x *SigVerData) String() string
type SigVerOrigin ¶
type SigVerOrigin struct {
Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
// Types that are assignable to Type:
// *SigVerOrigin_ContextStore
// *SigVerOrigin_Iss
// *SigVerOrigin_Dsl
// *SigVerOrigin_Checkpoint
Type isSigVerOrigin_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
func (*SigVerOrigin) Descriptor
deprecated
func (*SigVerOrigin) Descriptor() ([]byte, []int)
Deprecated: Use SigVerOrigin.ProtoReflect.Descriptor instead.
func (*SigVerOrigin) GetCheckpoint ¶
func (x *SigVerOrigin) GetCheckpoint() *checkpointpb.SigVerOrigin
func (*SigVerOrigin) GetContextStore ¶
func (x *SigVerOrigin) GetContextStore() *contextstorepb.Origin
func (*SigVerOrigin) GetDsl ¶
func (x *SigVerOrigin) GetDsl() *dslpb.Origin
func (*SigVerOrigin) GetIss ¶
func (x *SigVerOrigin) GetIss() *isspb.ISSSigVerOrigin
func (*SigVerOrigin) GetModule ¶
func (x *SigVerOrigin) GetModule() string
func (*SigVerOrigin) GetType ¶
func (m *SigVerOrigin) GetType() isSigVerOrigin_Type
func (*SigVerOrigin) ProtoMessage ¶
func (*SigVerOrigin) ProtoMessage()
func (*SigVerOrigin) ProtoReflect ¶
func (x *SigVerOrigin) ProtoReflect() protoreflect.Message
func (*SigVerOrigin) Reset ¶
func (x *SigVerOrigin) Reset()
func (*SigVerOrigin) String ¶
func (x *SigVerOrigin) String() string
type SigVerOrigin_Checkpoint ¶
type SigVerOrigin_Checkpoint struct {
Checkpoint *checkpointpb.SigVerOrigin `protobuf:"bytes,5,opt,name=checkpoint,proto3,oneof"`
}
type SigVerOrigin_ContextStore ¶
type SigVerOrigin_ContextStore struct {
ContextStore *contextstorepb.Origin `protobuf:"bytes,2,opt,name=context_store,json=contextStore,proto3,oneof"`
}
type SigVerOrigin_Dsl ¶
type SigVerOrigin_Iss ¶
type SigVerOrigin_Iss struct {
Iss *isspb.ISSSigVerOrigin `protobuf:"bytes,3,opt,name=iss,proto3,oneof"`
}
type SignOrigin ¶
type SignOrigin struct {
Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
// Types that are assignable to Type:
// *SignOrigin_ContextStore
// *SignOrigin_Iss
// *SignOrigin_Dsl
// *SignOrigin_Checkpoint
Type isSignOrigin_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
func (*SignOrigin) Descriptor
deprecated
func (*SignOrigin) Descriptor() ([]byte, []int)
Deprecated: Use SignOrigin.ProtoReflect.Descriptor instead.
func (*SignOrigin) GetCheckpoint ¶
func (x *SignOrigin) GetCheckpoint() *checkpointpb.SignOrigin
func (*SignOrigin) GetContextStore ¶
func (x *SignOrigin) GetContextStore() *contextstorepb.Origin
func (*SignOrigin) GetDsl ¶
func (x *SignOrigin) GetDsl() *dslpb.Origin
func (*SignOrigin) GetIss ¶
func (x *SignOrigin) GetIss() *isspb.ISSSignOrigin
func (*SignOrigin) GetModule ¶
func (x *SignOrigin) GetModule() string
func (*SignOrigin) GetType ¶
func (m *SignOrigin) GetType() isSignOrigin_Type
func (*SignOrigin) ProtoMessage ¶
func (*SignOrigin) ProtoMessage()
func (*SignOrigin) ProtoReflect ¶
func (x *SignOrigin) ProtoReflect() protoreflect.Message
func (*SignOrigin) Reset ¶
func (x *SignOrigin) Reset()
func (*SignOrigin) String ¶
func (x *SignOrigin) String() string
type SignOrigin_Checkpoint ¶
type SignOrigin_Checkpoint struct {
Checkpoint *checkpointpb.SignOrigin `protobuf:"bytes,5,opt,name=checkpoint,proto3,oneof"`
}
type SignOrigin_ContextStore ¶
type SignOrigin_ContextStore struct {
ContextStore *contextstorepb.Origin `protobuf:"bytes,2,opt,name=context_store,json=contextStore,proto3,oneof"`
}
type SignOrigin_Dsl ¶
type SignOrigin_Iss ¶
type SignOrigin_Iss struct {
Iss *isspb.ISSSignOrigin `protobuf:"bytes,3,opt,name=iss,proto3,oneof"`
}
type SignRequest ¶
type SignRequest struct {
Data [][]byte `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
Origin *SignOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
// contains filtered or unexported fields
}
func (*SignRequest) Descriptor
deprecated
func (*SignRequest) Descriptor() ([]byte, []int)
Deprecated: Use SignRequest.ProtoReflect.Descriptor instead.
func (*SignRequest) GetData ¶
func (x *SignRequest) GetData() [][]byte
func (*SignRequest) GetOrigin ¶
func (x *SignRequest) GetOrigin() *SignOrigin
func (*SignRequest) ProtoMessage ¶
func (*SignRequest) ProtoMessage()
func (*SignRequest) ProtoReflect ¶
func (x *SignRequest) ProtoReflect() protoreflect.Message
func (*SignRequest) Reset ¶
func (x *SignRequest) Reset()
func (*SignRequest) String ¶
func (x *SignRequest) String() string
type SignResult ¶
type SignResult struct {
Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
Origin *SignOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
// contains filtered or unexported fields
}
func (*SignResult) Descriptor
deprecated
func (*SignResult) Descriptor() ([]byte, []int)
Deprecated: Use SignResult.ProtoReflect.Descriptor instead.
func (*SignResult) GetOrigin ¶
func (x *SignResult) GetOrigin() *SignOrigin
func (*SignResult) GetSignature ¶
func (x *SignResult) GetSignature() []byte
func (*SignResult) ProtoMessage ¶
func (*SignResult) ProtoMessage()
func (*SignResult) ProtoReflect ¶
func (x *SignResult) ProtoReflect() protoreflect.Message
func (*SignResult) Reset ¶
func (x *SignResult) Reset()
func (*SignResult) String ¶
func (x *SignResult) String() string
type StoreVerifiedRequest ¶
type StoreVerifiedRequest struct {
Request *requestpb.Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
Authenticator []byte `protobuf:"bytes,3,opt,name=authenticator,proto3" json:"authenticator,omitempty"`
// contains filtered or unexported fields
}
func (*StoreVerifiedRequest) Descriptor
deprecated
func (*StoreVerifiedRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreVerifiedRequest.ProtoReflect.Descriptor instead.
func (*StoreVerifiedRequest) GetAuthenticator ¶
func (x *StoreVerifiedRequest) GetAuthenticator() []byte
func (*StoreVerifiedRequest) GetData ¶
func (x *StoreVerifiedRequest) GetData() []byte
func (*StoreVerifiedRequest) GetRequest ¶
func (x *StoreVerifiedRequest) GetRequest() *requestpb.Request
func (*StoreVerifiedRequest) ProtoMessage ¶
func (*StoreVerifiedRequest) ProtoMessage()
func (*StoreVerifiedRequest) ProtoReflect ¶
func (x *StoreVerifiedRequest) ProtoReflect() protoreflect.Message
func (*StoreVerifiedRequest) Reset ¶
func (x *StoreVerifiedRequest) Reset()
func (*StoreVerifiedRequest) String ¶
func (x *StoreVerifiedRequest) String() string
type Tick ¶
type Tick struct {
// contains filtered or unexported fields
}
func (*Tick) Descriptor
deprecated
func (*Tick) ProtoMessage ¶
func (*Tick) ProtoMessage()
func (*Tick) ProtoReflect ¶
func (x *Tick) ProtoReflect() protoreflect.Message
type TimerDelay ¶
type TimerDelay struct {
Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
Delay uint64 `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
// contains filtered or unexported fields
}
func (*TimerDelay) Descriptor
deprecated
func (*TimerDelay) Descriptor() ([]byte, []int)
Deprecated: Use TimerDelay.ProtoReflect.Descriptor instead.
func (*TimerDelay) GetDelay ¶
func (x *TimerDelay) GetDelay() uint64
func (*TimerDelay) GetEvents ¶
func (x *TimerDelay) GetEvents() []*Event
func (*TimerDelay) ProtoMessage ¶
func (*TimerDelay) ProtoMessage()
func (*TimerDelay) ProtoReflect ¶
func (x *TimerDelay) ProtoReflect() protoreflect.Message
func (*TimerDelay) Reset ¶
func (x *TimerDelay) Reset()
func (*TimerDelay) String ¶
func (x *TimerDelay) String() string
type TimerGarbageCollect ¶
type TimerGarbageCollect struct {
RetentionIndex uint64 `protobuf:"varint,1,opt,name=retention_index,json=retentionIndex,proto3" json:"retention_index,omitempty"`
// contains filtered or unexported fields
}
func (*TimerGarbageCollect) Descriptor
deprecated
func (*TimerGarbageCollect) Descriptor() ([]byte, []int)
Deprecated: Use TimerGarbageCollect.ProtoReflect.Descriptor instead.
func (*TimerGarbageCollect) GetRetentionIndex ¶
func (x *TimerGarbageCollect) GetRetentionIndex() uint64
func (*TimerGarbageCollect) ProtoMessage ¶
func (*TimerGarbageCollect) ProtoMessage()
func (*TimerGarbageCollect) ProtoReflect ¶
func (x *TimerGarbageCollect) ProtoReflect() protoreflect.Message
func (*TimerGarbageCollect) Reset ¶
func (x *TimerGarbageCollect) Reset()
func (*TimerGarbageCollect) String ¶
func (x *TimerGarbageCollect) String() string
type TimerRepeat ¶
type TimerRepeat struct {
Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
Delay uint64 `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
RetentionIndex uint64 `protobuf:"varint,3,opt,name=retention_index,json=retentionIndex,proto3" json:"retention_index,omitempty"`
// contains filtered or unexported fields
}
func (*TimerRepeat) Descriptor
deprecated
func (*TimerRepeat) Descriptor() ([]byte, []int)
Deprecated: Use TimerRepeat.ProtoReflect.Descriptor instead.
func (*TimerRepeat) GetDelay ¶
func (x *TimerRepeat) GetDelay() uint64
func (*TimerRepeat) GetEvents ¶
func (x *TimerRepeat) GetEvents() []*Event
func (*TimerRepeat) GetRetentionIndex ¶
func (x *TimerRepeat) GetRetentionIndex() uint64
func (*TimerRepeat) ProtoMessage ¶
func (*TimerRepeat) ProtoMessage()
func (*TimerRepeat) ProtoReflect ¶
func (x *TimerRepeat) ProtoReflect() protoreflect.Message
func (*TimerRepeat) Reset ¶
func (x *TimerRepeat) Reset()
func (*TimerRepeat) String ¶
func (x *TimerRepeat) String() string
type VerifyNodeSigs ¶
type VerifyNodeSigs struct {
Data []*SigVerData `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
Signatures [][]byte `protobuf:"bytes,2,rep,name=signatures,proto3" json:"signatures,omitempty"`
Origin *SigVerOrigin `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
NodeIds []string `protobuf:"bytes,4,rep,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
// contains filtered or unexported fields
}
func (*VerifyNodeSigs) Descriptor
deprecated
func (*VerifyNodeSigs) Descriptor() ([]byte, []int)
Deprecated: Use VerifyNodeSigs.ProtoReflect.Descriptor instead.
func (*VerifyNodeSigs) GetData ¶
func (x *VerifyNodeSigs) GetData() []*SigVerData
func (*VerifyNodeSigs) GetNodeIds ¶
func (x *VerifyNodeSigs) GetNodeIds() []string
func (*VerifyNodeSigs) GetOrigin ¶
func (x *VerifyNodeSigs) GetOrigin() *SigVerOrigin
func (*VerifyNodeSigs) GetSignatures ¶
func (x *VerifyNodeSigs) GetSignatures() [][]byte
func (*VerifyNodeSigs) ProtoMessage ¶
func (*VerifyNodeSigs) ProtoMessage()
func (*VerifyNodeSigs) ProtoReflect ¶
func (x *VerifyNodeSigs) ProtoReflect() protoreflect.Message
func (*VerifyNodeSigs) Reset ¶
func (x *VerifyNodeSigs) Reset()
func (*VerifyNodeSigs) String ¶
func (x *VerifyNodeSigs) String() string
type VerifyRequestSig ¶
type VerifyRequestSig struct {
Request *requestpb.Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
// contains filtered or unexported fields
}
func (*VerifyRequestSig) Descriptor
deprecated
func (*VerifyRequestSig) Descriptor() ([]byte, []int)
Deprecated: Use VerifyRequestSig.ProtoReflect.Descriptor instead.
func (*VerifyRequestSig) GetRequest ¶
func (x *VerifyRequestSig) GetRequest() *requestpb.Request
func (*VerifyRequestSig) GetSignature ¶
func (x *VerifyRequestSig) GetSignature() []byte
func (*VerifyRequestSig) ProtoMessage ¶
func (*VerifyRequestSig) ProtoMessage()
func (*VerifyRequestSig) ProtoReflect ¶
func (x *VerifyRequestSig) ProtoReflect() protoreflect.Message
func (*VerifyRequestSig) Reset ¶
func (x *VerifyRequestSig) Reset()
func (*VerifyRequestSig) String ¶
func (x *VerifyRequestSig) String() string
type WALAppend ¶
type WALAppend struct {
Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
RetentionIndex uint64 `protobuf:"varint,2,opt,name=retention_index,json=retentionIndex,proto3" json:"retention_index,omitempty"`
// contains filtered or unexported fields
}
func (*WALAppend) Descriptor
deprecated
func (*WALAppend) GetRetentionIndex ¶
func (*WALAppend) ProtoMessage ¶
func (*WALAppend) ProtoMessage()
func (*WALAppend) ProtoReflect ¶
func (x *WALAppend) ProtoReflect() protoreflect.Message
type WALEntry ¶
type WALEntry struct {
Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
// contains filtered or unexported fields
}
func (*WALEntry) Descriptor
deprecated
func (*WALEntry) ProtoMessage ¶
func (*WALEntry) ProtoMessage()
func (*WALEntry) ProtoReflect ¶
func (x *WALEntry) ProtoReflect() protoreflect.Message
type WALLoadAll ¶
type WALLoadAll struct {
// contains filtered or unexported fields
}
func (*WALLoadAll) Descriptor
deprecated
func (*WALLoadAll) Descriptor() ([]byte, []int)
Deprecated: Use WALLoadAll.ProtoReflect.Descriptor instead.
func (*WALLoadAll) ProtoMessage ¶
func (*WALLoadAll) ProtoMessage()
func (*WALLoadAll) ProtoReflect ¶
func (x *WALLoadAll) ProtoReflect() protoreflect.Message
func (*WALLoadAll) Reset ¶
func (x *WALLoadAll) Reset()
func (*WALLoadAll) String ¶
func (x *WALLoadAll) String() string
type WALTruncate ¶
type WALTruncate struct {
RetentionIndex uint64 `protobuf:"varint,1,opt,name=retention_index,json=retentionIndex,proto3" json:"retention_index,omitempty"`
// contains filtered or unexported fields
}
func (*WALTruncate) Descriptor
deprecated
func (*WALTruncate) Descriptor() ([]byte, []int)
Deprecated: Use WALTruncate.ProtoReflect.Descriptor instead.
func (*WALTruncate) GetRetentionIndex ¶
func (x *WALTruncate) GetRetentionIndex() uint64
func (*WALTruncate) ProtoMessage ¶
func (*WALTruncate) ProtoMessage()
func (*WALTruncate) ProtoReflect ¶
func (x *WALTruncate) ProtoReflect() protoreflect.Message
func (*WALTruncate) Reset ¶
func (x *WALTruncate) Reset()
func (*WALTruncate) String ¶
func (x *WALTruncate) String() string