cluster

Documentation

Index

• func NewRemoteWriteServer(handler *http.HandlerFunc) *httptest.Server
• func SchemaWithBoltDBAndBoltDB(c *Cluster)
• func SchemaWithBoltDBAndTSDB(c *Cluster)
• func SchemaWithTSDB(c *Cluster)
• func SchemaWithTSDBAndTSDB(c *Cluster)
• type Cluster
  • func New(logLevel level.Value, opts ...func(*Cluster)) *Cluster
  • func (c *Cluster) AddComponent(name string, flags ...string) *Component
  • func (c *Cluster) Cleanup() error
  • func (c *Cluster) ResetSchemaConfig()
  • func (c *Cluster) Restart() error
  • func (c *Cluster) Run() error
  • func (c *Cluster) SetSchemaVer(schemaVer string)
• type Component
  • func (c *Component) AddFlags(flags ...string)
  • func (c *Component) ClusterSharedPath() string
  • func (c *Component) GRPCURL() string
  • func (c *Component) GetTenantLimits(tenant string) validation.Limits
  • func (c *Component) HTTPURL() string
  • func (c *Component) MergedConfig() ([]byte, error)
  • func (c *Component) Restart() error
  • func (c *Component) SetTenantLimits(tenant string, limits validation.Limits) error
  • func (c *Component) WithExtraConfig(cfg string)
  • func (c *Component) WithRulerRemoteWrite(name, url string)
  • func (c *Component) WithTenantRules(tenantFilesMap map[string]map[string]string) error

Functions

func NewRemoteWriteServer

func NewRemoteWriteServer(handler *http.HandlerFunc) *httptest.Server

func SchemaWithBoltDBAndBoltDB

func SchemaWithBoltDBAndBoltDB(c *Cluster)

func SchemaWithBoltDBAndTSDB

func SchemaWithBoltDBAndTSDB(c *Cluster)

func SchemaWithTSDB

func SchemaWithTSDB(c *Cluster)

func SchemaWithTSDBAndTSDB

func SchemaWithTSDBAndTSDB(c *Cluster)

Types

type Cluster

type Cluster struct {
	// contains filtered or unexported fields
}

func New

func New(logLevel level.Value, opts ...func(*Cluster)) *Cluster

func (*Cluster) AddComponent

func (c *Cluster) AddComponent(name string, flags ...string) *Component

func (*Cluster) Cleanup

func (c *Cluster) Cleanup() error

func (*Cluster) ResetSchemaConfig

func (c *Cluster) ResetSchemaConfig()

func (*Cluster) Restart

func (c *Cluster) Restart() error

func (*Cluster) Run

func (c *Cluster) Run() error

func (*Cluster) SetSchemaVer

func (c *Cluster) SetSchemaVer(schemaVer string)

SetSchemaVer sets a schema version for all the schemas

type Component

type Component struct {
	// contains filtered or unexported fields
}

func (*Component) AddFlags

func (c *Component) AddFlags(flags ...string)

component should be restarted if it's already running for the new flags to take effect

func (*Component) ClusterSharedPath

func (c *Component) ClusterSharedPath() string

ClusterSharedPath returns the path to the shared directory between all components in the cluster. This path will be removed once the cluster is stopped.

func (*Component) GRPCURL

func (c *Component) GRPCURL() string

func (*Component) GetTenantLimits

func (c *Component) GetTenantLimits(tenant string) validation.Limits

func (*Component) HTTPURL

func (c *Component) HTTPURL() string

func (*Component) MergedConfig

func (c *Component) MergedConfig() ([]byte, error)

MergedConfig merges the base config template with any additional config that has been provided

func (*Component) Restart

func (c *Component) Restart() error

func (*Component) SetTenantLimits

func (c *Component) SetTenantLimits(tenant string, limits validation.Limits) error

func (*Component) WithExtraConfig

func (c *Component) WithExtraConfig(cfg string)

func (*Component) WithRulerRemoteWrite

func (c *Component) WithRulerRemoteWrite(name, url string)

func (*Component) WithTenantRules

func (c *Component) WithTenantRules(tenantFilesMap map[string]map[string]string) error