volume_watch

Jun 23, 2023

Changes in this version

+ type Msg struct

+ Period time.Duration

+ func (msg Msg) String() string

+ type VolumeCheck struct

+ Period time.Duration

+ Volume float64

+ func (cfg *VolumeCheck) MarshalJSON() ([]byte, error)

+ func (cfg *VolumeCheck) UnmarshalJSON(data []byte) error

+ type VolumeWatchConfig struct

+ VolumeChecks []*VolumeCheck

+ func DefaultConfig() VolumeWatchConfig

+ func (cfg VolumeWatchConfig) IsValid() (bool, error)

+ type VolumeWatchProcessor struct

+ func NewVolumeWatchProcessor(cfg VolumeWatchConfig, tikiClient *tiki.TikiClient, db *store.Store, ...) (*VolumeWatchProcessor, error)

+ func (p *VolumeWatchProcessor) Queue(msg interface{})

+ func (p *VolumeWatchProcessor) Start(ctx context.Context)