cluster

Jun 25, 2025

Changes in this version

type Cluster

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

+ type ClusterOption func(c *Cluster)

+ func WithV1() ClusterOption

+ func WithV2() ClusterOption

May 30, 2024

Changes in this version

+ type Cluster struct

+ Components []*Component

+ func NewMicroServiceCluster() *Cluster

+ func (c *Cluster) Prepare() (err error)

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

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

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

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

+ func (c *Cluster) Wait()

+ type Component struct

+ Target string

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

+ func (comp *Component) String() string