eventpb

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_eventpb_eventpb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Event 

type Event struct {
	DestModule string `protobuf:"bytes,1,opt,name=dest_module,json=destModule,proto3" json:"dest_module,omitempty"`
	// Types that are assignable to Type:
	//	*Event_Init
	//	*Event_Timer
	//	*Event_Hasher
	//	*Event_Bcb
	//	*Event_Mempool
	//	*Event_Availability
	//	*Event_BatchDb
	//	*Event_BatchFetcher
	//	*Event_ThreshCrypto
	//	*Event_Checkpoint
	//	*Event_Factory
	//	*Event_Iss
	//	*Event_Orderer
	//	*Event_Crypto
	//	*Event_App
	//	*Event_Transport
	//	*Event_PingPong
	//	*Event_TestingString
	//	*Event_TestingUint
	//	*Event_Tester
	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.
	// (This is a hypothetical example, the WAL functionality is not implemented at a moment.)
	Next []*Event `protobuf:"bytes,400,rep,name=next,proto3" json:"next,omitempty"`
	// 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) GetApp added in v0.4.0 

func (x *Event) GetApp() *apppb.Event

func (*Event) GetAvailability 

func (x *Event) GetAvailability() *availabilitypb.Event

func (*Event) GetBatchDb 

func (x *Event) GetBatchDb() *batchdbpb.Event

func (*Event) GetBatchFetcher 

func (x *Event) GetBatchFetcher() *batchfetcherpb.Event

func (*Event) GetBcb 

func (x *Event) GetBcb() *bcbpb.Event

func (*Event) GetCheckpoint 

func (x *Event) GetCheckpoint() *checkpointpb.Event

func (*Event) GetCrypto added in v0.4.0 

func (x *Event) GetCrypto() *cryptopb.Event

func (*Event) GetDestModule 

func (x *Event) GetDestModule() string

func (*Event) GetFactory 

func (x *Event) GetFactory() *factorypb.Event

func (*Event) GetHasher added in v0.4.0 

func (x *Event) GetHasher() *hasherpb.Event

func (*Event) GetInit 

func (x *Event) GetInit() *Init

func (*Event) GetIss 

func (x *Event) GetIss() *isspb.Event

func (*Event) GetMempool 

func (x *Event) GetMempool() *mempoolpb.Event

func (*Event) GetNext 

func (x *Event) GetNext() []*Event

func (*Event) GetOrderer added in v0.4.0 

func (x *Event) GetOrderer() *ordererpb.Event

func (*Event) GetPingPong 

func (x *Event) GetPingPong() *pingpongpb.Event

func (*Event) GetTester added in v0.4.0 

func (x *Event) GetTester() *testerpb.Tester

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) GetTimer added in v0.4.0 

func (x *Event) GetTimer() *TimerEvent

func (*Event) GetTransport added in v0.4.0 

func (x *Event) GetTransport() *transportpb.Event

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) ReflectTypeOptions added in v0.2.0 

func (*Event) ReflectTypeOptions() []reflect.Type

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_App added in v0.4.0 

type Event_App struct {
	App *apppb.Event `protobuf:"bytes,22,opt,name=app,proto3,oneof"`
}

func (*Event_App) Unwrap added in v0.4.0 

func (w *Event_App) Unwrap() *apppb.Event

type Event_Availability 

type Event_Availability struct {
	Availability *availabilitypb.Event `protobuf:"bytes,13,opt,name=availability,proto3,oneof"`
}

func (*Event_Availability) Unwrap 

func (w *Event_Availability) Unwrap() *availabilitypb.Event

type Event_BatchDb 

type Event_BatchDb struct {
	BatchDb *batchdbpb.Event `protobuf:"bytes,14,opt,name=batch_db,json=batchDb,proto3,oneof"`
}

func (*Event_BatchDb) Unwrap 

func (w *Event_BatchDb) Unwrap() *batchdbpb.Event

type Event_BatchFetcher 

type Event_BatchFetcher struct {
	BatchFetcher *batchfetcherpb.Event `protobuf:"bytes,15,opt,name=batch_fetcher,json=batchFetcher,proto3,oneof"`
}

func (*Event_BatchFetcher) Unwrap 

func (w *Event_BatchFetcher) Unwrap() *batchfetcherpb.Event

type Event_Bcb 

type Event_Bcb struct {
	Bcb *bcbpb.Event `protobuf:"bytes,11,opt,name=bcb,proto3,oneof"`
}

