poolservice

package

v0.4.0 Latest Latest Go to latest Published: Feb 1, 2024 License: MIT Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

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

View Source

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

View Source

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

View Source

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

View Source

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

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

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

type ClusterState int

const (
	StateOk ClusterState = iota
	StateMigrating
	StateFail
)

func (cs ClusterState) String() string

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

func NewGcControl() *GcControl

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

func (c *GcControl) WaitInterrupt()

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