wingconnect

type Connection interface {
	Call(context.Context, string, json.RawMessage) (map[string]any, bool, error)
	Done() <-chan struct{}
	Close() error
}

type Options struct {
	Dir, LocalWingID            string
	Hello                       controlsocket.Hello
	Transport                   sshcontrol.Transport
	ConnectTimeout, CallTimeout time.Duration
	// Deterministic fixture seams; production uses real timers and OpenSSH.
	Dial     func(context.Context, config.Remote, controlsocket.Hello) (Connection, error)
	NewTimer func(time.Duration) Timer
	Jitter   func(time.Duration) time.Duration
	OnChange func()
}

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

type Timer interface {
	C() <-chan time.Time
	Stop()
}

type UnknownOutcome struct {
	WingID, Tool, Key string
	Err               error
}