Documentation
¶
Index ¶
- func CheckExistingContext(contextName, kubeconfig string) bool
- func ContextWithCancelOnSignals(ctx context.Context, sigs ...os.Signal) context.Context
- func CurrentAccount(user *v1.User) (string, error)
- func Die(err error, cause ...string)
- func Doc(doc string) string
- func JoinManifests(manifests ...[]byte) []byte
- func KubeContexts(kubeconfig string) []kubeContext
- func KubeCurrentContextName(kubeconfig string) string
- func KubeServerByContextName(contextName, kubeconfig string) (string, error)
- func MustParseDuration(dur string) time.Duration
- func OpenBrowserForGitLogin(ingressHost string, user string, account string) error
- func ReverseMap[K, V comparable](gitProviders map[K]V) map[V]K
- func SplitManifests(manifests []byte) [][]byte
- func StringIndexOf(slice []string, val string) int
- type AsyncRunner
- type RetryOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckExistingContext ¶
func ContextWithCancelOnSignals ¶
ContextWithCancelOnSignals returns a context that is canceled when one of the specified signals are received
func Die ¶
Die panics it the error is not nil. If a cause string is provided it will be displayed in the error message.
func Doc ¶
Doc returns a string where all the '<BIN>' are replaced with the binary name and all the '\t' are replaced with a uniformed indentation using space.
func JoinManifests ¶
JoinManifests concats all of the provided yaml manifests with a yaml separator.
func KubeContexts ¶
func KubeContexts(kubeconfig string) []kubeContext
func KubeCurrentContextName ¶
func KubeServerByContextName ¶
func MustParseDuration ¶
MustParseDuration parses the given string as "time.Duration", or panic.
func OpenBrowserForGitLogin ¶
func ReverseMap ¶
func ReverseMap[K, V comparable](gitProviders map[K]V) map[V]K
func SplitManifests ¶
func StringIndexOf ¶
Types ¶
type AsyncRunner ¶
type AsyncRunner struct {
// contains filtered or unexported fields
}
func NewAsyncRunner ¶
func NewAsyncRunner(n int) *AsyncRunner
NewAsyncRunner initializes a new AsyncRunner that can run up to n async operations.
func (*AsyncRunner) Run ¶
func (ar *AsyncRunner) Run(f func() error)
Run runs another async operation
func (*AsyncRunner) Wait ¶
func (ar *AsyncRunner) Wait() error
Wait waits for all async operations to finish and returns an error if one of the async operations returned an error, otherwise, returns nil.
Source Files
Directories