Documentation ¶
Index ¶
- func BrokerChannelName(brokerName, channelType string) string
- func FilterLabels(brokerName string) map[string]string
- func IngressLabels(brokerName string) map[string]string
- func MakeFilterDeployment(args *FilterArgs) *appsv1.Deployment
- func MakeFilterService(b *eventingv1alpha1.Broker) *corev1.Service
- func MakeIngress(args *IngressArgs) *appsv1.Deployment
- func MakeIngressService(b *eventingv1alpha1.Broker) *corev1.Service
- func MakeSubscription(b *v1alpha1.Broker, c *duckv1alpha1.Channelable, svc *corev1.Service) *messagingv1alpha1.Subscription
- func NewChannel(channelType string, b *v1alpha1.Broker, l map[string]string) (*unstructured.Unstructured, error)
- type FilterArgs
- type IngressArgs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BrokerChannelName ¶ added in v0.7.0
BrokerChannelName creates a name for the Channel for a Broker for a given Channel type.
func FilterLabels ¶
FilterLabels generates the labels present on all resources representing the filter of the given Broker.
func IngressLabels ¶
IngressLabels generates the labels present on all resources representing the ingress of the given Broker.
func MakeFilterDeployment ¶
func MakeFilterDeployment(args *FilterArgs) *appsv1.Deployment
MakeFilterDeployment creates the in-memory representation of the Broker's filter Deployment.
func MakeFilterService ¶
func MakeFilterService(b *eventingv1alpha1.Broker) *corev1.Service
MakeFilterService creates the in-memory representation of the Broker's filter Service.
func MakeIngress ¶
func MakeIngress(args *IngressArgs) *appsv1.Deployment
MakeIngress creates the in-memory representation of the Broker's ingress Deployment.
func MakeIngressService ¶
func MakeIngressService(b *eventingv1alpha1.Broker) *corev1.Service
MakeIngressService creates the in-memory representation of the Broker's ingress Service.
func MakeSubscription ¶ added in v0.10.0
func MakeSubscription(b *v1alpha1.Broker, c *duckv1alpha1.Channelable, svc *corev1.Service) *messagingv1alpha1.Subscription
MakeSubscription returns a placeholder subscription for broker 'b', channelable 'c', and service 'svc'.
func NewChannel ¶ added in v0.7.0
func NewChannel(channelType string, b *v1alpha1.Broker, l map[string]string) (*unstructured.Unstructured, error)
test NewChannel returns an unstructured.Unstructured based on the ChannelTemplateSpec for a given Broker.
Types ¶
type FilterArgs ¶
type FilterArgs struct { Broker *eventingv1alpha1.Broker Image string ServiceAccountName string }
FilterArgs are the arguments to create a Broker's filter Deployment.
type IngressArgs ¶
type IngressArgs struct { Broker *eventingv1alpha1.Broker Image string ServiceAccountName string ChannelAddress string }
IngressArgs are the arguments to create a Broker's ingress Deployment.