utils

package

v0.6.0 Latest Latest Go to latest Published: Jul 1, 2025 License: Apache-2.0 Imports: 7 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamnative/pulsarctl

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Convert(value string) (map[string]string, error)
func ConvertMap(i interface{}) interface{}
func InferMissingFunctionName(funcConf *utils.FunctionConfig)
func InferMissingNamespace(funcConf *utils.FunctionConfig)
func InferMissingSinkeArguments(sinkConf *utils.SinkConfig)
func InferMissingSourceArguments(sourceConf *utils.SourceConfig)
func InferMissingTenant(funcConf *utils.FunctionConfig)
func IsFileExist(filename string) bool
func IsPackageURLSupported(functionPkgURL string) bool
func NumProvidedStrings(sPointers ...*string) int
func ParseRelativeTimeInSeconds(relativeTime string) (time.Duration, error)
func ValidateSizeString(s string) (int64, error)

Constants ¶

View Source

const (
	HTTP    = "http"
	FILE    = "file"
	BUILTIN = "builtin"

	FUNCTION = "function"
	SINK     = "sink"
	SOURCE   = "source"

	PublicTenant     = "public"
	DefaultNamespace = "default"
)

Variables ¶

This section is empty.

Functions ¶

func Convert ¶

func Convert(value string) (map[string]string, error)

func ConvertMap ¶ added in v0.6.0

func ConvertMap(i interface{}) interface{}

ConvertMap converts a map[interface{}]interface{} to map[string]interface{}

func InferMissingFunctionName ¶

func InferMissingFunctionName(funcConf *utils.FunctionConfig)

func InferMissingNamespace ¶

func InferMissingNamespace(funcConf *utils.FunctionConfig)

func InferMissingSinkeArguments ¶

func InferMissingSinkeArguments(sinkConf *utils.SinkConfig)

func InferMissingSourceArguments ¶

func InferMissingSourceArguments(sourceConf *utils.SourceConfig)

func InferMissingTenant ¶

func InferMissingTenant(funcConf *utils.FunctionConfig)

func IsFileExist ¶

func IsFileExist(filename string) bool

func IsPackageURLSupported ¶

func IsPackageURLSupported(functionPkgURL string) bool

func NumProvidedStrings ¶ added in v0.6.0

func NumProvidedStrings(sPointers ...*string) int

func ParseRelativeTimeInSeconds ¶

func ParseRelativeTimeInSeconds(relativeTime string) (time.Duration, error)

func ValidateSizeString ¶

func ValidateSizeString(s string) (int64, error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

util.go

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