eventpb

package
v0.0.0-...-9727c61 Latest Latest
Warning

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

Go to latest
Published: Nov 28, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_eventpb_eventpb_proto protoreflect.FileDescriptor

Functions

func List

func List(evts ...*Event) *stdtypes.EventList

List returns EventList containing the given elements.

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_Hasher
	//	*Event_Bcb
	//	*Event_Mempool
	//	*Event_Availability
	//	*Event_BatchDb
	//	*Event_BatchFetcher
	//	*Event_ThreshCrypto
	//	*Event_Checkpoint
	//	*Event_Iss
	//	*Event_Orderer
	//	*Event_Crypto
	//	*Event_App
	//	*Event_Transport
	//	*Event_ChkpValidator
	//	*Event_PprepValiadtor
	//	*Event_Serialized
	//	*Event_PingPong
	//	*Event_TestingString
	//	*Event_TestingUint
	//	*Event_Tester
	Type isEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

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

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) Dest

func (event *Event) Dest() stdtypes.ModuleID

Dest returns the destination module of the event.

func (*Event) GetApp

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) GetChkpValidator

func (x *Event) GetChkpValidator() *chkpvalidatorpb.Event

func (*Event) GetCrypto

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

func (*Event) GetDestModule

func (x *Event) GetDestModule() string

func (*Event) GetHasher

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

func (*Event) GetIss

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

func (*Event) GetMempool

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

func (*Event) GetOrderer

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

func (*Event) GetPingPong

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

func (*Event) GetPprepValiadtor

func (x *Event) GetPprepValiadtor() *pprepvalidatorpb.Event

func (*Event) GetSerialized

func (x *Event) GetSerialized() *SerializedEvent

func (*Event) GetTester

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) GetTransport

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

func (*Event) GetType

func (m *Event) GetType() isEvent_Type

func (*Event) NewDest

func (event *Event) NewDest(newDest stdtypes.ModuleID) stdtypes.Event

NewDest returns a shallow copy of the event with a new destination module ID.

func (*Event) NewSrc

func (event *Event) NewSrc(newSrc stdtypes.ModuleID) stdtypes.Event

NewSrc returns a shallow copy of this Event with an updated source module ID. This method is not yet implemented in proto events.

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) ReflectTypeOptions

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) Src

func (event *Event) Src() stdtypes.ModuleID

Src returns the module that emitted the event. While this information is not always necessary for the system operation, it is useful for analyzing event traces and debugging.

func (*Event) String

func (x *Event) String() string

func (*Event) ToBytes

func (event *Event) ToBytes() ([]byte, error)

ToBytes returns a serialized representation of the event as a slice of bytes from which the event can be reconstructed. Note that ToBytes does not necessarily guarantee the output to be deterministic. Even multiple subsequent calls to ToBytes on the same event object might return different byte slices.

func (*Event) ToString

func (event *Event) ToString() string

type Event_App

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

func (*Event_App) Unwrap

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

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

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_ChkpValidator

type Event_ChkpValidator struct {
	ChkpValidator *chkpvalidatorpb.Event `protobuf:"bytes,24,opt,name=chkp_validator,json=chkpValidator,proto3,oneof"`
}

func (*Event_ChkpValidator) Unwrap

type Event_Crypto

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

func (*Event_Crypto) Unwrap

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

type Event_Hasher

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

func (*Event_Hasher) Unwrap

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

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

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

func (*Event_Orderer) Unwrap

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_PprepValiadtor

type Event_PprepValiadtor struct {
	PprepValiadtor *pprepvalidatorpb.Event `protobuf:"bytes,25,opt,name=pprep_valiadtor,json=pprepValiadtor,proto3,oneof"`
}

func (*Event_PprepValiadtor) Unwrap

type Event_Serialized

type Event_Serialized struct {
	// Temporarily used by the Gzip event writer for inclusion of non-proto events in the proto-based event record.
	Serialized *SerializedEvent `protobuf:"bytes,100,opt,name=serialized,proto3,oneof"`
}

func (*Event_Serialized) Unwrap

func (w *Event_Serialized) Unwrap() *SerializedEvent

type Event_Tester

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

func (*Event_Tester) Unwrap

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

type Event_TestingUint

type Event_TestingUint struct {
	TestingUint *wrapperspb.UInt64Value `protobuf:"bytes,302,opt,name=testingUint,proto3,oneof"`
}

func (*Event_TestingUint) Unwrap

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

type Event_Transport

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

func (*Event_Transport) Unwrap

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 SerializedEvent

type SerializedEvent struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SerializedEvent) Descriptor deprecated

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

Deprecated: Use SerializedEvent.ProtoReflect.Descriptor instead.

func (*SerializedEvent) GetData

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

func (*SerializedEvent) ProtoMessage

func (*SerializedEvent) ProtoMessage()

func (*SerializedEvent) ProtoReflect

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

func (*SerializedEvent) Reset

func (x *SerializedEvent) Reset()

func (*SerializedEvent) String

func (x *SerializedEvent) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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