scheduler_handlers

Documentation

Index

• type InAppScheduledJobService
  • func NewInAppScheduledJobService(eventEmitter *infrastructure.EventEmitter, kw *kafka.Writer, db *gorm.DB, ...) *InAppScheduledJobService
  • func (svc *InAppScheduledJobService) InitAndRegisterJobs(ctx context.Context)
  • func (svc *InAppScheduledJobService) InitEventHandlers()
  • func (svc *InAppScheduledJobService) ReleaseAllJobs() error
  • func (svc *InAppScheduledJobService) ScheduleEchoHello()

Types

type InAppScheduledJobService

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

func NewInAppScheduledJobService

func NewInAppScheduledJobService(
	eventEmitter *infrastructure.EventEmitter,
	kw *kafka.Writer,
	db *gorm.DB,
	rdb *redis.Client,
	s3Client *s3.S3,
	natsClient *nats.Conn,
	scheduler gocron.Scheduler,
) *InAppScheduledJobService

func (*InAppScheduledJobService) InitAndRegisterJobs

func (svc *InAppScheduledJobService) InitAndRegisterJobs(ctx context.Context)

func (*InAppScheduledJobService) InitEventHandlers

func (svc *InAppScheduledJobService) InitEventHandlers()

func (*InAppScheduledJobService) ReleaseAllJobs

func (svc *InAppScheduledJobService) ReleaseAllJobs() error

func (*InAppScheduledJobService) ScheduleEchoHello

func (svc *InAppScheduledJobService) ScheduleEchoHello()