publisher

Documentation

Index

• type EventPublisher
  • func New(rpc *cosmos.RPC) *EventPublisher
  • func (ep *EventPublisher) GetStream(f *event.Filter) *event.Listener
  • func (ep *EventPublisher) Publish(instanceHash hash.Hash, eventKey string, eventData *types.Struct) (*event.Event, error)

Types

type EventPublisher

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

EventPublisher exposes event APIs of MESG.

func New

func New(rpc *cosmos.RPC) *EventPublisher

New creates a new Event SDK with given options.

func (*EventPublisher) GetStream

func (ep *EventPublisher) GetStream(f *event.Filter) *event.Listener

GetStream broadcasts all events.

func (*EventPublisher) Publish

func (ep *EventPublisher) Publish(instanceHash hash.Hash, eventKey string, eventData *types.Struct) (*event.Event, error)

Publish a MESG event eventKey with eventData for service token.