time

Nov 4, 2023

Changes in this version

type ConnectorCfg

+ func (cfg *ConnectorCfg) ValidateJSON(v *ejson.Validator)

type DailyParameters

+ func (p *DailyParameters) ValidateJSON(v *ejson.Validator)

type HourlyParameters

+ func (p *HourlyParameters) ValidateJSON(v *ejson.Validator)

type Parameters

+ func (p *Parameters) ValidateJSON(v *ejson.Validator)

type WeeklyParameters

+ func (p *WeeklyParameters) ValidateJSON(v *ejson.Validator)

type Worker

+ Pg *pg.Client

Oct 24, 2022

Changes in this version

type Parameters

+ OneshotString string

+ func (p *Parameters) MarshalJSON() ([]byte, error)

type WeeklyParameters

+ func (p *WeeklyParameters) Check(c *check.Checker)

Jul 19, 2022

Changes in this version

+ var WeekDayValues = []WeekDay

+ func DeleteSubscription(conn pg.Conn, id eventline.Id) error

+ func NextDay(now time.Time, h, m, s int) time.Time

+ func NextHour(now time.Time, m, s int) time.Time

+ func NextWeekDay(now time.Time, day WeekDay, h, m, s int) time.Time

+ func TickEventDef() *eventline.EventDef

+ type Connector struct

+ Cfg *ConnectorCfg

+ Def *eventline.ConnectorDef

+ Log *log.Logger

+ func NewConnector() *Connector

+ func (c *Connector) DefaultCfg() eventline.ConnectorCfg

+ func (c *Connector) Definition() *eventline.ConnectorDef

+ func (c *Connector) Init(ccfg eventline.ConnectorCfg, initData eventline.ConnectorInitData) error

+ func (c *Connector) Name() string

+ func (c *Connector) Subscribe(conn pg.Conn, sctx *eventline.SubscriptionContext) error

+ func (c *Connector) Terminate()

+ func (c *Connector) Unsubscribe(conn pg.Conn, sctx *eventline.SubscriptionContext) error

+ type ConnectorCfg struct

+ Secret string

+ func (cfg *ConnectorCfg) Check(c *check.Checker)

+ type DailyParameters struct

+ Hour int

+ Minute int

+ Second int

+ func (p *DailyParameters) Check(c *check.Checker)

+ type HourlyParameters struct

+ Minute int

+ Second int

+ func (p *HourlyParameters) Check(c *check.Checker)

+ type OneshotParameters time.Time

+ type Parameters struct

+ Daily *DailyParameters

+ Hourly *HourlyParameters

+ Oneshot *OneshotParameters

+ Periodic *int

+ Weekly *WeeklyParameters

+ func (p *Parameters) Check(c *check.Checker)

+ func (p *Parameters) FirstTick() (tick time.Time)

+ func (p *Parameters) NextTick(expectedTick time.Time) (tick time.Time)

+ type Subscription struct

+ Id eventline.Id

+ LastTick *time.Time

+ NextTick time.Time

+ func LoadSubscriptionForProcessing(conn pg.Conn) (*Subscription, *eventline.Subscription, error)

+ func (s *Subscription) FromRow(row pgx.Row) error

+ func (s *Subscription) Insert(conn pg.Conn) error

+ func (s *Subscription) Update(conn pg.Conn) error

+ type TickEvent struct

+ type WeekDay string

+ const WeekDayFriday

+ const WeekDayMonday

+ const WeekDaySaturday

+ const WeekDaySunday

+ const WeekDayThursday

+ const WeekDayTuesday

+ const WeekDayWednesday

+ func (wd WeekDay) Number() (n int)

+ type WeeklyParameters struct

+ Day WeekDay

+ Hour int

+ Minute int

+ Second int

+ type Worker struct

+ Daemon *daemon.Daemon

+ Log *log.Logger

+ func NewWorker() *Worker

+ func (w *Worker) Init(ew *eventline.Worker)

+ func (w *Worker) ProcessJob() (bool, error)

+ func (w *Worker) Start() error

+ func (w *Worker) Stop()