schedule

Documentation

Index

• Variables
• type Daily
  • func NewDaily(db *ent.Database, producer sarama.SyncProducer) *Daily
  • func (r Daily) Run(ctx context.Context) error
• type Schedule
  • func NewSchedule(logger log.Logger, client *ent.Client, daily *Daily) *Schedule
  • func (s Schedule) Start(ctx context.Context) error
  • func (s Schedule) Stop(ctx context.Context) error

Variables

var ProviderSet = wire.NewSet(NewSchedule, NewDaily)

Types

type Daily

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

func NewDaily

func NewDaily(db *ent.Database, producer sarama.SyncProducer) *Daily

func (Daily) Run

func (r Daily) Run(ctx context.Context) error

Run mock daily send stat data to accounts

type Schedule

type Schedule struct {
	*schedule.Schedule
	// contains filtered or unexported fields
}

func NewSchedule

func NewSchedule(logger log.Logger, client *ent.Client, daily *Daily) *Schedule

func (Schedule) Start

func (s Schedule) Start(ctx context.Context) error

func (Schedule) Stop

func (s Schedule) Stop(ctx context.Context) error