Documentation ¶
Index ¶
Constants ¶
View Source
const DeploymentIDLength = 8
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Engine ¶
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 }
Click to show internal directories.
Click to hide internal directories.