event

Documentation

Overview

Package event contains all event emitters supported by this package.

Index

• Variables
• type Cron
  • func NewCron(schedule string, c *cron.Cron, logger *logrus.Entry) Cron
  • func (c *Cron) BuildTickChannel() <-chan any
  • func (c *Cron) Run()
• type DockerEvent
  • func NewDockerEvent(connection string, containerMatcher string, imageMatcher string, ...) *DockerEvent
  • func (de *DockerEvent) BuildTickChannel() <-chan any
• type ErrorLimitPolicy
• type Init
  • func (c *Init) BuildTickChannel() <-chan any
• type Interval
  • func NewInterval(schedule time.Duration, logger *logrus.Entry) Interval
  • func (c *Interval) BuildTickChannel() <-chan any
• type WebEventListener
  • func NewEventListener(event string) WebEventListener
  • func (w *WebEventListener) BuildTickChannel() <-chan any

Variables

var CronParser = cron.NewParser(cron.SecondOptional | cron.Minute | cron.Hour | cron.Dom | cron.Month | cron.Dow | cron.Descriptor)

Types

type Cron

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

func NewCron

func NewCron(schedule string, c *cron.Cron, logger *logrus.Entry) Cron

func (*Cron) BuildTickChannel

func (c *Cron) BuildTickChannel() <-chan any

BuildTickChannel implements abstraction.Scheduler.

func (*Cron) Run

func (c *Cron) Run()

type DockerEvent

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

func NewDockerEvent

func NewDockerEvent(
	connection string,
	containerMatcher string,
	imageMatcher string,
	actions []string,
	labels map[string]string,
	errorLimit uint,
	errorPolicy ErrorLimitPolicy,
	errorThrottle time.Duration,
	logger *logrus.Entry,
) *DockerEvent

func (*DockerEvent) BuildTickChannel

func (de *DockerEvent) BuildTickChannel() <-chan any

BuildTickChannel implements abstraction.Scheduler.

type ErrorLimitPolicy

type ErrorLimitPolicy string

const (
	Kill      ErrorLimitPolicy = "kill"
	GiveUp    ErrorLimitPolicy = "give-up"
	Reconnect ErrorLimitPolicy = "reconnect"
)

type Init

type Init struct{}

func (*Init) BuildTickChannel

func (c *Init) BuildTickChannel() <-chan any

BuildTickChannel implements abstraction.Scheduler.

type Interval

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

func NewInterval

func NewInterval(schedule time.Duration, logger *logrus.Entry) Interval

func (*Interval) BuildTickChannel

func (c *Interval) BuildTickChannel() <-chan any

BuildTickChannel implements abstraction.Scheduler.

type WebEventListener

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

func NewEventListener

func NewEventListener(event string) WebEventListener

func (*WebEventListener) BuildTickChannel

func (w *WebEventListener) BuildTickChannel() <-chan any

BuildTickChannel implements abstraction.Scheduler.