executor

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

type BashExecutor struct {
	BaseExecutor
	// contains filtered or unexported fields
}

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

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

type ContentType struct {
	Type    string
	Subtype string
	Params  map[string]string
}

type ExecRequest struct {
	Hdr *RequestHdr

	// Content refers to the payload provided by the requester
	Content []byte

	// ContentType refers to the MIME type of the content
	ContentType *ContentType

	// In represents the additional input provided by the requester,
	// a side-effect. This is in-addition to the regular input provided
	// by the Content byte array.
	// Example: In a shell command execution (i.e ContentType=text/bash).
	// Content can be process command line, while In could represents the stdin.
	In *os.File

	// the executor publishes all side effects (Stdout, Stderr, debugging events etc.)
	Stdout io.WriteCloser
	Stderr io.WriteCloser
}

type ExecResponse struct {
	Hdr *ResponseHdr

	// Exit status of the command
	ExitStatus int

	// Err is set to non-nil on error/cancellation
	Err error
}

type Executor interface {
	Name() string

	// ContentType returns the content type supported by the Executor
	ContentType() *ContentType

	// Execute requests the Executor to execute the provided request
	Execute(context.Context, *ExecRequest) *ExecResponse

	// Cleanup is the Internal function invoked when the Register is torn down
	Cleanup()
}

type IgnoreCloseWriter struct {
	Writer io.Writer
}

type MySQLExecutor struct {
	BaseExecutor
}

type PSQLExecutor struct {
	BaseExecutor
}

type Register struct {
	sync.Map
}

type RemoteShellExecutor struct {
	BaseExecutor
}

type RequestHdr struct {
	// A unique ID, identifying request
	ID string
	// ExecutionID uniquely identifies a playbook execution
	ExecutionID string
	// NodeID identifies the node being execution
	NodeID string
	// UserID identifies the user executing the run
	UserID string
}

type ResponseHdr struct {
	// RequestID refers to request's unique ID
	RequestID string
}

type WinBashExecutor struct {
	BaseExecutor
}