k8scache

package module

Go to main page

Versions in this module

v1

v1.0.6

Dec 4, 2020

Changes in this version

type ClusterCache

+ func (c *ClusterCache) GetDeploymentsWithLabels(ns string, filter labels.Selector) ([]*v1.Deployment, error)

+ func (c *ClusterCache) GetNamespace(ns string) (*corev1.Namespace, error)

+ func (c *ClusterCache) GetNamespacesWithLabels(filter labels.Selector) ([]*corev1.Namespace, error)

+ func (c *ClusterCache) GetNode(name string) (*corev1.Node, error)

+ func (c *ClusterCache) GetNodesWithLabels(filter labels.Selector) ([]*corev1.Node, error)

+ func (c *ClusterCache) GetPodsWithLabels(ns string, filter labels.Selector) ([]*corev1.Pod, error)

+ func (c *ClusterCache) GetReplicasWithLabels(ns string, filter labels.Selector) ([]*v1.ReplicaSet, error)

+ func (c *ClusterCache) GetServicesWithLabels(ns string, filter labels.Selector) ([]*corev1.Service, error)

+ func (c *ClusterCache) ToLabels(mm map[string]string) labels.Selector

v1.0.5

Nov 29, 2020

Changes in this version

+ var ErrCauseTimeout = errors.New("timeout")

+ var ErrFullQueue = errors.New("channel is full")

+ var ErrNotSupportResource = errors.New("not support resource")

type AnyListener

+ Name string

+ Namespace string

+ func NewAnyListener(ns, name string, uequal func(interface{}) bool) *AnyListener

+ func (p *AnyListener) Equal(obj interface{}) bool

+ func (p *AnyListener) Error() error

+ func (p *AnyListener) IsDone() bool

+ func (p *AnyListener) Notify(ev interface{})

+ func (p *AnyListener) Receive() chan interface{}

+ func (p *AnyListener) Stop()

type Listener

+ Equal func(interface{}) bool

v1.0.4

Nov 28, 2020

Changes in this version

+ var ErrBeyondExpireInterval = errors.New("beyond expire interval")

+ type AnyListener struct

type ClusterCache

+ func (c *ClusterCache) GetAllDaemonsWithLabels(ns string, filter labels.Selector) ([]*v1.DaemonSet, error)

+ func (c *ClusterCache) GetAllEndpointsWithLabels(ns string, filter labels.Selector) ([]*corev1.Endpoints, error)

+ func (c *ClusterCache) GetAllEventsWithLabels(ns string, filter labels.Selector) ([]*corev1.Event, error)

+ func (c *ClusterCache) GetAllStatefulsWithLabels(ns string, filter labels.Selector) ([]*v1.StatefulSet, error)

+ func (c *ClusterCache) Labels(mm map[string]string) labels.Selector

+ func (c *ClusterCache) RegisterListener(lis Listener)

+ func (c *ClusterCache) UnRegisterListener(lis Listener)

+ type Listener interface

+ IsDone func() bool

+ Notify func(interface{})

+ Receive func() chan interface{}

+ Stop func()

+ type ListenerPool struct

+ type PodListener struct

+ Name string

+ Namespace string

+ func NewPodListener(ns, name string, ufunc func(interface{}) bool) *PodListener

+ func (p *PodListener) IsDone() bool

+ func (p *PodListener) Notify(ev interface{})

+ func (p *PodListener) Receive() chan interface{}

+ func (p *PodListener) Stop()

v1.0.3

Nov 26, 2020

Changes in this version

type Client

+ func (cs *Client) SetClient(cli *kubernetes.Clientset)

type ClusterCachePool

+ func NewClusterCachePool() *ClusterCachePool

+ func (cp *ClusterCachePool) Get(id string) (*ClusterCache, bool)

+ func (cp *ClusterCachePool) Set(id string, cc *ClusterCache)

v1.0.2

Nov 26, 2020

v1.0.1

Nov 26, 2020

Changes in this version

+ const TypeEndpoint

type ClusterCache

+ func (c *ClusterCache) GetAllDaemons(ns string) (map[string]*v1.DaemonSet, error)

+ func (c *ClusterCache) GetAllDeployments(ns string) (map[string]*v1.Deployment, error)

+ func (c *ClusterCache) GetAllEndpoints(ns string) (map[string]*corev1.Endpoints, error)

+ func (c *ClusterCache) GetAllEvents(ns string) (map[string]map[string][]*corev1.Event, error)

+ func (c *ClusterCache) GetAllPods(ns string) (map[string]*corev1.Pod, error)

+ func (c *ClusterCache) GetAllReplicas(ns string) (map[string]*v1.ReplicaSet, error)

+ func (c *ClusterCache) GetAllServices(ns string) (map[string]*corev1.Service, error)

+ func (c *ClusterCache) GetAllStatefuls(ns string) (map[string]*v1.StatefulSet, error)

+ func (c *ClusterCache) GetEndpoints(ns string, name string) (*corev1.Endpoints, error)

+ func (c *ClusterCache) GetEvents(ns, kind, name string) ([]*corev1.Event, error)

+ func (c *ClusterCache) SyncEndpointsCache(timeout time.Duration) error

type DataSet

+ Endpoints map[string]*corev1.Endpoints

+ func (d *DataSet) CopyEndpoints() map[string]*corev1.Endpoints

+ func (d *DataSet) CopyEvents() map[string]map[string][]*corev1.Event

v1.0.0

Nov 26, 2020

Changes in this version

+ const TypeDaemonSet

+ const TypeDeployment

+ const TypeEvent

+ const TypeNamespace

+ const TypeNode

+ const TypePod

+ const TypeReplicaSet

+ const TypeService

+ const TypeStatefulSet

