util

package

Go to main page

Versions in this module

v2

v2.3.0

Jul 15, 2020

Changes in this version

+ func AddFinalizer(obj metav1.Object, finalizer string) bool

+ func Contains(s string, arr []string) bool

+ func GetEnvVariable(env *[]corev1.EnvVar, name string) *corev1.EnvVar

+ func IsAzurePlatform() bool

+ func KubeDeleteAllOf(obj runtime.Object, opts ...client.DeleteAllOfOption) bool

+ func ReflectEnvVariable(env *[]corev1.EnvVar, name string)

v2.2.0

Jun 7, 2020

v2.1.1

Apr 20, 2020

v2.1.0

Mar 24, 2020

Changes in this version

+ var InsecureHTTPTransport = &http.Transport

+ var SecureHTTPTransport = newSecureHTTPTransport()

+ func IsStringGraphicOrSpacesCharsOnly(s string) bool

+ func IsValidS3BucketName(name string) bool

+ func KubeCheckQuiet(obj runtime.Object) bool

+ func KubeGet(obj runtime.Object) (name string, kind string, err error)

v2.0.10

Feb 13, 2020

v2.0.9

Nov 28, 2019

v2.0.8

Nov 19, 2019

Changes in this version

+ func WriteYamlFile(name string, obj runtime.Object, moreObjects ...runtime.Object) error

v2.0.7

Nov 12, 2019

Changes in this version

+ func GetPodLogs(pod corev1.Pod) (map[string]io.ReadCloser, error)

+ func SaveCRsToFile(crs runtime.Object, path string) error

+ func SaveStreamToFile(body io.ReadCloser, path string) error

+ func Tar(src string, writers ...io.Writer) error

v2.0.6

Nov 7, 2019

Changes in this version

+ func IsStringGraphicCharsOnly(s string) bool

+ type OAuth2Endpoints struct

+ AuthorizationEndpoint string

+ TokenEndpoint string

+ func DiscoverOAuthEndpoints() (*OAuth2Endpoints, error)

v2.0.5

Oct 31, 2019

v2.0.4

Oct 24, 2019

v2.0.3

Oct 22, 2019

v2.0.2

Oct 10, 2019

Changes in this version

+ func PrintThisNoteWhenFinishedApplyingAndStartWaitLoop()

v2.0.1

Oct 3, 2019

Changes in this version

+ func CombineErrors(errs ...error) error

+ func Context() context.Context

+ func CurrentNamespace() string

+ func GetAWSRegion() string

+ func GetContainerStatusLine(cont *corev1.ContainerStatus) string

+ func GetFlagStringOrPrompt(cmd *cobra.Command, flag string) string

+ func GetFlagStringOrPromptPassword(cmd *cobra.Command, flag string) string

+ func GetPodStatusLine(pod *corev1.Pod) string

+ func IgnoreError(err error)

+ func InitLogger()

+ func IsAWSPlatform() bool

+ func IsPersistentError(err error) bool

+ func KubeApply(obj runtime.Object) bool

+ func KubeCheck(obj runtime.Object) bool

+ func KubeCheckOptional(obj runtime.Object) bool

+ func KubeClient() client.Client

+ func KubeConfig() *rest.Config

+ func KubeCreateSkipExisting(obj runtime.Object) bool

+ func KubeDelete(obj runtime.Object, opts ...client.DeleteOptionFunc) bool

+ func KubeList(list runtime.Object, options *client.ListOptions) bool

+ func KubeObject(text string) runtime.Object

+ func KubeRest() *rest.RESTClient

+ func KubeUpdate(obj runtime.Object) bool

+ func LogError(err error)

+ func Logger() *logrus.Entry

+ func MapperProvider(config *rest.Config) (meta.RESTMapper, error)

+ func NewFastRESTMapper(dc discovery.DiscoveryInterface, filter APIGroupFilterFunc) meta.RESTMapper

+ func NoGroupFilter(*metav1.APIGroup) bool

+ func ObjectKey(obj runtime.Object) client.ObjectKey

+ func Panic(err error)

+ func RandomBase64(numBytes int) string

+ func RandomHex(numBytes int) string

+ func RemoveFinalizer(obj metav1.Object, finalizer string) bool

+ func SecretResetStringDataFromData(obj runtime.Object)

+ func SetAvailableCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ func SetErrorCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ func SetProgressingCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ type APIGroupFilterFunc func(*metav1.APIGroup) bool

+ type FastRESTMapper struct

+ Discovery discovery.DiscoveryInterface

+ Filter APIGroupFilterFunc

+ Mapper meta.RESTMapper

+ func (m *FastRESTMapper) Discover() error

+ func (m *FastRESTMapper) DiscoverGroup(gr *restmapper.APIGroupResources) error

+ func (m *FastRESTMapper) DiscoverOnError(err error) bool

+ func (m *FastRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error)

+ func (m *FastRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error)

+ func (m *FastRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)

+ func (m *FastRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error)

+ func (m *FastRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)

+ func (m *FastRESTMapper) ResourceSingularizer(resource string) (string, error)

+ func (m *FastRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)

+ type PersistentError struct

+ Message string

+ Reason string

+ func NewPersistentError(reason string, message string) *PersistentError

+ func (e *PersistentError) Error() string

+ type PrintColumn struct

+ Items []string

+ Width int

+ func (c *PrintColumn) Pad(s string) string

+ func (c *PrintColumn) RecalcWidth()

+ type PrintTable struct

+ Columns []PrintColumn

+ NumRows int

+ func (t *PrintTable) AddRow(items ...string) *PrintTable

+ func (t *PrintTable) RecalcWidth() *PrintTable

+ func (t *PrintTable) String() string

v2.0.1-rc.1

Oct 3, 2019

Other modules containing this package

github.com/noobaa/noobaa-operator

github.com/noobaa/noobaa-operator/v5

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