Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kubernetes

package

Go to main page

Versions in this module

v0

v0.6.0

Dec 23, 2019

Changes in this version

type CelleryKubeCli

+ func (kubeCli *CelleryKubeCli) ApplyLabel(itemType, itemName, labelName string, overWrite bool) error

+ func (kubeCli *CelleryKubeCli) CreateNamespace(namespace string) error

+ func (kubeCli *CelleryKubeCli) DeleteAllCells() error

+ func (kubeCli *CelleryKubeCli) DeleteAllComposites() error

+ func (kubeCli *CelleryKubeCli) DeleteNameSpace(nameSpace string) error

+ func (kubeCli *CelleryKubeCli) DeletePersistedVolume(persistedVolume string) error

+ func (kubeCli *CelleryKubeCli) GetContext() (string, error)

+ func (kubeCli *CelleryKubeCli) GetContexts() ([]byte, error)

+ func (kubeCli *CelleryKubeCli) GetMasterNodeName() (string, error)

+ func (kubeCli *CelleryKubeCli) GetNamespace(namespace string) ([]byte, error)

+ func (kubeCli *CelleryKubeCli) GetVirtualService(vs string) (VirtualService, error)

+ func (kubeCli *CelleryKubeCli) IsComponentAvailable(instanceName, componentName string) error

+ func (kubeCli *CelleryKubeCli) IsInstanceAvailable(instanceName string) error

+ func (kubeCli *CelleryKubeCli) SetNamespace(namespace string) error

+ func (kubeCli *CelleryKubeCli) StreamCellLogsAllComponents(instanceName string, follow bool) error

+ func (kubeCli *CelleryKubeCli) StreamCellLogsUserComponents(instanceName string, follow bool) error

+ func (kubeCli *CelleryKubeCli) StreamComponentLogs(instanceName string, componentName string, follow bool) error

+ func (kubeCli *CelleryKubeCli) UseContext(context string) error

+ type Component struct

+ APIVersion string

+ ComponentMetaData K8SMetaData

+ ComponentSpec ComponentTemplateSpec

+ ComponentStatus ComponentStatus

+ Kind string

+ type ComponentStatus struct

+ ServiceName string

+ Status string

+ Type string

+ type Components struct

+ Items []Component

type KubeCli

+ ApplyLabel func(itemType, itemName, labelName string, overWrite bool) error

+ CreateNamespace func(namespace string) error

+ DeleteAllCells func() error

+ DeleteAllComposites func() error

+ DeleteNameSpace func(nameSpace string) error

+ DeletePersistedVolume func(persistedVolume string) error

+ GetContext func() (string, error)

+ GetContexts func() ([]byte, error)

+ GetMasterNodeName func() (string, error)

+ GetNamespace func(namespace string) ([]byte, error)

+ GetVirtualService func(vs string) (VirtualService, error)

+ IsComponentAvailable func(instanceName, componentName string) error

+ IsInstanceAvailable func(instanceName string) error

+ SetNamespace func(namespace string) error

+ StreamCellLogsAllComponents func(instanceName string, follow bool) error

+ StreamCellLogsUserComponents func(instanceName string, follow bool) error

+ StreamComponentLogs func(instanceName, componentName string, follow bool) error

+ UseContext func(context string) error

v0.5.0

Nov 19, 2019

Changes in this version

+ func ApplyFile(file string) error

+ func ApplyFileWithNamespace(file, namespace string) error

+ func ApplyLable(itemType, itemName, labelName string, overWrite bool) error

+ func CreateClusterRoleBinding(clusterRole, user string) error

+ func CreateConfigMapWithNamespace(name, confFile, namespace string) error

+ func CreateFile(file string) error

+ func DefaultConfigDir() (string, error)

+ func DefaultConfigFile() (string, error)

+ func DeleteAllCells() error

+ func DeleteCell(cellInstance string) (string, error)

+ func DeleteFile(file string) error

+ func DeleteFileWithNamespace(file, namespace string) error

+ func DeleteNameSpace(nameSpace string) error

+ func DeletePersistedVolume(persistedVolume string) error

+ func DeleteResource(kind, instance string) (string, error)

+ func GetContext() (string, error)

+ func GetContexts() ([]byte, error)

+ func GetDeployment(namespace, deployment string) (string, error)

+ func GetDeploymentNames(namespace string) ([]string, error)

