poolservice

Documentation

Index

• Variables
• func NewDagPoolService(ctx context.Context, cfg config.PoolConfig) (*dagPoolService, error)
• type ClusterState
  • func (cs ClusterState) String() string
• type GcControl
  • func NewGcControl() *GcControl
  • func (c *GcControl) Interrupt() chan chan<- struct{}
  • func (c *GcControl) WaitInterrupt()
• type MigrateSlot

Variables

var ErrClusterAvailable = errors.New("cluster is unavailable, please check the slots")

var ErrClusterMigrating = errors.New("the cluster is migrating")

var ErrDagNodeAlreadyExist = errors.New("this dag node already exists")

var ErrDagNodeNotFound = errors.New("this dag node does not exist")

var ErrDagNodeRemove = errors.New("this dag node still has slots and cannot be removed")

Functions

func NewDagPoolService

func NewDagPoolService(ctx context.Context, cfg config.PoolConfig) (*dagPoolService, error)

NewDagPoolService constructs a new DAGPool (using the default implementation).

Types

type ClusterState

type ClusterState int

const (
	StateOk ClusterState = iota
	StateMigrating
	StateFail
)

func (ClusterState) String

func (cs ClusterState) String() string

type GcControl

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

func NewGcControl

func NewGcControl() *GcControl

func (*GcControl) Interrupt

func (c *GcControl) Interrupt() chan chan<- struct{}

func (*GcControl) WaitInterrupt

func (c *GcControl) WaitInterrupt()

type MigrateSlot

type MigrateSlot struct {
	From      string
	To        string
	SlotPairs []slotsmgr.SlotPair
}