activity_queue

Documentation

Index

• type ActivityQueueService
  • func NewActivityQueueService() ActivityQueueService

Types

type ActivityQueueService

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

func NewActivityQueueService

func NewActivityQueueService() ActivityQueueService

NewActivityQueueService create a new activity queue service