resources

Jan 21, 2021

Changes in this version

type Coordinator

+ WriteProm func(name string, tags map[string]string, samples []prompb.Sample) error

+ type ResponseVerifier func(int, map[string][]string, string, error) error

+ type SetupOptions func(*setupOptions)

+ func WithCoordinatorImage(name, tag string) SetupOptions

+ func WithDBNodeImage(name, tag string) SetupOptions

+ func WithExistingCluster(dbNodeContainerName, coordinatorContainerName string) SetupOptions

Jun 12, 2020

Changes in this version

+ const AggName

+ const ColdWriteNsName

+ const UnaggName

+ type Admin interface

+ AddNamespace func(admin.NamespaceAddRequest) (admin.NamespaceGetResponse, error)

+ Close func() error

+ CreateDatabase func(admin.DatabaseCreateRequest) (admin.DatabaseCreateResponse, error)

+ GetNamespace func() (admin.NamespaceGetResponse, error)

+ GetPlacement func() (admin.PlacementGetResponse, error)

+ WaitForInstances func(ids []string) error

+ WaitForNamespace func(name string) error

+ type Coordinator interface

+ RunQuery func(verifier GoalStateVerifier, query string) error

+ WriteCarbon func(port int, metric string, v float64, t time.Time) error

+ type DockerResources interface

+ Cleanup func() error

+ Coordinator func() Coordinator

+ Nodes func() Nodes

+ func SetupSingleM3DBNode() (DockerResources, error)

+ type GoalStateVerifier func(string, error) error

+ type Node interface

+ Close func() error

+ Exec func(commands ...string) (string, error)

+ Fetch func(req *rpc.FetchRequest) (*rpc.FetchResult_, error)

+ GoalStateExec func(verifier GoalStateVerifier, commands ...string) error

+ Health func() (*rpc.NodeHealthResult_, error)

+ HostDetails func(port int) (*admin.Host, error)

+ Restart func() error

+ WaitForBootstrap func() error

+ WritePoint func(req *rpc.WriteRequest) error

+ type Nodes []Node