util

Documentation

Index

• Constants
• func GetCalculationBulksByRegisteredTime(bulks map[string]workersv1.CalculationBulk) []workersv1.CalculationBulk
• func GetCalculationFinalPhase(steps []v1.Step) v1.CalculationPhase
• func GetCalculationName(calc bulkv1.Calculation) string
• func GetFirstAvailableWorker(workers map[string]workersv1.Worker) *workersv1.Worker
• func GetSortedCreatedCalculations(calcs map[string]bulkv1.Calculation) sortedCalculations
• func InputHash(inputs ...[]byte) string
• func IsAllFinishedCalculations(calcs map[string]bulkv1.Calculation) bool
• func IsFinishedCalculation(steps []v1.Step) bool
• func LoadClusterConfig() (*rest.Config, error)
• func NewCalculation(calc *bulkv1.Calculation) *v1.Calculation
• func UpdateWorkerStatusInPool(ctx context.Context, client ctrlruntimeclient.Client, ...) error
• type Result

Constants

const (
	ResultsCollected = "vegaproject.io/results-collected"

	BulkLabel            = "vegaproject.io/bulk"
	CalculationNameLabel = "vegaproject.io/calculationName"
	PostCalculationLabel = "vegaproject.io/postCalculation"
	CalcRootFolder       = "vegaproject.io/rootFolder"
	FactoryLabel         = "vegaproject.io/factory"
	AssignWorkerLabel    = "vegaproject.io/assign"
)

Functions

func GetCalculationBulksByRegisteredTime

func GetCalculationBulksByRegisteredTime(bulks map[string]workersv1.CalculationBulk) []workersv1.CalculationBulk

func GetCalculationFinalPhase

func GetCalculationFinalPhase(steps []v1.Step) v1.CalculationPhase

func GetCalculationName

func GetCalculationName(calc bulkv1.Calculation) string

func GetFirstAvailableWorker

func GetFirstAvailableWorker(workers map[string]workersv1.Worker) *workersv1.Worker

func GetSortedCreatedCalculations

func GetSortedCreatedCalculations(calcs map[string]bulkv1.Calculation) sortedCalculations

func InputHash

func InputHash(inputs ...[]byte) string

InputHash returns a string that hashes the unique parts of the input to avoid collisions.

func IsAllFinishedCalculations

func IsAllFinishedCalculations(calcs map[string]bulkv1.Calculation) bool

func IsFinishedCalculation

func IsFinishedCalculation(steps []v1.Step) bool

func LoadClusterConfig

func LoadClusterConfig() (*rest.Config, error)

LoadClusterConfig returns a cluster config

func NewCalculation

func NewCalculation(calc *bulkv1.Calculation) *v1.Calculation

NewCalculation gets the values of teff and logG and creates a calculation with its minimum values

func UpdateWorkerStatusInPool

func UpdateWorkerStatusInPool(ctx context.Context, client ctrlruntimeclient.Client, workerPool, nodename, namespace string, state workersv1.WorkerState) error

Types

type Result

type Result struct {
	CalcName     string
	Step         int
	Status       v1.CalculationPhase
	StdoutStderr string
	CommandError error
}