+ func GetGatewayAsMapInterface(gw string) (map[string]interface{}, error)

+ func GetMasterNodeName() (string, error)

+ func JsonPatchWithNameSpace(kind, instance, jsonPatch, nameSpace string) error

+ func UseContext(context string) error

+ func WaitForCell(condition string, timeoutSeconds int, resourceName string, namespace string) error

+ func WaitForCluster(timeout time.Duration) error

+ func WaitForCondition(condition string, timeoutSeconds int, resourceName string, namespace string) error

+ func WaitForDeployment(condition string, timeoutSeconds int, resourceName string, namespace string) error

+ func WaitForDeployments(namespace string, timeout time.Duration) error

+ func WriteConfig(file string, conf *Config) error

+ type APIDefinition struct

+ Method string

+ Path string

+ type ApiPublisherConfig struct

+ Authenticate bool

+ Backend string

+ Context string

+ Version string

+ type AuthInfo struct

+ AuthProvider *AuthProviderConfig

+ ClientCertificate string

+ ClientCertificateData []byte

+ ClientKey string

+ ClientKeyData []byte

+ Exec *ExecConfig

+ Extensions map[string]interface{}

+ Impersonate string

+ ImpersonateGroups []string

+ ImpersonateUserExtra map[string][]string

+ LocationOfOrigin string

+ Password string

+ Token string

+ TokenFile string

+ Username string

+ type AuthProviderConfig struct

+ Config map[string]string

+ Name string

+ type Authority struct

+ Regex string

+ type AutoScalingPolicy struct

+ Components []ComponentScalePolicy

+ Gateway GwScalePolicy

+ type AutoscalePolicy struct

+ APIVersion string

+ Kind string

+ Metadata AutoscalePolicyMetadata

+ Spec AutoscalePolicySpec

+ type AutoscalePolicyMetadata struct

+ Name string

+ type AutoscalePolicySpec struct

+ Overridable bool

+ Policy Policy

+ type Cell struct

+ APIVersion string

+ CellMetaData K8SMetaData

+ CellSpec CellSpec

+ CellStatus CellStatus

+ Component map[string]ComponentDetail

+ Kind string

+ func GetCell(cellName string) (Cell, error)

+ type CellAnnotations struct

+ ApiVersion string

+ Dependencies string

+ Name string

+ Organization string

+ OriginalDependencyComponentServices string

+ Version string

+ type CellSpec struct

+ ComponentTemplates []ComponentTemplate

+ GateWayTemplate Gateway

+ type CellStatus struct

+ Gateway string

+ ServiceCount int

+ Status string

+ type CelleryKubeCli struct

+ func NewCelleryKubeCli() *CelleryKubeCli

+ func (kubeCli *CelleryKubeCli) ApplyFile(file string) error

+ func (kubeCli *CelleryKubeCli) DeleteResource(kind, instance string) (string, error)

+ func (kubeCli *CelleryKubeCli) DescribeCell(cellName string) error

+ func (kubeCli *CelleryKubeCli) GetCell(cellName string) (Cell, error)

+ func (kubeCli *CelleryKubeCli) GetCellInstanceAsMapInterface(cell string) (map[string]interface{}, error)

+ func (kubeCli *CelleryKubeCli) GetCellLogsAllComponents(cellName string) (string, error)

+ func (kubeCli *CelleryKubeCli) GetCellLogsUserComponents(cellName string) (string, error)

+ func (kubeCli *CelleryKubeCli) GetCells() ([]Cell, error)

+ func (kubeCli *CelleryKubeCli) GetComponentLogs(cellName, componentName string) (string, error)

+ func (kubeCli *CelleryKubeCli) GetComposite(compositeName string) (Composite, error)

+ func (kubeCli *CelleryKubeCli) GetCompositeInstanceAsMapInterface(composite string) (map[string]interface{}, error)

+ func (kubeCli *CelleryKubeCli) GetComposites() ([]Composite, error)

+ func (kubeCli *CelleryKubeCli) GetInstanceBytes(instanceKind, InstanceName string) ([]byte, error)

+ func (kubeCli *CelleryKubeCli) GetInstancesNames() ([]string, error)

+ func (kubeCli *CelleryKubeCli) GetPodsForCell(cellName string) (Pods, error)

+ func (kubeCli *CelleryKubeCli) GetPodsForComposite(compName string) (Pods, error)

+ func (kubeCli *CelleryKubeCli) GetServices(cellName string) (Services, error)

