client

Documentation

Index

• Variables
• func NewObjectAPI[T interface{}](kc Interface, gvr types.GroupVersionResource, opt ...ObjectAPIOption) types.ObjectAPI[T]
• type DefaultClient
  • func NewInCluster() (*DefaultClient, error)
  • func (kc *DefaultClient) APIServerURL() string
  • func (kc *DefaultClient) Do(req *http.Request) (*http.Response, error)
  • func (kc *DefaultClient) Token() string
• type DefaultLogger
  • func (l *DefaultLogger) Infof(format string, args ...any)
• type Header
• type Interface
• type Logger
• type ObjectAPIOption
  • func WithLogger(log Logger) ObjectAPIOption
  • func WithResponseDecoder(decoderFunc ResponseDecoderFunc) ObjectAPIOption
• type ResourceRequest
• type ResponseDecoder
• type ResponseDecoderFunc

Variables

var ApplyPatchHeader = Header{
	Name:  "content-type",
	Value: "application/apply-patch+yaml",
}

var MergePatchHeader = Header{
	Name:  "content-type",
	Value: "application/merge-patch+json",
}

Functions

func NewObjectAPI

func NewObjectAPI[T interface{}](kc Interface, gvr types.GroupVersionResource, opt ...ObjectAPIOption) types.ObjectAPI[T]

Types

type DefaultClient

type DefaultClient struct {
	HttpClient *http.Client
	// contains filtered or unexported fields
}

func NewInCluster

func NewInCluster() (*DefaultClient, error)

NewInCluster creates Client if it is inside Kubernetes.

func (*DefaultClient) APIServerURL

func (kc *DefaultClient) APIServerURL() string

func (*DefaultClient) Do

func (kc *DefaultClient) Do(req *http.Request) (*http.Response, error)

func (*DefaultClient) Token

func (kc *DefaultClient) Token() string

type DefaultLogger

type DefaultLogger struct {
}

func (*DefaultLogger) Infof

func (l *DefaultLogger) Infof(format string, args ...any)

type Header

type Header struct {
	Name  string
	Value string
}

type Interface

type Interface interface {
	// Do sends HTTP request to ObjectAPI server.
	Do(req *http.Request) (*http.Response, error)
	// Token returns current access token.
	Token() string
	// APIServerURL returns API server URL.
	APIServerURL() string
}

Interface is minimal kubernetes Client interface.

type Logger

type Logger interface {
	Infof(format string, args ...any)
}

type ObjectAPIOption

type ObjectAPIOption func(opts *objectAPIOptions)

func WithLogger

func WithLogger(log Logger) ObjectAPIOption

func WithResponseDecoder

func WithResponseDecoder(decoderFunc ResponseDecoderFunc) ObjectAPIOption

type ResourceRequest

type ResourceRequest struct {
	Verb      string
	Namespace string
	Name      string
	Extra     []string
	Body      io.Reader
}

type ResponseDecoder

type ResponseDecoder interface {
	Decode(v any) error
}

ResponseDecoder allows to specify custom JSON response decoder. By default, std json decoder is used.

type ResponseDecoderFunc

type ResponseDecoderFunc func(r io.Reader) ResponseDecoder