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

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