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 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 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