Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

util

package

Go to main page

Versions in this module

v3

v3.2.5

Sep 27, 2024

v3.2.2

Jul 25, 2024

v3.2.1

Jul 11, 2024

v3.2.0

Jun 21, 2024

Changes in this version

+ func AddToWorkqueue(workqueue workqueue.Interface, req *generalpb.ResourceId) (*emptypb.Empty, error)

+ func AppendDynamicScenariosByCategories(ctx context.Context, scenariosList []string, categories []string, ...) []string

+ func ContainsFinalizer(finalizers []string, finalizer string) bool

+ func ConvertIntMap[T, U IntegerType](input map[string]T) map[string]U

+ func ConvertMapStruct[K comparable, V any, T any](input map[string]T, getMapFunc func(T) map[K]V) map[string]map[K]V

+ func ConvertToStringMapSlice(stringMapSlice []*generalpb.StringMap) []map[string]string

+ func ConvertToStringMapStructMap(in map[string]map[string]string) map[string]*generalpb.StringMap

+ func DeleteHfCollection(ctx context.Context, listOptions *generalpb.ListOptions, ...) (*emptypb.Empty, error)

+ func DeleteHfResource(ctx context.Context, req *generalpb.ResourceId, clientDelete HfClientDelete, ...) (*emptypb.Empty, error)

+ func FilterByCourse(se *scheduledeventpb.ScheduledEvent, course string) bool

+ func FilterByScenario[T ScenarioProvider](obj T, scenario string) bool

+ func FilterScheduledEvents(objId string, seList *scheduledeventpb.ListScheduledEventsResponse, ...) []*scheduledeventpb.ScheduledEvent

+ func FilterSessions(objId string, sessList *sessionpb.ListSessionsResponse, ...) []*sessionpb.Session

+ func GenericHfGetter[T metav1.Object, G HfClientGet[T], C GenericCacheRetriever[T]](ctx context.Context, req *generalpb.GetRequest, getter G, cacheGetter C, ...) (T, error)

+ func GenericUnmarshal[T any](rawObj string, propName string) (T, error)

+ func GetDurationWithDays(s string) (string, error)

+ func GetOwnerReferences[T metav1.Object, G HfClientGet[T], C GenericCacheRetriever[T]](ctx context.Context, req *generalpb.GetRequest, getter G, cacheGetter C, ...) (*generalpb.OwnerReferences, error)

+ func GetRawStringMap(val *generalpb.StringMap) map[string]string

+ func GetRawVMTemplateCountMap(val *scheduledeventpb.VMTemplateCountMap) map[string]uint32

+ func IsSessionOfCourse(sess *sessionpb.Session, course string) bool

+ func IsSessionOfScenario(sess *sessionpb.Session, scenario string) bool

+ func ListByCache[T any, L GenericLister[T]](listOptions *generalpb.ListOptions, lister L, resourcename string, ...) ([]T, error)

+ func ListByHfClient[T any, L HfClientList[T]](ctx context.Context, listOptions *generalpb.ListOptions, lister L, ...) (T, error)

+ func MaxUint32(x, y uint32) uint32

+ func RemoveFinalizer(finalizers []string, finalizer string) []string

+ func VerifyDeletion(ctx context.Context, clientWatch HfClientWatch, resourceId string) error

+ func VerifyTaskContent(vm_tasks []hfv1.VirtualMachineTasks, request proto.Message) error

+ func Verify[T metav1.Object, C GenericCacheRetriever[T]](getter C, object T, timeout time.Duration) error

+ type EventFilterfunc func(se *scheduledeventpb.ScheduledEvent, objId string) bool

+ type GenericCacheRetriever interface

+ Get func(id string) (T, error)

+ type GenericLister interface

+ List func(labels.Selector) ([]*T, error)

+ type HfClientDelete interface

+ Delete func(ctx context.Context, id string, opts metav1.DeleteOptions) error

