Versions in this module Expand all Collapse all v1 v1.3.0 Oct 7, 2021 Changes in this version + func ZapMethod(s string) zapcore.Field + type CoordinatorClient struct + func NewCoordinatorClient(opts CoordinatorClientOptions) CoordinatorClient + func (c *CoordinatorClient) AddM3msgTopicConsumer(topicOpts resources.M3msgTopicOptions, addRequest admin.TopicAddRequest) (admin.TopicGetResponse, error) + func (c *CoordinatorClient) AddNamespace(addRequest admin.NamespaceAddRequest) (admin.NamespaceGetResponse, error) + func (c *CoordinatorClient) ApplyKVUpdate(update string) error + func (c *CoordinatorClient) CreateDatabase(addRequest admin.DatabaseCreateRequest) (admin.DatabaseCreateResponse, error) + func (c *CoordinatorClient) DeleteNamespace(namespaceID string) error + func (c *CoordinatorClient) GetM3msgTopic(topicOpts resources.M3msgTopicOptions) (admin.TopicGetResponse, error) + func (c *CoordinatorClient) GetNamespace() (admin.NamespaceGetResponse, error) + func (c *CoordinatorClient) GetPlacement(opts resources.PlacementRequestOptions) (admin.PlacementGetResponse, error) + func (c *CoordinatorClient) InitM3msgTopic(topicOpts resources.M3msgTopicOptions, initRequest admin.TopicInitRequest) (admin.TopicGetResponse, error) + func (c *CoordinatorClient) InitPlacement(opts resources.PlacementRequestOptions, initRequest admin.PlacementInitRequest) (admin.PlacementGetResponse, error) + func (c *CoordinatorClient) RunQuery(verifier resources.ResponseVerifier, query string, headers map[string][]string) error + func (c *CoordinatorClient) UpdateNamespace(req admin.NamespaceUpdateRequest) (admin.NamespaceGetResponse, error) + func (c *CoordinatorClient) WaitForInstances(ids []string) error + func (c *CoordinatorClient) WaitForNamespace(name string) error + func (c *CoordinatorClient) WaitForShardsReady() error + func (c *CoordinatorClient) WriteCarbon(url string, metric string, v float64, t time.Time) error + func (c *CoordinatorClient) WriteProm(name string, tags map[string]string, samples []prompb.Sample) error + type CoordinatorClientOptions struct + Client *http.Client + HTTPPort int + Logger *zap.Logger + RetryFunc RetryFunc + type RetryFunc func(op func() error) error