environment

Documentation

Overview

Package environment defines Environment, environment.Manager and other types and methods related to handling O² environments.

Index

• type ConfigureTransition
• type Environment
  • func (env *Environment) CreatedWhen() time.Time
  • func (env *Environment) CurrentState() string
  • func (env *Environment) GetCurrentRunNumber() (rn uint32)
  • func (env *Environment) GetPath() string
  • func (env *Environment) Id() uuid.UUID
  • func (env *Environment) IsSafeToStop() bool
  • func (env *Environment) QueryRoles(pathSpec string) (rs []workflow.Role)
  • func (env *Environment) TryTransition(t Transition) (err error)
  • func (env *Environment) Workflow() workflow.Role
• type Manager
  • func NewEnvManager(tm *task.Manager) *Manager
  • func (envs *Manager) CreateEnvironment(workflowPath string, userVars map[string]string) (uuid.UUID, error)
  • func (envs *Manager) Environment(environmentId uuid.UUID) (env *Environment, err error)
  • func (envs *Manager) Ids() (keys []uuid.UUID)
  • func (envs *Manager) TeardownEnvironment(environmentId uuid.UUID) error
• type ResetTransition
• type StartActivityTransition
• type StopActivityTransition
• type Transition
  • func MakeTransition(taskman *task.Manager, optype pb.ControlEnvironmentRequest_Optype) Transition
  • func NewConfigureTransition(taskman *task.Manager, addRoles []string, removeRoles []string, ...) Transition
  • func NewResetTransition(taskman *task.Manager) Transition
  • func NewStartActivityTransition(taskman *task.Manager) Transition
  • func NewStopActivityTransition(taskman *task.Manager) Transition

Types

type ConfigureTransition

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

type Environment

type Environment struct {
	Mu sync.RWMutex
	Sm *fsm.FSM

	GlobalDefaults gera.StringMap // From Consul
	GlobalVars     gera.StringMap // From Consul
	UserVars       gera.StringMap // From user input
	// contains filtered or unexported fields
}

func (*Environment) CreatedWhen

func (env *Environment) CreatedWhen() time.Time

func (*Environment) CurrentState

func (env *Environment) CurrentState() string

func (*Environment) GetCurrentRunNumber

func (env *Environment) GetCurrentRunNumber() (rn uint32)

func (*Environment) GetPath

func (env *Environment) GetPath() string

func (*Environment) Id

func (env *Environment) Id() uuid.UUID

func (*Environment) IsSafeToStop

func (env *Environment) IsSafeToStop() bool

func (*Environment) QueryRoles

func (env *Environment) QueryRoles(pathSpec string) (rs []workflow.Role)

func (*Environment) TryTransition

func (env *Environment) TryTransition(t Transition) (err error)

func (*Environment) Workflow

func (env *Environment) Workflow() workflow.Role

type Manager

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

func NewEnvManager

func NewEnvManager(tm *task.Manager) *Manager

func (*Manager) CreateEnvironment

func (envs *Manager) CreateEnvironment(workflowPath string, userVars map[string]string) (uuid.UUID, error)

func (*Manager) Environment

func (envs *Manager) Environment(environmentId uuid.UUID) (env *Environment, err error)

func (*Manager) Ids

func (envs *Manager) Ids() (keys []uuid.UUID)

func (*Manager) TeardownEnvironment

func (envs *Manager) TeardownEnvironment(environmentId uuid.UUID) error

type ResetTransition

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

type StartActivityTransition

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

type StopActivityTransition

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

type Transition

type Transition interface {
	// contains filtered or unexported methods
}

func MakeTransition

func MakeTransition(taskman *task.Manager, optype pb.ControlEnvironmentRequest_Optype) Transition

func NewConfigureTransition

func NewConfigureTransition(taskman *task.Manager, addRoles []string, removeRoles []string, reconfigureAll bool) Transition

func NewResetTransition

func NewResetTransition(taskman *task.Manager) Transition

func NewStartActivityTransition

func NewStartActivityTransition(taskman *task.Manager) Transition

func NewStopActivityTransition

func NewStopActivityTransition(taskman *task.Manager) Transition