server

type Engine interface {
	Create(ctx context.Context, deploymentID string, pkg *pbsubstreams.Package, zlog *zap.Logger) (*pbsinksvc.InfoResponse, error)
	Update(ctx context.Context, deploymentID string, pkg *pbsubstreams.Package, reset bool, zlog *zap.Logger) error

	Resume(ctx context.Context, deploymentID string, currentState pbsinksvc.DeploymentStatus, zlog *zap.Logger) (string, error)
	Pause(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)
	Stop(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)

	Remove(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)

	Info(ctx context.Context, deploymentID string, zlog *zap.Logger) (*pbsinksvc.InfoResponse, error)
	List(ctx context.Context, zlog *zap.Logger) ([]*pbsinksvc.DeploymentWithStatus, error)

	Shutdown(ctx context.Context, err error, zlog *zap.Logger) error
}