machinery

Documentation

Overview

Package machinery contains general-purpose utilities used for integrating functionality between multiple packages.

Index

• func BuildTrustStrategy(kind v1beta1.TrustStrategyKind, kr keyring.Keyring) (trust.Strategy, error)
• func ConfigureAgentUpgrader(cfg *v1beta1.AgentUpgradeSpec, lg *zap.SugaredLogger) (update.SyncHandler, error)
• func ConfigureOCIFetcher(providerType string, args ...any) (oci.Fetcher, error)
• func ConfigurePluginUpgrader(cfg v1beta1.PluginUpgradeSpec, pluginDir string, lg *zap.SugaredLogger) (update.SyncHandler, error)
• func ConfigureStorageBackend(ctx context.Context, cfg *v1beta1.StorageSpec) (storage.Backend, error)
• func LoadAuthProviders(ctx context.Context, objects meta.ObjectList) map[string]auth.Middleware
• func LoadDocuments[T JsonDocument](documents []T) (meta.ObjectList, error)
• func LoadEphemeralKeys(fsys afero.Afero, dirs ...string) ([]*keyring.EphemeralKey, error)
• func NewNoauthServer(ctx context.Context, ap *v1beta1.AuthProvider) *noauth.Server
• func SubjectAccessCapableStore(client managementv1.ManagementClient) storage.SubjectAccessCapableStore
• type JsonDocument

Functions

func BuildTrustStrategy

func BuildTrustStrategy(kind v1beta1.TrustStrategyKind, kr keyring.Keyring) (trust.Strategy, error)

func ConfigureAgentUpgrader

func ConfigureAgentUpgrader(cfg *v1beta1.AgentUpgradeSpec, lg *zap.SugaredLogger) (update.SyncHandler, error)

func ConfigureOCIFetcher

func ConfigureOCIFetcher(providerType string, args ...any) (oci.Fetcher, error)

func ConfigurePluginUpgrader

func ConfigurePluginUpgrader(cfg v1beta1.PluginUpgradeSpec, pluginDir string, lg *zap.SugaredLogger) (update.SyncHandler, error)

func ConfigureStorageBackend

func ConfigureStorageBackend(ctx context.Context, cfg *v1beta1.StorageSpec) (storage.Backend, error)

func LoadAuthProviders

func LoadAuthProviders(ctx context.Context, objects meta.ObjectList) map[string]auth.Middleware

func LoadDocuments

func LoadDocuments[T JsonDocument](documents []T) (meta.ObjectList, error)

func LoadEphemeralKeys

func LoadEphemeralKeys(fsys afero.Afero, dirs ...string) ([]*keyring.EphemeralKey, error)

func NewNoauthServer

func NewNoauthServer(
	ctx context.Context,
	ap *v1beta1.AuthProvider,
) *noauth.Server

func SubjectAccessCapableStore

func SubjectAccessCapableStore(client managementv1.ManagementClient) storage.SubjectAccessCapableStore

Types

type JsonDocument

type JsonDocument interface {
	GetJson() []byte
}