managedresource

Jan 26, 2022

Changes in this version

+ const AnnotationConsumerPodSpecHash

+ const AnnotationSuperStreamPartition

Dec 11, 2023

Changes in this version

+ const AnnotationSuperStream

+ const AnnotationSuperStreamRoutingKey

+ func PartitionNameToRoutingKey(parentObjectName, partitionName string) string

+ func RoutingKeyToPartitionName(parentObjectName, routingKey string) string

+ type Builder struct

+ ObjectOwner metav1.Object

+ Scheme *runtime.Scheme

+ func (builder *Builder) SuperStreamBinding(partitionIndex int, routingKey, vhost string, ...) *SuperStreamBindingBuilder

+ func (builder *Builder) SuperStreamExchange(vhost string, rabbitmqCluster *topology.RabbitmqClusterReference) *SuperStreamExchangeBuilder

+ func (builder *Builder) SuperStreamPartition(partitionIndex int, routingKey, vhost string, ...) *SuperStreamPartitionBuilder

+ func (builder Builder) GenerateChildResourceName(suffix string) string

+ type ResourceBuilder interface

+ Build func() (client.Object, error)

+ ResourceType func() string

+ Update func(client.Object) error

+ type SuperStreamBindingBuilder struct

+ func (builder *SuperStreamBindingBuilder) Build() (client.Object, error)

+ func (builder *SuperStreamBindingBuilder) ResourceType() string

+ func (builder *SuperStreamBindingBuilder) Update(object client.Object) error

+ type SuperStreamExchangeBuilder struct

+ func (builder *SuperStreamExchangeBuilder) Build() (client.Object, error)

+ func (builder *SuperStreamExchangeBuilder) ResourceType() string

+ func (builder *SuperStreamExchangeBuilder) Update(object client.Object) error

+ type SuperStreamPartitionBuilder struct

+ func (builder *SuperStreamPartitionBuilder) Build() (client.Object, error)

+ func (builder *SuperStreamPartitionBuilder) ResourceType() string

+ func (builder *SuperStreamPartitionBuilder) Update(object client.Object) error