kube

Documentation

Index

• Variables
• type Auth
• type Config
• type DeploymentClient
• type EventClient
• type Fetch
• type Helper
  • func (h *Helper) GetDeployment(name string) (*appsv1.Deployment, error)
  • func (h *Helper) GetNode(name string) (*corev1.Node, error)
  • func (h *Helper) GetNodeIP(nodeName string, addrType string) (string, error)
  • func (h *Helper) GetSVC(name string) (*corev1.Service, error)
  • func (h *Helper) GetSVCNodePortByTargetPort(svcName string, targetPort int) (int, error)
  • func (h *Helper) IsNamespaceExist(namespace string) bool
  • func (h *Helper) ListEvent(opt metav1.ListOptions) (*corev1.EventList, error)
  • func (h *Helper) ListPod(opt metav1.ListOptions) (*corev1.PodList, error)
  • func (h *Helper) RunLeaseCron(ctx *context.Context)
  • func (h *Helper) SetDeploymentClient()
  • func (h *Helper) SetEventClient()
  • func (h *Helper) SetKubeAuth()
  • func (h *Helper) SetLeaseClient(id string, name string, namespace string)
  • func (h *Helper) SetLeaseCron(schedule func())
  • func (h *Helper) SetNamespaceClient()
  • func (h *Helper) SetNodeClient()
  • func (h *Helper) SetPodClient()
  • func (h *Helper) SetSVCClient()
• type LeaseClient
• type NamespaceClient
• type NodeClient
• type PodClient
• type SVCClient

Variables

var (
	InClusterAuth    = "inCluster"
	OutOfClusterAuth = "outOfCluster"
	LeaseRun         = leaderelection.RunOrDie
)

Types

type Auth

type Auth struct {
	Type     string
	Token    string
	FilePath string
	CAFile   string
	RestConf *rest.Config
}

type Config

type Config struct {
	Namespace string
	URL       string
	Auth

	metav1.ListOptions

	Fetch
}

type DeploymentClient

type DeploymentClient interface {
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*appsv1.Deployment, error)
}

type EventClient

type EventClient interface {
	List(ctx context.Context, opts metav1.ListOptions) (*corev1.EventList, error)
}

type Fetch

type Fetch struct {
	Interval int
	Retry    int
}

type Helper

type Helper struct {
	EventClient
	PodClient
	DeploymentClient
	NamespaceClient
	NodeClient
	SVCClient

	LeaseClient
	LeaseID       string
	LeaseCallback leaderelection.LeaderCallbacks

	Config
	// contains filtered or unexported fields
}

func (*Helper) GetDeployment

func (h *Helper) GetDeployment(name string) (*appsv1.Deployment, error)

func (*Helper) GetNode

func (h *Helper) GetNode(name string) (*corev1.Node, error)

func (*Helper) GetNodeIP

func (h *Helper) GetNodeIP(nodeName string, addrType string) (string, error)

func (*Helper) GetSVC

func (h *Helper) GetSVC(name string) (*corev1.Service, error)

func (*Helper) GetSVCNodePortByTargetPort

func (h *Helper) GetSVCNodePortByTargetPort(svcName string, targetPort int) (int, error)

func (*Helper) IsNamespaceExist

func (h *Helper) IsNamespaceExist(namespace string) bool

func (*Helper) ListEvent

func (h *Helper) ListEvent(opt metav1.ListOptions) (*corev1.EventList, error)

func (*Helper) ListPod

func (h *Helper) ListPod(opt metav1.ListOptions) (*corev1.PodList, error)

func (*Helper) RunLeaseCron

func (h *Helper) RunLeaseCron(ctx *context.Context)

func (*Helper) SetDeploymentClient

func (h *Helper) SetDeploymentClient()

func (*Helper) SetEventClient

func (h *Helper) SetEventClient()

func (*Helper) SetKubeAuth

func (h *Helper) SetKubeAuth()

func (*Helper) SetLeaseClient

func (h *Helper) SetLeaseClient(id string, name string, namespace string)

func (*Helper) SetLeaseCron

func (h *Helper) SetLeaseCron(schedule func())

func (*Helper) SetNamespaceClient

func (h *Helper) SetNamespaceClient()

func (*Helper) SetNodeClient

func (h *Helper) SetNodeClient()

func (*Helper) SetPodClient

func (h *Helper) SetPodClient()

func (*Helper) SetSVCClient

func (h *Helper) SetSVCClient()

type LeaseClient

type LeaseClient interface {
	Get(context.Context) (*resourcelock.LeaderElectionRecord, []byte, error)
	Create(context.Context, resourcelock.LeaderElectionRecord) error
	Update(context.Context, resourcelock.LeaderElectionRecord) error
	RecordEvent(string)
	Identity() string
	Describe() string
}

type NamespaceClient

type NamespaceClient interface {
	Get(context.Context, string, metav1.GetOptions) (*v1.Namespace, error)
}

type NodeClient

type NodeClient interface {
	Get(context.Context, string, metav1.GetOptions) (*corev1.Node, error)
}

type PodClient

type PodClient interface {
	List(ctx context.Context, opts metav1.ListOptions) (*corev1.PodList, error)
}

type SVCClient

type SVCClient interface {
	Get(context.Context, string, metav1.GetOptions) (*corev1.Service, error)
}