+ func (kubeCli *CelleryKubeCli) JsonPatch(kind, instance, jsonPatch string) error

+ func (kubeCli *CelleryKubeCli) SetVerboseMode(enable bool)

+ func (kubeCli *CelleryKubeCli) Version() (string, string, error)

+ type Cells struct

+ Items []Cell

+ func GetCells() (Cells, error)

+ type Cluster struct

+ CertificateAuthority string

+ CertificateAuthorityData []byte

+ Extensions map[string]interface{}

+ InsecureSkipTLSVerify bool

+ LocationOfOrigin string

+ Server string

+ type ClusterInfo struct

+ Cluster *Cluster

+ Name string

+ type ClusterIngress struct

+ Host string

+ Tls interface{}

+ type ComponentDetail struct

+ ComponentName string

+ Ingress map[string]IngressDetail

+ type ComponentScalePolicy struct

+ Name string

+ ScalingPolicy interface{}

+ type ComponentTemplate struct

+ Metadata ComponentTemplateMetadata

+ Spec ComponentTemplateSpec

+ type ComponentTemplateMetadata struct

+ Name string

+ type ComponentTemplateSpec struct

+ PodTemplate PodTemplate

+ Ports []Port

+ type Composite struct

+ APIVersion string

+ CompositeMetaData K8SMetaData

+ CompositeSpec CompositeSpec

+ CompositeStatus CompositeStatus

+ Kind string

+ func GetComposite(compositeName string) (Composite, error)

+ type CompositeSpec struct

+ ComponentTemplates []ComponentTemplate

+ type CompositeStatus struct

+ ServiceCount int

+ Status string

+ type Composites struct

+ Items []Composite

+ func GetComposites() (Composites, error)

+ type Config struct

+ APIVersion string

+ AuthInfos []*UserInfo

+ Clusters []*ClusterInfo

+ Contexts []*ContextInfo

+ CurrentContext string

+ Extensions map[string]interface{}

+ Kind string

+ Preferences Preferences

+ func MergeConfig(old, new *Config) *Config

+ func ReadConfig(file string) (*Config, error)

+ type ContainerTemplate struct

+ Env []Env

+ Image string

+ Name string

+ type Context struct

+ AuthInfo string

+ Cluster string

+ Extensions map[string]interface{}

+ LocationOfOrigin string

+ Namespace string

+ type ContextInfo struct

+ Context *Context

+ Name string

+ type Destination struct

+ Host string

+ type Env struct

+ Name string

+ Value string

+ type ExecConfig struct

+ APIVersion string

+ Args []string

+ Command string

+ Env []ExecEnvVar

+ type ExecEnvVar struct

+ Name string

+ Value string

+ type Extensions struct

+ ApiPublisher ApiPublisherConfig

+ ClusterIngress ClusterIngress

+ Oidc interface{}

+ type Gateway struct

+ GatewaySpec GatewaySpec

+ type GatewayConfig struct

+ Context string

+ Vhost string

+ type GatewayDefinition struct

+ Method string

+ Path string

+ type GatewayGrpcApi struct

+ Backend string

+ Context string

+ Definitions []GatewayDefinition

+ Global bool

+ Vhost string

+ type GatewayHttpApi struct

+ Authenticate bool

+ Context string

+ Definitions []APIDefinition

+ Destination Destination

+ Global bool

+ Port uint32

+ Version string

+ ZeroScale bool

+ type GatewaySpec struct

+ Ingress Ingress

+ type GatewayTcpApi struct

+ Backend string

+ Context string

+ Definitions []GatewayDefinition

+ Global bool

+ Vhost string

+ type GwScalePolicy struct

+ ScalingPolicy interface{}

+ type HTTP struct

+ Match []HTTPMatch

+ Route []HTTPRoute

+ type HTTPMatch struct

+ Authority Authority

+ Headers map[string]*StringMatch

+ SourceLabels map[string]string

+ type HTTPRoute struct

+ Destination Destination

+ Weight int

+ type Ingress struct

+ Extensions Extensions

+ GrpcApis []GatewayGrpcApi

+ HttpApis []GatewayHttpApi

+ TcpApis []GatewayTcpApi

+ type IngressDetail struct

+ ApiVersion string

+ Context string

+ Definition map[string][]APIDefinition

+ Expose string

+ GatewayConfig GatewayConfig

+ GatewayPort int

+ IngressType string

+ IngressTypeTCP string

+ Port int

+ type InstanceKind string

+ const InstanceKindCell

+ const InstanceKindComposite

+ type K8SMetaData struct

+ Annotations CellAnnotations

+ CreationTimestamp string

+ Name string

+ type K8sVersion struct

+ ClientVersion struct{ ... }

+ ServerVersion struct{ ... }

+ type KubeCli interface

+ ApplyFile func(file string) error

+ DeleteResource func(kind, instance string) (string, error)

+ DescribeCell func(cellName string) error

+ GetCell func(cellName string) (Cell, error)

+ GetCellInstanceAsMapInterface func(cell string) (map[string]interface{}, error)

+ GetCellLogsAllComponents func(cellName string) (string, error)

+ GetCellLogsUserComponents func(cellName string) (string, error)

+ GetCells func() ([]Cell, error)

+ GetComponentLogs func(cellName, componentName string) (string, error)

+ GetComposite func(compositeName string) (Composite, error)

+ GetCompositeInstanceAsMapInterface func(composite string) (map[string]interface{}, error)

+ GetComposites func() ([]Composite, error)

+ GetInstanceBytes func(instanceKind, InstanceName string) ([]byte, error)

+ GetInstancesNames func() ([]string, error)

+ GetPodsForCell func(cellName string) (Pods, error)

+ GetPodsForComposite func(compName string) (Pods, error)

+ GetServices func(cellName string) (Services, error)

+ JsonPatch func(kind, instance, jsonPatch string) error

+ SetVerboseMode func(enable bool)

+ Version func() (string, string, error)

+ type Metric struct

+ Resource Resource

+ Type string

+ type Node struct

+ Items []NodeItem

+ func GetNodes() (Node, error)

+ type NodeInfo struct

+ KubeletVersion string

+ type NodeItem struct

+ Metadata NodeMetaData

+ Status NodeStatus

+ type NodeMetaData struct

+ Name string

+ type NodeStatus struct

+ NodeInfo NodeInfo

+ type Pod struct

+ MetaData PodMetaData

+ PodStatus PodStatus

+ type PodCondition struct

+ LastTransitionTime string

+ Status string

+ Type string

+ type PodMetaData struct

+ Name string

+ type PodStatus struct

+ Conditions []PodCondition

+ Phase string

+ StartTime string

+ type PodTemplate struct

+ Containers []ContainerTemplate

+ type Pods struct

+ Items []Pod

+ type Policy struct

+ MaxReplicas int

+ Metrics []Metric

+ MinReplicas string

+ ScaleTargetRef ScaleTargetRef

+ type Port struct

+ Name string

+ Port int32

+ Protocol string

+ TargetContainer string

+ TargetPort int32

+ type Preferences struct

+ Colors bool

+ Extensions map[string]interface{}

+ type Resource struct

+ Name string

+ TargetAverageUtilization int

+ TargetAverageValue string

+ type ScaleResource struct

+ Spec struct{ ... }

+ type ScaleTargetRef struct

+ ApiVersion string

+ Kind string

+ Name string

+ type ScalingPolicy struct

+ Hpa struct{ ... }

+ type Service struct

+ Metadata ServiceMetaData

+ Spec ServiceSpec

+ func GetService(service, namespace string) (Service, error)

+ type ServiceMetaData struct

+ Name string

+ type ServicePort struct

+ Port int

+ type ServiceSpec struct

+ ExternalIPs []string

+ Ports []ServicePort

+ type Services struct

+ Items []Service

+ type StringMatch struct

+ Exact string

+ Prefix string

+ Regex string

+ type TCP struct

+ Match []TCPMatch

+ Route []TCPRoute

+ type TCPDestination struct

+ Host string

+ Port TCPPort

+ type TCPMatch struct

+ Port int

+ SourceLabels map[string]string

+ type TCPPort struct

+ Number int

+ type TCPRoute struct

+ Destination TCPDestination

+ Weight int

+ type UserInfo struct

+ Name string

+ User *AuthInfo

+ type VirtualService struct

+ APIVersion string

+ Kind string

+ VsMetaData VsMetaData

+ VsSpec VsSpec

+ func GetVirtualService(vs string) (VirtualService, error)

+ type VsMetaData struct

+ Name string

+ type VsSpec struct

+ HTTP []HTTP

+ Hosts []string

+ TCP []TCP