Versions in this module Expand all Collapse all v1 v1.3.19 Jun 6, 2023 v1.3.18 Jun 6, 2023 Changes in this version + const Code + const HealthStatusRunning + const Hpull + const Hpush + const HpushStdin + const Hrev + const PrefixXactID + const Spec + func CheckSecret(secret string) error + func InitCode(t cluster.Target, msg *InitCodeMsg, xid string) error + func InitSpec(t cluster.Target, msg *InitSpecMsg, etlName string, opts StartOpts) error + func ParsePodSpec(errCtx *cmn.ETLErrCtx, spec []byte) (*corev1.Pod, error) + func PodHealth(t cluster.Target, etlName string) (string, error) + func Stop(t cluster.Target, id string, errCause error) error + func StopAll(t cluster.Target) + type Aborter struct + func (e *Aborter) ListenSmapChanged() + func (e *Aborter) String() string + type CPUMemByTarget []*CPUMemUsed + type CPUMemUsed struct + CPU float64 + Mem int64 + TargetID string + func PodMetrics(t cluster.Target, etlName string) (*CPUMemUsed, error) + type CommStats interface + InBytes func() int64 + ObjCount func() int64 + OutBytes func() int64 + type Communicator interface + CommType func() string + Name func() string + OfflineTransform func(bck *meta.Bck, objName string, timeout time.Duration) (cos.ReadCloseSizer, error) + OnlineTransform func(w http.ResponseWriter, r *http.Request, bck *meta.Bck, objName string) error + PodName func() string + Stop func() + String func() string + SvcName func() string + Xact func() cluster.Xact + func GetCommunicator(etlName string, lsnode *meta.Snode) (Communicator, error) + type ETLs map[string]InitMsg + type HealthByTarget []*HealthStatus + type HealthStatus struct + Status string + TargetID string + type Info struct + InBytes int64 + Name string + ObjCount int64 + OutBytes int64 + XactID string + func List() []Info + type InfoList []Info + func (il InfoList) Len() int + func (il InfoList) Less(i, j int) bool + func (il InfoList) Swap(i, j int) + type InitCodeMsg struct + ChunkSize int64 + Code []byte + Deps []byte + Flags int64 + Funcs struct{ ... } + Runtime string + TransformURL bool + func (*InitCodeMsg) Type() string + func (m *InitCodeMsg) String() string + func (m *InitCodeMsg) Validate() error + type InitMsg interface + CommType func() string + Name func() string + String func() string + Type func() string + Validate func() error + func UnmarshalInitMsg(b []byte) (msg InitMsg, err error) + type InitMsgBase struct + CommTypeX string + IDX string + Timeout cos.Duration + func (m InitMsgBase) CommType() string + func (m InitMsgBase) Name() string + type InitSpecMsg struct + Spec []byte + func (*InitSpecMsg) Type() string + func (m *InitSpecMsg) String() string + func (m *InitSpecMsg) Validate() (err error) + type Logs struct + Logs []byte + TargetID string + func PodLogs(t cluster.Target, transformID string) (logs Logs, err error) + type LogsByTarget []Logs + type MD struct + ETLs ETLs + Ext any + Version int64 + func (*MD) JspOpts() jsp.Options + func (e *MD) Add(msg InitMsg) + func (e *MD) Del(id string) (deleted bool) + func (e *MD) Get(id string) (msg InitMsg, present bool) + func (e *MD) Init(l int) + func (e *MD) MarshalJSON() ([]byte, error) + func (e *MD) String() string + func (e *MD) UnmarshalJSON(data []byte) (err error) + type OfflineDP struct + func NewOfflineDP(msg *apc.TCBMsg, lsnode *meta.Snode) (*OfflineDP, error) + func (dp *OfflineDP) Reader(lom *cluster.LOM) (cos.ReadOpenCloser, cos.OAH, error) + type StartOpts struct + Env map[string]string