aws

Documentation

Index

• type Manager
  • func NewManager(cfg *config.Config) (*Manager, error)
  • func (m *Manager) DeleteEnvironment(ctx context.Context, envName string) error
  • func (m *Manager) GetClient() *client.Client
  • func (m *Manager) GetConfig() *config.Config
  • func (m *Manager) GetParameterStore() *parameter_store.Store
  • func (m *Manager) GetSecretsManager() *secrets_manager.Manager
  • func (m *Manager) ListEnvironmentVariables(ctx context.Context, envName string) (map[string]string, error)
  • func (m *Manager) PullEnvironment(ctx context.Context, envName string) (*env.File, error)
  • func (m *Manager) PullEnvironmentWithStreaming(ctx context.Context, envName string, writer func(*env.Variable) error) error
  • func (m *Manager) PushEnvironment(ctx context.Context, envName string, file *env.File, overwrite bool) error
  • func (m *Manager) PushEnvironmentWithMemoryOptimization(ctx context.Context, envName string, file *env.File, overwrite bool) error
• type ParallelManager
  • func NewParallelManager(manager *Manager, opts ParallelOptions) *ParallelManager
  • func (pm *ParallelManager) GetMaxWorkers() int
  • func (m *ParallelManager) ListEnvironmentsParallel(ctx context.Context, envNames []string, showProgress bool) (map[string]map[string]string, error)
  • func (m *ParallelManager) PullEnvironmentParallel(ctx context.Context, envName string, showProgress bool) (*env.File, error)
  • func (m *ParallelManager) PushEnvironmentParallel(ctx context.Context, envName string, file *env.File, overwrite bool, ...) error
  • func (m *ParallelManager) PutParameter(ctx context.Context, name, value, paramType string, overwrite bool) error
  • func (m *ParallelManager) PutSecret(ctx context.Context, name string, data map[string]string, overwrite bool) error
  • func (m *ParallelManager) ValidateEnvironmentsParallel(ctx context.Context, envNames []string, ...) (map[string]error, error)
• type ParallelOptions
  • func DefaultParallelOptions() ParallelOptions

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

Manager manages AWS operations for envy

func NewManager

func NewManager(cfg *config.Config) (*Manager, error)

NewManager creates a new AWS manager

func (*Manager) DeleteEnvironment

func (m *Manager) DeleteEnvironment(ctx context.Context, envName string) error

DeleteEnvironment deletes all variables for an environment

func (*Manager) GetClient

func (m *Manager) GetClient() *client.Client

GetClient returns the underlying AWS client

func (*Manager) GetConfig

func (m *Manager) GetConfig() *config.Config

GetConfig returns the configuration

func (*Manager) GetParameterStore

func (m *Manager) GetParameterStore() *parameter_store.Store

GetParameterStore returns the Parameter Store client

func (*Manager) GetSecretsManager

func (m *Manager) GetSecretsManager() *secrets_manager.Manager

GetSecretsManager returns the Secrets Manager client

func (*Manager) ListEnvironmentVariables

func (m *Manager) ListEnvironmentVariables(ctx context.Context, envName string) (map[string]string, error)

ListEnvironmentVariables lists variables for an environment

func (*Manager) PullEnvironment

func (m *Manager) PullEnvironment(ctx context.Context, envName string) (*env.File, error)

PullEnvironment pulls environment variables from AWS

func (*Manager) PullEnvironmentWithStreaming

func (m *Manager) PullEnvironmentWithStreaming(ctx context.Context, envName string, writer func(*env.Variable) error) error

PullEnvironmentWithStreaming pulls environment variables using streaming approach

func (*Manager) PushEnvironment

func (m *Manager) PushEnvironment(ctx context.Context, envName string, file *env.File, overwrite bool) error

PushEnvironment pushes environment variables to AWS

func (*Manager) PushEnvironmentWithMemoryOptimization

func (m *Manager) PushEnvironmentWithMemoryOptimization(ctx context.Context, envName string, file *env.File, overwrite bool) error

PushEnvironmentWithMemoryOptimization pushes environment variables with memory optimization

type ParallelManager

type ParallelManager struct {
	*Manager
	// contains filtered or unexported fields
}

ParallelManager is an AWS manager with parallel processing capabilities

func NewParallelManager

func NewParallelManager(manager *Manager, opts ParallelOptions) *ParallelManager

NewParallelManager creates a new parallel AWS manager

func (*ParallelManager) GetMaxWorkers

func (pm *ParallelManager) GetMaxWorkers() int

GetMaxWorkers returns the maximum number of workers

func (*ParallelManager) ListEnvironmentsParallel

func (m *ParallelManager) ListEnvironmentsParallel(
	ctx context.Context,
	envNames []string,
	showProgress bool,
) (map[string]map[string]string, error)

ListEnvironmentsParallel lists variables for multiple environments in parallel

func (*ParallelManager) PullEnvironmentParallel

func (m *ParallelManager) PullEnvironmentParallel(
	ctx context.Context,
	envName string,
	showProgress bool,
) (*env.File, error)

PullEnvironmentParallel pulls environment variables from AWS in parallel

func (*ParallelManager) PushEnvironmentParallel

func (m *ParallelManager) PushEnvironmentParallel(
	ctx context.Context,
	envName string,
	file *env.File,
	overwrite bool,
	showProgress bool,
) error

PushEnvironmentParallel pushes environment variables to AWS in parallel

func (*ParallelManager) PutParameter

func (m *ParallelManager) PutParameter(ctx context.Context, name, value, paramType string, overwrite bool) error

PutParameter puts a single parameter to Parameter Store

func (*ParallelManager) PutSecret

func (m *ParallelManager) PutSecret(ctx context.Context, name string, data map[string]string, overwrite bool) error

PutSecret puts a secret to Secrets Manager

func (*ParallelManager) ValidateEnvironmentsParallel

func (m *ParallelManager) ValidateEnvironmentsParallel(
	ctx context.Context,
	envNames []string,
	validator func(envName string, vars map[string]string) error,
	showProgress bool,
) (map[string]error, error)

ValidateEnvironmentsParallel validates multiple environments in parallel

type ParallelOptions

type ParallelOptions struct {
	MaxWorkers int
	BatchSize  int
	RateLimit  int // requests per second
	Timeout    time.Duration
}

ParallelOptions contains options for parallel processing

func DefaultParallelOptions

func DefaultParallelOptions() ParallelOptions

DefaultParallelOptions returns default parallel options