utils

Mar 23, 2020

Changes in this version

+ var APIServerDefaultArgs = []string

+ type FakeCachedDiscovery struct

+ func (d *FakeCachedDiscovery) Fresh() bool

+ func (d *FakeCachedDiscovery) Invalidate()

Mar 11, 2020

Changes in this version

+ func GetDiscoveryClient(mgr manager.Manager) (*discovery.DiscoveryClient, error)

Jan 10, 2020

Changes in this version

type DockerClient

+ ImageSave func(context.Context, []string) (io.ReadCloser, error)

Dec 13, 2019

Changes in this version

+ func NewClusterRoleBinding(apiVersion, kind, name, namespace string, serviceAccount string, ...) runtime.Object

Sep 30, 2019

Changes in this version

+ func GetArgs(ctx context.Context, command string, cmd kudo.Command, namespace string) (*exec.Cmd, error)

+ func RunCommand(ctx context.Context, namespace string, command string, cmd kudo.Command, ...) error

+ func RunCommands(logger Logger, namespace string, command string, commands []kudo.Command, ...) []error

+ type DockerClient interface

+ NegotiateAPIVersion func(context.Context)

+ VolumeCreate func(context.Context, volumetypes.VolumeCreateBody) (dockertypes.Volume, error)

Sep 6, 2019

Changes in this version

+ func WaitForDelete(c *RetryClient, objs []runtime.Object) error

type RetryClient

+ func (r *RetryClient) DeleteAllOf(ctx context.Context, obj runtime.Object, opts ...client.DeleteAllOfOption) error

Aug 2, 2019

Changes in this version

+ func GetKubectlArgs(args string, namespace string) ([]string, error)

+ func Kubeconfig(cfg *rest.Config, w io.Writer) error

+ func Kubectl(ctx context.Context, namespace string, args string, cwd string, ...) error

+ func RunKubectlCommands(logger Logger, namespace string, commands []string, workdir string) []error

Jul 29, 2019

Changes in this version

+ func CleanObjectForMarshalling(o runtime.Object) (runtime.Object, error)

+ func IsJSONSyntaxError(err error) bool

+ func MarshalObjectJSON(o runtime.Object, w io.Writer) error

+ func MatchesKind(obj runtime.Object, kinds ...runtime.Object) bool

+ func NewDynamicRESTMapper(cfg *rest.Config) (meta.RESTMapper, error)

+ type Client interface

+ Watch func(ctx context.Context, obj runtime.Object) (watch.Interface, error)

+ type DynamicRESTMapper struct

+ func (drm *DynamicRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error)

+ func (drm *DynamicRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error)

+ func (drm *DynamicRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)

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

+ func (drm *DynamicRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)

+ func (drm *DynamicRESTMapper) ResourceSingularizer(resource string) (singular string, err error)

+ func (drm *DynamicRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)

+ type RetryClient struct

+ Client client.Client

+ func NewRetryClient(cfg *rest.Config, opts client.Options) (*RetryClient, error)

+ func (r *RetryClient) Create(ctx context.Context, obj runtime.Object, opts ...client.CreateOptionFunc) error

+ func (r *RetryClient) Delete(ctx context.Context, obj runtime.Object, opts ...client.DeleteOptionFunc) error

+ func (r *RetryClient) Get(ctx context.Context, key client.ObjectKey, obj runtime.Object) error

+ func (r *RetryClient) List(ctx context.Context, list runtime.Object, opts ...client.ListOptionFunc) error

+ func (r *RetryClient) Patch(ctx context.Context, obj runtime.Object, patch client.Patch, ...) error

+ func (r *RetryClient) Status() client.StatusWriter

+ func (r *RetryClient) Update(ctx context.Context, obj runtime.Object, opts ...client.UpdateOptionFunc) error

+ func (r *RetryClient) Watch(ctx context.Context, obj runtime.Object) (watch.Interface, error)

+ type RetryStatusWriter struct

+ StatusWriter client.StatusWriter

+ func (r *RetryStatusWriter) Patch(ctx context.Context, obj runtime.Object, patch client.Patch, ...) error

+ func (r *RetryStatusWriter) Update(ctx context.Context, obj runtime.Object, opts ...client.UpdateOptionFunc) error

+ type TestEnvironment struct

+ Client Client

+ Config *rest.Config

+ DiscoveryClient discovery.DiscoveryInterface

+ Environment *envtest.Environment

+ func StartTestEnvironment() (env TestEnvironment, err error)

Jun 28, 2019

Changes in this version

+ func ConvertUnstructured(in runtime.Object) (runtime.Object, error)

+ func CreateOrUpdate(ctx context.Context, client client.Client, obj runtime.Object, ...) error

+ func FakeDiscoveryClient() discovery.DiscoveryInterface

+ func GetAPIResource(dClient discovery.DiscoveryInterface, gvk schema.GroupVersionKind) (metav1.APIResource, error)

+ func InstallManifests(ctx context.Context, client client.Client, ...) ([]runtime.Object, error)

+ func IsSubset(expected, actual interface{}) error

+ func LoadYAML(path string) ([]runtime.Object, error)

+ func MarshalObject(o runtime.Object, w io.Writer) error

+ func Namespaced(dClient discovery.DiscoveryInterface, obj runtime.Object, namespace string) (string, string, error)

+ func NewPod(name, namespace string) runtime.Object

+ func NewResource(apiVersion, kind, name, namespace string) runtime.Object

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

+ func PatchObject(actual, expected runtime.Object) error

+ func PrettyDiff(expected runtime.Object, actual runtime.Object) (string, error)

+ func ResourceID(obj runtime.Object) string

+ func Retry(ctx context.Context, fn func(context.Context) error, ...) error

+ func RunTests(testName string, testFunc func(*testing.T))

+ func Scheme() *runtime.Scheme

+ func SetAnnotation(obj runtime.Object, key, value string) runtime.Object

+ func ValidateErrors(err error, errValidationFuncs ...func(error) bool) error

+ func WaitForCRDs(dClient discovery.DiscoveryInterface, crds []runtime.Object) error

+ func WithAnnotations(obj runtime.Object, annotations map[string]string) runtime.Object

+ func WithKeyValue(obj runtime.Object, key string, value map[string]interface{}) runtime.Object

+ func WithLabels(obj runtime.Object, labels map[string]string) runtime.Object

+ func WithNamespace(obj runtime.Object, namespace string) runtime.Object

+ func WithSpec(obj runtime.Object, spec map[string]interface{}) runtime.Object

+ func WithStatus(obj runtime.Object, status map[string]interface{}) runtime.Object

+ type Logger interface

+ Log func(args ...interface{})

+ Logf func(format string, args ...interface{})

+ WithPrefix func(string) Logger

+ type SubsetError struct

+ func (e *SubsetError) AppendPath(key string)

+ func (e *SubsetError) Error() string

+ type TestLogger struct

+ func NewTestLogger(test *testing.T, prefix string) *TestLogger

+ func (t *TestLogger) Log(args ...interface{})

+ func (t *TestLogger) Logf(format string, args ...interface{})

+ func (t *TestLogger) WithPrefix(prefix string) Logger