+ DeleteCollection func(ctx context.Context, deleteOptions metav1.DeleteOptions, ...) error

+ type HfClientGet interface

+ Get func(ctx context.Context, id string, opts metav1.GetOptions) (T, error)

+ type HfClientList interface

+ List func(ctx context.Context, opts metav1.ListOptions) (T, error)

+ type HfClientWatch interface

+ Watch func(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)

+ type IntegerType interface

+ type ScenarioProvider interface

+ GetScenarios func() []string

+ type SessionFilterfunc func(se *sessionpb.Session, objId string) bool

v3.1.0

Nov 21, 2023

Changes in this version

+ const AccessCodeLabel

+ const EnvironmentLabel

+ const OneTimeAccessCodeLabel

+ const RBACManagedLabel

+ const ScheduledEventLabel

+ const SessionLabel

+ const UserLabel

+ const VirtualMachineTemplate

+ func CountMachinesPerTemplateAndEnvironment(vmLister hfListers.VirtualMachineLister, template string, enviroment string) (int, error)

+ func CountMachinesPerTemplateAndEnvironmentAndScheduledEvent(vmLister hfListers.VirtualMachineLister, template string, enviroment string, ...) (int, error)

+ func EnsureVMNotReady(hfClientset hfClientset.Interface, vmLister hfListers.VirtualMachineLister, ...) error

+ func GenKeyPair() (string, string, error)

+ func GenerateResourceName(prefix string, input string, hashlength int) string

+ func GetHTTPErrorCode(httpStatus int) string

+ func GetLock(lockName string, cfg *rest.Config) (resourcelock.Interface, error)

+ func GetProtoMarshaller() protojson.MarshalOptions

+ func GetReleaseNamespace() string

+ func GetVMConfig(env *hfv1.Environment, vmt *hfv1.VirtualMachineTemplate) map[string]string

+ func Max(x, y int) int

+ func RandStringRunes(n int) string

+ func ResourceVersionAtLeast(curr, min string) bool

+ func ReturnHTTPContent(w http.ResponseWriter, r *http.Request, httpStatus int, messageType string, ...)

+ func ReturnHTTPMessage(w http.ResponseWriter, r *http.Request, httpStatus int, messageType string, ...)

+ func ReturnHTTPRaw(w http.ResponseWriter, r *http.Request, content string)

+ func StringInSlice(a string, list []string) bool

+ func StringPtr(s string) *string

+ func UniqueStringSlice(stringSlice []string) []string

+ func VerifySession(sLister hfListers.SessionLister, s *hfv1.Session) error

+ func VerifyVM(vmLister hfListers.VirtualMachineLister, vm *hfv1.VirtualMachine) error

+ func VerifyVMClaim(vmClaimLister hfListers.VirtualMachineClaimLister, ...) error

+ func VerifyVMDeleted(vmLister hfListers.VirtualMachineLister, vm *hfv1.VirtualMachine) error

+ func VerifyVMSet(vmSetLister hfListers.VirtualMachineSetLister, vms *hfv1.VirtualMachineSet) error

+ func VirtualMachinesUsedDuringPeriod(hfClientset hfClientset.Interface, environment string, startString string, ...) (map[time.Time]map[string]int, map[string]int, error)

+ type ByTime []time.Time

+ func (t ByTime) Len() int

+ func (t ByTime) Less(i, j int) bool

+ func (t ByTime) Swap(i, j int)

+ type HTTPContent struct

+ Content []byte

+ Status string

+ Type string

+ type HTTPMessage struct

+ Message string

+ Status string

+ Type string

+ type Maximus struct

+ AvailableCount map[string]int

+ func MaxAvailableDuringPeriod(hfClientset hfClientset.Interface, environment string, startString string, ...) (Maximus, error)

+ type Range struct

+ End time.Time

+ Start time.Time

+ VMMapping map[string]int

Other modules containing this package

github.com/hobbyfarm/gargantua