agent

package

v0.0.18 Latest Latest Go to latest Published: Oct 21, 2025 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sapslaj/mid

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CallAgent[I any, O any](ctx context.Context, resourceConnection *midtypes.Connection, ...) (O, error)
func ToOptional[T comparable](v T) *T
type AgentPing
- func (f AgentPing) Invoke(ctx context.Context, req infer.FunctionRequest[AgentPingInput]) (infer.FunctionResponse[AgentPingOutput], error)
type AgentPingInput
type AgentPingOutput
type AnsibleExecute
- func (f AnsibleExecute) Invoke(ctx context.Context, req infer.FunctionRequest[AnsibleExecuteInput]) (infer.FunctionResponse[AnsibleExecuteOutput], error)
type AnsibleExecuteInput
type AnsibleExecuteOutput
type Exec
- func (f Exec) Invoke(ctx context.Context, req infer.FunctionRequest[ExecInput]) (infer.FunctionResponse[ExecOutput], error)
type ExecInput
type ExecOutput
type FileStat
- func (f FileStat) Invoke(ctx context.Context, req infer.FunctionRequest[FileStatInput]) (infer.FunctionResponse[FileStatOutput], error)
type FileStatFileMode
type FileStatInput
type FileStatOutput

Constants ¶

This section is empty.

Variables ¶

View Source

var Tracer = otel.Tracer("mid/provider/executor")

Functions ¶

func CallAgent ¶

func CallAgent[I any, O any](
	ctx context.Context,
	resourceConnection *midtypes.Connection,
	resourceConfig *midtypes.ResourceConfig,
	rpcFunction rpc.RPCFunction,
	args I,
) (O, error)

func ToOptional ¶

func ToOptional[T comparable](v T) *T

Types ¶

type AgentPing ¶

type AgentPing struct{}

func (AgentPing) Invoke ¶ added in v0.0.8

func (f AgentPing) Invoke(
	ctx context.Context,
	req infer.FunctionRequest[AgentPingInput],
) (infer.FunctionResponse[AgentPingOutput], error)

type AgentPingInput ¶ added in v0.0.8

type AgentPingInput struct {
	Ping       string                   `pulumi:"ping,optional"`
	Connection *midtypes.Connection     `pulumi:"connection,optional"`
	Config     *midtypes.ResourceConfig `pulumi:"config,optional"`
}

type AgentPingOutput ¶ added in v0.0.8

type AgentPingOutput struct {
	Ping string `pulumi:"ping"`
	Pong string `pulumi:"pong"`
}

type AnsibleExecute ¶

type AnsibleExecute struct{}

func (AnsibleExecute) Invoke ¶ added in v0.0.8

func (f AnsibleExecute) Invoke(
	ctx context.Context,
	req infer.FunctionRequest[AnsibleExecuteInput],
) (infer.FunctionResponse[AnsibleExecuteOutput], error)

type AnsibleExecuteInput ¶ added in v0.0.8

type AnsibleExecuteInput struct {
	Name               string                   `pulumi:"name"`
	Args               map[string]any           `pulumi:"args"`
	Environment        map[string]string        `pulumi:"environment,optional"`
	Check              bool                     `pulumi:"check,optional"`
	DebugKeepTempFiles bool                     `pulumi:"debugKeepTempFiles,optional"`
	Connection         *midtypes.Connection     `pulumi:"connection,optional"`
	Config             *midtypes.ResourceConfig `pulumi:"config,optional"`
}

type AnsibleExecuteOutput ¶ added in v0.0.8

type AnsibleExecuteOutput struct {
	AnsibleExecuteInput
	Stderr       string         `pulumi:"stderr"`
	Stdout       string         `pulumi:"stdout"`
	ExitCode     int            `pulumi:"exitCode"`
	Result       map[string]any `pulumi:"result"`
	DebugTempDir *string        `pulumi:"debugTempDir,optional"`
}

type Exec ¶

type Exec struct{}

func (Exec) Invoke ¶ added in v0.0.8

func (f Exec) Invoke(
	ctx context.Context,
	req infer.FunctionRequest[ExecInput],
) (infer.FunctionResponse[ExecOutput], error)

type ExecInput ¶ added in v0.0.8

type ExecInput struct {
	Command            []string                 `pulumi:"command"`
	Dir                string                   `pulumi:"dir,optional"`
	Environment        map[string]string        `pulumi:"environment,optional"`
	Stdin              string                   `pulumi:"stdin,optional"`
	ExpandArgumentVars bool                     `pulumi:"expandArgumentVars,optional"`
	Connection         *midtypes.Connection     `pulumi:"connection,optional"`
	Config             *midtypes.ResourceConfig `pulumi:"config,optional"`
}

type ExecOutput ¶ added in v0.0.8

type ExecOutput struct {
	ExecInput
	Stdout   string `pulumi:"stdout"`
	Stderr   string `pulumi:"stderr"`
	ExitCode int    `pulumi:"exitCode"`
	Pid      int    `pulumi:"pid"`
}

type FileStat ¶

type FileStat struct{}

func (FileStat) Invoke ¶ added in v0.0.8

func (f FileStat) Invoke(
	ctx context.Context,
	req infer.FunctionRequest[FileStatInput],
) (infer.FunctionResponse[FileStatOutput], error)

type FileStatFileMode ¶

type FileStatFileMode struct {
	IsDir     bool   `pulumi:"isDir"`
	IsRegular bool   `pulumi:"isRegular"`
	Int       int    `pulumi:"int"`
	Octal     string `pulumi:"octal"`
	String    string `pulumi:"string"`
}

type FileStatInput ¶ added in v0.0.8

type FileStatInput struct {
	Path              string                   `pulumi:"path"`
	FollowSymlinks    bool                     `pulumi:"followSymlinks,optional"`
	CalculateChecksum bool                     `pulumi:"calculateChecksum,optional"`
	Connection        *midtypes.Connection     `pulumi:"connection,optional"`
	Config            *midtypes.ResourceConfig `pulumi:"config,optional"`
}

type FileStatOutput ¶ added in v0.0.8

type FileStatOutput struct {
	FileStatInput
	midtypes.FileStatState
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL