MCPcopy
hub / github.com/dapr/dapr / schedulerClient

Struct schedulerClient

pkg/proto/scheduler/v1/schedulerconnect/scheduler.connect.go:144–153  ·  view source on GitHub ↗

schedulerClient implements SchedulerClient.

Source from the content-addressed store, hash-verified

142
143// schedulerClient implements SchedulerClient.
144type schedulerClient struct {
145 scheduleJob *connect.Client[v1.ScheduleJobRequest, v1.ScheduleJobResponse]
146 getJob *connect.Client[v1.GetJobRequest, v1.GetJobResponse]
147 deleteJob *connect.Client[v1.DeleteJobRequest, v1.DeleteJobResponse]
148 watchJobs *connect.Client[v1.WatchJobsRequest, v1.WatchJobsResponse]
149 listJobs *connect.Client[v1.ListJobsRequest, v1.ListJobsResponse]
150 watchHosts *connect.Client[v1.WatchHostsRequest, v1.WatchHostsResponse]
151 deleteByMetadata *connect.Client[v1.DeleteByMetadataRequest, v1.DeleteByMetadataResponse]
152 deleteByNamePrefix *connect.Client[v1.DeleteByNamePrefixRequest, v1.DeleteByNamePrefixResponse]
153}
154
155// ScheduleJob calls dapr.proto.scheduler.v1.Scheduler.ScheduleJob.
156func (c *schedulerClient) ScheduleJob(ctx context.Context, req *connect.Request[v1.ScheduleJobRequest]) (*connect.Response[v1.ScheduleJobResponse], error) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected