coordinator

Documentation

Index

• type EventHub
  • func NewEventHub(l log.FieldLogger) (*EventHub, error)
  • func (h *EventHub) Close()
  • func (h *EventHub) PublishExperimentEvent(source string, event ExperimentEventMsg)
  • func (h *EventHub) PublishModelEvent(source string, event ModelEventMsg)
  • func (h *EventHub) PublishPipelineEvent(source string, event PipelineEventMsg)
  • func (h *EventHub) RegisterExperimentEventHandler(name string, queueSize int, logger log.FieldLogger, ...)
  • func (h *EventHub) RegisterModelEventHandler(name string, queueSize int, logger log.FieldLogger, ...)
  • func (h *EventHub) RegisterPipelineEventHandler(name string, queueSize int, logger log.FieldLogger, ...)
• type ExperimentEventMsg
  • func (e ExperimentEventMsg) String() string
• type ExperimentEventStatus
• type KubernetesMeta
• type ModelEventMsg
  • func (m ModelEventMsg) String() string
• type PipelineEventMsg
  • func (p PipelineEventMsg) String() string
• type SequenceGenerator
  • func (g *SequenceGenerator) Generate() string

Types

type EventHub

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

func NewEventHub

func NewEventHub(l log.FieldLogger) (*EventHub, error)

NewEventHub creates a new EventHub with topics pre-registered. The logger l does not need fields preset.

func (*EventHub) Close

func (h *EventHub) Close()

func (*EventHub) PublishExperimentEvent

func (h *EventHub) PublishExperimentEvent(source string, event ExperimentEventMsg)

func (*EventHub) PublishModelEvent

func (h *EventHub) PublishModelEvent(source string, event ModelEventMsg)

func (*EventHub) PublishPipelineEvent

func (h *EventHub) PublishPipelineEvent(source string, event PipelineEventMsg)

func (*EventHub) RegisterExperimentEventHandler

func (h *EventHub) RegisterExperimentEventHandler(
	name string,
	queueSize int,
	logger log.FieldLogger,
	handle func(event ExperimentEventMsg),
)

func (*EventHub) RegisterModelEventHandler

func (h *EventHub) RegisterModelEventHandler(
	name string,
	queueSize int,
	logger log.FieldLogger,
	handle func(event ModelEventMsg),
)

func (*EventHub) RegisterPipelineEventHandler

func (h *EventHub) RegisterPipelineEventHandler(
	name string,
	queueSize int,
	logger log.FieldLogger,
	handle func(event PipelineEventMsg),
)

type ExperimentEventMsg

type ExperimentEventMsg struct {
	ExperimentName    string
	UpdatedExperiment bool
	Status            *ExperimentEventStatus
	KubernetesMeta    *KubernetesMeta
}

func (ExperimentEventMsg) String

func (e ExperimentEventMsg) String() string

type ExperimentEventStatus

type ExperimentEventStatus struct {
	Active            bool
	CandidatesReady   bool
	MirrorReady       bool
	StatusDescription string
}

type KubernetesMeta

type KubernetesMeta struct {
	Namespace  string
	Generation int64
}

type ModelEventMsg

type ModelEventMsg struct {
	ModelName    string
	ModelVersion uint32
}

func (ModelEventMsg) String

func (m ModelEventMsg) String() string

type PipelineEventMsg

type PipelineEventMsg struct {
	PipelineName      string
	PipelineVersion   uint32
	UID               string
	ExperimentUpdate  bool
	ModelStatusChange bool
}

func (PipelineEventMsg) String

func (p PipelineEventMsg) String() string

type SequenceGenerator

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

func (*SequenceGenerator) Generate

func (g *SequenceGenerator) Generate() string