managedresource

Documentation

Index

• Constants
• func PartitionNameToRoutingKey(parentObjectName, partitionName string) string
• func RoutingKeyToPartitionName(parentObjectName, routingKey string) string
• type Builder
  • func (builder *Builder) GenerateChildResourceName(suffix string) string
  • 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
• type ResourceBuilder
• type SuperStreamBindingBuilder
  • func (builder *SuperStreamBindingBuilder) Build() (client.Object, error)
  • func (builder *SuperStreamBindingBuilder) ResourceType() string
  • func (builder *SuperStreamBindingBuilder) Update(object client.Object) error
• type SuperStreamExchangeBuilder
  • func (builder *SuperStreamExchangeBuilder) Build() (client.Object, error)
  • func (builder *SuperStreamExchangeBuilder) ResourceType() string
  • func (builder *SuperStreamExchangeBuilder) Update(object client.Object) error
• type SuperStreamPartitionBuilder
  • func (builder *SuperStreamPartitionBuilder) Build() (client.Object, error)
  • func (builder *SuperStreamPartitionBuilder) ResourceType() string
  • func (builder *SuperStreamPartitionBuilder) Update(object client.Object) error

Constants

const (
	AnnotationSuperStream           = "rabbitmq.com/super-stream"
	AnnotationSuperStreamRoutingKey = "rabbitmq.com/super-stream-routing-key"
)

Functions

func PartitionNameToRoutingKey

func PartitionNameToRoutingKey(parentObjectName, partitionName string) string

func RoutingKeyToPartitionName

func RoutingKeyToPartitionName(parentObjectName, routingKey string) string

Types

type Builder

type Builder struct {
	ObjectOwner metav1.Object
	Scheme      *runtime.Scheme
}

func (*Builder) GenerateChildResourceName

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

func (*Builder) SuperStreamBinding

func (builder *Builder) SuperStreamBinding(partitionIndex int, routingKey, vhost string, rabbitmqCluster *topology.RabbitmqClusterReference) *SuperStreamBindingBuilder

func (*Builder) SuperStreamExchange

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

func (*Builder) SuperStreamPartition

func (builder *Builder) SuperStreamPartition(partitionIndex int, routingKey, vhost string, rabbitmqCluster *topology.RabbitmqClusterReference) *SuperStreamPartitionBuilder

type ResourceBuilder

type ResourceBuilder interface {
	Build() (client.Object, error)
	Update(client.Object) error
	ResourceType() string
}

type SuperStreamBindingBuilder

type SuperStreamBindingBuilder struct {
	*Builder
	// contains filtered or unexported fields
}

func (*SuperStreamBindingBuilder) Build

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

func (*SuperStreamBindingBuilder) ResourceType

func (builder *SuperStreamBindingBuilder) ResourceType() string

func (*SuperStreamBindingBuilder) Update

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

type SuperStreamExchangeBuilder

type SuperStreamExchangeBuilder struct {
	*Builder
	// contains filtered or unexported fields
}

func (*SuperStreamExchangeBuilder) Build

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

func (*SuperStreamExchangeBuilder) ResourceType

func (builder *SuperStreamExchangeBuilder) ResourceType() string

func (*SuperStreamExchangeBuilder) Update

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

type SuperStreamPartitionBuilder

type SuperStreamPartitionBuilder struct {
	*Builder
	// contains filtered or unexported fields
}

func (*SuperStreamPartitionBuilder) Build

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

func (*SuperStreamPartitionBuilder) ResourceType

func (builder *SuperStreamPartitionBuilder) ResourceType() string

func (*SuperStreamPartitionBuilder) Update

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