func (*Event_Bcb) Unwrap 

func (w *Event_Bcb) Unwrap() *bcbpb.Event

type Event_Checkpoint 

type Event_Checkpoint struct {
	Checkpoint *checkpointpb.Event `protobuf:"bytes,17,opt,name=checkpoint,proto3,oneof"`
}

func (*Event_Checkpoint) Unwrap 

func (w *Event_Checkpoint) Unwrap() *checkpointpb.Event

type Event_Crypto added in v0.4.0 

type Event_Crypto struct {
	Crypto *cryptopb.Event `protobuf:"bytes,21,opt,name=crypto,proto3,oneof"`
}

func (*Event_Crypto) Unwrap added in v0.4.0 

func (w *Event_Crypto) Unwrap() *cryptopb.Event

type Event_Factory 

type Event_Factory struct {
	Factory *factorypb.Event `protobuf:"bytes,18,opt,name=factory,proto3,oneof"`
}

func (*Event_Factory) Unwrap 

func (w *Event_Factory) Unwrap() *factorypb.Event

type Event_Hasher added in v0.4.0 

type Event_Hasher struct {
	// Module-specific events
	Hasher *hasherpb.Event `protobuf:"bytes,10,opt,name=hasher,proto3,oneof"`
}

func (*Event_Hasher) Unwrap added in v0.4.0 

func (w *Event_Hasher) Unwrap() *hasherpb.Event

type Event_Init 

type Event_Init struct {
	// Special global event produced by the runtime itself and sent to each module on initialization.
	Init *Init `protobuf:"bytes,2,opt,name=init,proto3,oneof"`
}

func (*Event_Init) Unwrap 

func (w *Event_Init) Unwrap() *Init

type Event_Iss 

type Event_Iss struct {
	Iss *isspb.Event `protobuf:"bytes,19,opt,name=iss,proto3,oneof"`
}

func (*Event_Iss) Unwrap 

func (w *Event_Iss) Unwrap() *isspb.Event

type Event_Mempool 

type Event_Mempool struct {
	Mempool *mempoolpb.Event `protobuf:"bytes,12,opt,name=mempool,proto3,oneof"`
}

func (*Event_Mempool) Unwrap 

func (w *Event_Mempool) Unwrap() *mempoolpb.Event

type Event_Orderer added in v0.4.0 

type Event_Orderer struct {
	Orderer *ordererpb.Event `protobuf:"bytes,20,opt,name=orderer,proto3,oneof"`
}

func (*Event_Orderer) Unwrap added in v0.4.0 

func (w *Event_Orderer) Unwrap() *ordererpb.Event

type Event_PingPong 

type Event_PingPong struct {
	// Events for code samples
	PingPong *pingpongpb.Event `protobuf:"bytes,200,opt,name=ping_pong,json=pingPong,proto3,oneof"`
}

func (*Event_PingPong) Unwrap 

func (w *Event_PingPong) Unwrap() *pingpongpb.Event

type Event_Tester added in v0.4.0 

type Event_Tester struct {
	Tester *testerpb.Tester `protobuf:"bytes,303,opt,name=tester,proto3,oneof"`
}

func (*Event_Tester) Unwrap added in v0.4.0 

