monitor

Feb 10, 2023

Changes in this version

+ type JobHandler interface

+ Create func(context.Context, *Job) error

type Monitor

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

Jan 12, 2023

Changes in this version

+ func MetaJobLabelKeyFunc(obj interface{}) (string, error)

+ func NewJobLister(ctx context.Context, log *zap.Logger, clientset kubernetes.Interface, ...) (batchv1.JobLister, error)

+ type Config struct

+ MaxInFlight int

+ Namespace string

+ Org string

+ Tags []string

+ Token string

+ type Job struct

+ Err error

+ Tag string

+ type Monitor struct

+ func New(ctx context.Context, logger *zap.Logger, k8s kubernetes.Interface, ...) (*Monitor, error)

+ func (m *Monitor) Scheduled() <-chan Job