shard

Documentation

Index

• type Shard
  • func NewShard(name, runtimeDir, logFilePath string, args []string) *Shard
  • func (s *Shard) Start(ctx context.Context) error
  • func (s *Shard) WaitForReady(ctx context.Context) (<-chan error, 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) Start

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

Start starts a kcp Shard server.

func (*Shard) WaitForReady

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