batch

Documentation

Index

• type Adapter
  • func NewAdapter(mgr ctrl.Manager, kubeClient kubeClient, apiServer apiServer, ...) *Adapter
  • func (a Adapter) GetFromRuntime(id string) (types.RuntimeEntity, error)
  • func (a Adapter) GetFromStorage(id string) (types.StorageEntity, error)
  • func (a Adapter) ListRuntime() ([]types.RuntimeEntity, error)
  • func (a Adapter) ListStorage() ([]types.StorageEntity, error)
  • func (a Adapter) SubscribeRuntimeUpdates(hook types.StatusPollingHookFunc) error
• type KubeEntity
  • func (k KubeEntity) Delete() error
  • func (k KubeEntity) GetID() string
  • func (k KubeEntity) GetSpecHash() (uint64, error)
  • func (k KubeEntity) GetStatusHash() (uint64, error)
  • func (k KubeEntity) IsDeleting() bool
  • func (k KubeEntity) ReportStatus() error
• type StorageEntity
  • func (s StorageEntity) CreateInRuntime() error
  • func (s StorageEntity) DeleteInDB() error
  • func (s StorageEntity) DeleteInRuntime() error
  • func (s StorageEntity) GetID() string
  • func (s StorageEntity) GetSpecHash() (uint64, error)
  • func (s StorageEntity) GetStatusHash() (uint64, error)
  • func (s StorageEntity) HasDeletionMark() bool
  • func (s StorageEntity) IsFinished() bool
  • func (s StorageEntity) UpdateInRuntime() error

Types

type Adapter

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

func NewAdapter

func NewAdapter(mgr ctrl.Manager,
	kubeClient kubeClient,
	apiServer apiServer,
	apiServerServiceAPI apiServerServiceAPI) *Adapter

func (Adapter) GetFromRuntime

func (a Adapter) GetFromRuntime(id string) (types.RuntimeEntity, error)

func (Adapter) GetFromStorage

func (a Adapter) GetFromStorage(id string) (types.StorageEntity, error)

func (Adapter) ListRuntime

func (a Adapter) ListRuntime() ([]types.RuntimeEntity, error)

func (Adapter) ListStorage

func (a Adapter) ListStorage() ([]types.StorageEntity, error)

func (Adapter) SubscribeRuntimeUpdates

func (a Adapter) SubscribeRuntimeUpdates(hook types.StatusPollingHookFunc) error

type KubeEntity

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

func (KubeEntity) Delete

func (k KubeEntity) Delete() error

func (KubeEntity) GetID

func (k KubeEntity) GetID() string

func (KubeEntity) GetSpecHash

func (k KubeEntity) GetSpecHash() (uint64, error)

func (KubeEntity) GetStatusHash

func (k KubeEntity) GetStatusHash() (uint64, error)

func (KubeEntity) IsDeleting

func (k KubeEntity) IsDeleting() bool

BatchInferenceJob in kubernetes operator is deleted immediately

func (KubeEntity) ReportStatus

func (k KubeEntity) ReportStatus() error

type StorageEntity

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

func (StorageEntity) CreateInRuntime

func (s StorageEntity) CreateInRuntime() error

func (StorageEntity) DeleteInDB

func (s StorageEntity) DeleteInDB() error

func (StorageEntity) DeleteInRuntime

func (s StorageEntity) DeleteInRuntime() error

func (StorageEntity) GetID

func (s StorageEntity) GetID() string

func (StorageEntity) GetSpecHash

func (s StorageEntity) GetSpecHash() (uint64, error)

func (StorageEntity) GetStatusHash

func (s StorageEntity) GetStatusHash() (uint64, error)

func (StorageEntity) HasDeletionMark

func (s StorageEntity) HasDeletionMark() bool

func (StorageEntity) IsFinished

func (s StorageEntity) IsFinished() bool

func (StorageEntity) UpdateInRuntime

func (s StorageEntity) UpdateInRuntime() error