common

Documentation

Index

• Constants
• func GetNormalizedPartitionName(partitionName string, rmID string) string
• func GetPartitionNameWithoutClusterID(partitionName string) string
• func GetRMIdFromPartitionName(partitionName string) string
• func ParallelizeUntil(ctx context.Context, workers, pieces int, doWorkPiece DoWorkPieceFunc)
• func ParseEndpoint(ep string) (string, string, error)
• func WaitFor(interval time.Duration, timeout time.Duration, condition func() bool) error
• type DoWorkPieceFunc
• type NodeSortingPolicy
  • func NewNodeSortingPolicy(policyType string) *NodeSortingPolicy
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer
• type SortingPolicy
  • func FromString(str string) (SortingPolicy, error)
  • func (nsp SortingPolicy) String() string

Constants

const (
	BinPackingPolicy = iota
	FairnessPolicy
	Undefined
)

Functions

func GetNormalizedPartitionName

func GetNormalizedPartitionName(partitionName string, rmID string) string

func GetPartitionNameWithoutClusterID

func GetPartitionNameWithoutClusterID(partitionName string) string

func GetRMIdFromPartitionName

func GetRMIdFromPartitionName(partitionName string) string

func ParallelizeUntil

func ParallelizeUntil(ctx context.Context, workers, pieces int, doWorkPiece DoWorkPieceFunc)

Copy from k8s.

func ParseEndpoint

func ParseEndpoint(ep string) (string, string, error)

func WaitFor

func WaitFor(interval time.Duration, timeout time.Duration, condition func() bool) error

Types

type DoWorkPieceFunc

type DoWorkPieceFunc func(piece int)

type NodeSortingPolicy

type NodeSortingPolicy struct {
	PolicyType SortingPolicy
}

func NewNodeSortingPolicy

func NewNodeSortingPolicy(policyType string) *NodeSortingPolicy

type NonBlockingGRPCServer

type NonBlockingGRPCServer interface {
	// Start services at the endpoint
	Start(endpoint string, ss si.SchedulerServer)
	// Waits for the service to stop
	Wait()
	// Stops the service gracefully
	Stop()
	// Stops the service forcefully
	ForceStop()
}

Defines Non blocking GRPC server interfaces

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() NonBlockingGRPCServer

type SortingPolicy

type SortingPolicy int

func FromString

func FromString(str string) (SortingPolicy, error)

func (SortingPolicy) String

func (nsp SortingPolicy) String() string