worker

Documentation

Index

• Constants
• type SSHConnector
  • func (conn *SSHConnector) Close() error
  • func (conn *SSHConnector) Connect(host string, filter func([]ssh.ClientConfig) []ssh.ClientConfig) (*ssh.Client, error)
• type Worker
  • func (w *Worker) ExecTargetTask(ctx context.Context, task *ent.Task, target *ent.Target, ...)
  • func (w *Worker) HandleTaskQueued(ctx context.Context, info event.TaskQueued)

Constants

const DefaultConfig = `` /* 1703-byte string literal not displayed */

const ServiceTag = "svc-pg-worker"

Types

type SSHConnector

type SSHConnector struct {
	Credentials []*ent.Credential
	// contains filtered or unexported fields
}

SSHConnector is used to establish ssh connections for the worker's task execution environment.

func (*SSHConnector) Close

func (conn *SSHConnector) Close() error

func (*SSHConnector) Connect

func (conn *SSHConnector) Connect(host string, filter func([]ssh.ClientConfig) []ssh.ClientConfig) (*ssh.Client, error)

type Worker

type Worker struct {
	cdn.Uploader
	cdn.Downloader
	Graph  graphql.Client
	Config string
}

func (*Worker) ExecTargetTask

func (w *Worker) ExecTargetTask(ctx context.Context, task *ent.Task, target *ent.Target, credentials []*ent.Credential)

func (*Worker) HandleTaskQueued

func (w *Worker) HandleTaskQueued(ctx context.Context, info event.TaskQueued)