pool

Documentation

Index

• Constants
• Variables
• type InitialWorkerNodeSet
• type WorkerNode
  • func ProvideWorkerNode(caCertificate cert.CACertificate, ...) WorkerNode

Constants

const (
	MaximumUnavailableCount  = 3
	AvailabilityCheckTimeout = 5 * time.Second
)

Variables

var (
	ErrNoAvailableWorkerNode  = errors.New("no available worker node in the pool")
	ErrNoAvailableDistributor = errors.New("no distributor available")
)

Types

type InitialWorkerNodeSet

type InitialWorkerNodeSet []models.NodeEntry

type WorkerNode

type WorkerNode interface {
	InitializePool(ctx context.Context, nodeEntries []models.NodeEntry)
	AddWorkerNode(ctx context.Context, node models.NodeEntry) error
	WorkerNodeAvailabilityCheck(ctx context.Context)
	DistributeWork(ctx context.Context, jobID models.Job, tasks []models.Task) ([]models.Task, []models.DistributeError, error)
	IsAvailableWorkerNode() bool
	RemoveNodeFromPool(ctx context.Context, nodeID string)
	CheckRunningTaskInEachWorkerNode(ctx context.Context) map[primitive.ObjectID]bool
}

func ProvideWorkerNode

func ProvideWorkerNode(caCertificate cert.CACertificate, distributorMapper distribution.DistributorMapper, grpcResolver grpc.RAJDSGRPCResolver, meter metric.Meter) WorkerNode