agent

package

v0.0.7 Latest Latest Go to latest Published: May 27, 2025 License: MIT Imports: 24 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 ¶

Overview ¶

Code generated by ./hack/generate-agent-binaries.py DO NOT EDIT

Index ¶

Variables
func Call[I any, O any](ctx context.Context, agent *Agent, call rpc.RPCCall[I]) (rpc.RPCResult[O], error)
func Connect(ctx context.Context, agent *Agent) error
func Disconnect(ctx context.Context, agent *Agent) error
func GetAgentBinary(goos string, goarch string) ([]byte, error)
func InstallAgent(ctx context.Context, agent *Agent) error
func RunRemoteCommand(ctx context.Context, agent *Agent, cmd string) ([]byte, error)
func StageFile(ctx context.Context, agent *Agent, f io.Reader) (string, error)
type Agent

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrRunningRemoteCommand   = errors.New("error running remote command")
	ErrInstallingAgent        = errors.New("error installing agent")
	ErrConnectingToAgent      = errors.New("error connecting to agent")
	ErrAgentShutDown          = errors.New("agent shut down")
	ErrDisconnectingFromAgent = errors.New("error disconnecting from agent")
	ErrCallingRPCSystem       = errors.New("error calling RPC system")
	ErrStagingFile            = errors.New("error staging file")
)

View Source

var AgentBinary_linux_amd64_ []byte

View Source

var AgentBinary_linux_arm64_ []byte

View Source

var Tracer = otel.Tracer("mid/agent")

Functions ¶

func Call ¶

func Call[I any, O any](ctx context.Context, agent *Agent, call rpc.RPCCall[I]) (rpc.RPCResult[O], error)

func Connect ¶

func Connect(ctx context.Context, agent *Agent) error

func Disconnect ¶

func Disconnect(ctx context.Context, agent *Agent) error

func GetAgentBinary ¶

func GetAgentBinary(goos string, goarch string) ([]byte, error)

func InstallAgent ¶

func InstallAgent(ctx context.Context, agent *Agent) error

func RunRemoteCommand ¶

func RunRemoteCommand(ctx context.Context, agent *Agent, cmd string) ([]byte, error)

func StageFile ¶ added in v0.0.7

func StageFile(ctx context.Context, agent *Agent, f io.Reader) (string, error)

Types ¶

type Agent ¶

type Agent struct {
	Mutex     sync.Mutex
	Client    *ssh.Client
	Session   *ssh.Session
	Encoder   *json.Encoder
	Decoder   *json.Decoder
	Running   *atomic.Bool
	WaitGroup *sync.WaitGroup
	InFlight  *syncmap.Map[string, chan rpc.RPCResult[any]]
}

func (*Agent) Disconnect ¶

func (agent *Agent) Disconnect(ctx context.Context) error

func (*Agent) GetLogger ¶ added in v0.0.7

func (agent *Agent) GetLogger(ctx context.Context) *slog.Logger

func (*Agent) RunLocal ¶ added in v0.0.7

func (agent *Agent) RunLocal()

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
ansible Code generated by ./hack/generate-ansible-types.py DO NOT EDIT	Code generated by ./hack/generate-ansible-types.py DO NOT EDIT
cmd
mid-agent command
rpc

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