agent

package

v0.0.6 Latest Latest Go to latest Published: May 23, 2025 License: MIT Imports: 19 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 AddLogger(agent *Agent) *slog.Logger
func Call[I any, O any](agent *Agent, call rpc.RPCCall[I]) (rpc.RPCResult[O], error)
func Connect(agent *Agent) error
func Disconnect(agent *Agent) error
func GetAgentBinary(goos string, goarch string) ([]byte, error)
func InstallAgent(agent *Agent) error
func RunRemoteCommand(agent *Agent, cmd string) ([]byte, error)
type Agent
- func (agent *Agent) Disconnect() error

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")
)

View Source

var AgentBinary_linux_amd64_ []byte

View Source

var AgentBinary_linux_arm64_ []byte

Functions ¶

func AddLogger ¶

func AddLogger(agent *Agent) *slog.Logger

func Call ¶

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

func Connect ¶

func Connect(agent *Agent) error

func Disconnect ¶

func Disconnect(agent *Agent) error

func GetAgentBinary ¶

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

func InstallAgent ¶

func InstallAgent(agent *Agent) error

func RunRemoteCommand ¶

func RunRemoteCommand(agent *Agent, cmd string) ([]byte, 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]]
	Logger    *slog.Logger
}

func (*Agent) Disconnect ¶

func (agent *Agent) Disconnect() error

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