models

Documentation

Index

• Constants
• Variables
• type AlgorithmRequest
• type CheckpointedRequest
  • func FromAlgorithmRequest(requestId string, algorithmName string, request *AlgorithmRequest, ...) (*CheckpointedRequest, []byte, error)
  • func (c *CheckpointedRequest) DeepCopy() *CheckpointedRequest
  • func (cr *CheckpointedRequest) ToCqlModel() *CheckpointedRequestCqlModel
  • func (c *CheckpointedRequest) ToV1Job() batchv1.Job
• type CheckpointedRequestCqlModel
• type ParentAlgorithmRequest
• type ParentJobReference
• type SubmissionBufferEntry
  • func FromCheckpoint(checkpoint *CheckpointedRequest) *SubmissionBufferEntry
  • func (sbe *SubmissionBufferEntry) SubmissionTemplate() (*batchv1.Job, error)

Constants

const (
	LifecyclestageNew              = "NEW"
	LifecyclestageBuffered         = "BUFFERED"
	LifecyclestageRunning          = "RUNNING"
	LifecyclestageCompleted        = "COMPLETED"
	LifecyclestageFailed           = "FAILED"
	LifecyclestageScheduleTimeout  = "SCHEDULING_TIMEOUT"
	LifecyclestageDeadlineExceeded = "DEADLINE_EXCEEDED"
	LifecyclestageCancelled        = "CANCELLED"
)

Variables

var CheckpointedRequestTable = table.New(table.Metadata{
	Name: "nexus.checkpoints",
	Columns: []string{
		"algorithm",
		"id",
		"lifecycle_stage",
		"payload_uri",
		"result_uri",
		"algorithm_failure_code",
		"algorithm_failure_cause",
		"algorithm_failure_details",
		"received_by_host",
		"received_at",
		"sent_at",
		"applied_configuration",
		"configuration_overrides",
		"monitoring_metadata",
		"content_hash",
		"last_modified",
		"tag",
		"api_version",
		"parent_job",
	},
	PartKey: []string{
		"algorithm",
		"id",
	},
	SortKey: []string{},
})

var SubmissionBufferTable = table.New(table.Metadata{
	Name: "nexus.submission_buffer",
	Columns: []string{
		"algorithm",
		"id",
		"template",
	},
	PartKey: []string{
		"algorithm",
		"id",
	},
	SortKey: []string{},
})

Types

type AlgorithmRequest

type AlgorithmRequest struct {
	AlgorithmParameters map[string]interface{}          `json:"algorithmParameters" binding:"required"`
	CustomConfiguration v1.MachineLearningAlgorithmSpec `json:"customConfiguration,omitempty"`
	MonitoringMetadata  map[string][]string             `json:"monitoringMetadata,omitempty"`
	RequestApiVersion   string                          `json:"requestApiVersion,omitempty"`
	Tag                 string                          `json:"tag,omitempty"`
	ParentRequest       *ParentAlgorithmRequest         `json:"parentRequest,omitempty"`
}

type CheckpointedRequest

type CheckpointedRequest struct {
	Algorithm               string                          `json:"algorithm"`
	Id                      string                          `json:"id"`
	LifecycleStage          string                          `json:"lifecycle_stage"`
	PayloadUri              string                          `json:"payload_uri"`
	ResultUri               string                          `json:"result_uri"`
	AlgorithmFailureCode    string                          `json:"algorithm_failure_code"`
	AlgorithmFailureCause   string                          `json:"algorithm_failure_cause"`
	AlgorithmFailureDetails string                          `json:"algorithm_failure_details"`
	ReceivedByHost          string                          `json:"received_by_host"`
	ReceivedAt              time.Time                       `json:"received_at"`
	SentAt                  time.Time                       `json:"sent_at"`
	AppliedConfiguration    v1.MachineLearningAlgorithmSpec `json:"applied_configuration"`
	ConfigurationOverrides  v1.MachineLearningAlgorithmSpec `json:"configuration_overrides"`
	MonitoringMetadata      map[string][]string             `json:"monitoring_metadata"`
	ContentHash             string                          `json:"content_hash"`
	LastModified            time.Time                       `json:"last_modified"`
	Tag                     string                          `json:"tag"`
	ApiVersion              string                          `json:"api_version"`
	JobUid                  string                          `json:"job_uid"`
	ParentJob               ParentJobReference              `json:"parent_job"`
}

func FromAlgorithmRequest

func FromAlgorithmRequest(requestId string, algorithmName string, request *AlgorithmRequest, config *v1.MachineLearningAlgorithmSpec) (*CheckpointedRequest, []byte, error)

func (*CheckpointedRequest) DeepCopy

func (c *CheckpointedRequest) DeepCopy() *CheckpointedRequest

func (*CheckpointedRequest) ToCqlModel

func (cr *CheckpointedRequest) ToCqlModel() *CheckpointedRequestCqlModel

func (*CheckpointedRequest) ToV1Job

func (c *CheckpointedRequest) ToV1Job() batchv1.Job

type CheckpointedRequestCqlModel

type CheckpointedRequestCqlModel struct {
	Algorithm               string
	Id                      string
	LifecycleStage          string
	PayloadUri              string
	ResultUri               string
	AlgorithmFailureCode    string
	AlgorithmFailureCause   string
	AlgorithmFailureDetails string
	ReceivedByHost          string
	ReceivedAt              time.Time
	SentAt                  time.Time
	AppliedConfiguration    string
	ConfigurationOverrides  string
	MonitoringMetadata      map[string][]string
	ContentHash             string
	LastModified            time.Time
	Tag                     string
	ApiVersion              string
	JobUid                  string
	ParentJob               string
}

type ParentAlgorithmRequest

type ParentAlgorithmRequest struct {
	RequestId     string `json:"requestId" binding:"required"`
	AlgorithmName string `json:"algorithmName" binding:"required"`
}

type ParentJobReference

type ParentJobReference struct{}

type SubmissionBufferEntry

type SubmissionBufferEntry struct {
	Algorithm string `json:"algorithm"`
	Id        string `json:"id"`
	Template  string `json:"template,omitempty"`
}

func FromCheckpoint

func FromCheckpoint(checkpoint *CheckpointedRequest) *SubmissionBufferEntry

func (*SubmissionBufferEntry) SubmissionTemplate

func (sbe *SubmissionBufferEntry) SubmissionTemplate() (*batchv1.Job, error)

SubmissionTemplate returns a Kubernetes Job object generated for the algorithm request