schedule

package

v0.0.0-...-bb63543 Latest Latest Go to latest Published: Feb 5, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(NewSchedule, NewDaily)

This section is empty.

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

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

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

Run mock daily send statistic data to accounts

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

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