collector

Documentation

Index

• func Register(s *Server, controllerRuntimeStopCh <-chan struct{})
• type ChaosCollector
  • func (r *ChaosCollector) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *ChaosCollector) Setup(mgr ctrl.Manager, apiType runtime.Object) error
• type Server
  • func NewServer(conf *config.ChaosDashboardConfig, archive core.ExperimentStore, ...) (*Server, client.Client, client.Reader, *runtime.Scheme)

Functions

func Register

func Register(s *Server, controllerRuntimeStopCh <-chan struct{})

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(req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles a chaos collector.

func (*ChaosCollector) Setup

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

Setup setups collectors by Manager.

type Server

type Server struct {
	Manager ctrl.Manager
}

Server defines a server to manage collectors.

func NewServer

func NewServer(
	conf *config.ChaosDashboardConfig,
	archive core.ExperimentStore,
	event core.EventStore,
) (*Server, client.Client, client.Reader, *runtime.Scheme)

NewServer returns a CollectorServer and Client.