Documentation ¶
Index ¶
- type EpClient
- type JobClient
- type K8sClient
- func (c *K8sClient) GetClientSet() kubernetes.Interface
- func (c *K8sClient) GetEpClient() EpClient
- func (c *K8sClient) GetJobClient() JobClient
- func (c *K8sClient) GetNodeClient() NodeClient
- func (c *K8sClient) GetPodClient() PodClient
- func (c *K8sClient) GetReplicaSetClient() ReplicaSetClient
- func (c *K8sClient) Shutdown()
- func (c *K8sClient) ShutdownEpClient()
- func (c *K8sClient) ShutdownJobClient()
- func (c *K8sClient) ShutdownNodeClient()
- func (c *K8sClient) ShutdownPodClient()
- func (c *K8sClient) ShutdownReplicaSetClient()
- type NodeClient
- type ObjStore
- func (s *ObjStore) Add(obj interface{}) error
- func (s *ObjStore) Delete(obj interface{}) error
- func (s *ObjStore) Get(obj interface{}) (item interface{}, exists bool, err error)
- func (s *ObjStore) GetByKey(key string) (item interface{}, exists bool, err error)
- func (s *ObjStore) GetResetRefreshStatus() bool
- func (s *ObjStore) List() []interface{}
- func (s *ObjStore) ListKeys() []string
- func (s *ObjStore) Replace(list []interface{}, _ string) error
- func (s *ObjStore) Resync() error
- func (s *ObjStore) Update(obj interface{}) error
- type Option
- type PodClient
- type ReplicaSetClient
- type Service
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type K8sClient ¶
type K8sClient struct {
// contains filtered or unexported fields
}
func Get ¶
Get returns a singleton instance of k8s client If the intialization fails, it returns nil
func (*K8sClient) GetClientSet ¶ added in v0.30.0
func (c *K8sClient) GetClientSet() kubernetes.Interface
func (*K8sClient) GetEpClient ¶ added in v0.30.0
func (*K8sClient) GetJobClient ¶ added in v0.30.0
func (*K8sClient) GetNodeClient ¶ added in v0.30.0
func (c *K8sClient) GetNodeClient() NodeClient
func (*K8sClient) GetPodClient ¶ added in v0.30.0
func (*K8sClient) GetReplicaSetClient ¶ added in v0.30.0
func (c *K8sClient) GetReplicaSetClient() ReplicaSetClient
func (*K8sClient) ShutdownEpClient ¶ added in v0.30.0
func (c *K8sClient) ShutdownEpClient()
func (*K8sClient) ShutdownJobClient ¶ added in v0.30.0
func (c *K8sClient) ShutdownJobClient()
func (*K8sClient) ShutdownNodeClient ¶ added in v0.30.0
func (c *K8sClient) ShutdownNodeClient()
func (*K8sClient) ShutdownPodClient ¶ added in v0.30.0
func (c *K8sClient) ShutdownPodClient()
func (*K8sClient) ShutdownReplicaSetClient ¶ added in v0.30.0
func (c *K8sClient) ShutdownReplicaSetClient()
type NodeClient ¶
type ObjStore ¶
type ObjStore struct {
// contains filtered or unexported fields
}
ObjStore implements the cache.Store interface: https://github.com/kubernetes/client-go/blob/release-1.20/tools/cache/store.go#L26-L71 It is used by cache.Reflector to keep the updated information about resources https://github.com/kubernetes/client-go/blob/release-1.20/tools/cache/reflector.go#L48
func NewObjStore ¶
func (*ObjStore) Add ¶
Add implements the Add method of the store interface. Add adds an entry to the ObjStore.
func (*ObjStore) Delete ¶
Delete implements the Delete method of the store interface. Delete deletes an existing entry in the ObjStore.
func (*ObjStore) GetResetRefreshStatus ¶
GetResetRefreshStatus tracks whether the underlying data store is refreshed or not. Calling this func itself will reset the state to false.
func (*ObjStore) List ¶
func (s *ObjStore) List() []interface{}
List implements the List method of the store interface. List lists all the objects in the ObjStore
func (*ObjStore) ListKeys ¶
ListKeys implements the ListKeys method of the store interface. ListKeys lists the keys for all objects in the ObjStore
func (*ObjStore) Replace ¶
Replace implements the Replace method of the store interface. Replace will delete the contents of the store, using instead the given list.
type Option ¶
type Option struct {
// contains filtered or unexported fields
}
Option is a struct that can be used to change the configuration of passed K8sClient It can be used as an option to the Get(...) function to create a customized K8sClient
func InitSyncPollInterval ¶
InitSyncPollInterval provides the option to set the init sync poll interval for testing connection to kubernetes api server
func InitSyncPollTimeout ¶
InitSyncPollTimeout provides the option to set the init sync poll timeout for testing connection to kubernetes api server
func KubeConfigPath ¶
KubeConfigPath provides the option to set the kube config which will be used if the service account that kubernetes gives to pods can't be used