cluster

Documentation

Index

• type Cluster
  • func NewMicroServiceCluster(opts ...ClusterOption) *Cluster
  • func (c *Cluster) CompactionJobsFinished(ctx context.Context) (float64, 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 WithV1() ClusterOption
  • func WithV2() ClusterOption
• type Component
  • func (comp *Component) Stop() func(context.Context) error
  • func (comp *Component) String() string

Types

type Cluster

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

func NewMicroServiceCluster

func NewMicroServiceCluster(opts ...ClusterOption) *Cluster

func (*Cluster) CompactionJobsFinished

func (c *Cluster) CompactionJobsFinished(ctx context.Context) (float64, 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 WithV1

func WithV1() ClusterOption

func WithV2

func WithV2() ClusterOption

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