deployer

type DeployerHandler interface {
	// IngestReaders is responsible for keeping the readers drained.
	// After the readers have been closed, it MUST signal completion by
	// closing the provided done channel.
	IngestReaders(done chan<- struct{}, stdout io.Reader, stderr io.Reader) error
	AugmentError(error) error
}

type FileSystemStats struct {
	Path       string `json:"path"`
	BlockSize  uint64 `json:"blockSize"`
	FreeBlocks uint64 `json:"freeBlocks"`
}

type Local struct {
	Payload     *payload.Payload
	KeepPayload bool
}

type LoggerHandler struct {
	LogCallback func(string)
	// contains filtered or unexported fields
}

type ProgressStatus struct {
	Path     string
	Reader   io.Reader
	Writer   io.Writer
	Size     int
	Callback ProgressStatusCallback

	StartTime time.Time
	// contains filtered or unexported fields
}

type ProgressStatusCallback func(path string, copied int, size int, startTime time.Time)

type SSH struct {
	Payload     *payload.Payload
	Client      *ssh.Client
	KeepPayload bool
}