vectoragent

Documentation

Index

• Constants
• type Controller
  • func NewController(v *vectorv1alpha1.Vector, c client.Client, cs *kubernetes.Clientset) *Controller
  • func (ctrl *Controller) ConfigReloaderInitContainer() *corev1.Container
  • func (ctrl *Controller) ConfigReloaderSidecarContainer() *corev1.Container
  • func (ctrl *Controller) EnsureVectorAgent(ctx context.Context, configOnly bool) error
  • func (ctrl *Controller) SetDefault()
  • func (ctrl *Controller) SetFailedStatus(ctx context.Context, reason string) error
  • func (ctrl *Controller) SetLastAppliedPipelineStatus(ctx context.Context, hash *uint32) error
  • func (ctrl *Controller) SetSucceesStatus(ctx context.Context) error
  • func (ctrl *Controller) VectorAgentContainer() *corev1.Container

Constants

const (
	ApiPort = 8686
)

Types

type Controller

type Controller struct {
	client.Client
	Vector *vectorv1alpha1.Vector

	Config []byte
	// Temp. Wait this issue - https://github.com/kubernetes-sigs/controller-runtime/issues/452
	ClientSet *kubernetes.Clientset
}

func NewController

func NewController(v *vectorv1alpha1.Vector, c client.Client, cs *kubernetes.Clientset) *Controller

func (*Controller) ConfigReloaderInitContainer

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

func (*Controller) ConfigReloaderSidecarContainer

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

func (*Controller) EnsureVectorAgent

func (ctrl *Controller) EnsureVectorAgent(ctx context.Context, configOnly bool) error

func (*Controller) SetDefault

func (ctrl *Controller) SetDefault()

func (*Controller) SetFailedStatus

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

func (*Controller) SetLastAppliedPipelineStatus

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

func (*Controller) SetSucceesStatus

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

func (*Controller) VectorAgentContainer

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