+ var ErrCacheNotReady = errors.New("cache not ready, wait to sync full cache in the beginning")

+ var ErrNotFoundName = errors.New("not found name")

+ var ErrNotFoundNamespace = errors.New("not found namespace")

+ var ErrSyncResourceTimeout = errors.New("sync resource timeout")

+ type Client struct

+ func NewClient() (*Client, error)

+ func (cs *Client) BuildForCustomKubecfg(kubecfg string) error

+ func (cs *Client) BuildForInCluster(kubecfg string) error

+ func (cs *Client) BuildForKubecfg() error

+ func (cs *Client) BuildForParams(addr, token, cert, key, ca string) error

+ func (cs *Client) GetClient() *kubernetes.Clientset

+ type ClusterCache struct

+ func NewClusterCache(client *Client, opts ...OptionFunc) (*ClusterCache, error)

+ func (c *ClusterCache) GetDaemon(ns string, name string) (*v1.DaemonSet, error)

+ func (c *ClusterCache) GetDaemons(ns string) (map[string]*v1.DaemonSet, error)

+ func (c *ClusterCache) GetDeployment(ns string, name string) (*v1.Deployment, error)

+ func (c *ClusterCache) GetDeployments(ns string) (map[string]*v1.Deployment, error)

+ func (c *ClusterCache) GetNamespaces() (map[string]*corev1.Namespace, error)

+ func (c *ClusterCache) GetNodes() (map[string]*corev1.Node, error)

+ func (c *ClusterCache) GetPod(ns string, name string) (*corev1.Pod, error)

+ func (c *ClusterCache) GetPodsWithNS(ns string) (map[string]*corev1.Pod, error)

+ func (c *ClusterCache) GetReplica(ns string, name string) (*v1.ReplicaSet, error)

+ func (c *ClusterCache) GetReplicas(ns string) (map[string]*v1.ReplicaSet, error)

+ func (c *ClusterCache) GetService(ns string, name string) (*corev1.Service, error)

+ func (c *ClusterCache) GetServices(ns string) (map[string]*corev1.Service, error)

+ func (c *ClusterCache) GetStateful(ns string, name string) (*v1.StatefulSet, error)

+ func (c *ClusterCache) GetStatefuls(ns string) (map[string]*v1.StatefulSet, error)

+ func (c *ClusterCache) GetUpdateTime(ns string) (time.Time, error)

+ func (c *ClusterCache) ListDaemons(ns string) (*v1.DaemonSetList, error)

+ func (c *ClusterCache) ListDeployments(ns string) (*v1.DeploymentList, error)

+ func (c *ClusterCache) ListEvents(ns string) (*corev1.EventList, error)

+ func (c *ClusterCache) ListPods(ns string) (*corev1.PodList, error)

+ func (c *ClusterCache) ListReplicaSets(ns string) (*v1.ReplicaSetList, error)

+ func (c *ClusterCache) ListServices(ns string) (*corev1.ServiceList, error)

+ func (c *ClusterCache) ListStatefuls(ns string) (*v1.StatefulSetList, error)

+ func (c *ClusterCache) Reset()

+ func (c *ClusterCache) Start()

+ func (c *ClusterCache) Stop()

+ func (c *ClusterCache) SyncCache() error

+ func (c *ClusterCache) SyncCacheWithTimeout(timeout time.Duration) error

+ func (c *ClusterCache) SyncDaemonCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncDeploymentsCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncEventsCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncNamespacesCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncNodesCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncPodsCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncReplicasCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncServicesCache(timeout time.Duration) error

+ func (c *ClusterCache) SyncStatefulCache(timeout time.Duration) error

+ func (c *ClusterCache) Wait()

+ func (c *ClusterCache) WatchDaemons(ns string) (<-chan watch.Event, error)

+ func (c *ClusterCache) WatchDeployments(ns string) (<-chan watch.Event, error)

+ func (c *ClusterCache) WatchEvents(ns string) (<-chan watch.Event, error)

+ func (c *ClusterCache) WatchPods(ns string) (<-chan watch.Event, error)

+ func (c *ClusterCache) WatchReplicaSets(ns string) (<-chan watch.Event, error)

+ func (c *ClusterCache) WatchServices(ns string) (<-chan watch.Event, error)

+ func (c *ClusterCache) WatchStatefuls(ns string) (<-chan watch.Event, error)

+ type ClusterCachePool struct

+ type DataSet struct

+ Daemons map[string]*v1.DaemonSet

+ Deployments map[string]*v1.Deployment

+ Events map[string][]*corev1.Event

+ Namespace string

+ Pods map[string]*corev1.Pod

+ Replicas map[string]*v1.ReplicaSet

+ Services map[string]*corev1.Service

+ StatefulSets map[string]*v1.StatefulSet

+ UpdateAT time.Time

+ func (d *DataSet) CopyDaemons() map[string]*v1.DaemonSet

+ func (d *DataSet) CopyDeployments() map[string]*v1.Deployment

+ func (d *DataSet) CopyPods() map[string]*corev1.Pod

+ func (d *DataSet) CopyReplicas() map[string]*v1.ReplicaSet

+ func (d *DataSet) CopyServices() map[string]*corev1.Service

+ func (d *DataSet) CopyStatefuls() map[string]*v1.StatefulSet

+ type OptionFunc func(*ClusterCache) error

+ func WithContext(ctx context.Context) OptionFunc

+ func WithFollowNamespaces(nlist []string) OptionFunc

+ func WithFollowResource(rlist []string) OptionFunc

+ func WithNamespace(ns string) OptionFunc

+ func WithNotFollowNamespaces(nlist []string) OptionFunc

+ func WithNotFollowResource(rlist []string) OptionFunc

+ func WithStopper(stopper chan struct{}) OptionFunc

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL