server

Documentation

Index

• Constants
• func New(ctx context.Context, engine string, dataDir string, httpListenAddr string, ...) (*server, error)
• type Engine

Constants

const DeploymentIDLength = 8

Functions

func New

func New(
	ctx context.Context,
	engine string,
	dataDir string,
	httpListenAddr string,
	corsHostRegexAllow *regexp.Regexp,
	logger *zap.Logger,
) (*server, error)

Types

type Engine

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

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

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

	Info(deploymentID string, zlog *zap.Logger) (pbsinksvc.DeploymentStatus, string, map[string]string, *pbsinksvc.PackageInfo, *pbsinksvc.SinkProgress, error)
	List(zlog *zap.Logger) ([]*pbsinksvc.DeploymentWithStatus, error)

	Shutdown(zlog *zap.Logger) error
}