k8s

Documentation

Index

• func NewClusterSet()
• type ClientSets
  • func NewClientSets(conf Conf, stop chan struct{}) (*ClientSets, error)
  • func (c *ClientSets) Stop()
• type ClusterSet
  • func (c *ClusterSet) Add(clusterName string, clientSets *ClientSets)
  • func (c *ClusterSet) Delete(clusterName string)
  • func (c *ClusterSet) Get(clusterName string) *ClientSets
  • func (c *ClusterSet) List() map[string]*ClientSets
  • func (c *ClusterSet) Update(clusterName string, clientSets *ClientSets)
• type Conf
• type CoreV1
  • func NewCoreV1Store(c kubernetes.Interface, metricsClientSet versioned.Interface, ...) *CoreV1
  • func (c *CoreV1) Deployments() IDeploymentAction
  • func (c *CoreV1) Events() IEventAction
  • func (c *CoreV1) Jobs() IJobAction
  • func (c *CoreV1) Namespaces() INamespaceAction
  • func (c *CoreV1) Nodes() INodeAction
  • func (c *CoreV1) Pods() IPodAction
  • func (c *CoreV1) Services() IServiceAction
  • func (c *CoreV1) StatefulSets() IStatefulSetAction
• type IClusterSet
  • func GetClusterSets() IClusterSet
• type ICoreV1Store
  • func GetClient() ICoreV1Store
• type IDeployment
• type IDeploymentAction
• type IEvent
• type IEventAction
• type IJob
• type IJobAction
• type INamespace
• type INamespaceAction
• type INode
• type INodeAction
• type IPod
• type IPodAction
• type IService
• type IServiceAction
• type IStatefulSet
• type IStatefulSetAction

Functions

func NewClusterSet

func NewClusterSet()

Types

type ClientSets

type ClientSets struct {
	NeuroK8sClient ICoreV1Store
	K8sClient      kubernetes.Interface
	MetricsClient  versioned.Interface
	InformerClient informer.Storer
	// contains filtered or unexported fields
}

func NewClientSets

func NewClientSets(conf Conf, stop chan struct{}) (*ClientSets, error)

func (*ClientSets) Stop

func (c *ClientSets) Stop()

type ClusterSet

type ClusterSet struct {
	// contains filtered or unexported fields
}

func (*ClusterSet) Add

func (c *ClusterSet) Add(clusterName string, clientSets *ClientSets)

func (*ClusterSet) Delete

func (c *ClusterSet) Delete(clusterName string)

func (*ClusterSet) Get

func (c *ClusterSet) Get(clusterName string) *ClientSets

func (*ClusterSet) List

func (c *ClusterSet) List() map[string]*ClientSets

func (*ClusterSet) Update

func (c *ClusterSet) Update(clusterName string, clientSets *ClientSets)

type Conf

type Conf struct {
	KubeConfigPath  string `yaml:"kubeConfigPath"`
	Pvc             string `yaml:"pvc"`
	Namespace       string `yaml:"namespace"`
	ResourceMonitor string `yaml:"resourceMonitor"`
}

type CoreV1

type CoreV1 struct {
	KubeConfigPath string
	Informer       informer.Storer
	Client         kubernetes.Interface
	MetricsClient  versioned.Interface
}

func NewCoreV1Store

func NewCoreV1Store(c kubernetes.Interface, metricsClientSet versioned.Interface, informer informer.Storer, kubeConfigPath string) *CoreV1

func (*CoreV1) Deployments

func (c *CoreV1) Deployments() IDeploymentAction

func (*CoreV1) Events

func (c *CoreV1) Events() IEventAction

func (*CoreV1) Jobs

func (c *CoreV1) Jobs() IJobAction

func (*CoreV1) Namespaces

func (c *CoreV1) Namespaces() INamespaceAction

func (*CoreV1) Nodes

func (c *CoreV1) Nodes() INodeAction

func (*CoreV1) Pods

func (c *CoreV1) Pods() IPodAction

func (*CoreV1) Services

func (c *CoreV1) Services() IServiceAction

func (*CoreV1) StatefulSets

func (c *CoreV1) StatefulSets() IStatefulSetAction

type IClusterSet

