util

package

v0.7.17 Latest Latest Go to latest Published: Aug 9, 2023 License: Apache-2.0 Imports: 33 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/milvus-io/milvus-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func BoolPtr(val bool) *bool
func CheckSum(s []byte) string
func DeepCopyValues(input map[string]interface{}) map[string]interface{}
func DeleteValue(values map[string]interface{}, fields ...string)
func DiffStr(expected interface{}, actual interface{}) string
func DoWithBackoff(name string, fn func() error, maxRetry int, backOff time.Duration) error
func GetBoolValue(values map[string]interface{}, fields ...string) (bool, bool)
func GetGitRepoRootDir() string
func GetHostPort(endpoint string) (string, int32)
func GetStringValue(values map[string]interface{}, fields ...string) (string, bool)
func GetTemplatedValues(templateConfig string, values interface{}) ([]byte, error)
func HTTPGetBytes(url string) ([]byte, error)
func JoinErrors(errs []error) string
func MergeValues(origin, patch map[string]interface{})
func SetStringSlice(values map[string]interface{}, v []string, fields ...string)
func SetValue(values map[string]interface{}, v interface{}, fields ...string)
type K8sClient
type K8sClients
- func NewK8sClientsForConfig(config *rest.Config) (*K8sClients, error)
- func (clis K8sClients) Create(ctx context.Context, manifest []byte) error
- func (clis K8sClients) Delete(ctx context.Context, manifest []byte) error
- func (clis K8sClients) Exist(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) (bool, error)
- func (clis *K8sClients) GetCRDVersionsByNames(ctx context.Context, crdNames []string) (map[string]string, error)
- func (clis *K8sClients) ListCRDs(ctx context.Context) (*apiextensionsv1.CustomResourceDefinitionList, error)
- func (clis K8sClients) WaitDeploymentsReadyByNamespace(ctx context.Context, namespace string) error

Constants ¶

View Source

const MqTypeConfigKey = "messageQueue"

Variables ¶

View Source

var DefaultHTTPTimeout = 15 * time.Second

View Source

var DefaultMaxRetry = 3

View Source

var DefualtBackOffInterval = time.Second * 1

Functions ¶

func BoolPtr ¶ added in v0.7.6

func BoolPtr(val bool) *bool

func CheckSum ¶

func CheckSum(s []byte) string

func DeepCopyValues ¶ added in v0.4.1

func DeepCopyValues(input map[string]interface{}) map[string]interface{}

func DeleteValue ¶

func DeleteValue(values map[string]interface{}, fields ...string)

func DiffStr ¶ added in v0.3.2

func DiffStr(expected interface{}, actual interface{}) string

DiffStr returns a diff of both values as long as both are of the same type and are a struct, map, slice, array or string. Otherwise it returns an empty string. ref: github.com/stretchr/testify/assert:diff()

func DoWithBackoff ¶ added in v0.7.16

func DoWithBackoff(name string, fn func() error, maxRetry int, backOff time.Duration) error

func GetBoolValue ¶

func GetBoolValue(values map[string]interface{}, fields ...string) (bool, bool)

func GetGitRepoRootDir ¶ added in v0.2.0

func GetGitRepoRootDir() string

func GetHostPort ¶

func GetHostPort(endpoint string) (string, int32)

func GetStringValue ¶ added in v0.5.0

func GetStringValue(values map[string]interface{}, fields ...string) (string, bool)

func GetTemplatedValues ¶

func GetTemplatedValues(templateConfig string, values interface{}) ([]byte, error)

func HTTPGetBytes ¶ added in v0.3.0

func HTTPGetBytes(url string) ([]byte, error)

func JoinErrors ¶

func JoinErrors(errs []error) string

func MergeValues ¶

func MergeValues(origin, patch map[string]interface{})

func SetStringSlice ¶

func SetStringSlice(values map[string]interface{}, v []string, fields ...string)

func SetValue ¶

func SetValue(values map[string]interface{}, v interface{}, fields ...string)

only contains types bool, int64, float64, string, []interface{}, map[string]interface{}, json.Number and nil

Types ¶

type K8sClient ¶ added in v0.3.0

type K8sClient interface {
	Exist(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) (bool, error)

	// Create creates resources from manifest
	Create(ctx context.Context, manifest []byte) error

	// Delete delete resources from manifest
	Delete(ctx context.Context, manifest []byte) error

	// ListCRDs list all CRDs
	ListCRDs(ctx context.Context) (*apiextensionsv1.CustomResourceDefinitionList, error)

	// GetCRDVersionsByNames returns map[crdName]crdVersion
	GetCRDVersionsByNames(ctx context.Context, crdNames []string) (map[string]string, error)

	// WaitDeploymentReady
	WaitDeploymentsReadyByNamespace(ctx context.Context, namespace string) error
}

K8sClient wrap functions by k8s clients

type K8sClients ¶ added in v0.3.0

type K8sClients struct {
	ClientSet     kubernetes.Interface
	ExtClientSet  clientset.Interface
	DynamicClient dynamic.Interface
}

func NewK8sClientsForConfig ¶ added in v0.3.0

func NewK8sClientsForConfig(config *rest.Config) (*K8sClients, error)

func (K8sClients) Create ¶ added in v0.3.0

func (clis K8sClients) Create(ctx context.Context, manifest []byte) error

Create creates resource from manifest

func (K8sClients) Delete ¶ added in v0.3.0

func (clis K8sClients) Delete(ctx context.Context, manifest []byte) error

Delete delete resource from manifest

func (K8sClients) Exist ¶ added in v0.3.0

func (clis K8sClients) Exist(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) (bool, error)

func (*K8sClients) GetCRDVersionsByNames ¶ added in v0.3.0

func (clis *K8sClients) GetCRDVersionsByNames(ctx context.Context, crdNames []string) (map[string]string, error)

func (*K8sClients) ListCRDs ¶ added in v0.3.0

func (clis *K8sClients) ListCRDs(ctx context.Context) (*apiextensionsv1.CustomResourceDefinitionList, error)

ListCRDs list all CRDs

func (K8sClients) WaitDeploymentsReadyByNamespace ¶ added in v0.3.0

func (clis K8sClients) WaitDeploymentsReadyByNamespace(ctx context.Context, namespace string) error

Source Files ¶

View all Source files

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