Versions in this module Expand all Collapse all v0 v0.0.1 Mar 24, 2023 Changes in this version + func ConfigK8s(ctx context.Context, namespace string, name string) (values map[string]string, err kv.Error) + func GetPrometheusPort() (port int) + func InitiateK8s(ctx context.Context, namespace string, cfgMap string, readyC chan struct{}, ...) + func IsAliveK8s() (err kv.Error) + func K8sUpdateSecret(config string, secret string, content []byte) (err kv.Error) + func ListenK8s(ctx context.Context, namespace string, globalMap string, podMap string, ...) (err kv.Error) + func MonitorK8s(ctx context.Context, errC chan<- kv.Error) + func StartPrometheusExporter(ctx context.Context, promAddr string, getRsc ResourceAvailable, ...) (err kv.Error) + func StartTelemetry(ctx context.Context, options StartTelemetryOpts, logger *log.Logger) (newCtx context.Context, err kv.Error) + type K8sStateUpdate struct + Name string + State types.K8sState + type Listeners struct + Master chan K8sStateUpdate + func K8sStateUpdates() (l *Listeners) + func NewStateBroadcast(ctx context.Context, errorC chan<- kv.Error) (l *Listeners) + func (l *Listeners) Add(listen chan<- K8sStateUpdate) (id xid.ID, err kv.Error) + func (l *Listeners) Delete(id xid.ID) + type Resource struct + Cpus uint + GpuCount uint + GpuMem string + Gpus uint + Hdd string + Ram string + func (rsc *Resource) Clone() (r *Resource) + func (rsc *Resource) Fit(r *Resource) (didFit bool, err kv.Error) + func (rsc Resource) String() (serialized string) + type ResourceAvailable interface + FetchMachineResources func() (rsc *Resource) + type Resources struct + func (*Resources) FetchMachineResources() (rsc *Resource) + type StartTelemetryOpts struct + ApiEndpoint string + ApiKey string + Bag *baggage.Baggage + Cooldown time.Duration + Dataset string + NodeName string + ProjectID string + ServiceName string