ops

Documentation

Index

• Variables
• type Cron
  • func NewCron(opts CronOptions) *Cron
  • func (c *Cron) Process(ctx context.Context, args selina.ProcessArgs) error
• type CronOptions
  • func (o CronOptions) Check() error
• type TimeSerie
  • func NewTimeSerie(opts TimeSerieOptions) *TimeSerie
  • func (t *TimeSerie) Process(ctx context.Context, args selina.ProcessArgs) error
• type TimeSerieOptions

Variables

var ErrBadCronSpec = errors.New("bad cron spec")

ErrBadCronSpec is returned when an job spec is not parseable

Types

type Cron

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

Cron send an specific message at scheduled intervals

func NewCron

func NewCron(opts CronOptions) *Cron

NewCron create a new Cron Worker with given options

func (*Cron) Process

func (c *Cron) Process(ctx context.Context, args selina.ProcessArgs) error

Process add a job scec, any message received will be discarded when input is closed this worker return nil

type CronOptions

type CronOptions struct {
	// Spec use same format as github.com/robfig/cron/v3
	// Second Minute Hour DayOfMonth Month DayOfWeek
	Spec string
	// Which message will be sent every schedule
	Message []byte
}

CronOptions customize cron behaviour

func (CronOptions) Check

func (o CronOptions) Check() error

Check if a combination of options is valid

type TimeSerie

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

TimeSerie generate time and values in a given time range

func NewTimeSerie

func NewTimeSerie(opts TimeSerieOptions) *TimeSerie

NewTimeSerie create a new TimeSerie generator with given options

func (*TimeSerie) Process

func (t *TimeSerie) Process(ctx context.Context, args selina.ProcessArgs) error

Process generate timeseries and put it out in a channel

type TimeSerieOptions

type TimeSerieOptions struct {
	Start       time.Time
	Stop        time.Time
	Step        time.Duration
	Generator   func(time.Time) float64
	WriteFormat selina.Marshaler
}

TimeSerieOptions customize optiosn for generation