Documentation
¶
Index ¶
- type ActionMetadataManager
- type ActionStatusKey
- type ActionStatusManager
- type ActionStatusMap
- type ConditionManager
- type ConditionManagerOption
- type ConnectionKey
- type ConnectionManager
- type EnvironmentManager
- type EnvironmentManagerOption
- type ParameterManager
- type ParameterManagerOption
- type SecretManager
- type SpecManager
- type SpecManagerOption
- type StateManager
- type StateManagerOption
- type StepDecoratorKey
- type StepDecoratorManager
- type StepDecoratorMap
- type StepMessageKey
- type StepMessageManager
- type StepMessageMap
- type StepOutputKey
- type 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
- type StepOutputMap
- func (m *StepOutputMap) Get(key StepOutputKey) (interface{}, bool)
- func (m *StepOutputMap) GetMetadata(key StepOutputKey) (*model.StepOutputMetadata, bool)
- func (m *StepOutputMap) Keys() []StepOutputKey
- func (m *StepOutputMap) Set(key StepOutputKey, value interface{})
- func (m *StepOutputMap) SetMetadata(key StepOutputKey, metadata *model.StepOutputMetadata)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActionMetadataManager ¶
type ActionMetadataManager struct {
// contains filtered or unexported fields
}
func NewActionMetadataManager ¶
func NewActionMetadataManager(sm *model.ActionMetadata) *ActionMetadataManager
func (*ActionMetadataManager) Get ¶
func (s *ActionMetadataManager) Get(ctx context.Context) (*model.ActionMetadata, error)
type ActionStatusKey ¶
type ActionStatusKey struct {
ActionHash string
}
type ActionStatusManager ¶
type ActionStatusManager struct {
// contains filtered or unexported fields
}
func NewActionStatusManager ¶
func NewActionStatusManager(action model.Action, backend *ActionStatusMap) *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, sm *model.ActionStatus) error
type ActionStatusMap ¶
type ActionStatusMap struct {
// contains filtered or unexported fields
}
func NewActionStatusMap ¶
func NewActionStatusMap() *ActionStatusMap
func (*ActionStatusMap) Get ¶
func (m *ActionStatusMap) Get(key ActionStatusKey) (*model.ActionStatus, bool)
func (*ActionStatusMap) Keys ¶
func (m *ActionStatusMap) Keys() []ActionStatusKey
func (*ActionStatusMap) Set ¶
func (m *ActionStatusMap) Set(key ActionStatusKey, message *model.ActionStatus)
type ConditionManager ¶
type ConditionManager struct {
// contains filtered or unexported fields
}
func NewConditionManager ¶
func NewConditionManager(opts ...ConditionManagerOption) *ConditionManager
type ConditionManagerOption ¶
type ConditionManagerOption func(cm *ConditionManager)
func ConditionManagerWithInitialCondition ¶
func ConditionManagerWithInitialCondition(value interface{}) ConditionManagerOption
type ConnectionKey ¶
type ConnectionKey struct {
Type, Name string
}
type ConnectionManager ¶
type ConnectionManager struct {
// contains filtered or unexported fields
}
func NewConnectionManager ¶
func NewConnectionManager(m map[ConnectionKey]map[string]interface{}) *ConnectionManager
func (*ConnectionManager) Get ¶
func (cm *ConnectionManager) Get(ctx context.Context, typ, name string) (*model.Connection, error)
func (*ConnectionManager) List ¶
func (cm *ConnectionManager) List(ctx context.Context) ([]*model.Connection, error)
type EnvironmentManager ¶
type EnvironmentManager struct {
// contains filtered or unexported fields
}
func NewEnvironmentManager ¶
func NewEnvironmentManager(opts ...EnvironmentManagerOption) *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 EnvironmentManagerOption ¶
type EnvironmentManagerOption func(em *EnvironmentManager)
func EnvironmentManagerWithInitialEnvironment ¶
func EnvironmentManagerWithInitialEnvironment(value map[string]any) EnvironmentManagerOption
type ParameterManager ¶
type ParameterManager struct {
// contains filtered or unexported fields
}
func NewParameterManager ¶
func NewParameterManager(opts ...ParameterManagerOption) *ParameterManager
type ParameterManagerOption ¶
type ParameterManagerOption func(pm *ParameterManager)
func ParameterManagerWithInitialParameters ¶
func ParameterManagerWithInitialParameters(params map[string]interface{}) ParameterManagerOption
type SecretManager ¶
type SecretManager struct {
// contains filtered or unexported fields
}
func NewSecretManager ¶
func NewSecretManager(secrets map[string]string) *SecretManager
type SpecManager ¶
type SpecManager struct {
// contains filtered or unexported fields
}
func NewSpecManager ¶
func NewSpecManager(opts ...SpecManagerOption) *SpecManager
type SpecManagerOption ¶
type SpecManagerOption func(sm *SpecManager)
func SpecManagerWithInitialSpec ¶
func SpecManagerWithInitialSpec(value map[string]interface{}) SpecManagerOption
type StateManager ¶
type StateManager struct {
// contains filtered or unexported fields
}
func NewStateManager ¶
func NewStateManager(opts ...StateManagerOption) *StateManager
type StateManagerOption ¶
type StateManagerOption func(sm *StateManager)
func StateManagerWithInitialState ¶
func StateManagerWithInitialState(state map[string]interface{}) StateManagerOption
type StepDecoratorKey ¶
type StepDecoratorKey struct {
StepName, Name string
}
type StepDecoratorManager ¶
type StepDecoratorManager struct {
// contains filtered or unexported fields
}
func NewStepDecoratorManager ¶
func NewStepDecoratorManager(step *model.Step, backend *StepDecoratorMap) *StepDecoratorManager
func (*StepDecoratorManager) List ¶
func (s *StepDecoratorManager) List(ctx context.Context) ([]*model.StepDecorator, error)
type StepDecoratorMap ¶
type StepDecoratorMap struct {
// contains filtered or unexported fields
}
func NewStepDecoratorMap ¶
func NewStepDecoratorMap() *StepDecoratorMap
func (*StepDecoratorMap) List ¶
func (s *StepDecoratorMap) List() []relayv1beta1.Decorator
func (*StepDecoratorMap) Set ¶
func (s *StepDecoratorMap) Set(key StepDecoratorKey, dec relayv1beta1.Decorator)
type StepMessageKey ¶
type StepMessageKey struct {
StepName, ID string
}
type StepMessageManager ¶
type StepMessageManager struct {
// contains filtered or unexported fields
}
func NewStepMessageManager ¶
func NewStepMessageManager(step *model.Step, backend *StepMessageMap) *StepMessageManager
func (*StepMessageManager) List ¶
func (s *StepMessageManager) List(ctx context.Context) ([]*model.StepMessage, error)
func (*StepMessageManager) Set ¶
func (s *StepMessageManager) Set(ctx context.Context, sm *model.StepMessage) error
type StepMessageMap ¶
type StepMessageMap struct {
// contains filtered or unexported fields
}
func NewStepMessageMap ¶
func NewStepMessageMap() *StepMessageMap
func (*StepMessageMap) List ¶
func (s *StepMessageMap) List(step *model.Step) []*model.StepMessage
func (*StepMessageMap) Set ¶
func (s *StepMessageMap) Set(key StepMessageKey, message *model.StepMessage)
type StepOutputKey ¶
type StepOutputKey struct {
StepName, Name string
}
type StepOutputManager ¶
type StepOutputManager struct {
// contains filtered or unexported fields
}
func NewStepOutputManager ¶
func NewStepOutputManager(step *model.Step, backend *StepOutputMap) *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
type StepOutputMap ¶
type StepOutputMap struct {
// contains filtered or unexported fields
}
func NewStepOutputMap ¶
func NewStepOutputMap() *StepOutputMap
func (*StepOutputMap) Get ¶
func (m *StepOutputMap) Get(key StepOutputKey) (interface{}, bool)
func (*StepOutputMap) GetMetadata ¶
func (m *StepOutputMap) GetMetadata(key StepOutputKey) (*model.StepOutputMetadata, bool)
func (*StepOutputMap) Keys ¶
func (m *StepOutputMap) Keys() []StepOutputKey
func (*StepOutputMap) Set ¶
func (m *StepOutputMap) Set(key StepOutputKey, value interface{})
func (*StepOutputMap) SetMetadata ¶
func (m *StepOutputMap) SetMetadata(key StepOutputKey, metadata *model.StepOutputMetadata)
Click to show internal directories.
Click to hide internal directories.