backend

package
v0.6.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 9, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ProviderKMSName = "kms"
	ProviderOOSName = "oos"
)
View Source
const EnvClient = "env.client"

Variables

View Source
var EnableWorkerRole bool
View Source
var (
	SupportProvider map[string]CreateProvider
)

Functions

func NewProviderClientByENV

func NewProviderClientByENV() error

func RegisterProvider

func RegisterProvider(providerName string, provider Provider)

Types

type ClientManager

type ClientManager interface {
	Register(clientKey string, secretClient SecretClient)
	GetClient(clientKey string) (SecretClient, error)
	Delete(clientKey string)
}

type CreateProvider

type CreateProvider func(opt *ProviderOptions)

type Provider

type Provider interface {
	ClientManager
	// NewClient constructs secrets client by secret store
	// endpoint specifies a custom service endpoint (e.g., KMS VPC endpoint).
	// Pass empty string to use the provider's default endpoint.
	NewClient(ctx context.Context, store *v1alpha1.SecretStore, kube client.Client, endpoint string) (SecretClient, error)
	// NewClientByENV constructs secrets client by environment variable
	// endpoint specifies a custom service endpoint. Pass empty string to use default.
	NewClientByENV(endpoint string) (SecretClient, error)
	GetName() string
	GetRegion() string
	GetEndpoint() string
	GetClusterId() string
	GetUid() string
}

func GetProviderByName

func GetProviderByName(providerName string) Provider

type ProviderOptions

type ProviderOptions struct {
	Region           string
	ClusterId        string
	Uid              string
	KmsEndpoint      string
	KmsMaxConcurrent int
	OosMaxConcurrent int
}

type SecretClient

type SecretClient interface {
	GetName() string
	// GetSecret gets secret via externalSecret
	GetExternalSecret(data *v1alpha1.DataSource, kube client.Client) (map[string][]byte, error)
	GetExternalSecretWithExtract(data *v1alpha1.DataProcess, kube client.Client) (map[string][]byte, error)
}

Directories

Path Synopsis
kms
oos

Jump to

Keyboard shortcuts

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