deploypipe

Documentation

Index

• Constants
• type CleanupWorkspacePipeline
  • func (p *CleanupWorkspacePipeline) Cancel(c *DeployCtx, err error)
  • func (p *CleanupWorkspacePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)
• type CopyWorkspacePipeline
  • func (p *CopyWorkspacePipeline) Cancel(c *DeployCtx, err error)
  • func (p *CopyWorkspacePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)
• type CopyWriter
  • func (c *CopyWriter) Write(p []byte) (n int, err error)
• type DeployCtx
  • func NewDeployCtx(options options.IOptions, writer *sse.Writer, env map[string]string, ...) *DeployCtx
  • func (d *DeployCtx) GetDeployInfo() map[string]string
  • func (d *DeployCtx) GetServicePath() (string, error)
  • func (d *DeployCtx) Send(event string, data string) error
• type DockerComposeDownPipeline
  • func (p *DockerComposeDownPipeline) Cancel(c *DownCtx, err error)
  • func (p *DockerComposeDownPipeline) Process(ctx context.Context, c *DownCtx) (*DownCtx, error)
• type DockerComposeFileParsePipeline
  • func (p *DockerComposeFileParsePipeline) Cancel(c *DeployCtx, err error)
  • func (p *DockerComposeFileParsePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)
• type DockerComposeUpPipeline
  • func (p *DockerComposeUpPipeline) Cancel(c *DeployCtx, err error)
  • func (p *DockerComposeUpPipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)
• type DownCtx
  • func NewDownCtx(options options.IOptions, service *model.Service, nodeState *node.NodeState, ...) *DownCtx
  • func (d *DownCtx) GetServicePath() (string, error)
• type DownloadInstallerPipeline
  • func (p *DownloadInstallerPipeline) Cancel(c *DeployCtx, err error)
  • func (p *DownloadInstallerPipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)
• type LoadImagePipeline
  • func (p *LoadImagePipeline) Cancel(c *DeployCtx, err error)
  • func (p *LoadImagePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)

Constants

const (
	DockerComposeFile = "docker-compose.yml"
)

Types

type CleanupWorkspacePipeline

type CleanupWorkspacePipeline struct {
}

func (*CleanupWorkspacePipeline) Cancel

func (p *CleanupWorkspacePipeline) Cancel(c *DeployCtx, err error)

func (*CleanupWorkspacePipeline) Process

func (p *CleanupWorkspacePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)

type CopyWorkspacePipeline

type CopyWorkspacePipeline struct {
}

func (*CopyWorkspacePipeline) Cancel

func (p *CopyWorkspacePipeline) Cancel(c *DeployCtx, err error)

func (*CopyWorkspacePipeline) Process

func (p *CopyWorkspacePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)

type CopyWriter

type CopyWriter struct {
	*sse.Writer
}

func (*CopyWriter) Write

func (c *CopyWriter) Write(p []byte) (n int, err error)

type DeployCtx

type DeployCtx struct {
	App       *model.App
	Service   *model.Service
	NodeState *node.NodeState
	// contains filtered or unexported fields
}

func NewDeployCtx

func NewDeployCtx(
	options options.IOptions,
	writer *sse.Writer,
	env map[string]string,
	appCtx *ctx.AppCtx,
) *DeployCtx

func (*DeployCtx) GetDeployInfo

func (d *DeployCtx) GetDeployInfo() map[string]string

func (*DeployCtx) GetServicePath

func (d *DeployCtx) GetServicePath() (string, error)

func (*DeployCtx) Send

func (d *DeployCtx) Send(event string, data string) error

type DockerComposeDownPipeline

type DockerComposeDownPipeline struct {
}

func (*DockerComposeDownPipeline) Cancel

func (p *DockerComposeDownPipeline) Cancel(c *DownCtx, err error)

func (*DockerComposeDownPipeline) Process

func (p *DockerComposeDownPipeline) Process(ctx context.Context, c *DownCtx) (*DownCtx, error)

type DockerComposeFileParsePipeline

type DockerComposeFileParsePipeline struct {
}

func (*DockerComposeFileParsePipeline) Cancel

func (p *DockerComposeFileParsePipeline) Cancel(c *DeployCtx, err error)

func (*DockerComposeFileParsePipeline) Process

func (p *DockerComposeFileParsePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)

type DockerComposeUpPipeline

type DockerComposeUpPipeline struct {
}

func (*DockerComposeUpPipeline) Cancel

func (p *DockerComposeUpPipeline) Cancel(c *DeployCtx, err error)

func (*DockerComposeUpPipeline) Process

func (p *DockerComposeUpPipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)

type DownCtx

type DownCtx struct {
	Service   *model.Service
	NodeState *node.NodeState
	// contains filtered or unexported fields
}

func NewDownCtx

func NewDownCtx(
	options options.IOptions,
	service *model.Service,
	nodeState *node.NodeState,
	deployInfo map[string]string,
) *DownCtx

func (*DownCtx) GetServicePath

func (d *DownCtx) GetServicePath() (string, error)

type DownloadInstallerPipeline

type DownloadInstallerPipeline struct {
}

func (*DownloadInstallerPipeline) Cancel

func (p *DownloadInstallerPipeline) Cancel(c *DeployCtx, err error)

func (*DownloadInstallerPipeline) Process

func (p *DownloadInstallerPipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)

type LoadImagePipeline

type LoadImagePipeline struct {
}

func (*LoadImagePipeline) Cancel

func (p *LoadImagePipeline) Cancel(c *DeployCtx, err error)

func (*LoadImagePipeline) Process

func (p *LoadImagePipeline) Process(ctx context.Context, c *DeployCtx) (*DeployCtx, error)