inprocess

package

Go to main page

Versions in this module

v1

v1.6.0

Sep 25, 2026

Changes in this version

type AggregatorOptions

+ EtcdEndpoints []string

type ResourceOptions

+ Etcd *dockerexternal.EtcdNode

v1.5.0

Apr 7, 2022

v1.4.2

Jan 18, 2022

Changes in this version

+ func ConfigurePlacementsForAggregation(nodes resources.Nodes, coord resources.Coordinator, aggs resources.Aggregators, ...) error

type Aggregator

+ func (a *Aggregator) Configuration() config.Configuration

+ type AggregatorStartFn func(cfg *aggcfg.Configuration) (chan<- error, <-chan struct{})

type Coordinator

+ func (c *Coordinator) Configuration() config.Configuration

+ func (c *Coordinator) InstantQueryWithEngine(req resources.QueryRequest, engine options.QueryEngine, ...) (model.Vector, error)

+ func (c *Coordinator) RangeQueryWithEngine(req resources.RangeQueryRequest, engine options.QueryEngine, ...) (model.Matrix, error)

+ func (c *Coordinator) Start()

+ func (c *Coordinator) WritePromWithRequest(writeRequest prompb.WriteRequest, headers resources.Headers) error

type CoordinatorOptions

+ Start bool

+ type CoordinatorStartFn func(cfg *coordcfg.Configuration) (chan<- error, <-chan struct{})

type DBNode

+ func (d *DBNode) Configuration() config.Configuration

+ func (d *DBNode) Start()

type DBNodeOptions

+ Start bool

+ type DBNodeStartFn func(cfg *dbnodecfg.Configuration) (chan<- error, <-chan struct{})

v1.4.1

Nov 20, 2021

v1.4.0

Nov 19, 2021

Changes in this version

+ func GenerateAggregatorConfigsForCluster(configs ClusterConfigs, opts *resources.AggregatorClusterOptions) ([]aggcfg.Configuration, error)

+ func NewAggregatorFromYAML(yamlCfg string, opts AggregatorOptions) (resources.Aggregator, error)

+ func NewClusterFromSpecification(specs ClusterSpecification, opts resources.ClusterOptions) (resources.M3Resources, error)

+ type Aggregator struct

+ func (a *Aggregator) Close() error

+ func (a *Aggregator) HostDetails() (*resources.InstanceInfo, error)

+ func (a *Aggregator) IsHealthy() error

+ func (a *Aggregator) Resign() error

+ func (a *Aggregator) Start()

+ func (a *Aggregator) Status() (m3agg.RuntimeStatus, error)

type AggregatorOptions

+ GenerateHostID bool

+ GeneratePorts bool

+ Start bool

+ StartFn StartFn

+ type ClusterConfigs struct

+ Aggregator *aggcfg.Configuration

+ Coordinator coordinatorcfg.Configuration

+ DBNode dbcfg.Configuration

+ func NewClusterConfigsFromConfigFile(pathToDBNodeCfg string, pathToCoordCfg string, pathToAggCfg string) (ClusterConfigs, error)

+ func NewClusterConfigsFromYAML(dbnodeYaml string, coordYaml string, aggYaml string) (ClusterConfigs, error)

+ type ClusterSpecification struct

+ Configs PerInstanceConfigs

+ Options PerInstanceOptions

+ func GenerateClusterSpecification(configs ClusterConfigs, opts resources.ClusterOptions) (ClusterSpecification, error)

+ type Coordinator struct

+ func (c *Coordinator) AddM3msgTopicConsumer(opts resources.M3msgTopicOptions, req admin.TopicAddRequest) (admin.TopicGetResponse, error)

+ func (c *Coordinator) AddNamespace(request admin.NamespaceAddRequest) (admin.NamespaceGetResponse, error)

+ func (c *Coordinator) ApplyKVUpdate(update string) error

+ func (c *Coordinator) Close() error

+ func (c *Coordinator) CreateDatabase(request admin.DatabaseCreateRequest) (admin.DatabaseCreateResponse, error)

+ func (c *Coordinator) DeleteAllPlacements(opts resources.PlacementRequestOptions) error

+ func (c *Coordinator) DeleteNamespace(namespaceID string) error

+ func (c *Coordinator) GetM3msgTopic(opts resources.M3msgTopicOptions) (admin.TopicGetResponse, error)

+ func (c *Coordinator) GetNamespace() (admin.NamespaceGetResponse, error)

+ func (c *Coordinator) GetPlacement(opts resources.PlacementRequestOptions) (admin.PlacementGetResponse, error)

+ func (c *Coordinator) GraphiteQuery(req resources.GraphiteQueryRequest) ([]resources.Datapoint, error)

+ func (c *Coordinator) HostDetails() (*resources.InstanceInfo, error)

+ func (c *Coordinator) InitM3msgTopic(opts resources.M3msgTopicOptions, req admin.TopicInitRequest) (admin.TopicGetResponse, error)

+ func (c *Coordinator) InitPlacement(opts resources.PlacementRequestOptions, req admin.PlacementInitRequest) (admin.PlacementGetResponse, error)

+ func (c *Coordinator) InstantQuery(req resources.QueryRequest, headers resources.Headers) (model.Vector, error)

+ func (c *Coordinator) LabelNames(req resources.LabelNamesRequest, headers resources.Headers) (model.LabelNames, error)

