process

package
v0.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 12, 2024 License: LGPL-2.1 Imports: 9 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func EncodeScriptTask added in v0.3.2 

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

func EncodeServiceTask added in v0.3.2 

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

Types

type Builder added in v0.3.7 

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

func NewProcessBuilder added in v0.3.7 

func NewProcessBuilder() *Builder

func (*Builder) Build added in v0.3.7 

func (b *Builder) Build() *Process

func (*Builder) Named added in v0.3.7 

func (b *Builder) Named(id, name, desc string) *Builder

func (*Builder) SetHandlers added in v0.3.7 

func (b *Builder) SetHandlers(handlers ...*Handler) *Builder

func (*Builder) SetHosts added in v0.3.7 

func (b *Builder) SetHosts(hosts ...string) *Builder

func (*Builder) SetTasks added in v0.3.7 

func (b *Builder) SetTasks(tasks ...ITask) *Builder

func (*Builder) SetVar added in v0.3.7 

func (b *Builder) SetVar(name string, value any) *Builder

type ChildProcess 

type ChildProcess struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`
	Desc string `json:"desc,omitempty" yaml:"desc,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 ChildProcessBuilder added in v0.3.7 

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

func NewChildProcessBuilder added in v0.3.7 

func NewChildProcessBuilder() *ChildProcessBuilder

func (*ChildProcessBuilder) Build added in v0.3.7 

func (b *ChildProcessBuilder) Build() *ChildProcess

func (*ChildProcessBuilder) Named added in v0.3.7 

func (b *ChildProcessBuilder) Named(id, name, desc string) *ChildProcessBuilder

func (*ChildProcessBuilder) SetHandlers added in v0.3.7 

func (b *ChildProcessBuilder) SetHandlers(handlers ...*Handler) *ChildProcessBuilder

func (*ChildProcessBuilder) SetHosts added in v0.3.7 

func (b *ChildProcessBuilder) SetHosts(hosts ...string) *ChildProcessBuilder

func (*ChildProcessBuilder) SetTasks added in v0.3.7 

func (b *ChildProcessBuilder) SetTasks(tasks ...ITask) *ChildProcessBuilder

func (*ChildProcessBuilder) SetVar added in v0.3.7 

func (b *ChildProcessBuilder) SetVar(name string, value any) *ChildProcessBuilder

type Handler 

type Handler struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`
	Desc string `json:"desc,omitempty" yaml:"desc,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 added in v0.3.0 

func (h *Handler) String() string

type HandlerBuilder added in v0.3.7 

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

func NewHandlerBuilder added in v0.3.7 

func NewHandlerBuilder() *HandlerBuilder

func (*HandlerBuilder) Build added in v0.3.7 

func (b *HandlerBuilder) Build() *Handler

func (*HandlerBuilder) Named added in v0.3.7 

func (b *HandlerBuilder) Named(id, name, desc string) *HandlerBuilder

func (*HandlerBuilder) SetAction added in v0.3.7 

func (b *HandlerBuilder) SetAction(action string, args map[string]any) *HandlerBuilder

func (*HandlerBuilder) SetKind added in v0.3.7 

func (b *HandlerBuilder) SetKind(kind string) *HandlerBuilder

type ICatchTask added in v0.3.0 

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

type INamedTask added in v0.3.0 

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"`
	Desc string `json:"desc,omitempty" yaml:"desc,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 added in v0.3.2 

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

func (*Process) SubBuild added in v0.3.2 

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

func (*Process) ToBuilder added in v0.3.7 

func (p *Process) ToBuilder() *Builder

func (*Process) UnmarshalYAML 

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

type Service added in v0.2.2 

type Service struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`
	Desc string `json:"desc,omitempty" yaml:"desc,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 added in v0.3.2 

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

func (*Service) GetCatch added in v0.3.0 

func (s *Service) GetCatch() *Handler

func (*Service) GetFinish added in v0.3.0 

func (s *Service) GetFinish() *Handler

func (*Service) GetHosts added in v0.3.0 

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

func (*Service) GetId added in v0.3.0 

func (s *Service) GetId() string

func (*Service) GetName added in v0.3.0 

func (s *Service) GetName() string

type ServiceBuilder added in v0.3.7 

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

func NewServiceBuilder added in v0.3.7 

func NewServiceBuilder() *ServiceBuilder

func (*ServiceBuilder) Build added in v0.3.7 

func (b *ServiceBuilder) Build() *Service

func (*ServiceBuilder) Named added in v0.3.7 

func (b *ServiceBuilder) Named(id, name, desc string) *ServiceBuilder

func (*ServiceBuilder) SetAction added in v0.3.7 

func (b *ServiceBuilder) SetAction(action string, args map[string]any) *ServiceBuilder

func (*ServiceBuilder) SetCatch added in v0.3.7 

func (b *ServiceBuilder) SetCatch(catch *Handler) *ServiceBuilder

func (*ServiceBuilder) SetFinish added in v0.3.7 

func (b *ServiceBuilder) SetFinish(finish *Handler) *ServiceBuilder

func (*ServiceBuilder) SetHosts added in v0.3.7 

func (b *ServiceBuilder) SetHosts(hosts ...string) *ServiceBuilder

func (*ServiceBuilder) SetNotify added in v0.3.7 

func (b *ServiceBuilder) SetNotify(notify ...string) *ServiceBuilder

func (*ServiceBuilder) SetVar added in v0.3.7 

func (b *ServiceBuilder) SetVar(name string, value any) *ServiceBuilder

type Task 

type Task struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	Id   string `json:"id,omitempty" yaml:"id,omitempty"`
	Desc string `json:"desc,omitempty" yaml:"desc,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 added in v0.3.2 

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

func (*Task) GetCatch added in v0.3.0 

func (t *Task) GetCatch() *Handler

func (*Task) GetFinish added in v0.3.0 

func (t *Task) GetFinish() *Handler

func (*Task) GetHosts added in v0.3.0 

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

func (*Task) GetId added in v0.3.0 

func (t *Task) GetId() string

func (*Task) GetName added in v0.3.0 

func (t *Task) GetName() string

type TaskBuilder added in v0.3.7 

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

func NewTaskBuilder added in v0.3.7 

func NewTaskBuilder() *TaskBuilder

func (*TaskBuilder) Build added in v0.3.7 

func (b *TaskBuilder) Build() *Task

func (*TaskBuilder) Named added in v0.3.7 

func (b *TaskBuilder) Named(id, name, desc string) *TaskBuilder

func (*TaskBuilder) SetAction added in v0.3.7 

func (b *TaskBuilder) SetAction(action string, args map[string]any) *TaskBuilder

func (*TaskBuilder) SetCatch added in v0.3.7 

func (b *TaskBuilder) SetCatch(catch *Handler) *TaskBuilder

func (*TaskBuilder) SetFinish added in v0.3.7 

func (b *TaskBuilder) SetFinish(finish *Handler) *TaskBuilder

func (*TaskBuilder) SetHosts added in v0.3.7 

func (b *TaskBuilder) SetHosts(hosts ...string) *TaskBuilder

func (*TaskBuilder) SetNotify added in v0.3.7 

func (b *TaskBuilder) SetNotify(notify ...string) *TaskBuilder

func (*TaskBuilder) SetVar added in v0.3.7 

func (b *TaskBuilder) SetVar(name string, value any) *TaskBuilder

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)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.