Documentation
¶
Index ¶
- func InitMetrics() error
- func RecordConcurrencyInflight(key string, count int64)
- func RecordConcurrencyPending(key string, count int64)
- func RecordConcurrencyThrottled(key string)
- func RecordJobsBulkDeletedCount()
- func RecordJobsCreatedFailedCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsDeletedCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsFailedCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsScheduledCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsTriggeredCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsUndeliveredCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordPlacementDissemination(namespace string)
- func RecordPlacementDisseminationLatency(namespace string, elapsed time.Duration)
- func RecordPlacementIncapableSidecars(current int64)
- func RecordPlacementLeaderStatus(leader bool)
- func RecordPlacementStreamsConnected(namespace string, delta int64)
- func RecordPlacementTableUpdate(namespace, actorType string)
- func RecordSidecarAuthError()
- func RecordSidecarRecvError()
- func RecordSidecarSendError()
- func RecordSidecarsConnectedCount(change int)
- func RecordTriggerDuration(jobMetadata *schedulerv1pb.JobMetadata, duration time.Duration)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RecordConcurrencyInflight ¶ added in v1.18.0
RecordConcurrencyInflight records the current in-flight count for a concurrency gate on this scheduler instance.
func RecordConcurrencyPending ¶ added in v1.18.0
RecordConcurrencyPending records the current pending count for a concurrency gate on this scheduler instance.
func RecordConcurrencyThrottled ¶ added in v1.18.0
func RecordConcurrencyThrottled(key string)
RecordConcurrencyThrottled records that a trigger was throttled by a concurrency gate.
func RecordJobsBulkDeletedCount ¶ added in v1.18.0
func RecordJobsBulkDeletedCount()
RecordJobsBulkDeletedCount records a bulk job deletion operation.
func RecordJobsCreatedFailedCount ¶ added in v1.18.0
func RecordJobsCreatedFailedCount(jobMetadata *schedulerv1pb.JobMetadata)
RecordJobsCreatedFailedCount records a failed job creation attempt.
func RecordJobsDeletedCount ¶ added in v1.18.0
func RecordJobsDeletedCount(jobMetadata *schedulerv1pb.JobMetadata)
RecordJobsDeletedCount records the number of jobs deleted from the scheduler service.
func RecordJobsFailedCount ¶ added in v1.16.0
func RecordJobsFailedCount(jobMetadata *schedulerv1pb.JobMetadata)
RecordJobsFailed records the total number of failed jobs
func RecordJobsScheduledCount ¶
func RecordJobsScheduledCount(jobMetadata *schedulerv1pb.JobMetadata)
RecordJobsScheduledCount records the number of jobs scheduled to the scheduler service
func RecordJobsTriggeredCount ¶
func RecordJobsTriggeredCount(jobMetadata *schedulerv1pb.JobMetadata)
RecordJobsTriggeredCount records the total number of jobs successfully triggered from the scheduler service
func RecordJobsUndeliveredCount ¶ added in v1.16.0
func RecordJobsUndeliveredCount(jobMetadata *schedulerv1pb.JobMetadata)
RecordJobsUndelivered records the total number of undelivered jobs
func RecordPlacementDissemination ¶ added in v1.19.0
func RecordPlacementDissemination(namespace string)
RecordPlacementDissemination records a placement dissemination round starting for the given namespace.
func RecordPlacementDisseminationLatency ¶ added in v1.19.0
RecordPlacementDisseminationLatency records the duration of a completed placement dissemination round for the given namespace.
func RecordPlacementIncapableSidecars ¶ added in v1.19.0
func RecordPlacementIncapableSidecars(current int64)
RecordPlacementIncapableSidecars records the current number of connected sidecars which cannot use scheduler placement.
func RecordPlacementLeaderStatus ¶ added in v1.19.0
func RecordPlacementLeaderStatus(leader bool)
RecordPlacementLeaderStatus records whether this scheduler is the current placement leader.
func RecordPlacementStreamsConnected ¶ added in v1.19.0
RecordPlacementStreamsConnected records a daprd placement stream connecting (+1) or disconnecting (-1) for the given namespace.
func RecordPlacementTableUpdate ¶ added in v1.19.0
func RecordPlacementTableUpdate(namespace, actorType string)
RecordPlacementTableUpdate records a per actor type placement table rebuild being disseminated.
func RecordSidecarAuthError ¶ added in v1.18.0
func RecordSidecarAuthError()
RecordSidecarAuthError records a sidecar authorization error.
func RecordSidecarRecvError ¶ added in v1.18.0
func RecordSidecarRecvError()
RecordSidecarRecvError records a sidecar stream receive error.
func RecordSidecarSendError ¶ added in v1.18.0
func RecordSidecarSendError()
RecordSidecarSendError records a sidecar stream send error.
func RecordSidecarsConnectedCount ¶
func RecordSidecarsConnectedCount(change int)
RecordSidecarsConnectedCount records the number of dapr sidecars connected to the scheduler service
func RecordTriggerDuration ¶
func RecordTriggerDuration(jobMetadata *schedulerv1pb.JobMetadata, duration time.Duration)
RecordTriggerDuration records the time it takes to send the job to dapr from the scheduler service
Types ¶
This section is empty.
Source Files