shifts

Documentation

Index

• type ShiftsConfig
• type ShiftsProcessor
  • func NewShiftsProcessor(cfg *ShiftsConfig, backend *storage.RedisClient) *ShiftsProcessor
  • func (u *ShiftsProcessor) Start()

Types

type ShiftsConfig

type ShiftsConfig struct {
	Enabled       bool   `json:"enabled"`
	LongInterval  string `json:"longInterval"`
	ShortInterval string `json:"shortInterval"`
	FlushInterval string `json:"flushInterval"`
	KeepLong      string `json:"keepLong"`
	KeepShort     string `json:"keepShort"`
}

type ShiftsProcessor

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

func NewShiftsProcessor

func NewShiftsProcessor(cfg *ShiftsConfig, backend *storage.RedisClient) *ShiftsProcessor

func (*ShiftsProcessor) Start

func (u *ShiftsProcessor) Start()