resources

Documentation

Index

• Constants
• func CreateBrokerCell(b *v1beta1.Broker) *inteventsv1alpha1.BrokerCell
• func GenerateDecouplingSubscriptionName(b *brokerv1beta1.Broker) string
• func GenerateDecouplingTopicName(b *brokerv1beta1.Broker) string
• func GenerateRetrySubscriptionName(t *brokerv1beta1.Trigger) string
• func GenerateRetryTopicName(t *brokerv1beta1.Trigger) string

Constants

const DefaultBrokerCellName = "default"

Right now we only support one brokercell in the system namespace in the cluster. TODO(#866) Delete hard-coded brokercell once we can dynamically assign brokercell to brokers.

Functions

func CreateBrokerCell

func CreateBrokerCell(b *v1beta1.Broker) *inteventsv1alpha1.BrokerCell

func GenerateDecouplingSubscriptionName

func GenerateDecouplingSubscriptionName(b *brokerv1beta1.Broker) string

GenerateDecouplingSubscriptionName generates a deterministic subscription name for a Broker. If the subscription name would be longer than allowed by PubSub, the Broker name is truncated to fit.

func GenerateDecouplingTopicName

func GenerateDecouplingTopicName(b *brokerv1beta1.Broker) string

GenerateDecouplingTopicName generates a deterministic topic name for a Broker. If the topic name would be longer than allowed by PubSub, the Broker name is truncated to fit.

func GenerateRetrySubscriptionName

func GenerateRetrySubscriptionName(t *brokerv1beta1.Trigger) string

GenerateRetrySubscriptionName generates a deterministic subscription name for a Trigger. If the subscription name would be longer than allowed by PubSub, the Trigger name is truncated to fit.

func GenerateRetryTopicName

func GenerateRetryTopicName(t *brokerv1beta1.Trigger) string

GenerateRetryTopicName generates a deterministic topic name for a Trigger. If the topic name would be longer than allowed by PubSub, the Trigger name is truncated to fit.