shard

Documentation

Index

• func ScrapeMetrics(ctx context.Context, s *Shard, workDir string) error
• type Shard
  • func NewShard(name, runtimeDir, logFilePath string, args []string) *Shard
  • func (s *Shard) GatherMetrics(ctx context.Context)
  • func (s *Shard) Start(ctx context.Context, quiet bool) error
  • func (s *Shard) WaitForReady(ctx context.Context) (<-chan error, error)

Functions

func ScrapeMetrics

func ScrapeMetrics(ctx context.Context, s *Shard, workDir string) error

Types

type Shard

type Shard struct {
	// contains filtered or unexported fields
}

func NewShard

func NewShard(name, runtimeDir, logFilePath string, args []string) *Shard

func (*Shard) GatherMetrics

func (s *Shard) GatherMetrics(ctx context.Context)

func (*Shard) Start

func (s *Shard) Start(ctx context.Context, quiet bool) error

Start starts a kcp Shard server.

func (*Shard) WaitForReady

func (s *Shard) WaitForReady(ctx context.Context) (<-chan error, error)