collector

Documentation

Index

• type Collector
  • func New(reconcilerResultCh chan *runnerpb.ReconcileResult, ...) Collector
• type TaskID
  • func (r TaskID) String() string

Types

type Collector

type Collector interface {
	Start(ctx context.Context, once bool)
}

func New

func New(
	reconcilerResultCh chan *runnerpb.ReconcileResult,
	collectorResultCh chan *runnerpb.Once_RunResult,
) Collector

type TaskID

type TaskID struct {
	ReconcilerName string
	Group          string
	Kind           string
	Namespace      string
	Name           string
}

func (TaskID) String

func (r TaskID) String() string