resource

Documentation

Index

• Constants
• type DefaultUserSecretBuilder
  • func (builder *DefaultUserSecretBuilder) Build() (client.Object, error)
  • func (builder *DefaultUserSecretBuilder) Update(object client.Object) error
  • func (builder *DefaultUserSecretBuilder) UpdateMayRequireStsRecreate() bool
• type ErlangCookieBuilder
  • func (builder *ErlangCookieBuilder) Build() (client.Object, error)
  • func (builder *ErlangCookieBuilder) Update(object client.Object) error
  • func (builder *ErlangCookieBuilder) UpdateMayRequireStsRecreate() bool
• type HeadlessServiceBuilder
  • func (builder *HeadlessServiceBuilder) Build() (client.Object, error)
  • func (builder *HeadlessServiceBuilder) Update(object client.Object) error
  • func (builder *HeadlessServiceBuilder) UpdateMayRequireStsRecreate() bool
• type RabbitmqPlugins
  • func NewRabbitmqPlugins(plugins []rabbitmqv1beta1.Plugin) RabbitmqPlugins
  • func (r *RabbitmqPlugins) AsString(sep string) string
  • func (r *RabbitmqPlugins) DesiredPlugins() []string
• type RabbitmqPluginsConfigMapBuilder
  • func (builder *RabbitmqPluginsConfigMapBuilder) Build() (client.Object, error)
  • func (builder *RabbitmqPluginsConfigMapBuilder) Update(object client.Object) error
  • func (builder *RabbitmqPluginsConfigMapBuilder) UpdateMayRequireStsRecreate() bool
• type RabbitmqResourceBuilder
  • func (builder *RabbitmqResourceBuilder) DefaultUserSecret() *DefaultUserSecretBuilder
  • func (builder *RabbitmqResourceBuilder) ErlangCookie() *ErlangCookieBuilder
  • func (builder *RabbitmqResourceBuilder) HeadlessService() *HeadlessServiceBuilder
  • func (builder *RabbitmqResourceBuilder) RabbitmqPluginsConfigMap() *RabbitmqPluginsConfigMapBuilder
  • func (builder *RabbitmqResourceBuilder) ResourceBuilders() []ResourceBuilder
  • func (builder *RabbitmqResourceBuilder) Role() *RoleBuilder
  • func (builder *RabbitmqResourceBuilder) RoleBinding() *RoleBindingBuilder
  • func (builder *RabbitmqResourceBuilder) ServerConfigMap() *ServerConfigMapBuilder
  • func (builder *RabbitmqResourceBuilder) Service() *ServiceBuilder
  • func (builder *RabbitmqResourceBuilder) ServiceAccount() *ServiceAccountBuilder
  • func (builder *RabbitmqResourceBuilder) StatefulSet() *StatefulSetBuilder
• type ResourceBuilder
• type RoleBindingBuilder
  • func (builder *RoleBindingBuilder) Build() (client.Object, error)
  • func (builder *RoleBindingBuilder) Update(object client.Object) error
  • func (builder *RoleBindingBuilder) UpdateMayRequireStsRecreate() bool
• type RoleBuilder
  • func (builder *RoleBuilder) Build() (client.Object, error)
  • func (builder *RoleBuilder) Update(object client.Object) error
  • func (builder *RoleBuilder) UpdateMayRequireStsRecreate() bool
• type ServerConfigMapBuilder
  • func (builder *ServerConfigMapBuilder) Build() (client.Object, error)
  • func (builder *ServerConfigMapBuilder) Update(object client.Object) error
  • func (builder *ServerConfigMapBuilder) UpdateMayRequireStsRecreate() bool
• type ServiceAccountBuilder
  • func (builder *ServiceAccountBuilder) Build() (client.Object, error)
  • func (builder *ServiceAccountBuilder) Update(object client.Object) error
  • func (builder *ServiceAccountBuilder) UpdateMayRequireStsRecreate() bool
• type ServiceBuilder
  • func (builder *ServiceBuilder) Build() (client.Object, error)
  • func (builder *ServiceBuilder) Update(object client.Object) error
  • func (builder *ServiceBuilder) UpdateMayRequireStsRecreate() bool
• type StatefulSetBuilder
  • func (builder *StatefulSetBuilder) Build() (client.Object, error)
  • func (builder *StatefulSetBuilder) Update(object client.Object) error
  • func (builder *StatefulSetBuilder) UpdateMayRequireStsRecreate() bool

Constants

const (
	DefaultUserSecretName = "default-user"
)

const (
	DeletionMarker string = "skipPreStopChecks"
)

const PluginsConfigName = "plugins-conf"

const (
	ServerConfigMapName = "server-conf"
)

const (
	ServiceSuffix = ""
)

Types

type DefaultUserSecretBuilder

type DefaultUserSecretBuilder struct {
	*RabbitmqResourceBuilder
}

func (*DefaultUserSecretBuilder) Build

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

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