resources

Documentation

Index

• Constants
• func CommonLabels(brokerCellName string) map[string]string
• func Labels(brokerCellName, componentName string) map[string]string
• func MakeFanoutDeployment(args FanoutArgs) *appsv1.Deployment
• func MakeHorizontalPodAutoscaler(deployment *appsv1.Deployment, args AutoscalingArgs) *hpav2beta2.HorizontalPodAutoscaler
• func MakeIngressDeployment(args IngressArgs) *appsv1.Deployment
• func MakeIngressService(args IngressArgs) *corev1.Service
• func MakeRetryDeployment(args RetryArgs) *appsv1.Deployment
• func MakeTargetsConfig(bc *intv1alpha1.BrokerCell, brokerTargets config.Targets) (*corev1.ConfigMap, error)
• func Name(brokerCellName, componentName string) string
• type Args
• type AutoscalingArgs
• type FanoutArgs
• type IngressArgs
• type RetryArgs

Constants

const (
	// IngressName is the name used for the ingress container.
	IngressName = "ingress"
	// FanoutName is the name used for the fanout container.
	FanoutName = "fanout"
	// RetryName is the name used for the retry container.
	RetryName          = "retry"
	BrokerCellLabelKey = "brokerCell"
)

Functions

func CommonLabels

func CommonLabels(brokerCellName string) map[string]string

func Labels

func Labels(brokerCellName, componentName string) map[string]string

Labels generates the labels present on all resources representing the component of the given BrokerCell.

func MakeFanoutDeployment

func MakeFanoutDeployment(args FanoutArgs) *appsv1.Deployment

MakeFanoutDeployment creates the fanout Deployment object.

func MakeHorizontalPodAutoscaler

func MakeHorizontalPodAutoscaler(deployment *appsv1.Deployment, args AutoscalingArgs) *hpav2beta2.HorizontalPodAutoscaler

MakeHorizontalPodAutoscaler makes an HPA for the given arguments.

func MakeIngressDeployment

func MakeIngressDeployment(args IngressArgs) *appsv1.Deployment

MakeIngressDeployment creates the ingress Deployment object.

func MakeIngressService

func MakeIngressService(args IngressArgs) *corev1.Service

MakeIngressService creates the ingress Service.

func MakeRetryDeployment

func MakeRetryDeployment(args RetryArgs) *appsv1.Deployment

MakeRetryDeployment creates the retry Deployment object.

func MakeTargetsConfig

func MakeTargetsConfig(bc *intv1alpha1.BrokerCell, brokerTargets config.Targets) (*corev1.ConfigMap, error)

func Name

func Name(brokerCellName, componentName string) string

Name creates a name for the component (ingress/fanout/retry).

Types

type Args

type Args struct {
	ComponentName      string
	BrokerCell         *intv1alpha1.BrokerCell
	Image              string
	ServiceAccountName string
	MetricsPort        int
}

Args are the common arguments to create a Broker's data plane Deployment.

type AutoscalingArgs

type AutoscalingArgs struct {
	ComponentName     string
	BrokerCell        *intv1alpha1.BrokerCell
	AvgCPUUtilization int32
	AvgMemoryUsage    string
	MaxReplicas       int32
}

AutoscalingArgs are the arguments to create HPA for deployments.

type FanoutArgs

type FanoutArgs struct {
	Args
}

FanoutArgs are the arguments to create a Broker's fanout Deployment.

type IngressArgs

type IngressArgs struct {
	Args
	Port int
}

IngressArgs are the arguments to create a Broker's ingress Deployment.

type RetryArgs

type RetryArgs struct {
	Args
}

RetryArgs are the arguments to create a Broker's retry Deployment.