event_queue

Documentation

Index

• type EventQueueService
  • func NewEventQueueService() EventQueueService

Types

type EventQueueService

type EventQueueService interface {
	Send(ctx context.Context, msg *schema.EventMsg)
	RegisterHandler(handler func(ctx context.Context, msg *schema.EventMsg) error)
}

func NewEventQueueService

func NewEventQueueService() EventQueueService

NewEventQueueService create a new badge queue service