| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 4e4eb43 commit 335b09f
16 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -96,6 +96,51 @@ | |||
| 96 | 96 | ] | |
| 97 | 97 | } | |
| 98 | 98 | } | |
| 99 | + }, | ||
| 100 | + "rest": { | ||
| 101 | + "libraryClient": "CloudSchedulerClient", | ||
| 102 | + "rpcs": { | ||
| 103 | + "CreateJob": { | ||
| 104 | + "methods": [ | ||
| 105 | + "create_job" | ||
| 106 | + ] | ||
| 107 | + }, | ||
| 108 | + "DeleteJob": { | ||
| 109 | + "methods": [ | ||
| 110 | + "delete_job" | ||
| 111 | + ] | ||
| 112 | + }, | ||
| 113 | + "GetJob": { | ||
| 114 | + "methods": [ | ||
| 115 | + "get_job" | ||
| 116 | + ] | ||
| 117 | + }, | ||
| 118 | + "ListJobs": { | ||
| 119 | + "methods": [ | ||
| 120 | + "list_jobs" | ||
| 121 | + ] | ||
| 122 | + }, | ||
| 123 | + "PauseJob": { | ||
| 124 | + "methods": [ | ||
| 125 | + "pause_job" | ||
| 126 | + ] | ||
| 127 | + }, | ||
| 128 | + "ResumeJob": { | ||
| 129 | + "methods": [ | ||
| 130 | + "resume_job" | ||
| 131 | + ] | ||
| 132 | + }, | ||
| 133 | + "RunJob": { | ||
| 134 | + "methods": [ | ||
| 135 | + "run_job" | ||
| 136 | + ] | ||
| 137 | + }, | ||
| 138 | + "UpdateJob": { | ||
| 139 | + "methods": [ | ||
| 140 | + "update_job" | ||
| 141 | + ] | ||
| 142 | + } | ||
| 143 | + } | ||
| 99 | 144 | } | |
| 100 | 145 | } | |
| 101 | 146 | } | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -60,6 +60,7 @@ | |||
| 60 | 60 | from .transports.base import DEFAULT_CLIENT_INFO, CloudSchedulerTransport | |
| 61 | 61 | from .transports.grpc import CloudSchedulerGrpcTransport | |
| 62 | 62 | from .transports.grpc_asyncio import CloudSchedulerGrpcAsyncIOTransport | |
| 63 | + from .transports.rest import CloudSchedulerRestTransport | ||
| 63 | 64 | ||
| 64 | 65 | ||
| 65 | 66 | class CloudSchedulerClientMeta(type): | |
@@ -75,6 +76,7 @@ class CloudSchedulerClientMeta(type): | |||
| 75 | 76 | ) # type: Dict[str, Type[CloudSchedulerTransport]] | |
| 76 | 77 | _transport_registry["grpc"] = CloudSchedulerGrpcTransport | |
| 77 | 78 | _transport_registry["grpc_asyncio"] = CloudSchedulerGrpcAsyncIOTransport | |
| 79 | + _transport_registry["rest"] = CloudSchedulerRestTransport | ||
| 78 | 80 | ||
| 79 | 81 | def get_transport_class( | |
| 80 | 82 | cls, | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -19,14 +19,18 @@ | |||
| 19 | 19 | from .base import CloudSchedulerTransport | |
| 20 | 20 | from .grpc import CloudSchedulerGrpcTransport | |
| 21 | 21 | from .grpc_asyncio import CloudSchedulerGrpcAsyncIOTransport | |
| 22 | + from .rest import CloudSchedulerRestInterceptor, CloudSchedulerRestTransport | ||
| 22 | 23 | ||
| 23 | 24 | # Compile a registry of transports. | |
| 24 | 25 | _transport_registry = OrderedDict() # type: Dict[str, Type[CloudSchedulerTransport]] | |
| 25 | 26 | _transport_registry["grpc"] = CloudSchedulerGrpcTransport | |
| 26 | 27 | _transport_registry["grpc_asyncio"] = CloudSchedulerGrpcAsyncIOTransport | |
| 28 | + _transport_registry["rest"] = CloudSchedulerRestTransport | ||
| 27 | 29 | ||
| 28 | 30 | __all__ = ( | |
| 29 | 31 | "CloudSchedulerTransport", | |
| 30 | 32 | "CloudSchedulerGrpcTransport", | |
| 31 | 33 | "CloudSchedulerGrpcAsyncIOTransport", | |
| 34 | + "CloudSchedulerRestTransport", | ||
| 35 | + "CloudSchedulerRestInterceptor", | ||
| 32 | 36 | ) | |
| Back | FazBrowse Home | New Git URL |
0 commit comments