docker

Documentation

Index

• type DockerEngine
  • func NewEngine(dir string, sf_token string, endpoint string) (*DockerEngine, error)
  • 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

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) Pause

func (e *DockerEngine) Pause(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)

func (*DockerEngine) Remove

func (e *DockerEngine) Remove(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)

func (*DockerEngine) Resume

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

func (*DockerEngine) Shutdown

func (e *DockerEngine) Shutdown(ctx context.Context, _ error, zlog *zap.Logger) error

func (*DockerEngine) Stop

func (e *DockerEngine) Stop(ctx context.Context, deploymentID string, zlog *zap.Logger) (string, error)

func (*DockerEngine) Update

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

type StreamStats

type StreamStats struct {
	LastBlock string `json:"last_block"`
}