plugins

Documentation

Index

• Constants
• func CollectPolyaxonRunLogs(namespace, owner, project, uuid string, kind string, log logr.Logger) error
• func LogPolyaxonRunStatus(owner, project, uuid string, statusCond operationv1.OperationCondition, ...) error
• func NotifyPolyaxonRunStatus(namespace, name, owner, project, uuid string, ...) error
• type Metrics
  • func NewMetrics(cli client.Client) *Metrics
  • func (m *Metrics) Collect(ch chan<- prometheus.Metric)
  • func (m *Metrics) Describe(ch chan<- *prometheus.Desc)

Constants

const (

	// PolyaxonAuthToken polyaxon auth token
	PolyaxonAuthToken = "POLYAXON_AUTH_TOKEN"

	// PolyaxonInternalToken polyaxon internal token
	PolyaxonInternalToken = "POLYAXON_SECRET_INTERNAL_TOKEN"

	// PolyaxonAPIHost polyaxon api host
	PolyaxonAPIHost = "POLYAXON_PROXY_API_HOST"

	// PolyaxonAPIPort polyaxon api port
	PolyaxonAPIPort = "POLYAXON_PROXY_API_PORT"

	// PolyaxonStreamsHost polyaxon streams host
	PolyaxonStreamsHost = "POLYAXON_PROXY_STREAMS_HOST"

	// PolyaxonStreamsPort polyaxon api port
	PolyaxonStreamsPort = "POLYAXON_PROXY_STREAMS_PORT"
)

Functions

func CollectPolyaxonRunLogs

func CollectPolyaxonRunLogs(namespace, owner, project, uuid string, kind string, log logr.Logger) error

CollectPolyaxonRunLogs archives logs before removing the operation

func LogPolyaxonRunStatus

func LogPolyaxonRunStatus(owner, project, uuid string, statusCond operationv1.OperationCondition, log logr.Logger) error

LogPolyaxonRunStatus creates polyaxon run status

func NotifyPolyaxonRunStatus

func NotifyPolyaxonRunStatus(namespace, name, owner, project, uuid string, statusCond operationv1.OperationCondition, connections []string, log logr.Logger) error

NotifyPolyaxonRunStatus creates polyaxon run status

Types

type Metrics

type Metrics struct {
	OperationsRunning       *prometheus.GaugeVec
	OperationsCreated       *prometheus.CounterVec
	OperationsFailedCreated *prometheus.CounterVec
	// contains filtered or unexported fields
}

Metrics exposed by the operator

func NewMetrics

func NewMetrics(cli client.Client) *Metrics

NewMetrics prometheus initializer

func (*Metrics) Collect

func (m *Metrics) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (*Metrics) Describe

func (m *Metrics) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface.