Documentation ¶
Index ¶
- type DockerEngine
- func (e *DockerEngine) CheckVersion() error
- func (e *DockerEngine) Create(ctx context.Context, deploymentID string, pkg *pbsubstreams.Package, ...) (*pbsinksvc.InfoResponse, error)
- func (e *DockerEngine) Info(ctx context.Context, deploymentID string, zlog *zap.Logger) (*pbsinksvc.InfoResponse, error)
- func (e *DockerEngine) List(ctx context.Context, zlog *zap.Logger) (out []*pbsinksvc.DeploymentWithStatus, err error)
- func (e *DockerEngine) Pause(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)
- func (e *DockerEngine) Remove(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)
- func (e *DockerEngine) Resume(ctx context.Context, deploymentID string, _ pbsinksvc.DeploymentStatus, ...) (string, error)
- func (e *DockerEngine) Shutdown(ctx context.Context, _ error, zlog *zap.Logger) error
- func (e *DockerEngine) Stop(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)
- func (e *DockerEngine) Update(ctx context.Context, deploymentID string, pkg *pbsubstreams.Package, ...) 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 NewEngine ¶
func NewEngine(dir string, sf_token string, endpoint string) (*DockerEngine, error)
func (*DockerEngine) CheckVersion ¶
func (e *DockerEngine) CheckVersion() error
func (*DockerEngine) Create ¶
func (e *DockerEngine) Create(ctx context.Context, deploymentID string, pkg *pbsubstreams.Package, zlog *zap.Logger) (*pbsinksvc.InfoResponse, error)
func (*DockerEngine) Info ¶
func (e *DockerEngine) Info(ctx context.Context, deploymentID string, zlog *zap.Logger) (*pbsinksvc.InfoResponse, error)
func (*DockerEngine) List ¶
func (e *DockerEngine) List(ctx context.Context, zlog *zap.Logger) (out []*pbsinksvc.DeploymentWithStatus, err error)
func (*DockerEngine) Resume ¶
func (e *DockerEngine) Resume(ctx context.Context, deploymentID string, _ pbsinksvc.DeploymentStatus, zlog *zap.Logger) (string, error)
type StreamStats ¶
type StreamStats struct {
LastBlock string `json:"last_block"`
}
Click to show internal directories.
Click to hide internal directories.