Documentation
¶
Index ¶
- func CheckConnection(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
- func CheckUnauthenticatedAccess(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
- func GetAndWait[O runtime.Object](ctx context.Context, timeout time.Duration, get Getter[O], name string, ...) (O, error)
- func GetRetry[O runtime.Object](ctx context.Context, getter Getter[O], name string, opts ...GetOption) (O, error)
- func ListAndWait[O runtime.Object](ctx context.Context, timeout time.Duration, list Lister[O], ready func(O) bool, ...) (O, error)
- func ListRetry[O runtime.Object](ctx context.Context, lister Lister[O], opts ...ListOption) (O, error)
- func MakeUnauthenticatedRequest(ctx context.Context, endpoint string, caCertificate []byte) error
- func WaitFor[O runtime.Object](ctx context.Context, timeout time.Duration, read Read[O], ready func(O) bool) (O, error)
- type AccessValidator
- type GetOption
- type GetOptions
- type Getter
- type GetterDynamic
- type GetterFromDynamic
- type ListOption
- type ListOptions
- type Lister
- type Read
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckConnection ¶
func CheckConnection(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
func CheckUnauthenticatedAccess ¶
func CheckUnauthenticatedAccess(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
func GetAndWait ¶ added in v1.0.6
func GetAndWait[O runtime.Object](ctx context.Context, timeout time.Duration, get Getter[O], name string, ready func(O) bool) (O, error)
GetAndWait waits for an object to meet a condition. It will retry until the timeout is reached or the condition is met. To allow for longer wait times while avoiding to retry non-transient errors, we only retry up to 3 consecutive errors coming from the API server.
func GetRetry ¶ added in v1.0.6
func GetRetry[O runtime.Object](ctx context.Context, getter Getter[O], name string, opts ...GetOption) (O, error)
GetRetry retries the get request until it succeeds or the retry limit is reached.
func ListAndWait ¶ added in v1.0.6
func ListAndWait[O runtime.Object](ctx context.Context, timeout time.Duration, list Lister[O], ready func(O) bool, opts ...ListOption) (O, error)
ListAndWait waits for a list of objects to meet a condition. It will retry until the timeout is reached or the condition is met. To allow for longer wait times while avoiding to retry non-transient errors, we only retry up to 3 consecutive errors coming from the API server.
func ListRetry ¶ added in v1.0.6
func ListRetry[O runtime.Object](ctx context.Context, lister Lister[O], opts ...ListOption) (O, error)
ListRetry retries the list request until it succeeds or the retry limit is reached.
func WaitFor ¶ added in v1.0.6
func WaitFor[O runtime.Object](ctx context.Context, timeout time.Duration, read Read[O], ready func(O) bool) (O, error)
WaitFor waits for an object/s to meet a condition. It will retry until the timeout is reached or the condition is met. To allow for longer wait times while avoiding to retry non-transient errors, we only retry up to 3 consecutive errors coming from the API server.
Types ¶
type AccessValidator ¶
type AccessValidator struct {
// contains filtered or unexported fields
}
func NewAccessValidator ¶
func NewAccessValidator(config aws.Config) AccessValidator
func (AccessValidator) Run ¶
func (a AccessValidator) Run(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
type GetOption ¶ added in v1.0.6
type GetOption func(*GetOptions)
GetOption is an option for the Get request.
type GetOptions ¶ added in v1.0.6
type GetOptions struct {
metav1.GetOptions
}
GetOptions configures a Get request.
type Getter ¶ added in v1.0.6
type Getter[O runtime.Object] interface { Get(ctx context.Context, name string, options metav1.GetOptions) (O, error) }
Getter retrieves an object of type O from the Kubernetes API. It matches the Get signature of client-go clients.
type GetterDynamic ¶ added in v1.0.6
type GetterDynamic[O runtime.Object] interface { Get(ctx context.Context, name string, options metav1.GetOptions, subresources ...string) (O, error) }
GetterDynamic retrieves an object of type O from the Kubernetes API. It matches the Get signature of client-go dynamic client.
type GetterFromDynamic ¶ added in v1.0.6
type GetterFromDynamic[O runtime.Object] struct { GetterDynamic[O] }
GetterFromDynamic converts a dynamic client to a Getter.
func GetterForDynamic ¶ added in v1.0.6
func GetterForDynamic[O runtime.Object](dyn GetterDynamic[O]) *GetterFromDynamic[O]
GetterForDynamic makes a Getter from a dynamic client.
func (*GetterFromDynamic[O]) Get ¶ added in v1.0.6
func (g *GetterFromDynamic[O]) Get(ctx context.Context, name string, options metav1.GetOptions) (O, error)
type ListOption ¶ added in v1.0.6
type ListOption func(*ListOptions)
ListOption is an option for the List request.
type ListOptions ¶ added in v1.0.6
type ListOptions struct {
metav1.ListOptions
}
ListOptions configures a List request.
Source Files