deployer

type AnyConnectorFactory interface {
	Name() string
	ConfigurationSchema() schema.Object
	Create(config any, logger log.Logger) (Connector, error)
	DeploymentType() DeploymentType
}

type Connector interface {
	// Deploy instructs the connector to aquire the plugin and run it,
	// resulting in the plugin starting its ATP server.
	// The ATP server will be accessible through the `Plugin` interface.
	//
	// Parameters:
	// ctx: The context that lasts the length of the deployment.
	// 	     A cancelled context means the plugin is in the process of getting shut down, or is shut down. No new
	//	     deployment should be allowed.
	// pluginSource: The source of the plugin. This can be the tag of the image to run, a Python module, or
	//		 anything else that the deployer supports.
	Deploy(ctx context.Context, pluginSource string) (Plugin, error)
}

type ConnectorFactory[ConfigType any] interface {
	Name() string
	ConfigurationSchema() *schema.TypedScopeSchema[ConfigType]
	Create(config ConfigType, logger log.Logger) (Connector, error)
	DeploymentType() DeploymentType
}

type DeploymentType string

type Plugin interface {
	io.Reader
	io.Writer
	io.Closer
	ID() string
}