volume_watch

Documentation

Index

• type Msg
  • func (msg Msg) String() string
• type VolumeCheck
  • func (cfg *VolumeCheck) MarshalJSON() ([]byte, error)
  • func (cfg *VolumeCheck) UnmarshalJSON(data []byte) error
• type VolumeWatchConfig
  • func DefaultConfig() VolumeWatchConfig
  • func (cfg VolumeWatchConfig) IsValid() (bool, error)
• type VolumeWatchProcessor
  • 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)

Types

type Msg

type Msg struct {
	tiki.Orders
	Period time.Duration
}

func (Msg) String

func (msg Msg) String() string

type VolumeCheck

type VolumeCheck struct {
	Period time.Duration
	Volume float64
}

func (*VolumeCheck) MarshalJSON

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

func (*VolumeCheck) UnmarshalJSON

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

type VolumeWatchConfig

type VolumeWatchConfig struct {
	common.BaseConfig
	VolumeChecks []*VolumeCheck
}

func DefaultConfig

func DefaultConfig() VolumeWatchConfig

func (VolumeWatchConfig) IsValid

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

type VolumeWatchProcessor

type VolumeWatchProcessor struct {
	*processorCommon.BaseProcessor
	*tiki.TikiClient
	// contains filtered or unexported fields
}

func NewVolumeWatchProcessor

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

func (*VolumeWatchProcessor) Queue

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

func (*VolumeWatchProcessor) Start

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