metadata_mq

Documentation

Index

• type Event
  • func New(mq mq.MQ) (*Event, error)
  • func (e *Event) Notify(ctx context.Context, event uint32, payload interface{}) notify.Response

Types

type Event

type Event struct {

	// Observer interface for subscribe on system event
	notify.Subscriber // Observer interface for subscribe on system event
	// contains filtered or unexported fields
}

func New

func New(mq mq.MQ) (*Event, error)

func (*Event) Notify

func (e *Event) Notify(ctx context.Context, event uint32, payload interface{}) notify.Response

Notify ...