configmap

Documentation

Index

• func MutateConfigMap(ctx context.Context, cm ConfigMap, fn func(cm *corev1.ConfigMap)) (*corev1.ConfigMap, error)
• type ActionStatusManager
  • func NewActionStatusManager(action model.Action, cm ConfigMap) *ActionStatusManager
  • func (m *ActionStatusManager) Get(ctx context.Context, action model.Action) (*model.ActionStatus, error)
  • func (m *ActionStatusManager) List(ctx context.Context) ([]*model.ActionStatus, error)
  • func (m *ActionStatusManager) Set(ctx context.Context, as *model.ActionStatus) error
• type ClientConfigMap
  • func NewClientConfigMap(client kubernetes.Interface, namespace, name string) *ClientConfigMap
  • func (ccm *ClientConfigMap) CreateOrUpdate(ctx context.Context, cm *corev1.ConfigMap) (*corev1.ConfigMap, error)
  • func (ccm *ClientConfigMap) Get(ctx context.Context) (*corev1.ConfigMap, error)
• type ConditionManager
  • func NewConditionManager(action model.Action, cm ConfigMap) *ConditionManager
  • func (m *ConditionManager) Get(ctx context.Context) (*model.Condition, error)
  • func (m *ConditionManager) Set(ctx context.Context, value interface{}) (*model.Condition, error)
• type ConfigMap
• type ControllerRuntimeConfigMap
  • func NewControllerRuntimeConfigMap(cl client.Client, key client.ObjectKey) *ControllerRuntimeConfigMap
  • func (crcm *ControllerRuntimeConfigMap) CreateOrUpdate(ctx context.Context, cm *corev1.ConfigMap) (*corev1.ConfigMap, error)
  • func (crcm *ControllerRuntimeConfigMap) Get(ctx context.Context) (*corev1.ConfigMap, error)
• type EnvironmentManager
  • func NewEnvironmentManager(action model.Action, cm ConfigMap) *EnvironmentManager
  • func (m *EnvironmentManager) Get(ctx context.Context) (*model.Environment, error)
  • func (m *EnvironmentManager) Set(ctx context.Context, value map[string]any) (*model.Environment, error)
• type KVConfigMap
  • func NewKVConfigMap(backend ConfigMap) *KVConfigMap
  • func (kcm *KVConfigMap) Get(ctx context.Context, key string) (interface{}, error)
  • func (kcm *KVConfigMap) Insert(ctx context.Context, key string, value interface{}) (bool, error)
  • func (kcm *KVConfigMap) List(ctx context.Context, prefix string) (map[string]interface{}, error)
  • func (kcm *KVConfigMap) Set(ctx context.Context, key string, value interface{}) error
• type LocalConfigMap
  • func NewLocalConfigMap(delegate *corev1.ConfigMap) *LocalConfigMap
  • func (lcm *LocalConfigMap) CreateOrUpdate(ctx context.Context, cm *corev1.ConfigMap) (*corev1.ConfigMap, error)
  • func (lcm *LocalConfigMap) Get(ctx context.Context) (*corev1.ConfigMap, error)
• type ParameterManager
  • func NewParameterManager(cm ConfigMap) *ParameterManager
  • func (m *ParameterManager) Get(ctx context.Context, name string) (*model.Parameter, error)
  • func (m *ParameterManager) List(ctx context.Context) ([]*model.Parameter, error)
  • func (m *ParameterManager) Set(ctx context.Context, name string, value interface{}) (*model.Parameter, error)
• type SpecManager
  • func NewSpecManager(action model.Action, cm ConfigMap) *SpecManager
  • func (m *SpecManager) Get(ctx context.Context) (*model.Spec, error)
  • func (m *SpecManager) Set(ctx context.Context, value map[string]interface{}) (*model.Spec, error)
• type StateManager
  • func NewStateManager(action model.Action, cm ConfigMap) *StateManager
  • func (m *StateManager) Get(ctx context.Context, name string) (*model.State, error)
  • func (m *StateManager) Set(ctx context.Context, name string, value interface{}) (*model.State, error)
