cluster

package

v1.15.0 Latest Latest Go to latest Published: Oct 7, 2025 License: AGPL-3.0 Imports: 27 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewMicroServiceCluster(opts ...ClusterOption) *Cluster

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

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

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

func (c *Cluster) Prepare(ctx context.Context) (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 ClusterOption func(c *Cluster)

func WithSymbolizer(debuginfodURL string) ClusterOption

func WithV1() ClusterOption

func WithV2() ClusterOption

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

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

func (comp *Component) String() string