rabbitmqclient

May 7, 2024

Changes in this version

type Client

+ GetQueue func(string, string) (*rabbithole.DetailedQueueInfo, error)

Jun 14, 2022

Changes in this version

+ var FirstLoginAttemptResultCh = make(chan error, 1)

+ type ConnectionCredentials interface

+ Data func(key string) ([]byte, bool)

Dec 11, 2023

Changes in this version

+ var LoginToVaultFunc = LoginToVault

+ var NoServiceReferenceSetError = errors.New("RabbitmqCluster has no ServiceReference set in status.defaultUser")

+ var NoSuchRabbitmqClusterError = errors.New("RabbitmqCluster object does not exist")

+ var ReadServiceAccountTokenFunc = ReadServiceAccountToken

+ var ReadVaultClientSecretFunc = ReadVaultClientSecret

+ var ResourceNotAllowedError = errors.New(...)

+ var SecretClient SecretStoreClient

+ var SecretClientCreationError error

+ var SecretStoreClientProvider = GetSecretStoreClient

+ func AllowedNamespace(rmq topology.RabbitmqClusterReference, requestNamespace string, ...) bool

+ func AllowedNamespaceSecret(rmq topology.RabbitmqClusterReference, requestNamespace string, ...) bool

+ func InitializeClient() func()

+ func LoginToVault(vaultClient *vault.Client, authPath string, params map[string]interface{}) (*vault.Secret, error)

+ func ParseReference(ctx context.Context, c client.Client, rmq topology.RabbitmqClusterReference, ...) (map[string]string, bool, error)

+ func ReadServiceAccountToken() ([]byte, error)

+ func ReadVaultClientSecret(vaultClient *vault.Client, jwtToken string, vaultRole string, authPath string) (*vault.Secret, error)

+ type Client interface

+ ClearPermissionsIn func(string, string) (*http.Response, error)

+ DeclareBinding func(string, rabbithole.BindingInfo) (*http.Response, error)

+ DeclareExchange func(string, string, rabbithole.ExchangeSettings) (*http.Response, error)

+ DeclareQueue func(string, string, rabbithole.QueueSettings) (*http.Response, error)

+ DeclareShovel func(vhost, shovel string, info rabbithole.ShovelDefinition) (res *http.Response, err error)

+ DeleteBinding func(string, rabbithole.BindingInfo) (*http.Response, error)

+ DeleteExchange func(string, string) (*http.Response, error)

+ DeleteFederationUpstream func(vhost, name string) (res *http.Response, err error)

+ DeleteGlobalParameter func(name string) (*http.Response, error)

+ DeleteOperatorPolicy func(vhost, name string) (res *http.Response, err error)

+ DeletePolicy func(string, string) (*http.Response, error)

+ DeleteQueue func(string, string, ...rabbithole.QueueDeleteOptions) (*http.Response, error)

+ DeleteShovel func(vhost, shovel string) (res *http.Response, err error)

+ DeleteTopicPermissionsIn func(vhost, username string, exchange string) (res *http.Response, err error)

+ DeleteUser func(string) (*http.Response, error)

+ DeleteVhost func(string) (*http.Response, error)

+ GetVhost func(vhost string) (rec *rabbithole.VhostInfo, err error)

+ ListExchangeBindingsBetween func(string, string, string) ([]rabbithole.BindingInfo, error)

+ ListQueueBindingsBetween func(string, string, string) ([]rabbithole.BindingInfo, error)

+ PutFederationUpstream func(vhost, name string, def rabbithole.FederationDefinition) (res *http.Response, err error)

+ PutGlobalParameter func(name string, value interface{}) (*http.Response, error)

+ PutOperatorPolicy func(string, string, rabbithole.OperatorPolicy) (*http.Response, error)

+ PutPolicy func(string, string, rabbithole.Policy) (*http.Response, error)

+ PutUser func(string, rabbithole.UserSettings) (*http.Response, error)

+ PutVhost func(string, rabbithole.VhostSettings) (*http.Response, error)

+ UpdatePermissionsIn func(string, string, rabbithole.Permissions) (*http.Response, error)

+ UpdateTopicPermissionsIn func(vhost, username string, TopicPermissions rabbithole.TopicPermissions) (res *http.Response, err error)

+ type ClusterCredentials struct

+ func (c ClusterCredentials) Data(key string) ([]byte, bool)

+ type Factory func(connectionCreds map[string]string, tlsEnabled bool, certPool *x509.CertPool) (Client, error)

+ var RabbitholeClientFactory Factory = func(connectionCreds map[string]string, tlsEnabled bool, certPool *x509.CertPool) (Client, error) { ... }

+ type SecretReader interface

+ ReadSecret func(path string) (*vault.Secret, error)

+ type SecretStoreClient interface

+ ReadCredentials func(path string) (string, string, error)

+ func GetSecretStoreClient() (SecretStoreClient, error)

+ type VaultClient struct

+ Reader SecretReader

+ func (vc VaultClient) ReadCredentials(path string) (string, string, error)

+ type VaultSecretReader struct

+ func (s VaultSecretReader) ReadSecret(path string) (*vault.Secret, error)