/dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/github.com/minio/madmin-go/ |
H A D | api.go | 47 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 D | admin.go | 29 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 D | admin.go | 29 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 D | admin.go | 38 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 D | admin.go | 38 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 D | admin.go | 39 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 D | admin.go | 39 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 D | admin.go | 39 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 D | pqformat.c | 55 * 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 D | admin.go | 36 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 D | admin.go | 38 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 D | admin.go | 38 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 D | admin.go | 38 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 D | admin.go | 38 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 D | admin.go | 38 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 D | admin.go | 50 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 D | admin.go | 50 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 D | admin.go | 50 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 D | admin.go | 50 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 D | admin.go | 50 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 D | admin_client.go | 256 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 D | admin_client.go | 255 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 D | admin_client.go | 255 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 D | admin_client.go | 256 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 D | admin_client.go | 83 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 …]
|