monitor

Documentation

Index

• type Config
• type Job
• type JobHandler
• type Monitor
  • func New(logger *zap.Logger, k8s kubernetes.Interface, cfg api.Config) (*Monitor, error)
  • func (m *Monitor) Start(ctx context.Context, handler JobHandler) <-chan error

Types

type Config

type Config struct {
	Namespace   string
	Token       string
	MaxInFlight int
	Org         string
	Tags        []string
}

type Job

type Job struct {
	api.CommandJob
	Tag string
}

type JobHandler

type JobHandler interface {
	Create(context.Context, *Job) error
}

type Monitor

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

func New

func New(logger *zap.Logger, k8s kubernetes.Interface, cfg api.Config) (*Monitor, error)

func (*Monitor) Start

func (m *Monitor) Start(ctx context.Context, handler JobHandler) <-chan error