resource

package
v2.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 13, 2026 License: MPL-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultUserSecretName = "default-user"
)
View Source 
const (
	DeletionMarker string = "skipPreStopChecks"
)
View Source 
const PluginsConfigName = "plugins-conf"
View Source 
const (
	ServerConfigMapName = "server-conf"
)
View Source 
const (
	ServiceSuffix = ""
)

Variables

View Source 
var ErrInvalidEnvConfig = errors.New("spec.rabbitmq.envConfig must not contain shell command substitution ('$(...)' or backticks)")

Functions

func ShouldCreatePeerDiscoveryRBAC added in v2.21.0 

func ShouldCreatePeerDiscoveryRBAC(rmq *rabbitmqv1beta1.RabbitmqCluster) bool

ShouldCreatePeerDiscoveryRBAC returns true if the peer-discovery Role and RoleBinding should be created for this RabbitmqCluster. The ServiceAccount is always created regardless of RabbitMQ version because other integrations (e.g. Vault Kubernetes auth) may rely on it.

Types

type DefaultUserSecretBuilder 

type DefaultUserSecretBuilder struct {
	*RabbitmqResourceBuilder
}

func (*DefaultUserSecretBuilder) Build 

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

Build creates a Secret for the default RabbitMQ user. If default_user and/or default_pass are specified in spec.rabbitmq.additionalConfig, those values are used. Otherwise, credentials are randomly generated.

func (*DefaultUserSecretBuilder) Update 

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

func (*DefaultUserSecretBuilder) UpdateMayRequireStsRecreate 

func (builder *DefaultUserSecretBuilder) UpdateMayRequireStsRecreate() bool

type ErlangCookieBuilder 

type ErlangCookieBuilder struct {
	*RabbitmqResourceBuilder
}

func (*ErlangCookieBuilder) Build 

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

func (*ErlangCookieBuilder) Update 

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

func (*ErlangCookieBuilder) UpdateMayRequireStsRecreate 

func (builder *ErlangCookieBuilder) UpdateMayRequireStsRecreate() bool

type HeadlessServiceBuilder 

type HeadlessServiceBuilder struct {
	*RabbitmqResourceBuilder
}

func (*HeadlessServiceBuilder) Build 

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

func (*HeadlessServiceBuilder) Update 

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

func (*HeadlessServiceBuilder) UpdateMayRequireStsRecreate 

func (builder *HeadlessServiceBuilder) UpdateMayRequireStsRecreate() bool

type RabbitmqPlugins 

type RabbitmqPlugins struct {
	// contains filtered or unexported fields
}

func NewRabbitmqPlugins 

func NewRabbitmqPlugins(plugins []rabbitmqv1beta1.Plugin) RabbitmqPlugins

func (*RabbitmqPlugins) AsString 

func (r *RabbitmqPlugins) AsString(sep string) string

func (*RabbitmqPlugins) DesiredPlugins 

func (r *RabbitmqPlugins) DesiredPlugins() []string

type RabbitmqPluginsConfigMapBuilder 

type RabbitmqPluginsConfigMapBuilder struct {
	*RabbitmqResourceBuilder
}

func (*RabbitmqPluginsConfigMapBuilder) Build 

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

func (*RabbitmqPluginsConfigMapBuilder) Update 

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

func (*RabbitmqPluginsConfigMapBuilder) UpdateMayRequireStsRecreate 

func (builder *RabbitmqPluginsConfigMapBuilder) UpdateMayRequireStsRecreate() bool

type RabbitmqResourceBuilder 

type RabbitmqResourceBuilder struct {
	Instance *rabbitmqv1beta1.RabbitmqCluster
	Scheme   *runtime.Scheme
}

func (*RabbitmqResourceBuilder) DefaultUserSecret 

func (builder *RabbitmqResourceBuilder) DefaultUserSecret() *DefaultUserSecretBuilder

func (*RabbitmqResourceBuilder) ErlangCookie 

func (builder *RabbitmqResourceBuilder) ErlangCookie() *ErlangCookieBuilder

