kube

Documentation

Index

• func NewFakeInformer(_ kubernetes.Interface, namespace string, labelSelector labels.Selector, ...) cache.SharedInformer
• type APIClientsetProvider
• type Association
• type Associations
• type Client
  • func New(logger *zap.Logger, apiCfg k8sconfig.APIConfig, rules ExtractionRules, ...) (Client, error)
• type ClientProvider
• type ExtractionRules
• type FakeController
  • func (c *FakeController) HasStopped() bool
  • func (c *FakeController) HasSynced() bool
  • func (c *FakeController) LastSyncResourceVersion() string
  • func (c *FakeController) Run(stopCh <-chan struct{})
• type FakeInformer
  • func (f *FakeInformer) AddEventHandler(handler cache.ResourceEventHandler)
  • func (f *FakeInformer) AddEventHandlerWithResyncPeriod(handler cache.ResourceEventHandler, period time.Duration)
  • func (f *FakeInformer) GetController() cache.Controller
  • func (f *FakeInformer) GetStore() cache.Store
  • func (f *FakeInformer) SetWatchErrorHandler(cache.WatchErrorHandler) error
• type FieldExtractionRule
• type FieldFilter
• type Filters
• type InformerProvider
• type Pod
• type PodIdentifier
• type WatchClient
  • func (c *WatchClient) GetPod(identifier PodIdentifier) (*Pod, bool)
  • func (c *WatchClient) Start()
  • func (c *WatchClient) Stop()

Functions

func NewFakeInformer

func NewFakeInformer(
	_ kubernetes.Interface,
	namespace string,
	labelSelector labels.Selector,
	fieldSelector fields.Selector,
) cache.SharedInformer

Types

type APIClientsetProvider

type APIClientsetProvider func(config k8sconfig.APIConfig) (kubernetes.Interface, error)

APIClientsetProvider defines a func type that initializes and return a new kubernetes Clientset object.

type Association

type Association struct {
	From string
	Name string
}

Association represents one association rule

type Associations

type Associations struct {
	Associations []Association
}

Associations represent a list of rules for Pod metadata associations with resources

type Client

type Client interface {
	GetPod(PodIdentifier) (*Pod, bool)
	Start()
	Stop()
}

Client defines the main interface that allows querying pods by metadata.

func New

func New(logger *zap.Logger, apiCfg k8sconfig.APIConfig, rules ExtractionRules, filters Filters, associations []Association, newClientSet APIClientsetProvider, newInformer InformerProvider) (Client, error)

New initializes a new k8s Client.

type ClientProvider

type ClientProvider func(*zap.Logger, k8sconfig.APIConfig, ExtractionRules, Filters, []Association, APIClientsetProvider, InformerProvider) (Client, error)

ClientProvider defines a func type that returns a new Client.

type ExtractionRules

type ExtractionRules struct {
	Deployment bool
	Namespace  bool
	PodName    bool
	PodUID     bool
	Node       bool
	Cluster    bool
	StartTime  bool

	Annotations []FieldExtractionRule
	Labels      []FieldExtractionRule
}

ExtractionRules is used to specify the information that needs to be extracted from pods and added to the spans as tags.

type FakeController

type FakeController struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*FakeController) HasStopped

func (c *FakeController) HasStopped() bool

func (*FakeController) HasSynced

func (c *FakeController) HasSynced() bool

func (*FakeController) LastSyncResourceVersion

func (c *FakeController) LastSyncResourceVersion() string

func (*FakeController) Run

func (c *FakeController) Run(stopCh <-chan struct{})

type FakeInformer

type FakeInformer struct {
	*FakeController
	// contains filtered or unexported fields
}

func (*FakeInformer) AddEventHandler

func (f *FakeInformer) AddEventHandler(handler cache.ResourceEventHandler)

func (*FakeInformer) AddEventHandlerWithResyncPeriod

func (f *FakeInformer) AddEventHandlerWithResyncPeriod(handler cache.ResourceEventHandler, period time.Duration)

func (*FakeInformer) GetController

func (f *FakeInformer) GetController() cache.Controller

func (*FakeInformer) GetStore

func (f *FakeInformer) GetStore() cache.Store

func (*FakeInformer) SetWatchErrorHandler

func (f *FakeInformer) SetWatchErrorHandler(cache.WatchErrorHandler) error

type FieldExtractionRule

type FieldExtractionRule struct {
	// Name is used to as the Span tag name.
	Name string
	// Key is used to lookup k8s pod fields.
	Key string
	// Regex is a regular expression used to extract a sub-part of a field value.
	// Full value is extracted when no regexp is provided.
	Regex *regexp.Regexp
}

FieldExtractionRule is used to specify which fields to extract from pod fields and inject into spans as attributes.

type FieldFilter

type FieldFilter struct {
	// Key matches the field name.
	Key string
	// Value matches the field value.
	Value string
	// Op determines the matching operation.
	// Currently only two operations are supported,
	//  - Equals
	//  - NotEquals
	Op selection.Operator
}

FieldFilter represents exactly one filter by field rule.

type Filters

type Filters struct {
	Node      string
	Namespace string
	Fields    []FieldFilter
	Labels    []FieldFilter
}

Filters is used to instruct the client on how to filter out k8s pods. Right now only filters supported are the ones supported by k8s API itself for performance reasons. We can support adding additional custom filters in future if there is a real need.

type InformerProvider

type InformerProvider func(
	client kubernetes.Interface,
	namespace string,
	labelSelector labels.Selector,
	fieldSelector fields.Selector,
) cache.SharedInformer

InformerProvider defines a function type that returns a new SharedInformer. It is used to allow passing custom shared informers to the watch client.

type Pod

type Pod struct {
	Name       string
	Address    string
	PodUID     string
	Attributes map[string]string
	StartTime  *metav1.Time
	Ignore     bool

	DeletedAt time.Time
}

Pod represents a kubernetes pod.

type PodIdentifier

type PodIdentifier string

PodIdentifier is a custom type to represent IP Address or Pod UID

type WatchClient

type WatchClient struct {

	// A map containing Pod related data, used to associate them with resources.
	// Key can be either an IP address or Pod UID
	Pods         map[PodIdentifier]*Pod
	Rules        ExtractionRules
	Filters      Filters
	Associations []Association
	// contains filtered or unexported fields
}

WatchClient is the main interface provided by this package to a kubernetes cluster.

func (*WatchClient) GetPod

func (c *WatchClient) GetPod(identifier PodIdentifier) (*Pod, bool)

GetPod takes an IP address or Pod UID and returns the pod the identifier is associated with.

func (*WatchClient) Start

func (c *WatchClient) Start()

Start registers pod event handlers and starts watching the kubernetes cluster for pod changes.

func (*WatchClient) Stop

func (c *WatchClient) Stop()

Stop signals the the k8s watcher/informer to stop watching for new events.