api

type Client interface {
	Connect(*domain.AgentInit) (*domain.AgentConfig, error)
	ReConn() <-chan struct{}

	UploadLog(filePath string) error
	ReportProfile(profile *domain.AgentProfile) error

	GetCmdIn() <-chan []byte
	SendCmdOut(out domain.CmdOut) error
	SendShellLog(jobId, stepId, b64Log string)
	SendTtyLog(ttyId, b64Log string)

	CachePut(jobId, name, workspace string, paths []string) error
	CacheGet(jobId, name string) *domain.JobCache
	CacheDownload(cacheId, workspace, file string, progress io.Writer)

	GetSecret(name string) (domain.Secret, error)
	GetConfig(name string) (domain.Config, error)

	Close()
}

type CounterWrite struct {
	Total uint64
}