Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VolumeCheck ¶
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)
Click to show internal directories.
Click to hide internal directories.