func (*RabbitmqResourceBuilder) HeadlessService 

func (builder *RabbitmqResourceBuilder) HeadlessService() *HeadlessServiceBuilder

func (*RabbitmqResourceBuilder) RabbitmqPluginsConfigMap 

func (builder *RabbitmqResourceBuilder) RabbitmqPluginsConfigMap() *RabbitmqPluginsConfigMapBuilder

func (*RabbitmqResourceBuilder) ResourceBuilders 

func (builder *RabbitmqResourceBuilder) ResourceBuilders() []ResourceBuilder

func (*RabbitmqResourceBuilder) Role 

func (builder *RabbitmqResourceBuilder) Role() *RoleBuilder

func (*RabbitmqResourceBuilder) RoleBinding 

func (builder *RabbitmqResourceBuilder) RoleBinding() *RoleBindingBuilder

func (*RabbitmqResourceBuilder) ServerConfigMap 

func (builder *RabbitmqResourceBuilder) ServerConfigMap() *ServerConfigMapBuilder

func (*RabbitmqResourceBuilder) Service 

func (builder *RabbitmqResourceBuilder) Service() *ServiceBuilder

func (*RabbitmqResourceBuilder) ServiceAccount 

func (builder *RabbitmqResourceBuilder) ServiceAccount() *ServiceAccountBuilder

func (*RabbitmqResourceBuilder) StatefulSet 

func (builder *RabbitmqResourceBuilder) StatefulSet() *StatefulSetBuilder

type ResourceBuilder 

type ResourceBuilder interface {
	Build() (client.Object, error)
	Update(client.Object) error
	UpdateMayRequireStsRecreate() bool
}

type RoleBindingBuilder 

type RoleBindingBuilder struct {
	*RabbitmqResourceBuilder
}

func (*RoleBindingBuilder) Build 

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

func (*RoleBindingBuilder) Update 

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

func (*RoleBindingBuilder) UpdateMayRequireStsRecreate 

func (builder *RoleBindingBuilder) UpdateMayRequireStsRecreate() bool

type RoleBuilder 

type RoleBuilder struct {
	*RabbitmqResourceBuilder
}

func (*RoleBuilder) Build 

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

func (*RoleBuilder) Update 

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

func (*RoleBuilder) UpdateMayRequireStsRecreate 

func (builder *RoleBuilder) UpdateMayRequireStsRecreate() bool

type ServerConfigMapBuilder 

type ServerConfigMapBuilder struct {
	*RabbitmqResourceBuilder
	UpdateRequiresStsRestart bool
}

func (*ServerConfigMapBuilder) Build 

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

func (*ServerConfigMapBuilder) Update 

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

func (*ServerConfigMapBuilder) UpdateMayRequireStsRecreate 

func (builder *ServerConfigMapBuilder) UpdateMayRequireStsRecreate() bool

type ServiceAccountBuilder 

type ServiceAccountBuilder struct {
	*RabbitmqResourceBuilder
}

func (*ServiceAccountBuilder) Build 

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

func (*ServiceAccountBuilder) Update 

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

func (*ServiceAccountBuilder) UpdateMayRequireStsRecreate 

func (builder *ServiceAccountBuilder) UpdateMayRequireStsRecreate() bool

type ServiceBuilder 

type ServiceBuilder struct {
	*RabbitmqResourceBuilder
}

func (*ServiceBuilder) Build 

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

func (*ServiceBuilder) Update 

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

func (*ServiceBuilder) UpdateMayRequireStsRecreate 

func (builder *ServiceBuilder) UpdateMayRequireStsRecreate() bool

type StatefulSetBuilder 

type StatefulSetBuilder struct {
	*RabbitmqResourceBuilder
}

func (*StatefulSetBuilder) Build 

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

func (*StatefulSetBuilder) Update 

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

func (*StatefulSetBuilder) UpdateMayRequireStsRecreate 

func (builder *StatefulSetBuilder) UpdateMayRequireStsRecreate() bool

updates to storage capacity will recreate sts

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.