▽

Package collector

func Register ¶

func Register(ctx context.Context, s *Server)

Register starts collectors manager.

type ChaosCollector ¶

ChaosCollector represents a collector for Chaos Object.

type ChaosCollector struct {
    client.Client
    Log logr.Logger
    // contains filtered or unexported fields
}

func (*ChaosCollector) Reconcile ¶

func (r *ChaosCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles a chaos collector.

func (*ChaosCollector) Setup ¶

func (r *ChaosCollector) Setup(mgr ctrl.Manager, apiType client.Object) error

Setup setups collectors by Manager.

type EventCollector ¶

EventCollector represents a collector for Event Object.

type EventCollector struct {
    client.Client
    Log logr.Logger
    // contains filtered or unexported fields
}

func (*EventCollector) Reconcile ¶

func (r *EventCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles a Event collector.

func (*EventCollector) Setup ¶

func (r *EventCollector) Setup(mgr ctrl.Manager, apiType client.Object) error

Setup setups collectors by Manager.

type ScheduleCollector ¶

ScheduleCollector represents a collector for Schedule Object.

type ScheduleCollector struct {
    client.Client
    Log logr.Logger
    // contains filtered or unexported fields
}

func (*ScheduleCollector) Reconcile ¶

func (r *ScheduleCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles a Schedule collector.

func (*ScheduleCollector) Setup ¶

func (r *ScheduleCollector) Setup(mgr ctrl.Manager, apiType client.Object) error

Setup setups collectors by Manager.

type Server ¶

Server defines a server to manage collectors.

type Server struct {
    Manager ctrl.Manager
    // contains filtered or unexported fields
}

func Bootstrap ¶

func Bootstrap(
    conf *config.ChaosDashboardConfig,
    experimentArchive core.ExperimentStore,
    scheduleArchive core.ScheduleStore,
    event core.EventStore,
    workflowStore core.WorkflowStore,
    logger logr.Logger,
) (*Server, client.Client, client.Reader, *runtime.Scheme)

func NewServer ¶

func NewServer(
    conf *config.ChaosDashboardConfig,
    experimentArchive core.ExperimentStore,
    scheduleArchive core.ScheduleStore,
    event core.EventStore,
    workflowStore core.WorkflowStore,
    logger logr.Logger,
) (*Server, client.Client, client.Reader, *runtime.Scheme)

NewServer returns a CollectorServer and Client.

type WorkflowCollector ¶

type WorkflowCollector struct {
    Log logr.Logger
    // contains filtered or unexported fields
}

func (*WorkflowCollector) Reconcile ¶

func (it *WorkflowCollector) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*WorkflowCollector) Setup ¶

func (it *WorkflowCollector) Setup(mgr ctrl.Manager, apiType client.Object) error