internal

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 GenerateUserSettings(credentials *corev1.Secret, tags []topology.UserTag) (rabbithole.UserSettings, error)
• func GenerateVhostSettings(v *topology.Vhost) *rabbithole.VhostSettings
• func RandomEncodedString(dataLen int) (string, error)
• type UpstreamEndpoints
  • func GenerateSchemaReplicationParameters(secret *corev1.Secret, endpoints string) (UpstreamEndpoints, error)

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

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

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 GenerateUserSettings

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

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)