utils

package

v0.0.0-...-b4f3a91 Latest Latest Go to latest Published: Jul 26, 2022 License: Apache-2.0 Imports: 20 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/paddlepaddle/paddlecloud

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CollectAllCacheStatus(runtimePodNames []string, serviceName string) (*v1alpha1.CacheStatus, error)
func ContainsString(slice []string, s string) bool
func DiskSpaceOfPaths(timeout time.Duration, paths ...string) (map[string]string, error)
func DiskUsageOfPaths(timeout time.Duration, paths ...string) (string, error)
func FileNumberOfPaths(timeout time.Duration, paths ...string) (string, error)
func Get(url string, filename types.UID) (resp *http.Response, err error)
func GetBaseUriByIndex(runtimeName, serviceName string, index int) string
func GetBaseUriByName(runtimePodName, serviceName string) string
func GetCacheStatus(runtimePodName, serviceName string) (*v1alpha1.CacheStatus, error)
func GetHostName() (string, error)
func GetJobOption(option interface{}, filename types.UID, baseUri, optionPath string) error
func GetJobResult(filename types.UID, baseUri, resultPath string) (*common.JobResult, error)
func GetOptionUri(baseUri, optionPath string) string
func GetResultUri(baseUri, resultPath string) string
func GetRuntimeImage() (string, error)
func GetUploadUri(baseUri, uploadPath string) string
func HasDeletionTimestamp(obj *metav1.ObjectMeta) bool
func HasFinalizer(obj *metav1.ObjectMeta, finalizer string) bool
func JuiceFileNumberOfPath(timeout time.Duration, path ...string) (string, error)
func NoRequeue() (ctrl.Result, error)
func NoZeroOptionToArgs(options interface{}) []string
func NoZeroOptionToMap(optionMap map[string]reflect.Value, i interface{})
func Post(url string, filename types.UID, body io.Reader) (resp *http.Response, err error)
func PostJobOption(option interface{}, filename types.UID, baseUri, optionPath, param string) error
func RemoveFinalizer(obj *metav1.ObjectMeta, finalizer string)
func RemoveString(slice []string, s string) (result []string)
func RequeueAfter(requeueAfter time.Duration) (ctrl.Result, error)
func RequeueWithError(err error) (ctrl.Result, error)
func WaitFileCreatedWithTimeout(ctx context.Context, path string, duration time.Duration) bool
type CacheStatusResult
type HttpClient
- func (c *HttpClient) Post(url string, filename types.UID, body io.Reader) (resp *http.Response, err error)

Constants ¶

This section is empty.

Variables ¶

View Source

var DefaultClient = &HttpClient{}

Functions ¶

func CollectAllCacheStatus ¶

func CollectAllCacheStatus(runtimePodNames []string, serviceName string) (*v1alpha1.CacheStatus, error)

func ContainsString ¶

func ContainsString(slice []string, s string) bool

ContainsString Determine whether the string array contains a specific string, return true if contains the string and return false if not.

func DiskSpaceOfPaths ¶

func DiskSpaceOfPaths(timeout time.Duration, paths ...string) (map[string]string, error)

func DiskUsageOfPaths ¶

func DiskUsageOfPaths(timeout time.Duration, paths ...string) (string, error)

func FileNumberOfPaths ¶

func FileNumberOfPaths(timeout time.Duration, paths ...string) (string, error)

func Get ¶

func Get(url string, filename types.UID) (resp *http.Response, err error)

func GetBaseUriByIndex ¶

func GetBaseUriByIndex(runtimeName, serviceName string, index int) string

func GetBaseUriByName ¶

func GetBaseUriByName(runtimePodName, serviceName string) string

func GetCacheStatus ¶

func GetCacheStatus(runtimePodName, serviceName string) (*v1alpha1.CacheStatus, error)

func GetHostName ¶

func GetHostName() (string, error)

func GetJobOption ¶

func GetJobOption(option interface{}, filename types.UID, baseUri, optionPath string) error

func GetJobResult ¶

func GetJobResult(filename types.UID, baseUri, resultPath string) (*common.JobResult, error)

func GetOptionUri ¶

func GetOptionUri(baseUri, optionPath string) string

func GetResultUri ¶

func GetResultUri(baseUri, resultPath string) string

func GetRuntimeImage ¶

func GetRuntimeImage() (string, error)

func GetUploadUri ¶

func GetUploadUri(baseUri, uploadPath string) string

func HasDeletionTimestamp ¶

func HasDeletionTimestamp(obj *metav1.ObjectMeta) bool

HasDeletionTimestamp method to check if an object need to delete.

func HasFinalizer ¶

func HasFinalizer(obj *metav1.ObjectMeta, finalizer string) bool

HasFinalizer check

func JuiceFileNumberOfPath ¶

func JuiceFileNumberOfPath(timeout time.Duration, path ...string) (string, error)

func NoRequeue ¶

func NoRequeue() (ctrl.Result, error)

func NoZeroOptionToArgs ¶

func NoZeroOptionToArgs(options interface{}) []string

func NoZeroOptionToMap ¶

func NoZeroOptionToMap(optionMap map[string]reflect.Value, i interface{})

func Post ¶

func Post(url string, filename types.UID, body io.Reader) (resp *http.Response, err error)

func PostJobOption ¶

func PostJobOption(option interface{}, filename types.UID, baseUri, optionPath, param string) error

func RemoveFinalizer ¶

func RemoveFinalizer(obj *metav1.ObjectMeta, finalizer string)

func RemoveString ¶

func RemoveString(slice []string, s string) (result []string)

func RequeueAfter ¶

func RequeueAfter(requeueAfter time.Duration) (ctrl.Result, error)

func RequeueWithError ¶

func RequeueWithError(err error) (ctrl.Result, error)

func WaitFileCreatedWithTimeout ¶

func WaitFileCreatedWithTimeout(ctx context.Context, path string, duration time.Duration) bool

Types ¶

type CacheStatusResult ¶

type CacheStatusResult struct {
	Status *v1alpha1.CacheStatus
	Error  error
}

type HttpClient ¶

type HttpClient struct {
	http.Client
}

func (*HttpClient) Post ¶

func (c *HttpClient) Post(url string, filename types.UID, body io.Reader) (resp *http.Response, err error)

Source Files ¶

View all Source files

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