scheduler_event

Documentation

Index

• Constants
• type MetricCollectedEvent
  • func (e MetricCollectedEvent) Namespace() string
• type MetricCollectionFailedEvent
  • func (e MetricCollectionFailedEvent) Namespace() string
• type TaskCreatedEvent
  • func (e TaskCreatedEvent) Namespace() string
• type TaskDeletedEvent
  • func (e TaskDeletedEvent) Namespace() string
• type TaskDisabledEvent
  • func (e TaskDisabledEvent) Namespace() string
• type TaskStartedEvent
  • func (e TaskStartedEvent) Namespace() string
• type TaskStoppedEvent
  • func (e TaskStoppedEvent) Namespace() string

Constants

const (
	TaskCreated            = "Scheduler.TaskCreated"
	TaskDeleted            = "Scheduler.TaskDeleted"
	TaskStarted            = "Scheduler.TaskStarted"
	TaskStopped            = "Scheduler.TaskStopped"
	TaskDisabled           = "Scheduler.TaskDisabled"
	MetricCollected        = "Scheduler.MetricsCollected"
	MetricCollectionFailed = "Scheduler.MetricCollectionFailed"
)

Types

type MetricCollectedEvent

type MetricCollectedEvent struct {
	TaskID  string
	Metrics []core.Metric
}

func (MetricCollectedEvent) Namespace

func (e MetricCollectedEvent) Namespace() string

type MetricCollectionFailedEvent

type MetricCollectionFailedEvent struct {
	TaskID string
	Errors []error
}

func (MetricCollectionFailedEvent) Namespace

func (e MetricCollectionFailedEvent) Namespace() string

type TaskCreatedEvent

type TaskCreatedEvent struct {
	TaskID        string
	StartOnCreate bool
	Source        string
}

func (TaskCreatedEvent) Namespace

func (e TaskCreatedEvent) Namespace() string

type TaskDeletedEvent

type TaskDeletedEvent struct {
	TaskID string
	Source string
}

func (TaskDeletedEvent) Namespace

func (e TaskDeletedEvent) Namespace() string

type TaskDisabledEvent

type TaskDisabledEvent struct {
	TaskID string
	Why    string
}

func (TaskDisabledEvent) Namespace

func (e TaskDisabledEvent) Namespace() string

type TaskStartedEvent

type TaskStartedEvent struct {
	TaskID string
	Source string
}

func (TaskStartedEvent) Namespace

func (e TaskStartedEvent) Namespace() string

type TaskStoppedEvent

type TaskStoppedEvent struct {
	TaskID string
	Source string
}

func (TaskStoppedEvent) Namespace

func (e TaskStoppedEvent) Namespace() string