collector

Documentation

Index

• func Register(ctx context.Context, s *Server)
• type ChaosCollector
  • func (r *ChaosCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ChaosCollector) Setup(mgr ctrl.Manager, apiType client.Object) error
• type EventCollector
  • func (r *EventCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EventCollector) Setup(mgr ctrl.Manager, apiType client.Object) error
• type ScheduleCollector
  • func (r *ScheduleCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ScheduleCollector) Setup(mgr ctrl.Manager, apiType client.Object) error
• type Server
  • func Bootstrap(conf *config.ChaosDashboardConfig, experimentArchive core.ExperimentStore, ...) (*Server, client.Client, client.Reader, *runtime.Scheme)
  • func NewServer(conf *config.ChaosDashboardConfig, experimentArchive core.ExperimentStore, ...) (*Server, client.Client, client.Reader, *runtime.Scheme)
• type WorkflowCollector
  • func (it *WorkflowCollector) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (it *WorkflowCollector) Setup(mgr ctrl.Manager, apiType client.Object) error

Functions

func Register

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

Register starts collectors manager.

Types

type ChaosCollector

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

ChaosCollector represents a collector for Chaos Object.

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

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

EventCollector represents a collector for Event Object.

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

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

ScheduleCollector represents a collector for Schedule Object.

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

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

Server defines a server to manage collectors.

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