SchedulerClient is the client API for Scheduler service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
| 33 | // |
| 34 | // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. |
| 35 | type SchedulerClient interface { |
| 36 | // ScheduleJob is used by the daprd sidecar to schedule a job. |
| 37 | ScheduleJob(ctx context.Context, in *ScheduleJobRequest, opts ...grpc.CallOption) (*ScheduleJobResponse, error) |
| 38 | // Get a job |
| 39 | GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error) |
| 40 | // DeleteJob is used by the daprd sidecar to delete a job. |
| 41 | DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error) |
| 42 | // WatchJobs is used by the daprd sidecar to connect to the Scheduler |
| 43 | // service to watch for jobs triggering back. |
| 44 | WatchJobs(ctx context.Context, opts ...grpc.CallOption) (Scheduler_WatchJobsClient, error) |
| 45 | // ListJobs is used by the daprd sidecar to list all jobs. |
| 46 | ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) |
| 47 | // WatchHosts is used by the daprd sidecar to retrieve the list of active |
| 48 | // scheduler hosts so that it can connect to each. Receives an updated list |
| 49 | // on leadership changes. |
| 50 | WatchHosts(ctx context.Context, in *WatchHostsRequest, opts ...grpc.CallOption) (Scheduler_WatchHostsClient, error) |
| 51 | // DeleteByMetadata is used by the daprd sidecar to delete jobs by a metadata |
| 52 | // target. |
| 53 | DeleteByMetadata(ctx context.Context, in *DeleteByMetadataRequest, opts ...grpc.CallOption) (*DeleteByMetadataResponse, error) |
| 54 | // DeleteByNamePrefix is used by the daprd sidecar to delete jobs by name |
| 55 | // prefix. An empty prefix deletes all jobs from the target. |
| 56 | DeleteByNamePrefix(ctx context.Context, in *DeleteByNamePrefixRequest, opts ...grpc.CallOption) (*DeleteByNamePrefixResponse, error) |
| 57 | } |
| 58 | |
| 59 | type schedulerClient struct { |
| 60 | cc grpc.ClientConnInterface |
no outgoing calls
no test coverage detected