metadata_mq

Documentation

Index

• Variables
• type Event
  • func New(dataBus mq.MQ) (*Event, error)
  • func (e *Event) Notify(ctx context.Context, event uint32, payload any) notify.Response[any]

Variables

var ErrInvalidPayload = errors.New("invalid payload")

Types

type Event

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

func New

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

func (*Event) Notify

func (e *Event) Notify(ctx context.Context, event uint32, payload any) notify.Response[any]

Notify - notify