Documentation
¶
Index ¶
- type DockerEngine
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DockerEngine ¶
type DockerEngine struct {
// contains filtered or unexported fields
}
func (*DockerEngine) CheckVersion ¶
func (e *DockerEngine) CheckVersion() error
func (*DockerEngine) Create ¶
func (e *DockerEngine) Create(deploymentID string, pkg *pbsubstreams.Package, zlog *zap.Logger) error
func (*DockerEngine) Info ¶
func (e *DockerEngine) Info(deploymentID string, zlog *zap.Logger) (pbsinksvc.DeploymentStatus, string, map[string]string, *pbsinksvc.PackageInfo, *pbsinksvc.SinkProgress, error)
func (*DockerEngine) List ¶
func (e *DockerEngine) List(zlog *zap.Logger) (out []*pbsinksvc.DeploymentWithStatus, err error)
func (*DockerEngine) Resume ¶
func (e *DockerEngine) Resume(deploymentID string, _ pbsinksvc.DeploymentStatus, zlog *zap.Logger) (string, error)
func (*DockerEngine) Update ¶
func (e *DockerEngine) Update(deploymentID string, pkg *pbsubstreams.Package, reset bool, zlog *zap.Logger) error
type StreamStats ¶
type StreamStats struct {
LastBlock string `json:"last_block"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.