Documentation
¶
Index ¶
- func InitMetrics() error
- func RecordJobsFailedCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsScheduledCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsTriggeredCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordJobsUndeliveredCount(jobMetadata *schedulerv1pb.JobMetadata)
- func RecordSidecarsConnectedCount(change int)
- func RecordTriggerDuration(jobMetadata *schedulerv1pb.JobMetadata, duration time.Duration)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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
Click to show internal directories.
Click to hide internal directories.