kubeclient

Documentation

Index

• type ApplyOptions
• type Client
  • func Get(ctx context.Context) *Client
  • func New(restConfig *rest.Config, scheme *runtime.Scheme) (*Client, error)
  • func (c *Client) Apply(ctx context.Context, obj kube.Object, opt ApplyOptions, out kube.Object) error
  • func (c *Client) Create(ctx context.Context, obj kube.Object) error
  • func (c *Client) Dynamic() dynamic.Interface
  • func (c *Client) Get(ctx context.Context, id types.NamespacedName, obj proto.Message) error
  • func (c *Client) Uncached() client.Client
• type Component
  • func (c *Component) AddToScope(ctx context.Context, scope *scopes.Scope)
  • func (c *Component) RegisterHandlers(s *components.Server, mux *http.ServeMux) error
• type ResourceClient
  • func TypedClient[T proto.Message](client *Client, obj T) *ResourceClient[T]
  • func (c *ResourceClient[T]) List(ctx context.Context, namespace string) ([]T, error)

Types

type ApplyOptions

type ApplyOptions struct {
	FieldManager string
	Force        bool
}

type Client

type Client struct {
	// contains filtered or unexported fields
}

func Get

func Get(ctx context.Context) *Client

func New

func New(restConfig *rest.Config, scheme *runtime.Scheme) (*Client, error)

func (*Client) Apply

func (c *Client) Apply(ctx context.Context, obj kube.Object, opt ApplyOptions, out kube.Object) error

func (*Client) Create

func (c *Client) Create(ctx context.Context, obj kube.Object) error

func (*Client) Dynamic

func (c *Client) Dynamic() dynamic.Interface

func (*Client) Get

func (c *Client) Get(ctx context.Context, id types.NamespacedName, obj proto.Message) error

func (*Client) Uncached

func (c *Client) Uncached() client.Client

type Component

type Component struct {
	Client *Client
}

func (*Component) AddToScope

func (c *Component) AddToScope(ctx context.Context, scope *scopes.Scope)

func (*Component) RegisterHandlers

func (c *Component) RegisterHandlers(s *components.Server, mux *http.ServeMux) error

type ResourceClient

type ResourceClient[T any] struct {
	// contains filtered or unexported fields
}

func TypedClient

func TypedClient[T proto.Message](client *Client, obj T) *ResourceClient[T]

func (*ResourceClient[T]) List

func (c *ResourceClient[T]) List(ctx context.Context, namespace string) ([]T, error)