• type StepDecoratorManager
  • func NewStepDecoratorManager(step *model.Step, cm ConfigMap) *StepDecoratorManager
  • func (m *StepDecoratorManager) List(ctx context.Context) ([]*model.StepDecorator, error)
  • func (m *StepDecoratorManager) Set(ctx context.Context, typ, name string, values map[string]interface{}) error
• type StepMessageManager
  • func NewStepMessageManager(step *model.Step, cm ConfigMap) *StepMessageManager
  • func (m *StepMessageManager) List(ctx context.Context) ([]*model.StepMessage, error)
  • func (m *StepMessageManager) Set(ctx context.Context, sm *model.StepMessage) error
• type StepOutputManager
  • func NewStepOutputManager(step *model.Step, cm ConfigMap) *StepOutputManager
  • func (m *StepOutputManager) Get(ctx context.Context, stepName, name string) (*model.StepOutput, error)
  • func (m *StepOutputManager) List(ctx context.Context) ([]*model.StepOutput, error)
  • func (m *StepOutputManager) ListSelf(ctx context.Context) ([]*model.StepOutput, error)
  • func (m *StepOutputManager) Set(ctx context.Context, name string, value interface{}) error
  • func (m *StepOutputManager) SetMetadata(ctx context.Context, name string, metadata *model.StepOutputMetadata) error

Functions

func MutateConfigMap

func MutateConfigMap(ctx context.Context, cm ConfigMap, fn func(cm *corev1.ConfigMap)) (*corev1.ConfigMap, error)

Types

type ActionStatusManager

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

func NewActionStatusManager

func NewActionStatusManager(action model.Action, cm ConfigMap) *ActionStatusManager

func (*ActionStatusManager) Get

func (m *ActionStatusManager) Get(ctx context.Context, action model.Action) (*model.ActionStatus, error)

func (*ActionStatusManager) List

func (m *ActionStatusManager) List(ctx context.Context) ([]*model.ActionStatus, error)

func (*ActionStatusManager) Set

func (m *ActionStatusManager) Set(ctx context.Context, as *model.ActionStatus) error

type ClientConfigMap

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

func NewClientConfigMap

func NewClientConfigMap(client kubernetes.Interface, namespace, name string) *ClientConfigMap

func (*ClientConfigMap) CreateOrUpdate

func (ccm *ClientConfigMap) CreateOrUpdate(ctx context.Context, cm *corev1.ConfigMap) (*corev1.ConfigMap, error)

func (*ClientConfigMap) Get

func (ccm *ClientConfigMap) Get(ctx context.Context) (*corev1.ConfigMap, error)

type ConditionManager

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

func NewConditionManager

func NewConditionManager(action model.Action, cm ConfigMap) *ConditionManager

func (*ConditionManager) Get

func (m *ConditionManager) Get(ctx context.Context) (*model.Condition, error)

func (*ConditionManager) Set

func (m *ConditionManager) Set(ctx context.Context, value interface{}) (*model.Condition, error)

type ConfigMap

type ConfigMap interface {
	Get(ctx context.Context) (*corev1.ConfigMap, error)
	CreateOrUpdate(ctx context.Context, cm *corev1.ConfigMap) (*corev1.ConfigMap, error)
}

type ControllerRuntimeConfigMap

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

func NewControllerRuntimeConfigMap

func NewControllerRuntimeConfigMap(cl client.Client, key client.ObjectKey) *ControllerRuntimeConfigMap

func (*ControllerRuntimeConfigMap) CreateOrUpdate

func (crcm *ControllerRuntimeConfigMap) CreateOrUpdate(ctx context.Context, cm *corev1.ConfigMap) (*corev1.ConfigMap, error)

func (*ControllerRuntimeConfigMap) Get

func (crcm *ControllerRuntimeConfigMap) Get(ctx context.Context) (*corev1.ConfigMap, error)

type EnvironmentManager

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

func NewEnvironmentManager

func NewEnvironmentManager(action model.Action, cm ConfigMap) *EnvironmentManager

func (*EnvironmentManager) Get

func (m *EnvironmentManager) Get(ctx context.Context) (*model.Environment, error)

func (*EnvironmentManager) Set

