etl

type Aborter struct {
	// contains filtered or unexported fields
}

type CPUMemByTarget []*CPUMemUsed

type CPUMemUsed struct {
	TargetID string  `json:"target_id"`
	CPU      float64 `json:"cpu"`
	Mem      int64   `json:"mem"`
}

type CommStats interface {
	ObjCount() int64
	InBytes() int64
	OutBytes() int64
}

type Communicator interface {
	meta.Slistener

	ETLName() string
	PodName() string
	SvcName() string

	String() string

	SetupConnection() error
	Stop()
	Restart(boot *etlBootstrapper)
	GetPodWatcher() *podWatcher
	GetSecret() string

	Xact() core.Xact // underlying `apc.ActETLInline` xaction (see xact/xs/etl.go)
	CommStats        // only stats for `apc.ActETLInline` inline transform

	// InlineTransform uses one of the two ETL container endpoints:
	//  - Method "PUT", Path "/"
	//  - Method "GET", Path "/bucket/object"
	InlineTransform(w http.ResponseWriter, r *http.Request, lom *core.LOM, latestVer bool, targs string) (int, error)
	// contains filtered or unexported methods
}

type ETLs map[string]InitMsg

type HealthByTarget []*HealthStatus

type HealthStatus struct {
	TargetID string `json:"target_id"`
	Status   string `json:"health_status"` // enum { HealthStatusRunning, ... } above
}

type Info struct {
	Name     string `json:"id"`
	Stage    string `json:"stage"`
	XactID   string `json:"xaction_id"`
	ObjCount int64  `json:"obj_count"`
	InBytes  int64  `json:"in_bytes"`
	OutBytes int64  `json:"out_bytes"`
}

type InfoList []Info

type InitCodeMsg struct {
	Runtime string `json:"runtime"`
	Funcs   struct {
		Transform string `json:"transform"`
	}
	Code []byte `json:"code"` // cannot be omitted

	Deps []byte `json:"dependencies"`
	InitMsgBase
	ChunkSize int64 `json:"chunk_size"`
	Flags     int64 `json:"flags"`
}

type InitMsg interface {
	Name() string
	MsgType() string // Code or Spec
	CommType() string
	ArgType() string
	Validate() error
	IsDirectPut() bool
	String() string
}

type InitMsgBase struct {
	EtlName          string       `json:"id"`
	CommTypeX        string       `json:"communication"` // enum commTypes
	ArgTypeX         string       `json:"argument"`      // enum argTypes
	Timeout          cos.Duration `json:"timeout"`
	SupportDirectPut bool         `json:"support_direct_put"`
}

type InitSpecMsg struct {
	Spec []byte `json:"spec"`
	InitMsgBase
}

type Logs struct {
	TargetID string `json:"target_id"`
	Logs     []byte `json:"logs"`
}

type LogsByTarget []Logs

type MD struct {
	Ext     any
	ETLs    ETLs
	Version int64
}

type Session interface {
	// OfflineTransform is an instance of `core.GetROC` function, which is driven by `TCB` and `TCO` to provide offline transformation
	OfflineTransform(lom *core.LOM, latestVer, sync bool, gargs *core.GetROCArgs) core.ReadResp
	// Finish cleans up the job's communication channel, and aborts the undergoing xaction (`TCB`/`TCO`) if errCause is provided
	Finish(errCause error) error
}

type Stage int

type StartOpts struct {
	Env map[string]string
}

type WebsocketCtrlMsg struct {
	Daddr string `json:"dst_addr,omitempty"`
	Targs string `json:"etl_args,omitempty"`
	FQN   string `json:"fqn,omitempty"`
	Path  string `json:"path,omitempty"`
}