kubernetes

Documentation

Index

• func DetectKubeConfig() (config *rest.Config, err error)
• func ErrApplyManifest(err error) error
• func ErrServiceDiscovery(err error) error
• type ApplyOptions
• type Client
  • func New(clientset kubernetes.Interface, cfg rest.Config) (*Client, error)
  • func (client *Client) ApplyManifest(contents []byte, recvOptions ApplyOptions) error
  • func (client *Client) GetServiceEndpoint(ctx context.Context, svcName, namespace string) (*utils.Endpoint, error)

Functions

func DetectKubeConfig

func DetectKubeConfig() (config *rest.Config, err error)

DetectKubeConfig detects the kubeconfig for the kubernetes cluster and returns it

func ErrApplyManifest

func ErrApplyManifest(err error) error

func ErrServiceDiscovery

func ErrServiceDiscovery(err error) error

ErrServiceDiscovery returns an error of type "ErrServiceDiscovery" along with the passed error

Types

type ApplyOptions

type ApplyOptions struct {
	Namespace string
	Update    bool
	Delete    bool
}

type Client

type Client struct {
	RestConfig rest.Config          `json:"restconfig,omitempty"`
	Clientset  kubernetes.Interface `json:"clientset,omitempty"`
}

func New

func New(clientset kubernetes.Interface, cfg rest.Config) (*Client, error)

func (*Client) ApplyManifest

func (client *Client) ApplyManifest(contents []byte, recvOptions ApplyOptions) error

ApplyManifest applies, updates or deletes resources as specified in ApplyOptions. The namespace specified in ApplyOptions is used, if no namespace is specified then the namespace from manifest is used. If the the namespace does not exists, it will be created.

func (*Client) GetServiceEndpoint

func (client *Client) GetServiceEndpoint(ctx context.Context, svcName, namespace string) (*utils.Endpoint, error)

GetServiceEndpoint returns the endpoint for the given service