networker

type Connection interface {
	// contains filtered or unexported methods
}

type FindPortForwardSessionRequest struct {
	ResourceID   string `json:"resource_id"`
	ConnectionID string `json:"connection_id"`
}

type ForwarderResult struct {
	SessionID string
	Ready     <-chan struct{} // closed when tunnel established
	ErrCh     <-chan error    // receives fatal error; closed on clean exit
}

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

type ManagerConfig struct {
	Logger       logging.Logger
	Settings     settings.Provider
	PortChecker  PortChecker    // nil → RealPortChecker
	Clock        timeutil.Clock // nil → timeutil.RealClock
	CloseTimeout time.Duration  // default 10s
}

type NetworkerError struct {
	Code      NetworkerErrorCode
	SessionID string
	Message   string
	Err       error // optional wrapped error
}

type NetworkerErrorCode int

type Plugin struct {
	plugin.Plugin
	Impl Provider
}

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

type PluginOpts struct {
	// ResourceForwarders maps resource key → ResourceForwarder.
	ResourceForwarders map[string]ResourceForwarder
	// StaticForwarders maps key → StaticForwarder.
	StaticForwarders map[string]StaticForwarder
}

type PluginServer struct {
	networkerpb.UnimplementedNetworkerPluginServer
	Impl Provider
}

type PortChecker interface {
	// FindFreePort returns a free TCP port.
	FindFreePort() (int32, error)
	// IsPortUnavailable returns true if the port is already in use.
	IsPortUnavailable(port int32) bool
}

type PortForwardConnectionType string

type PortForwardProtocol string

type PortForwardProvider interface {
	GetSupportedPortForwardTargets(*types.PluginContext) ([]string, error)
	GetPortForwardSession(*types.PluginContext, string) (*PortForwardSession, error)
	ListPortForwardSessions(*types.PluginContext) ([]*PortForwardSession, error)
	FindPortForwardSessions(
		*types.PluginContext,
		FindPortForwardSessionRequest,
	) ([]*PortForwardSession, error)
	StartPortForwardSession(
		*types.PluginContext,
		PortForwardSessionOptions,
	) (*PortForwardSession, error)
	ClosePortForwardSession(*types.PluginContext, string) (*PortForwardSession, error)
	StopAll()
}

type PortForwardResourceConnection struct {
	ResourceData map[string]interface{} `json:"resource_data"`
	ConnectionID string                 `json:"connection_id"`
	PluginID     string                 `json:"plugin_id"`
	ResourceID   string                 `json:"resource_id"`
	ResourceKey  string                 `json:"resource_key"`
}

type PortForwardSession struct {
	CreatedAt      time.Time                    `json:"created_at"`
	UpdatedAt      time.Time                    `json:"updated_at"`
	Connection     Connection                   `json:"connection"`
	Labels         map[string]string            `json:"labels"`
	ID             string                       `json:"id"`
	Protocol       PortForwardProtocol          `json:"protocol"`
	State          SessionState                 `json:"state"`
	ConnectionType PortForwardConnectionType    `json:"connection_type"`
	Encryption     PortForwardSessionEncryption `json:"encryption"`
	LocalPort      int32                        `json:"local_port"`
	RemotePort     int32                        `json:"remote_port"`
}

type PortForwardSessionEncryption struct {
	Algorithm string `json:"algorithm"`
	Key       string `json:"key"`
	Enabled   bool   `json:"enabled"`
}

type PortForwardSessionOptions struct {
	Connection     Connection                   `json:"connection"`
	Labels         map[string]string            `json:"labels"`
	Params         map[string]string            `json:"params"`
	Protocol       PortForwardProtocol          `json:"protocol"`
	ConnectionType PortForwardConnectionType    `json:"connection_type"`
	Encryption     PortForwardSessionEncryption `json:"encryption"`
	LocalPort      int32                        `json:"local_port"`
	RemotePort     int32                        `json:"remote_port"`
}

type PortForwardStaticConnection struct {
	Address string `json:"address"`
}

type Provider interface {
	PortForwardProvider
}

type RealPortChecker struct{}

type ResourceForwarder interface {
	ForwardResource(ctx context.Context, pctx *types.PluginContext, opts ResourcePortForwardHandlerOpts) (*ForwarderResult, error)
}

type ResourceForwarderFunc func(ctx context.Context, pctx *types.PluginContext, opts ResourcePortForwardHandlerOpts) (*ForwarderResult, error)

type ResourcePortForwardHandlerOpts struct {
	Resource PortForwardResourceConnection `json:"resource"`
	Options  PortForwardSessionOptions     `json:"options"`
}

type SessionState string

type StaticForwarder interface {
	ForwardStatic(ctx context.Context, pctx *types.PluginContext, opts StaticPortForwardHandlerOpts) (*ForwarderResult, error)
}

type StaticForwarderFunc func(ctx context.Context, pctx *types.PluginContext, opts StaticPortForwardHandlerOpts) (*ForwarderResult, error)

type StaticPortForwardHandlerOpts struct {
	Static  PortForwardStaticConnection `json:"static"`
	Options PortForwardSessionOptions   `json:"options"`
}