+ func (c *Coordinator) LabelValues(req resources.LabelValuesRequest, headers resources.Headers) (model.LabelValues, error)

+ func (c *Coordinator) RangeQuery(req resources.RangeQueryRequest, headers resources.Headers) (model.Matrix, error)

+ func (c *Coordinator) RunQuery(verifier resources.ResponseVerifier, query string, headers resources.Headers) error

+ func (c *Coordinator) Series(req resources.SeriesRequest, headers resources.Headers) ([]model.Metric, error)

+ func (c *Coordinator) UpdateNamespace(request admin.NamespaceUpdateRequest) (admin.NamespaceGetResponse, error)

+ func (c *Coordinator) WaitForClusterReady() error

+ func (c *Coordinator) WaitForInstances(ids []string) error

+ func (c *Coordinator) WaitForNamespace(name string) error

+ func (c *Coordinator) WaitForShardsReady() error

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

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

type CoordinatorOptions

+ StartFn StartFn

+ type DBNode struct

+ func (d *DBNode) AggregateTiles(req *rpc.AggregateTilesRequest) (int64, error)

+ func (d *DBNode) Close() error

+ func (d *DBNode) Exec(commands ...string) (string, error)

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

+ func (d *DBNode) FetchTagged(req *rpc.FetchTaggedRequest) (*rpc.FetchTaggedResult_, error)

+ func (d *DBNode) GoalStateExec(verifier resources.GoalStateVerifier, commands ...string) error

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

+ func (d *DBNode) HostDetails(_ int) (*admin.Host, error)

+ func (d *DBNode) Restart() error

+ func (d *DBNode) WaitForBootstrap() error

+ func (d *DBNode) WritePoint(req *rpc.WriteRequest) error

+ func (d *DBNode) WriteTaggedBatchRaw(req *rpc.WriteTaggedBatchRawRequest) error

+ func (d *DBNode) WriteTaggedPoint(req *rpc.WriteTaggedRequest) error

type DBNodeOptions

+ StartFn StartFn

+ func GenerateDBNodeConfigsForCluster(configs ClusterConfigs, opts *resources.DBNodeClusterOptions) ([]dbcfg.Configuration, []DBNodeOptions, environment.Configuration, error)

+ type PerInstanceConfigs struct

+ Aggregators []aggcfg.Configuration

+ Coordinator coordinatorcfg.Configuration

+ DBNodes []dbcfg.Configuration

+ type PerInstanceOptions struct

+ DBNode []DBNodeOptions

type ResourceOptions

+ Aggregators resources.Aggregators

+ type StartFn func() (chan<- error, <-chan struct{})

v1.3.0

Oct 7, 2021

Changes in this version

+ func NewAggregator(yamlCfg string, opts AggregatorOptions) (resources.Aggregator, error)

+ func NewCluster(opts ClusterOptions) (resources.M3Resources, error)

+ func NewCoordinator(cfg config.Configuration, opts CoordinatorOptions) (resources.Coordinator, error)

+ func NewCoordinatorFromConfigFile(pathToCfg string, opts CoordinatorOptions) (resources.Coordinator, error)

+ func NewCoordinatorFromYAML(yamlCfg string, opts CoordinatorOptions) (resources.Coordinator, error)

+ func NewDBNode(cfg config.Configuration, opts DBNodeOptions) (resources.Node, error)

+ func NewDBNodeFromConfigFile(pathToCfg string, opts DBNodeOptions) (resources.Node, error)

+ func NewDBNodeFromYAML(yamlCfg string, opts DBNodeOptions) (resources.Node, error)

+ func NewEmbeddedCoordinator(d *dbNode) (resources.Coordinator, error)

+ func NewM3Resources(options ResourceOptions) resources.M3Resources

+ type AggregatorOptions struct

+ Logger *zap.Logger

+ type ClusterOptions struct

+ Coordinator CoordinatorClusterOptions

+ DBNode DBNodeClusterOptions

+ type CoordinatorClusterConfig struct

+ ConfigObject *coordinatorcfg.Configuration

+ ConfigString string

+ func (c *CoordinatorClusterConfig) ToConfig() (coordinatorcfg.Configuration, error)

+ func (c *CoordinatorClusterConfig) Validate() error

+ type CoordinatorClusterOptions struct

+ Config CoordinatorClusterConfig

+ func (c *CoordinatorClusterOptions) Validate() error

+ type CoordinatorOptions struct

+ GeneratePorts bool

+ Logger *zap.Logger

+ type DBNodeClusterConfig struct

+ ConfigObject *dbcfg.Configuration

+ ConfigString string

+ func (d *DBNodeClusterConfig) ToConfig() (dbcfg.Configuration, error)

+ func (d *DBNodeClusterConfig) Validate() error

+ type DBNodeClusterOptions struct

+ Config DBNodeClusterConfig

+ NumInstances int32

+ NumIsolationGroups int32

+ NumShards int32

+ RF int32

+ func NewDBNodeClusterOptions() DBNodeClusterOptions

+ func (d *DBNodeClusterOptions) Validate() error

+ type DBNodeOptions struct

+ GenerateHostID bool

+ GeneratePorts bool

+ Logger *zap.Logger

+ type ResourceOptions struct

+ Coordinator resources.Coordinator

+ DBNodes resources.Nodes

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL