protocols

Documentation

Index

• type StatsJob
  • func NewStatsJob(writerDB api.WriteAPIBlocking, from, to time.Time, ...) *StatsJob
  • func (s *StatsJob) Run(ctx context.Context) error

Types

type StatsJob

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

func NewStatsJob

func NewStatsJob(writerDB api.WriteAPIBlocking, from, to time.Time, activityMeasurement, statsMeasurement string, repositories []repository.ProtocolRepository, logger *zap.Logger) *StatsJob

NewStatsJob creates an instance of the job implementation.

func (*StatsJob) Run

func (s *StatsJob) Run(ctx context.Context) error