pod

Documentation

Index

• func SyncWithDatahub(k8sClient client.Client, conn *grpc.ClientConn) error
• type PodRepository
  • func NewPodRepository(conn *grpc.ClientConn, 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)

Functions

func SyncWithDatahub

func SyncWithDatahub(k8sClient client.Client, conn *grpc.ClientConn) error

Types

type PodRepository

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

PodRepository creates predicted pod to datahub

func NewPodRepository

func NewPodRepository(conn *grpc.ClientConn, 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)