Home
last modified time | relevance | path

Searched defs:AdminClient (Results 1 – 25 of 186) sorted by relevance

12345678

/dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/github.com/minio/madmin-go/
H A Dapi.go47 type AdminClient struct { struct
51 endpointURL *url.URL
54 credsProvider *credentials.Credentials
57 appInfo struct {
63 secure bool
66 httpClient *http.Client
68 random *rand.Rand
71 isTraceEnabled bool
72 traceOutput io.Writer
202 func (adm *AdminClient) TraceOff() {
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/pubsublite/
H A Dadmin.go29 type AdminClient struct { struct
30 admin *vkit.AdminClient
49 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
64 … *AdminClient) UpdateTopic(ctx context.Context, config TopicConfigToUpdate) (*TopicConfig, error) {
73 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic TopicPath) error {
78 func (ac *AdminClient) Topic(ctx context.Context, topic TopicPath) (*TopicConfig, error) {
87 func (ac *AdminClient) TopicPartitions(ctx context.Context, topic TopicPath) (int, error) {
102 func (ac *AdminClient) Topics(ctx context.Context, location LocationPath) *TopicIterator {
133 …nc (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription SubscriptionPath) error {
148 …(ac *AdminClient) Subscriptions(ctx context.Context, location LocationPath) *SubscriptionIterator {
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go29 type AdminClient struct { struct
30 admin *vkit.AdminClient
49 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
64 … *AdminClient) UpdateTopic(ctx context.Context, config TopicConfigToUpdate) (*TopicConfig, error) {
73 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic TopicPath) error {
78 func (ac *AdminClient) Topic(ctx context.Context, topic TopicPath) (*TopicConfig, error) {
87 func (ac *AdminClient) TopicPartitions(ctx context.Context, topic TopicPath) (int, error) {
102 func (ac *AdminClient) Topics(ctx context.Context, location LocationPath) *TopicIterator {
133 …nc (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription SubscriptionPath) error {
148 …(ac *AdminClient) Subscriptions(ctx context.Context, location LocationPath) *SubscriptionIterator {
[all …]
/dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsublite/
H A Dadmin.go38 type AdminClient struct { struct
39 admin *vkit.AdminClient
57 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
93 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
102 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
116 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
130 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
141 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
192 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
216 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go38 type AdminClient struct { struct
39 admin *vkit.AdminClient
57 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
93 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
102 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
116 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
130 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
141 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
192 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
216 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go39 type AdminClient struct { struct
40 admin *vkit.AdminClient
58 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
94 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
103 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
117 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
244 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
316 func (ac *AdminClient) DeleteReservation(ctx context.Context, reservation string) error {
340 func (ac *AdminClient) Reservations(ctx context.Context, parent string) *ReservationIterator {
[all …]
/dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go39 type AdminClient struct { struct
40 admin *vkit.AdminClient
58 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
94 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
103 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
117 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
244 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
316 func (ac *AdminClient) DeleteReservation(ctx context.Context, reservation string) error {
340 func (ac *AdminClient) Reservations(ctx context.Context, parent string) *ReservationIterator {
[all …]
/dports/www/tusd/google-cloud-go-storage-v1.18.2/pubsublite/
H A Dadmin.go39 type AdminClient struct { struct
40 admin *vkit.AdminClient
58 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
94 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
103 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
117 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
244 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
316 func (ac *AdminClient) DeleteReservation(ctx context.Context, reservation string) error {
340 func (ac *AdminClient) Reservations(ctx context.Context, parent string) *ReservationIterator {
[all …]
/dports/databases/postgresql13-client/postgresql-13.5/src/backend/libpq/
H A Dpqformat.c55 * pq_puttextmessage - generate a character set-converted message in one step
56 * pq_putemptymessage - convenience routine for message with empty body
100
110 resetStringInfo(buf);
143 bool countincludesself)
154 pfree(p);
199 int slen = strlen(str);
239 appendStringInfoChar(buf, '\0');
288 }
479 swap.i = pq_getmsgint(msg, 4);
[all …]
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/profiler/google-cloud-go-0.1.0/bigtable/
H A Dadmin.go36 type AdminClient struct { struct
37 conn *grpc.ClientConn
38 tClient btapb.BigtableTableAdminClient
40 project, instance string
43 md metadata.MD
67 func (ac *AdminClient) Close() error {
71 func (ac *AdminClient) instancePrefix() string {
76 func (ac *AdminClient) Tables(ctx context.Context) ([]string, error) {
95 func (ac *AdminClient) CreateTable(ctx context.Context, table string) error {
128 func (ac *AdminClient) DeleteTable(ctx context.Context, table string) error {
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go38 type AdminClient struct { struct
39 admin *vkit.AdminClient
57 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
93 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
102 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
116 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
130 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
141 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
243 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
267 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go38 type AdminClient struct { struct
39 admin *vkit.AdminClient
57 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
93 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
102 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
116 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
130 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
141 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
243 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
267 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go38 type AdminClient struct { struct
39 admin *vkit.AdminClient
57 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
93 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
102 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
116 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
130 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
141 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
243 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
267 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go38 type AdminClient struct { struct
39 admin *vkit.AdminClient
57 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
93 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
102 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
116 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
130 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
141 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
243 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
267 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go38 type AdminClient struct { struct
39 admin *vkit.AdminClient
57 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
93 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
102 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
116 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
130 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
141 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
243 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
267 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go50 type AdminClient struct { struct
51 admin *vkit.AdminClient
69 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
105 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
114 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
128 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
153 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
236 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
260 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go50 type AdminClient struct { struct
51 admin *vkit.AdminClient
69 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
105 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
114 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
128 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
153 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
236 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
260 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go50 type AdminClient struct { struct
51 admin *vkit.AdminClient
69 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
105 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
114 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
128 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
153 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
236 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
260 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsublite/
H A Dadmin.go50 type AdminClient struct { struct
51 admin *vkit.AdminClient
69 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
105 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
114 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
128 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
153 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
236 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
260 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsublite/
H A Dadmin.go50 type AdminClient struct { struct
51 admin *vkit.AdminClient
69 func (ac *AdminClient) CreateTopic(ctx context.Context, config TopicConfig) (*TopicConfig, error) {
105 func (ac *AdminClient) DeleteTopic(ctx context.Context, topic string) error {
114 func (ac *AdminClient) Topic(ctx context.Context, topic string) (*TopicConfig, error) {
128 func (ac *AdminClient) TopicPartitionCount(ctx context.Context, topic string) (int, error) {
142 …(ac *AdminClient) TopicSubscriptions(ctx context.Context, topic string) *SubscriptionPathIterator {
153 func (ac *AdminClient) Topics(ctx context.Context, parent string) *TopicIterator {
236 func (ac *AdminClient) DeleteSubscription(ctx context.Context, subscription string) error {
260 func (ac *AdminClient) Subscriptions(ctx context.Context, parent string) *SubscriptionIterator {
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/apiv1/
H A Dadmin_client.go256 type AdminClient struct { struct
258 connPool gtransport.ConnPool
261 disableDeadlines bool
264 adminClient pubsublitepb.AdminServiceClient
267 CallOptions *AdminCallOptions
270 xGoogMetadata metadata.MD
312 func (c *AdminClient) Connection() *grpc.ClientConn {
318 func (c *AdminClient) Close() error {
325 func (c *AdminClient) setGoogleClientInfo(keyval ...string) {
398 …(ctx context.Context, req *pubsublitepb.ListTopicsRequest, opts ...gax.CallOption) *TopicIterator {
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/pubsublite/apiv1/
H A Dadmin_client.go255 type AdminClient struct { struct
257 connPool gtransport.ConnPool
260 disableDeadlines bool
263 adminClient pubsublitepb.AdminServiceClient
266 CallOptions *AdminCallOptions
269 xGoogMetadata metadata.MD
311 func (c *AdminClient) Connection() *grpc.ClientConn {
317 func (c *AdminClient) Close() error {
324 func (c *AdminClient) setGoogleClientInfo(keyval ...string) {
397 …(ctx context.Context, req *pubsublitepb.ListTopicsRequest, opts ...gax.CallOption) *TopicIterator {
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/cloud.google.com/go/pubsublite/apiv1/
H A Dadmin_client.go255 type AdminClient struct { struct
257 connPool gtransport.ConnPool
260 disableDeadlines bool
263 adminClient pubsublitepb.AdminServiceClient
266 CallOptions *AdminCallOptions
269 xGoogMetadata metadata.MD
311 func (c *AdminClient) Connection() *grpc.ClientConn {
317 func (c *AdminClient) Close() error {
324 func (c *AdminClient) setGoogleClientInfo(keyval ...string) {
397 …(ctx context.Context, req *pubsublitepb.ListTopicsRequest, opts ...gax.CallOption) *TopicIterator {
[all …]
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/apiv1/
H A Dadmin_client.go256 type AdminClient struct { struct
258 connPool gtransport.ConnPool
261 disableDeadlines bool
264 adminClient pubsublitepb.AdminServiceClient
267 CallOptions *AdminCallOptions
270 xGoogMetadata metadata.MD
312 func (c *AdminClient) Connection() *grpc.ClientConn {
318 func (c *AdminClient) Close() error {
325 func (c *AdminClient) setGoogleClientInfo(keyval ...string) {
398 …(ctx context.Context, req *pubsublitepb.ListTopicsRequest, opts ...gax.CallOption) *TopicIterator {
[all …]
/dports/sysutils/gomplate/google-cloud-go-storage-v1.12.0/pubsublite/apiv1/
H A Dadmin_client.go83 type AdminClient struct { struct
85 connPool gtransport.ConnPool
88 disableDeadlines bool
91 adminClient pubsublitepb.AdminServiceClient
94 CallOptions *AdminCallOptions
97 xGoogMetadata metadata.MD
139 func (c *AdminClient) Connection() *grpc.ClientConn {
145 func (c *AdminClient) Close() error {
152 func (c *AdminClient) setGoogleClientInfo(keyval ...string) {
210 …(ctx context.Context, req *pubsublitepb.ListTopicsRequest, opts ...gax.CallOption) *TopicIterator {
[all …]

12345678