clients

Documentation

Index

• type NoopClient
  • func (f *NoopClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (f *NoopClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (f *NoopClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (f *NoopClient) Get(ctx context.Context, key client.ObjectKey, obj runtime.Object) error
  • func (f *NoopClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (f *NoopClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (f *NoopClient) RESTMapper() meta.RESTMapper
  • func (f *NoopClient) Scheme() *runtime.Scheme
  • func (f *NoopClient) Status() client.StatusWriter
  • func (f *NoopClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type RetryClient
  • func NewRetryClient(c client.Client) *RetryClient
  • func (c *RetryClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (c *RetryClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (c *RetryClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (c *RetryClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error
  • func (c *RetryClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (c *RetryClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (c *RetryClient) Status() client.StatusWriter
  • func (c *RetryClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type RetryStatusWriter
  • func (c *RetryStatusWriter) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (c *RetryStatusWriter) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

Types

type NoopClient

type NoopClient struct{}

func (*NoopClient) Create

func (f *NoopClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*NoopClient) Delete

func (f *NoopClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*NoopClient) DeleteAllOf

func (f *NoopClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*NoopClient) Get

func (f *NoopClient) Get(ctx context.Context, key client.ObjectKey, obj runtime.Object) error

func (*NoopClient) List

func (f *NoopClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*NoopClient) Patch

func (f *NoopClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*NoopClient) RESTMapper

func (f *NoopClient) RESTMapper() meta.RESTMapper

func (*NoopClient) Scheme

func (f *NoopClient) Scheme() *runtime.Scheme

func (*NoopClient) Status

func (f *NoopClient) Status() client.StatusWriter

func (*NoopClient) Update

func (f *NoopClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type RetryClient

type RetryClient struct {
	Limiter *rate.Limiter
	client.Client
}

RetryClient wraps a client to provide rate-limiter respecting retry behavior.

func NewRetryClient

func NewRetryClient(c client.Client) *RetryClient

func (*RetryClient) Create

func (c *RetryClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*RetryClient) Delete

func (c *RetryClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*RetryClient) DeleteAllOf

func (c *RetryClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*RetryClient) Get

func (c *RetryClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

func (*RetryClient) List

func (c *RetryClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*RetryClient) Patch

func (c *RetryClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*RetryClient) Status

func (c *RetryClient) Status() client.StatusWriter

func (*RetryClient) Update

func (c *RetryClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type RetryStatusWriter

type RetryStatusWriter struct {
	client.StatusWriter
	Limiter *rate.Limiter
}

func (*RetryStatusWriter) Patch

func (c *RetryStatusWriter) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*RetryStatusWriter) Update

func (c *RetryStatusWriter) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error