cluster

Documentation

Index

• func NewTraceId() string
• type AgentClient
  • func NewAgentClient(models *model.Models) *AgentClient
• type KubeClient
  • func NewKubeClient(models *model.Models) *KubeClient
  • func (k *KubeClient) Apply(clusterId string, params interface{}) *utils.Response
  • func (k *KubeClient) Create(clusterId, resType string, params interface{}) *utils.Response
  • func (k *KubeClient) Delete(clusterId, resType string, params interface{}) *utils.Response
  • func (k *KubeClient) Get(clusterId, resType string, params interface{}) *utils.Response
  • func (k *KubeClient) List(clusterId, resType string, params interface{}) *utils.Response
  • func (k *KubeClient) Patch(clusterId, resType string, params interface{}) *utils.Response
  • func (k *KubeClient) Pods(clusterId string) (PodClient, error)
  • func (k *KubeClient) Request(clusterId, resType, action string, params interface{}) *utils.Response
  • func (k *KubeClient) Update(clusterId, resType string, params interface{}) *utils.Response
  • func (k *KubeClient) Watch(clusterId, resType string, params interface{}) (Outer, error)
• type Outer
• type PodClient
• type PodExec

Functions

func NewTraceId

func NewTraceId() string

Types

type AgentClient

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

func NewAgentClient

func NewAgentClient(models *model.Models) *AgentClient

type KubeClient

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

func NewKubeClient

func NewKubeClient(models *model.Models) *KubeClient

func (*KubeClient) Apply

func (k *KubeClient) Apply(clusterId string, params interface{}) *utils.Response

func (*KubeClient) Create

func (k *KubeClient) Create(clusterId, resType string, params interface{}) *utils.Response

func (*KubeClient) Delete

func (k *KubeClient) Delete(clusterId, resType string, params interface{}) *utils.Response

func (*KubeClient) Get

func (k *KubeClient) Get(clusterId, resType string, params interface{}) *utils.Response

func (*KubeClient) List

func (k *KubeClient) List(clusterId, resType string, params interface{}) *utils.Response

func (*KubeClient) Patch

func (k *KubeClient) Patch(clusterId, resType string, params interface{}) *utils.Response

func (*KubeClient) Pods

func (k *KubeClient) Pods(clusterId string) (PodClient, error)

func (*KubeClient) Request

func (k *KubeClient) Request(clusterId, resType, action string, params interface{}) *utils.Response

func (*KubeClient) Update

func (k *KubeClient) Update(clusterId, resType string, params interface{}) *utils.Response

func (*KubeClient) Watch

func (k *KubeClient) Watch(clusterId, resType string, params interface{}) (Outer, error)

type Outer

type Outer interface {
	OutCh() <-chan interface{}
	StopCh() <-chan struct{}
	Close()
}

type PodClient

type PodClient interface {
	Exec(interface{}) (PodExec, error)
	Log(interface{}) (Outer, error)
}

type PodExec

type PodExec interface {
	Outer
	Stdin(interface{}) error
}