util

Documentation

Index

• func IsTransientClientErr(err error) bool
• func StartLease()
• type ReloadableHubClient
  • func NewReloadableHubClient(filePath string, clientScheme *runtime.Scheme) (*ReloadableHubClient, error)
  • func NewReloadableHubClientWithReloadFunc(reload func() (client.Client, error)) (*ReloadableHubClient, error)
  • func (c *ReloadableHubClient) Reload() (*ReloadableHubClient, error)

Functions

func IsTransientClientErr

func IsTransientClientErr(err error) bool

IsTransientClientErr checks if the error is a transient error This suggests that a retry (without any change) might be successful

func StartLease

func StartLease()

Types

type ReloadableHubClient

type ReloadableHubClient struct {
	client.Client
	// contains filtered or unexported fields
}

ReloadableHubClient is a wrapper around the hub client that allows reloading the client. This is useful when the kubeconfig file is updated.

func NewReloadableHubClient

func NewReloadableHubClient(filePath string, clientScheme *runtime.Scheme) (*ReloadableHubClient, error)

NewReloadableHubClient creates a new hub client with a reload function.

func NewReloadableHubClientWithReloadFunc

func NewReloadableHubClientWithReloadFunc(reload func() (client.Client, error)) (*ReloadableHubClient, error)

NewReloadableHubClientWithReloadFunc creates a new hub client with a reload function. The reload function is called when the Reload method is called. This can be handy for testing purposes.

func (*ReloadableHubClient) Reload

func (c *ReloadableHubClient) Reload() (*ReloadableHubClient, error)

Reload reloads the hub client and returns a new instance of HubClientWithReload. HubClientWithReload is immutable.