sensors

Documentation

Index

• type CompletedJobProvider
  • func NewCompletedJobs(e store.ExecutionStore) *CompletedJobProvider
  • func (c *CompletedJobProvider) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)
• type LoggingSensor
  • func NewLoggingSensor(params LoggingSensorParams) *LoggingSensor
  • func (s LoggingSensor) Start(ctx context.Context)
• type LoggingSensorParams
• type RunningExecutionsInfoProvider
  • func NewRunningExecutionsInfoProvider(params RunningExecutionsInfoProviderParams) *RunningExecutionsInfoProvider
  • func (r RunningExecutionsInfoProvider) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)
• type RunningExecutionsInfoProviderParams

Types

type CompletedJobProvider

type CompletedJobProvider struct {
	ExecutionStore store.ExecutionStore
}

func NewCompletedJobs

func NewCompletedJobs(e store.ExecutionStore) *CompletedJobProvider

func (*CompletedJobProvider) GetDebugInfo

func (c *CompletedJobProvider) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)

GetDebugInfo implements models.DebugInfoProvider

type LoggingSensor

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

LoggingSensor is a sensor that periodically logs the debug info

func NewLoggingSensor

func NewLoggingSensor(params LoggingSensorParams) *LoggingSensor

NewLoggingSensor create a new LoggingSensor from LoggingSensorParams

func (LoggingSensor) Start

func (s LoggingSensor) Start(ctx context.Context)

type LoggingSensorParams

type LoggingSensorParams struct {
	InfoProvider models.DebugInfoProvider
	Interval     time.Duration
}

type RunningExecutionsInfoProvider

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

RunningExecutionsInfoProvider provides DebugInfo about the currently running executions. The info can be used for logging, metric, or to handle /debug API implementation.

func NewRunningExecutionsInfoProvider

func NewRunningExecutionsInfoProvider(params RunningExecutionsInfoProviderParams) *RunningExecutionsInfoProvider

func (RunningExecutionsInfoProvider) GetDebugInfo

func (r RunningExecutionsInfoProvider) GetDebugInfo(ctx context.Context) (models.DebugInfo, error)

type RunningExecutionsInfoProviderParams

type RunningExecutionsInfoProviderParams struct {
	Name          string
	BackendBuffer *compute.ExecutorBuffer
}