pod

Documentation

Index

• Constants
• Variables
• type SidecarInjector
  • func NewSidecarInjector(c client.Client) *SidecarInjector
  • func (s *SidecarInjector) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (s *SidecarInjector) InjectDecoder(d *admission.Decoder) error
  • func (s *SidecarInjector) Mutate(pod *v1.Pod, namespace string) (*v1.Pod, error)
  • func (s *SidecarInjector) MutationRequired(pod *v1.Pod, ns string) (bool, error)

Constants

const (
	MasterRole = "master"
	BatchJob   = "Job"
	// TrialKind is the name of Trial kind
	TrialKind = "Trial"
	// TrialAPIVersion is the name of Trial API Version
	TrialAPIVersion = "kubeflow.org/v1beta1"
)

Variables

var (
	NeedWrapWorkerMetricsCollectorList = [...]common.CollectorKind{
		common.StdOutCollector,
		common.TfEventCollector,
		common.FileCollector,
	}
)

Types

type SidecarInjector

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

SidecarInjector injects metrics collect sidecar to the primary pod.

func NewSidecarInjector

func NewSidecarInjector(c client.Client) *SidecarInjector

NewSidecarInjector returns a new sidecar injector with the given client.

func (*SidecarInjector) Handle

func (s *SidecarInjector) Handle(ctx context.Context, req admission.Request) admission.Response

func (*SidecarInjector) InjectDecoder

func (s *SidecarInjector) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder.

func (*SidecarInjector) Mutate

func (s *SidecarInjector) Mutate(pod *v1.Pod, namespace string) (*v1.Pod, error)

func (*SidecarInjector) MutationRequired

func (s *SidecarInjector) MutationRequired(pod *v1.Pod, ns string) (bool, error)