type IClusterSet interface {
	Add(clusterName string, clientSets *ClientSets)
	Update(clusterName string, clientSets *ClientSets)
	Delete(clusterName string)
	Get(clusterName string) *ClientSets
	List() map[string]*ClientSets
}

func GetClusterSets

func GetClusterSets() IClusterSet

type ICoreV1Store

type ICoreV1Store interface {
	IPod
	IDeployment
	IService
	IStatefulSet
	IJob
	IEvent
	INode
	INamespace
}

func GetClient

func GetClient() ICoreV1Store

type IDeployment

type IDeployment interface {
	Deployments() IDeploymentAction
}

type IDeploymentAction

type IDeploymentAction interface {
	Create(ctx context.Context, deployment *v1.Deployment, options meta.CreateOptions) error
	Update(ctx context.Context, deployment *v1.Deployment, options meta.UpdateOptions) error
	Delete(ctx context.Context, options meta.DeleteOptions) error
	List(ctx context.Context, options meta.ListOptions) ([]*v1.Deployment, error)
	Get(ctx context.Context, options meta.GetOptions) (*v1.Deployment, error)
	Restart(ctx context.Context, options meta.RestartOptions) error
}

type IEvent

type IEvent interface {
	Events() IEventAction
}

type IEventAction

type IEventAction interface {
	List(ctx context.Context, options meta.ListOptions) ([]v1.Event, error)
	Get(ctx context.Context, args apiv1.Event, options meta.GetOptions) ([]v1.Event, error)
}

type IJob

type IJob interface {
	Jobs() IJobAction
}

type IJobAction

type IJobAction interface {
	Create(ctx context.Context, job *batchv1.Job, createOptions meta.CreateOptions) error
	Delete(ctx context.Context, deleteOptions meta.DeleteOptions) error
	Get(ctx context.Context, getOptions meta.GetOptions) (*batchv1.Job, error)
	List(ctx context.Context, listOptions meta.ListOptions) ([]*batchv1.Job, error)
}

type INamespace

type INamespace interface {
	Namespaces() INamespaceAction
}

type INamespaceAction

type INamespaceAction interface {
	List(ctx context.Context) ([]*v1.Namespace, error)
}

type INode

type INode interface {
	Nodes() INodeAction
}

type INodeAction

type INodeAction interface {
	Get(ctx context.Context, getOptions meta.GetOptions) (*v1.Node, error)
	List(ctx context.Context, listOptions meta.ListOptions) ([]*v1.Node, error)
}

type IPod

type IPod interface {
	Pods() IPodAction
}

type IPodAction

type IPodAction interface {
	Get(ctx context.Context, options meta.GetOptions) (*v1.Pod, error)
	List(ctx context.Context, options meta.ListOptions) ([]*v1.Pod, error)
	Top(ctx context.Context, options meta.TopOptions) (*apiv1.TopPod, error)
	Logs(ctx context.Context, w http.ResponseWriter, r *http.Request, options meta.LogOptions) error
	Command(ctx context.Context, w http.ResponseWriter, r *http.Request, options *meta.TerminalOptions) error
}

type IService

type IService interface {
	Services() IServiceAction
}

type IServiceAction

type IServiceAction interface {
	Create(ctx context.Context, service *v1.Service, options meta.CreateOptions) error
	Update(ctx context.Context, service *v1.Service, options meta.UpdateOptions) error
	Delete(ctx context.Context, options meta.DeleteOptions) error
	Get(ctx context.Context, options meta.GetOptions) (*v1.Service, error)
	List(ctx context.Context, options meta.ListOptions) ([]*v1.Service, error)
}

type IStatefulSet

type IStatefulSet interface {
	StatefulSets() IStatefulSetAction
}

type IStatefulSetAction

type IStatefulSetAction interface {
	Create(ctx context.Context, statefulSet *v1.StatefulSet, options meta.CreateOptions) error
	Update(ctx context.Context, statefulSet *v1.StatefulSet, options meta.UpdateOptions) error
	Delete(ctx context.Context, options meta.DeleteOptions) error
	Get(ctx context.Context, options meta.GetOptions) (*v1.StatefulSet, error)
	List(ctx context.Context, options meta.ListOptions) ([]*v1.StatefulSet, error)
}