pod

Documentation

Index

• type PodRepository
  • func NewPodRepository(datahubClient *datahubpkg.Client, clusterUID string) *PodRepository
  • func (repo *PodRepository) CreatePods(ctx context.Context, pods []*datahub_resources.Pod) error
  • func (repo *PodRepository) DeletePods(ctx context.Context, objectMetas []*datahub_resources.ObjectMeta) error
  • func (repo *PodRepository) ListAlamedaPods() ([]*datahub_resources.Pod, error)
  • func (repo *PodRepository) ListAlamedaPodsByAlamedaScaler(ctx context.Context, namespace, name string) ([]*datahub_resources.Pod, error)

Types

type PodRepository

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

PodRepository creates predicted pod to datahub

func NewPodRepository

func NewPodRepository(datahubClient *datahubpkg.Client, clusterUID string) *PodRepository

NewPodRepository return PodRepository instance

func (*PodRepository) CreatePods

func (repo *PodRepository) CreatePods(ctx context.Context, pods []*datahub_resources.Pod) error

func (*PodRepository) DeletePods

func (repo *PodRepository) DeletePods(ctx context.Context, objectMetas []*datahub_resources.ObjectMeta) error

DeletePods delete pods from datahub

func (*PodRepository) ListAlamedaPods

func (repo *PodRepository) ListAlamedaPods() ([]*datahub_resources.Pod, error)

func (*PodRepository) ListAlamedaPodsByAlamedaScaler

func (repo *PodRepository) ListAlamedaPodsByAlamedaScaler(ctx context.Context, namespace, name string) ([]*datahub_resources.Pod, error)