event

Documentation

Index

• func MustPublish(ctx context.Context, pubsubServer *pubsub.Server, msg any, ...)
• func MustSubscribe(ctx context.Context, pubsubServer *pubsub.Server, clientID string, ...)
• func QueryFor(eventTypeKey, eventType string) tmpubsub.Query

Functions

func MustPublish

func MustPublish(ctx context.Context, pubsubServer *pubsub.Server, msg any, events map[string][]string)

MustPublish submits an event or panics

func MustSubscribe

func MustSubscribe(
	ctx context.Context,
	pubsubServer *pubsub.Server,
	clientID string,
	eventQuery pubsub.Query,
	callback func(event pubsub.Message),
	logger types.Logger,
	outCapacity ...int,
)

MustSubscribe subscribes to events and sends back a callback clientID is essentially the subscriber id, see https://pkg.go.dev/github.com/tendermint/tendermint/libs/pubsub#pkg-overview

func QueryFor

func QueryFor(eventTypeKey, eventType string) tmpubsub.Query

QueryFor returns a query for the given event.