internal

package

v1.17.3 Latest Latest Go to latest Published: Jul 24, 2025 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation ¶

Index ¶

func GenerateBindingInfo(binding *topology.Binding) (*rabbithole.BindingInfo, error)
func GenerateExchangeSettings(e *topology.Exchange) (*rabbithole.ExchangeSettings, error)
func GenerateFederationDefinition(f *topology.Federation, uri string) rabbithole.FederationDefinition
func GenerateOperatorPolicy(p *topology.OperatorPolicy) (*rabbithole.OperatorPolicy, error)
func GeneratePermissions(p *topology.Permission) rabbithole.Permissions
func GeneratePolicy(p *topology.Policy) (*rabbithole.Policy, error)
func GeneratePropertiesKey(binding *topology.Binding) string
func GenerateQueueDeleteOptions(q *topology.Queue) (*rabbithole.QueueDeleteOptions, error)
func GenerateQueueSettings(q *topology.Queue) (*rabbithole.QueueSettings, error)
func GenerateShovelDefinition(s *topology.Shovel, srcUri, destUri string) (*rabbithole.ShovelDefinition, error)
func GenerateTopicPermissions(p *topology.TopicPermission) rabbithole.TopicPermissions
func GenerateUserLimits(userLimits *topology.UserLimits) rabbithole.UserLimitsValues
func GenerateUserSettings(credentials *corev1.Secret, tags []topology.UserTag) (rabbithole.UserSettings, error)
func GenerateVhostLimits(limits *topology.VhostLimits) rabbithole.VhostLimitsValues
func GenerateVhostSettings(v *topology.Vhost) *rabbithole.VhostSettings
func RandomEncodedString(dataLen int) (string, error)
type UpstreamEndpoints
- func GenerateSchemaReplicationParameters(secret *corev1.Secret, endpoints string) (UpstreamEndpoints, error)
type UserCredentials

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GenerateBindingInfo ¶

func GenerateBindingInfo(binding *topology.Binding) (*rabbithole.BindingInfo, error)

func GenerateExchangeSettings ¶

func GenerateExchangeSettings(e *topology.Exchange) (*rabbithole.ExchangeSettings, error)

func GenerateFederationDefinition ¶

func GenerateFederationDefinition(f *topology.Federation, uri string) rabbithole.FederationDefinition

func GenerateOperatorPolicy ¶ added in v1.13.0

func GenerateOperatorPolicy(p *topology.OperatorPolicy) (*rabbithole.OperatorPolicy, error)

func GeneratePermissions ¶

func GeneratePermissions(p *topology.Permission) rabbithole.Permissions

func GeneratePolicy ¶

func GeneratePolicy(p *topology.Policy) (*rabbithole.Policy, error)

func GeneratePropertiesKey ¶

func GeneratePropertiesKey(binding *topology.Binding) string

func GenerateQueueDeleteOptions ¶ added in v1.14.0

func GenerateQueueDeleteOptions(q *topology.Queue) (*rabbithole.QueueDeleteOptions, error)

GenerateQueueDeleteOptions generates rabbithole.QueueDeleteOptions for a given Queue queue.Spec.Arguments (type k8s runtime.RawExtensions) is unmarshalled

func GenerateQueueSettings ¶

func GenerateQueueSettings(q *topology.Queue) (*rabbithole.QueueSettings, error)

GenerateQueueSettings generates rabbithole.QueueSettings for a given Queue queue.Spec.Arguments (type k8s runtime.RawExtensions) is unmarshalled Unmarshall stores float64, for JSON numbers See: https://golang.org/pkg/encoding/json/#Unmarshal

func GenerateShovelDefinition ¶

func GenerateShovelDefinition(s *topology.Shovel, srcUri, destUri string) (*rabbithole.ShovelDefinition, error)

func GenerateTopicPermissions ¶

func GenerateTopicPermissions(p *topology.TopicPermission) rabbithole.TopicPermissions

func GenerateUserLimits ¶ added in v1.17.0

func GenerateUserLimits(userLimits *topology.UserLimits) rabbithole.UserLimitsValues

func GenerateUserSettings ¶

func GenerateUserSettings(credentials *corev1.Secret, tags []topology.UserTag) (rabbithole.UserSettings, error)

func GenerateVhostLimits ¶ added in v1.17.0

func GenerateVhostLimits(limits *topology.VhostLimits) rabbithole.VhostLimitsValues

func GenerateVhostSettings ¶

func GenerateVhostSettings(v *topology.Vhost) *rabbithole.VhostSettings

func RandomEncodedString ¶

func RandomEncodedString(dataLen int) (string, error)

Types ¶

type UpstreamEndpoints ¶

type UpstreamEndpoints struct {
	Username  string   `json:"username"`
	Password  string   `json:"password"`
	Endpoints []string `json:"endpoints"`
}

func GenerateSchemaReplicationParameters ¶

func GenerateSchemaReplicationParameters(secret *corev1.Secret, endpoints string) (UpstreamEndpoints, error)

type UserCredentials ¶ added in v1.15.0

type UserCredentials struct {
	// Must be present if ImportCredentialsSecret is provided.
	Username string
	// If PasswordHash is an empty string, a passwordless user is created.
	// If PasswordHash is nil, Password is used instead.
	PasswordHash *string
	// If Password is empty and PasswordHash is nil, a random password is generated.
	Password string
}

UserCredentials describes the credentials that can be provided in ImportCredentialsSecret for a User. If the secret is not provided, a random username and password will be generated.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
managedresource
testutils

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL