process

Documentation

Index

• Constants
• func EncodeScriptTask(task *Task) (props map[string]any, headers map[string]any)
• func EncodeServiceTask(service *Service) (props map[string]any, headers map[string]any)
• type ChildProcess
• type Handler
  • func (h *Handler) String() string
• type ICatchTask
• type INamedTask
• type ITask
• type Process
  • func (p *Process) Build() (*schema.Definitions, map[string]string, map[string]string, error)
  • func (p *Process) SubBuild() (*schema.Definitions, map[string]string, map[string]string, error)
  • func (p *Process) UnmarshalYAML(unmarshal func(interface{}) error) (err error)
• type Service
  • func DecodeServiceTask(props, headers map[string]any) *Service
  • func (s *Service) GetCatch() *Handler
  • func (s *Service) GetFinish() *Handler
  • func (s *Service) GetHosts() []string
  • func (s *Service) GetId() string
  • func (s *Service) GetName() string
• type Task
  • func DecodeScriptTask(props, headers map[string]any) *Task
  • func (t *Task) GetCatch() *Handler
  • func (t *Task) GetFinish() *Handler
  • func (t *Task) GetHosts() []string
  • func (t *Task) GetId() string
  • func (t *Task) GetName() string
• type YamlKV
  • func (kv YamlKV) Apply(name string, to any) (bool, error)
  • func (kv YamlKV) ApplyArray(name string, to any) (bool, error)
  • func (kv YamlKV) ApplyMap(name string, to any) (bool, error)
  • func (kv YamlKV) GetRV(name string) (reflect.Value, bool)

Constants

const (
	ChildProcessKey = "process"
	ServiceKey      = "service"
	TaskKey         = "task"
)

Functions

func EncodeScriptTask

func EncodeScriptTask(task *Task) (props map[string]any, headers map[string]any)

func EncodeServiceTask

func EncodeServiceTask(service *Service) (props map[string]any, headers map[string]any)

Types

type ChildProcess

type ChildProcess struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`
	Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`

	Hosts []string `json:"hosts,omitempty" yaml:"hosts,omitempty"`

	Vars map[string]any `json:"vars,omitempty" yaml:"vars,omitempty"`

	RemoteUser string `json:"remote_user,omitempty" yaml:"remote_user,omitempty"`

	Sudo     bool   `json:"sudo,omitempty" yaml:"sudo,omitempty"`
	SudoUser string `json:"sudo_user,omitempty" yaml:"sudo_user,omitempty"`

	Tasks []ITask `json:"tasks,omitempty" yaml:"tasks,omitempty"`

	Handlers []*Handler `json:"handlers,omitempty" yaml:"handlers,omitempty"`
}

type Handler

type Handler struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`
	Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`

	Action string         `json:"action,omitempty" yaml:"action,omitempty"`
	Args   map[string]any `json:"args,omitempty" yaml:"args,omitempty"`
}

func (*Handler) String

func (h *Handler) String() string

type ICatchTask

type ICatchTask interface {
	GetHosts() []string
	GetCatch() *Handler
	GetFinish() *Handler
}

type INamedTask

type INamedTask interface {
	GetName() string
	GetId() string
}

type ITask

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

type Process

type Process struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`

	Hosts []string `json:"hosts,omitempty" yaml:"hosts,omitempty"`

	Vars map[string]any `json:"vars,omitempty" yaml:"vars,omitempty"`

	RemoteUser string `json:"remote_user,omitempty" yaml:"remote_user,omitempty"`

	Sudo     bool   `json:"sudo,omitempty" yaml:"sudo,omitempty"`
	SudoUser string `json:"sudo_user,omitempty" yaml:"sudo_user,omitempty"`

	Tasks []ITask `json:"tasks,omitempty" yaml:"tasks,omitempty"`

	Handlers []*Handler `json:"handlers,omitempty" yaml:"handlers,omitempty"`
}

func (*Process) Build

func (p *Process) Build() (*schema.Definitions, map[string]string, map[string]string, error)

func (*Process) SubBuild

func (p *Process) SubBuild() (*schema.Definitions, map[string]string, map[string]string, error)

func (*Process) UnmarshalYAML

func (p *Process) UnmarshalYAML(unmarshal func(interface{}) error) (err error)

type Service

type Service struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`

	Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`

	Vars map[string]any `json:"vars,omitempty" yaml:"vars,omitempty"`

	Hosts []string `json:"hosts,omitempty" yaml:"hosts,omitempty"`

	Action string         `json:"action,omitempty" yaml:"action,omitempty"`
	Args   map[string]any `json:"args,omitempty" yaml:"args,omitempty"`

	Catch  *Handler `json:"catch,omitempty" yaml:"catch,omitempty"`
	Finish *Handler `json:"finish,omitempty" yaml:"finish,omitempty"`

	Notify []string `json:"notify,omitempty" yaml:"notify,omitempty"`
}

func DecodeServiceTask

func DecodeServiceTask(props, headers map[string]any) *Service

func (*Service) GetCatch

func (s *Service) GetCatch() *Handler

func (*Service) GetFinish

func (s *Service) GetFinish() *Handler

func (*Service) GetHosts

func (s *Service) GetHosts() []string

func (*Service) GetId

func (s *Service) GetId() string

func (*Service) GetName

func (s *Service) GetName() string

type Task

type Task struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`

	Vars map[string]any `json:"vars,omitempty" yaml:"vars,omitempty"`

	Action string         `json:"action,omitempty" yaml:"action,omitempty"`
	Args   map[string]any `json:"args,omitempty" yaml:"args,omitempty"`

	RemoteUser string `json:"remote_user,omitempty" yaml:"remote_user,omitempty"`

	Sudo     bool   `json:"sudo,omitempty" yaml:"sudo,omitempty"`
	SudoUser string `json:"sudo_user,omitempty" yaml:"sudo_user,omitempty"`

	Hosts []string `json:"hosts,omitempty" yaml:"hosts,omitempty"`

	Catch  *Handler `json:"catch,omitempty" yaml:"catch,omitempty"`
	Finish *Handler `json:"finish,omitempty" yaml:"finish,omitempty"`

	Notify []string `json:"notify,omitempty" yaml:"notify,omitempty"`
}

func DecodeScriptTask

func DecodeScriptTask(props, headers map[string]any) *Task

func (*Task) GetCatch

func (t *Task) GetCatch() *Handler

func (*Task) GetFinish

func (t *Task) GetFinish() *Handler

func (*Task) GetHosts

func (t *Task) GetHosts() []string

func (*Task) GetId

func (t *Task) GetId() string

func (*Task) GetName

func (t *Task) GetName() string

type YamlKV

type YamlKV map[string]interface{}

func (YamlKV) Apply

func (kv YamlKV) Apply(name string, to any) (bool, error)

func (YamlKV) ApplyArray

func (kv YamlKV) ApplyArray(name string, to any) (bool, error)

func (YamlKV) ApplyMap

func (kv YamlKV) ApplyMap(name string, to any) (bool, error)

func (YamlKV) GetRV

func (kv YamlKV) GetRV(name string) (reflect.Value, bool)