func (w *Event_Tester) Unwrap() *testerpb.Tester

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 (w *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 (w *Event_TestingUint) Unwrap() *wrapperspb.UInt64Value

type Event_ThreshCrypto 

type Event_ThreshCrypto struct {
	ThreshCrypto *threshcryptopb.Event `protobuf:"bytes,16,opt,name=thresh_crypto,json=threshCrypto,proto3,oneof"`
}

func (*Event_ThreshCrypto) Unwrap 

func (w *Event_ThreshCrypto) Unwrap() *threshcryptopb.Event

type Event_Timer added in v0.4.0 

type Event_Timer struct {
	// Timer events are recursive and must be defined in this file for protobuf-specific reasons, see below.
	Timer *TimerEvent `protobuf:"bytes,3,opt,name=timer,proto3,oneof"`
}

func (*Event_Timer) Unwrap added in v0.4.0 

func (w *Event_Timer) Unwrap() *TimerEvent

type Event_Transport added in v0.4.0 

type Event_Transport struct {
	Transport *transportpb.Event `protobuf:"bytes,23,opt,name=transport,proto3,oneof"`
}

func (*Event_Transport) Unwrap added in v0.4.0 

func (w *Event_Transport) Unwrap() *transportpb.Event

type Event_Type 

type Event_Type = isEvent_Type

type Event_TypeWrapper 

type Event_TypeWrapper[T any] interface {
	Event_Type
	Unwrap() *T
}

type Init 

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

func (*Init) Descriptor deprecated 

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

Deprecated: Use Init.ProtoReflect.Descriptor instead.

func (*Init) ProtoMessage 

func (*Init) ProtoMessage()

func (*Init) ProtoReflect 

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

func (*Init) Reset 

func (x *Init) Reset()

func (*Init) String 

func (x *Init) String() string

type TimerDelay 

type TimerDelay struct {

	// TODO: The field name must not be `events`, since it conflicts with a package name in the generated code.
	//       This is a bug in the Mir code generator that should be fixed.
	EventsToDelay []*Event `protobuf:"bytes,1,rep,name=events_to_delay,json=eventsToDelay,proto3" json:"events_to_delay,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) GetEventsToDelay added in v0.4.0 

func (x *TimerDelay) GetEventsToDelay() []*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 TimerEvent added in v0.4.0 

type TimerEvent struct {

	// Types that are assignable to Type:
	//	*TimerEvent_Delay
	//	*TimerEvent_Repeat
	//	*TimerEvent_GarbageCollect
	Type isTimerEvent_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*TimerEvent) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use TimerEvent.ProtoReflect.Descriptor instead.

func (*TimerEvent) GetDelay added in v0.4.0 

func (x *TimerEvent) GetDelay() *TimerDelay

func (*TimerEvent) GetGarbageCollect added in v0.4.0 

func (x *TimerEvent) GetGarbageCollect() *TimerGarbageCollect

func (*TimerEvent) GetRepeat added in v0.4.0 

func (x *TimerEvent) GetRepeat() *TimerRepeat

func (*TimerEvent) GetType added in v0.4.0 

func (m *TimerEvent) GetType() isTimerEvent_Type

func (*TimerEvent) ProtoMessage added in v0.4.0 

func (*TimerEvent) ProtoMessage()

func (*TimerEvent) ProtoReflect added in v0.4.0 

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

func (*TimerEvent) ReflectTypeOptions added in v0.4.0 

func (*TimerEvent) ReflectTypeOptions() []reflect.Type

func (*TimerEvent) Reset added in v0.4.0 

func (x *TimerEvent) Reset()

func (*TimerEvent) String added in v0.4.0 

func (x *TimerEvent) String() string

type TimerEvent_Delay added in v0.4.0 

type TimerEvent_Delay struct {
	Delay *TimerDelay `protobuf:"bytes,1,opt,name=delay,proto3,oneof"`
}

func (*TimerEvent_Delay) Unwrap added in v0.4.0 

func (w *TimerEvent_Delay) Unwrap() *TimerDelay

type TimerEvent_GarbageCollect added in v0.4.0 

type TimerEvent_GarbageCollect struct {
	GarbageCollect *TimerGarbageCollect `protobuf:"bytes,3,opt,name=garbage_collect,json=garbageCollect,proto3,oneof"`
}

func (*TimerEvent_GarbageCollect) Unwrap added in v0.4.0 

func (w *TimerEvent_GarbageCollect) Unwrap() *TimerGarbageCollect

type TimerEvent_Repeat added in v0.4.0 

type TimerEvent_Repeat struct {
	Repeat *TimerRepeat `protobuf:"bytes,2,opt,name=repeat,proto3,oneof"`
}

func (*TimerEvent_Repeat) Unwrap added in v0.4.0 

func (w *TimerEvent_Repeat) Unwrap() *TimerRepeat

type TimerEvent_Type added in v0.4.0 

type TimerEvent_Type = isTimerEvent_Type

type TimerEvent_TypeWrapper added in v0.4.0 

type TimerEvent_TypeWrapper[T any] interface {
	TimerEvent_Type
	Unwrap() *T
}

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 {
	EventsToRepeat []*Event `protobuf:"bytes,1,rep,name=events_to_repeat,json=eventsToRepeat,proto3" json:"events_to_repeat,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) GetEventsToRepeat added in v0.3.5 

func (x *TimerRepeat) GetEventsToRepeat() []*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

Source Files

View all Source files

Directories

Path Synopsis

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.