util

package

v0.0.0-...-5231612 Latest Latest Go to latest Published: Mar 13, 2024 License: GPL-3.0 Imports: 14 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

Repository

github.com/vega-project/ccb-operator

Links

Open Source Insights

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 ¶

View Source

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"
)

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL