eventbus

Documentation

Index

• type Event
  • func SkywayBatchBuilt() *Event[SkywayBatchBuiltEvent]
  • func (e Event[E]) Publish(ctx context.Context, event E)
  • func (e Event[E]) Subscribe(id string, fn EventHandler[E])
  • func (e Event[E]) Unsubscribe(id string)
• type EventHandler
• type SkywayBatchBuiltEvent

Types

type Event

type Event[E any] struct {
	// contains filtered or unexported fields
}

func SkywayBatchBuilt

func SkywayBatchBuilt() *Event[SkywayBatchBuiltEvent]

func (Event[E]) Publish

func (e Event[E]) Publish(ctx context.Context, event E)

func (Event[E]) Subscribe

func (e Event[E]) Subscribe(id string, fn EventHandler[E])

func (Event[E]) Unsubscribe

func (e Event[E]) Unsubscribe(id string)

type EventHandler

type EventHandler[E any] func(context.Context, E) error

type SkywayBatchBuiltEvent

type SkywayBatchBuiltEvent struct {
	ChainReferenceID string
}