cluster

package

v0.0.100-dev Latest Latest Go to latest Published: Apr 30, 2025 License: AGPL-3.0 Imports: 23 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() *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
	// contains filtered or unexported fields
}

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

func (comp *Component) String() string