func (m *EnvironmentManager) Set(ctx context.Context, value map[string]any) (*model.Environment, error)

type KVConfigMap

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

func NewKVConfigMap

func NewKVConfigMap(backend ConfigMap) *KVConfigMap

func (*KVConfigMap) Get

func (kcm *KVConfigMap) Get(ctx context.Context, key string) (interface{}, error)

func (*KVConfigMap) Insert

func (kcm *KVConfigMap) Insert(ctx context.Context, key string, value interface{}) (bool, error)

func (*KVConfigMap) List

func (kcm *KVConfigMap) List(ctx context.Context, prefix string) (map[string]interface{}, error)

func (*KVConfigMap) Set

func (kcm *KVConfigMap) Set(ctx context.Context, key string, value interface{}) error

type LocalConfigMap

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

func NewLocalConfigMap

func NewLocalConfigMap(delegate *corev1.ConfigMap) *LocalConfigMap

func (*LocalConfigMap) CreateOrUpdate

func (lcm *LocalConfigMap) CreateOrUpdate(ctx context.Context, cm *corev1.ConfigMap) (*corev1.ConfigMap, error)

func (*LocalConfigMap) Get

func (lcm *LocalConfigMap) Get(ctx context.Context) (*corev1.ConfigMap, error)

type ParameterManager

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

func NewParameterManager

func NewParameterManager(cm ConfigMap) *ParameterManager

func (*ParameterManager) Get

func (m *ParameterManager) Get(ctx context.Context, name string) (*model.Parameter, error)

func (*ParameterManager) List

func (m *ParameterManager) List(ctx context.Context) ([]*model.Parameter, error)

func (*ParameterManager) Set

func (m *ParameterManager) Set(ctx context.Context, name string, value interface{}) (*model.Parameter, error)

type SpecManager

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

func NewSpecManager

func NewSpecManager(action model.Action, cm ConfigMap) *SpecManager

func (*SpecManager) Get

func (m *SpecManager) Get(ctx context.Context) (*model.Spec, error)

func (*SpecManager) Set

func (m *SpecManager) Set(ctx context.Context, value map[string]interface{}) (*model.Spec, error)

type StateManager

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

func NewStateManager

func NewStateManager(action model.Action, cm ConfigMap) *StateManager

func (*StateManager) Get

func (m *StateManager) Get(ctx context.Context, name string) (*model.State, error)

func (*StateManager) Set

func (m *StateManager) Set(ctx context.Context, name string, value interface{}) (*model.State, error)

type StepDecoratorManager

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

func NewStepDecoratorManager

func NewStepDecoratorManager(step *model.Step, cm ConfigMap) *StepDecoratorManager

func (*StepDecoratorManager) List

func (m *StepDecoratorManager) List(ctx context.Context) ([]*model.StepDecorator, error)

func (*StepDecoratorManager) Set

func (m *StepDecoratorManager) Set(ctx context.Context, typ, name string, values map[string]interface{}) error

type StepMessageManager

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

func NewStepMessageManager

func NewStepMessageManager(step *model.Step, cm ConfigMap) *StepMessageManager

func (*StepMessageManager) List

func (m *StepMessageManager) List(ctx context.Context) ([]*model.StepMessage, error)

func (*StepMessageManager) Set

func (m *StepMessageManager) Set(ctx context.Context, sm *model.StepMessage) error

type StepOutputManager

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

func NewStepOutputManager

func NewStepOutputManager(step *model.Step, cm ConfigMap) *StepOutputManager

func (*StepOutputManager) Get

func (m *StepOutputManager) Get(ctx context.Context, stepName, name string) (*model.StepOutput, error)

func (*StepOutputManager) List

func (m *StepOutputManager) List(ctx context.Context) ([]*model.StepOutput, error)

func (*StepOutputManager) ListSelf

func (m *StepOutputManager) ListSelf(ctx context.Context) ([]*model.StepOutput, error)

func (*StepOutputManager) Set

func (m *StepOutputManager) Set(ctx context.Context, name string, value interface{}) error

func (*StepOutputManager) SetMetadata

func (m *StepOutputManager) SetMetadata(ctx context.Context, name string, metadata *model.StepOutputMetadata) error