analytics

Oct 7, 2024

Changes in this version

+ const ComputeMessageExecutionEventType

+ const CreatedExecutionEventType

+ const DefaultOtelCollectorEndpoint

+ const NodeIDHashKey

+ const NodeInstallationIDKey

+ const NodeInstanceIDKey

+ const NodeTypeKey

+ const NodeVersionKey

+ const ProviderKey

+ const SubmitJobEventType

+ const TerminalExecutionEventType

+ const TerminalJobEventType

+ func EmitEvent(ctx context.Context, event *Event)

+ func SetupAnalyticsProvider(ctx context.Context, opts ...Option) error

+ func ShutdownAnalyticsProvider(ctx context.Context) error

+ type Config struct

+ type Event struct

+ Properties any

+ Type string

+ func NewComputeMessageExecutionEvent(e models.Execution) *Event

+ func NewCreatedExecutionEvent(e models.Execution) *Event

+ func NewEvent(eventType string, properties any) *Event

+ func NewJobTerminalEvent(j models.Job) *Event

+ func NewTerminalExecutionEvent(e models.Execution) *Event

+ func (e *Event) ToLogRecord() (otellog.Record, error)

+ type EventType string

+ type ExecutionComputeMessage struct

+ ComputeErrorCode string

+ ComputeMessage string

+ ExecutionID string

+ JobID string

+ type ExecutionEvent struct

+ ComputeState string

+ ComputeStateErrorCode string

+ CreateTime time.Time

+ DesiredState string

+ DesiredStateErrorCode string

+ EvalID string

+ ExecutionID string

+ FollowupEvalID string

+ JobID string

+ ModifyTime time.Time

+ NameSet bool

+ NamespaceHash string

+ NextExecution string

+ NodeNameHash string

+ PreviousExecution string

+ PublishedResultType string

+ Resources map[string]Resource

+ Revision uint64

+ RunResultExitCode int

+ RunResultStderrTruncated bool

+ RunResultStdoutTruncated bool

+ type GPUInfo struct

+ Name string

+ Vendor string

+ type JobTerminalEvent struct

+ Count int

+ CreateTime time.Time

+ JobID string

+ LabelsCount int

+ MetaCount int

+ ModifyTime time.Time

+ NameSet bool

+ NamespaceHash string

+ Resources Resource

+ Revision uint64

+ State string

+ TaskDomainsCount int

+ TaskEngineType string

+ TaskEnvVarCount int

+ TaskExecutionTimeout int64

+ TaskInputSourceTypes []string

+ TaskMetaCount int

+ TaskNameHash string

+ TaskNetworkType string

+ TaskPublisherType string

+ TaskQueueTimeout int64

+ TaskResultPathCount int

+ TaskTotalTimeout int64

+ Type string

+ Version uint64

+ type Option func(*Config)

+ func WithEndpoint(endpoint string) Option

+ func WithInstallationID(id string) Option

+ func WithInstanceID(id string) Option

+ func WithNodeID(id string) Option

+ func WithNodeType(isRequester, isCompute bool) Option

+ func WithVersion(bv *models.BuildVersionInfo) Option

+ type Resource struct

+ CPUUnits float64

+ DiskBytes uint64

+ GPUCount uint64

+ GPUTypes []GPUInfo

+ MemoryBytes uint64

+ type SubmitJobEvent struct

+ Count int

+ CreateTime time.Time

+ Error string

+ JobID string

+ LabelsCount int

+ MetaCount int

+ ModifyTime time.Time

+ NameSet bool

+ NamespaceHash string

+ Resources Resource

+ Revision uint64

+ TaskDomainsCount int

+ TaskEngineType string

+ TaskEnvVarCount int

+ TaskExecutionTimeout int64

+ TaskInputSourceTypes []string

+ TaskMetaCount int

+ TaskNameHash string

+ TaskNetworkType string

+ TaskPublisherType string

+ TaskQueueTimeout int64

+ TaskResultPathCount int

+ TaskTotalTimeout int64

+ Type string

+ Version uint64

+ Warnings []string

+ func NewSubmitJobEvent(j models.Job, warnings ...string) SubmitJobEvent