subengine

Documentation

Index

• func NewEngine(appCtx srvctx.ServiceContext, pb pubsub.Pubsub) *consumerEngine
• type ConsumerJob
• type GroupJob

Functions

func NewEngine

func NewEngine(appCtx srvctx.ServiceContext, pb pubsub.Pubsub) *consumerEngine

Types

type ConsumerJob

type ConsumerJob struct {
	Title   string
	Handler func(ctx context.Context, message *pubsub.Message) error
}

type GroupJob

type GroupJob interface {
	Run(ctx context.Context) error
}