cluster

Documentation

Index

• type Cluster
  • 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
  • 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() *Cluster

func (*Cluster) Prepare

func (c *Cluster) Prepare() (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 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