cluster

package

v2.1.1 Latest Latest Go to latest Published: Jul 10, 2026 License: AGPL-3.0 Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/grafana/pyroscope

Links

Open Source Insights

Documentation ¶

Index ¶

type Cluster
- func NewMicroServiceCluster(opts ...ClusterOption) *Cluster
type ClusterOption
type Component
- func (comp *Component) Stop() func(context.Context) error
- func (comp *Component) String() string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Cluster ¶

type Cluster struct {
	Components []*Component
	// contains filtered or unexported fields
}

func NewMicroServiceCluster ¶

func NewMicroServiceCluster(opts ...ClusterOption) *Cluster

func (*Cluster) AddMetastoreWithAutoJoin ¶

func (c *Cluster) AddMetastoreWithAutoJoin(ctx context.Context) error

func (*Cluster) CompactionJobsFinished ¶

func (c *Cluster) CompactionJobsFinished(ctx context.Context) (float64, error)

func (*Cluster) GetMetastoreRaftNodeClient ¶

func (c *Cluster) GetMetastoreRaftNodeClient() (raftnodepb.RaftNodeServiceClient, error)

func (*Cluster) Prepare ¶

func (c *Cluster) Prepare(ctx context.Context) (err error)

func (*Cluster) PushClient ¶

func (c *Cluster) PushClient() pushv1connect.PusherServiceClient

func (*Cluster) QueryClient ¶

func (c *Cluster) QueryClient() querierv1connect.QuerierServiceClient

func (*Cluster) Start ¶

func (c *Cluster) Start(ctx context.Context) (err error)

func (*Cluster) Stop ¶

func (c *Cluster) Stop() func(context.Context) error

func (*Cluster) Wait ¶

func (c *Cluster) Wait()

type ClusterOption ¶

type ClusterOption func(c *Cluster)

func WithSymbolizer ¶

func WithSymbolizer(debuginfodURL string) ClusterOption

func WithV1 ¶

func WithV1() ClusterOption

func WithV2 ¶

func WithV2() ClusterOption

func WithV2Federated ¶ added in v2.1.0

func WithV2Federated() ClusterOption

WithV2Federated configures a V2 cluster suitable for exercising the federated (multi-tenant) query path. It mirrors the V2 cluster but without a compaction-worker: L0 segment blocks therefore remain Format1 (per-tenant dataset_index pseudo-datasets) for the duration of the test, which is what the multi-Format1 resolution path in the query backend handles.

With two segment-writers and adaptive placement defaults, profiles from each tenant are spread across both writers, so each flushed L0 segment is a multi-tenant block and naturally exercises the multi-Format1 resolution path.

type Component ¶

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

func (*Component) Stop ¶

func (comp *Component) Stop() func(context.Context) error

func (*Component) String ¶

func (comp *Component) String() string

Source Files ¶

View all Source files

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