internal

func GenerateBindingInfo ¶

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

func GenerateExchangeSettings ¶

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

func GenerateQueueSettings ¶

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

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 GenerateUserSettings ¶

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

func GenerateVhostSettings ¶

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

func RandomEncodedString ¶

func RandomEncodedString(dataLen int) (string, error)