aggregator

Documentation

Index

• Constants
• type Aggregator
• type Controller
  • func NewController(v Aggregator, c client.Client, cs *kubernetes.Clientset, ...) *Controller
  • func (ctrl *Controller) ConfigReloaderInitContainer() *corev1.Container
  • func (ctrl *Controller) ConfigReloaderSidecarContainer() *corev1.Container
  • func (ctrl *Controller) DeleteVectorAggregator(ctx context.Context) error
  • func (ctrl *Controller) EnsureVectorAggregator(ctx context.Context) error
  • func (ctrl *Controller) GetServiceName() string
  • func (ctrl *Controller) SetFailedStatus(ctx context.Context, reason string) error
  • func (ctrl *Controller) SetSuccessStatus(ctx context.Context, hash *uint32) error
  • func (ctrl *Controller) VectorAggregatorContainer() *corev1.Container

Constants

const ApiPort = 8686

Types

type Aggregator

type Aggregator interface {
	client.Object
}

type Controller

type Controller struct {
	client.Client

	Name             string
	Namespace        string
	VectorAggregator Aggregator
	APIVersion       string
	Kind             string
	Spec             *vectorv1alpha1.VectorAggregatorCommon
	Status           *vectorv1alpha1.VectorCommonStatus
	ConfigBytes      []byte
	Config           *config.VectorConfig
	ClientSet        *kubernetes.Clientset
	EventsCollector  *k8sevents.EventsCollector
	// contains filtered or unexported fields
}

func NewController

func NewController(
	v Aggregator,
	c client.Client,
	cs *kubernetes.Clientset,
	evCollector *k8sevents.EventsCollector,
) *Controller

func (*Controller) ConfigReloaderInitContainer

func (ctrl *Controller) ConfigReloaderInitContainer() *corev1.Container

func (*Controller) ConfigReloaderSidecarContainer

func (ctrl *Controller) ConfigReloaderSidecarContainer() *corev1.Container

func (*Controller) DeleteVectorAggregator

func (ctrl *Controller) DeleteVectorAggregator(ctx context.Context) error

func (*Controller) EnsureVectorAggregator

func (ctrl *Controller) EnsureVectorAggregator(ctx context.Context) error

func (*Controller) GetServiceName

func (ctrl *Controller) GetServiceName() string

func (*Controller) SetFailedStatus

func (ctrl *Controller) SetFailedStatus(ctx context.Context, reason string) error

func (*Controller) SetSuccessStatus

func (ctrl *Controller) SetSuccessStatus(ctx context.Context, hash *uint32) error

func (*Controller) VectorAggregatorContainer

func (ctrl *Controller) VectorAggregatorContainer() *corev1.Container