provisioners

Documentation

Index

• Constants
• func AddFinalizer(c *eventingv1alpha1.Channel, finalizerName string)
• func CreateDispatcherService(ctx context.Context, client runtimeClient.Client, ...) (*corev1.Service, error)
• func CreateK8sService(ctx context.Context, client runtimeClient.Client, c *eventingv1alpha1.Channel) (*corev1.Service, error)
• func CreateVirtualService(ctx context.Context, client runtimeClient.Client, c *eventingv1alpha1.Channel) (*istiov1alpha3.VirtualService, error)
• func DispatcherLabels(ccpName string) map[string]string
• func NewLoggingConfig() *logging.Config
• func NewProvisionerLoggerFromConfig(config *logging.Config) *zap.SugaredLogger
• func RemoveFinalizer(c *eventingv1alpha1.Channel, finalizerName string)
• func UpdateChannel(ctx context.Context, client runtimeClient.Client, u *eventingv1alpha1.Channel) error
• func UpdateClusterChannelProvisionerStatus(ctx context.Context, client runtimeClient.Client, ...) error

Constants

const (
	PortName   = "http"
	PortNumber = 80
)

Functions

func AddFinalizer

func AddFinalizer(c *eventingv1alpha1.Channel, finalizerName string)

func CreateDispatcherService

func CreateDispatcherService(ctx context.Context, client runtimeClient.Client, ccp *eventingv1alpha1.ClusterChannelProvisioner) (*corev1.Service, error)

func CreateK8sService

func CreateK8sService(ctx context.Context, client runtimeClient.Client, c *eventingv1alpha1.Channel) (*corev1.Service, error)

func CreateVirtualService

func CreateVirtualService(ctx context.Context, client runtimeClient.Client, c *eventingv1alpha1.Channel) (*istiov1alpha3.VirtualService, error)

func DispatcherLabels

func DispatcherLabels(ccpName string) map[string]string

func NewLoggingConfig

func NewLoggingConfig() *logging.Config

NewLoggingConfig creates a static logging configuration appropriate for a provisioner. All logging levels are set to Info.

func NewProvisionerLoggerFromConfig

func NewProvisionerLoggerFromConfig(config *logging.Config) *zap.SugaredLogger

NewProvisionerLoggerFromConfig creates a new zap logger for the provisioner component based on the provided configuration

func RemoveFinalizer

func RemoveFinalizer(c *eventingv1alpha1.Channel, finalizerName string)

func UpdateChannel

func UpdateChannel(ctx context.Context, client runtimeClient.Client, u *eventingv1alpha1.Channel) error

func UpdateClusterChannelProvisionerStatus

func UpdateClusterChannelProvisionerStatus(ctx context.Context, client runtimeClient.Client, u *eventingv1alpha1.ClusterChannelProvisioner) error