pipelineutil

Documentation

Index

• Constants
• func DebugLogger[T context.Context](ctx T) pipeline.Listener[T]
• func FetchProviderConfig(ctx context.Context, kube client.Client, providerConfigRef string) (string, string, error)
• type ExoscaleConnector
  • func OpenExoscaleClient(ctx context.Context, kube client.Client, providerConfigRef string, ...) (*ExoscaleConnector, error)

Constants

const (
	// ExoscaleAPIKey identifies the key in which the API Key of the exoscale.com is expected in a Secret.
	ExoscaleAPIKey = "EXOSCALE_API_KEY"
	// ExoscaleAPISecret identifies the secret in which the API Secret of the exoscale.com is expected in a Secret.
	ExoscaleAPISecret = "EXOSCALE_API_SECRET"
)

Functions

func DebugLogger

func DebugLogger[T context.Context](ctx T) pipeline.Listener[T]

DebugLogger returns a list with a single hook that logs the step name. The logger is retrieved from the given context.

func FetchProviderConfig

func FetchProviderConfig(ctx context.Context, kube client.Client, providerConfigRef string) (string, string, error)

FetchProviderConfig returns the apiKey and apiSecret of the given providerConfigRef

Types

type ExoscaleConnector

type ExoscaleConnector struct {
	ApiKey    string
	ApiSecret string
	Exoscale  *exoscalesdk.Client
}

func OpenExoscaleClient

func OpenExoscaleClient(ctx context.Context, kube client.Client, providerConfigRef string, opts ...exoscalesdk.ClientOpt) (*ExoscaleConnector, error)

OpenExoscaleClient fetches the ProviderConfig given by the name, fetches the API secret and returns a ExoscaleConnector with an initialized client.