operator

Documentation

Index

• Variables
• func GetKubernetesConfig(config *config2.Kubernetes) (*rest.Config, error)
• type B3ScaleOperator
  • func NewB3ScaleOperator(config *config.Config) (*B3ScaleOperator, error)
  • func (o *B3ScaleOperator) Reconcile(ctx context.Context, op *skop.Operator, res skop.Resource) error
  • func (o *B3ScaleOperator) Run() error
• type OperatorKubernetesClient
  • func NewOperatorKubernetesClient(cs *kubernetes.Clientset) *OperatorKubernetesClient
  • func (o *OperatorKubernetesClient) CompleteBBBFrontend(ctx context.Context, bbb *v1.BBBFrontend, finalizer string, id string) error
  • func (o *OperatorKubernetesClient) RemoveFinalizerFromBBBFrontend(ctx context.Context, bbb *v1.BBBFrontend, finalizer string) error
  • func (o *OperatorKubernetesClient) SetReadyStatusCondition(ctx context.Context, bbb *v1.BBBFrontend, isReady bool, err error) error
  • func (o *OperatorKubernetesClient) UpdateBBBFrontend(ctx context.Context, bbb *v1.BBBFrontend) error
  • func (o *OperatorKubernetesClient) UpdateBBBFrontendStatus(ctx context.Context, bbb *v1.BBBFrontend) error

Variables

var FINALIZER_URL = "b3scale.io/finalizer"

Functions

func GetKubernetesConfig

func GetKubernetesConfig(config *config2.Kubernetes) (*rest.Config, error)

Types

type B3ScaleOperator

type B3ScaleOperator struct {
	// contains filtered or unexported fields
}

func NewB3ScaleOperator

func NewB3ScaleOperator(config *config.Config) (*B3ScaleOperator, error)

func (*B3ScaleOperator) Reconcile

func (o *B3ScaleOperator) Reconcile(ctx context.Context, op *skop.Operator, res skop.Resource) error

func (*B3ScaleOperator) Run

func (o *B3ScaleOperator) Run() error

type OperatorKubernetesClient

type OperatorKubernetesClient struct {
	// contains filtered or unexported fields
}

func NewOperatorKubernetesClient

func NewOperatorKubernetesClient(cs *kubernetes.Clientset) *OperatorKubernetesClient

func (*OperatorKubernetesClient) CompleteBBBFrontend

func (o *OperatorKubernetesClient) CompleteBBBFrontend(ctx context.Context, bbb *v1.BBBFrontend, finalizer string, id string) error

func (*OperatorKubernetesClient) RemoveFinalizerFromBBBFrontend

func (o *OperatorKubernetesClient) RemoveFinalizerFromBBBFrontend(ctx context.Context, bbb *v1.BBBFrontend, finalizer string) error

func (*OperatorKubernetesClient) SetReadyStatusCondition

func (o *OperatorKubernetesClient) SetReadyStatusCondition(ctx context.Context, bbb *v1.BBBFrontend, isReady bool, err error) error

func (*OperatorKubernetesClient) UpdateBBBFrontend

func (o *OperatorKubernetesClient) UpdateBBBFrontend(ctx context.Context, bbb *v1.BBBFrontend) error

func (*OperatorKubernetesClient) UpdateBBBFrontendStatus

func (o *OperatorKubernetesClient) UpdateBBBFrontendStatus(ctx context.Context, bbb *v1.BBBFrontend) error