job

Documentation

Index

• type Job
• type UpdateElectricMeterJob
  • func NewUpdateMeterJob(meter meter.ElectricMeter, mqttClient mqtt.Client, log *zap.Logger) *UpdateElectricMeterJob
  • func (j *UpdateElectricMeterJob) Execute(ctx context.Context) error

Types

type Job

type Job interface {
	Execute(ctx context.Context) error
}

type UpdateElectricMeterJob

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

func NewUpdateMeterJob

func NewUpdateMeterJob(
	meter meter.ElectricMeter,
	mqttClient mqtt.Client,
	log *zap.Logger,
) *UpdateElectricMeterJob

func (*UpdateElectricMeterJob) Execute

func (j *UpdateElectricMeterJob) Execute(ctx context.Context) error