docker

Oct 5, 2023

Changes in this version

+ type DockerEngine struct

+ func NewEngine(dir string, sf_token string) (*DockerEngine, error)

+ func (e *DockerEngine) CheckVersion() error

+ func (e *DockerEngine) Create(deploymentID string, pkg *pbsubstreams.Package, zlog *zap.Logger) error

+ func (e *DockerEngine) Info(deploymentID string, zlog *zap.Logger) (pbsinksvc.DeploymentStatus, string, map[string]string, *pbsinksvc.PackageInfo, ...)

+ func (e *DockerEngine) List(zlog *zap.Logger) (out []*pbsinksvc.DeploymentWithStatus, err error)

+ func (e *DockerEngine) Pause(deploymentID string, zlog *zap.Logger) (string, error)

+ func (e *DockerEngine) Remove(deploymentID string, zlog *zap.Logger) (string, error)

+ func (e *DockerEngine) Resume(deploymentID string, _ pbsinksvc.DeploymentStatus, zlog *zap.Logger) (string, error)

+ func (e *DockerEngine) Shutdown(zlog *zap.Logger) (err error)

+ func (e *DockerEngine) Stop(deploymentID string, zlog *zap.Logger) (string, error)

+ func (e *DockerEngine) Update(deploymentID string, pkg *pbsubstreams.Package, reset bool, zlog *zap.Logger) error

+ type StreamStats struct

+ LastBlock string