Documentation
¶
Overview ¶
Package client provides an implementation of a restricted subset of kubernetes API client
Index ¶
- Variables
- func CertPoolFromFile(filename string) (*x509.CertPool, error)
- func CertsFromPEM(pemCerts []byte) ([]*x509.Certificate, error)
- func Format(v string) string
- func NewClusterClient() *client
- func NewLocalClient(hosts ...string) *client
- type Client
- type Container
- type ContainerPort
- type Deployment
- type DeploymentCondition
- type DeploymentList
- type DeploymentSpec
- type DeploymentStatus
- type EnvVar
- type Event
- type EventType
- type LabelSelector
- type LoadBalancerIngress
- type LoadBalancerStatus
- type LogOption
- type LogOptions
- type Metadata
- type Pod
- type PodCondition
- type PodList
- type PodSpec
- type PodStatus
- type Resource
- type Service
- type ServiceList
- type ServicePort
- type ServiceSpec
- type ServiceStatus
- type Template
- type WatchOption
- type WatchOptions
- type Watcher
Constants ¶
This section is empty.
Variables ¶
var ( // ErrReadNamespace is returned when the names could not be read from service account ErrReadNamespace = errors.New("Could not read namespace from service account secret") // DefaultImage is default micro image DefaultImage = "micro/go-micro" )
Functions ¶
func CertPoolFromFile ¶
CertPoolFromFile returns an x509.CertPool containing the certificates in the given PEM-encoded file. Returns an error if the file could not be read, a certificate could not be parsed, or if the file does not contain any certificates
func CertsFromPEM ¶
func CertsFromPEM(pemCerts []byte) ([]*x509.Certificate, error)
CertsFromPEM returns the x509.Certificates contained in the given PEM-encoded byte array Returns an error if a certificate could not be parsed, or if the data does not contain any certificates
func NewClusterClient ¶
func NewClusterClient() *client
NewClusterClient creates a Kubernetes client for use from within a k8s pod.
func NewLocalClient ¶
func NewLocalClient(hosts ...string) *client
NewLocalClient returns a client that can be used with `kubectl proxy`
Types ¶
type Client ¶
type Client interface {
// Create creates new API resource
Create(*Resource) error
// Get queries API resrouces
Get(*Resource, map[string]string) error
// Update patches existing API object
Update(*Resource) error
// Delete deletes API resource
Delete(*Resource) error
// List lists API resources
List(*Resource) error
// Log gets log for a pod
Log(*Resource, ...LogOption) (io.ReadCloser, error)
// Watch for events
Watch(*Resource, ...WatchOption) (Watcher, error)
}
Client Kubernetes client
type Container ¶
type Container struct {
Name string `json:"name"`
Image string `json:"image"`
Env []EnvVar `json:"env,omitempty"`
Command []string `json:"command,omitempty"`
Args []string `json:"args,omitempty"`
Ports []ContainerPort `json:"ports,omitempty"`
}
Container defined container runtime values
type ContainerPort ¶
type ContainerPort struct {
Name string `json:"name,omitempty"`
HostPort int `json:"hostPort,omitempty"`
ContainerPort int `json:"containerPort"`
Protocol string `json:"protocol,omitempty"`
}
ContainerPort
type Deployment ¶
type Deployment struct {
Metadata *Metadata `json:"metadata"`
Spec *DeploymentSpec `json:"spec,omitempty"`
Status *DeploymentStatus `json:"status,omitempty"`
}
Deployment is Kubernetes deployment
func NewDeployment ¶
func NewDeployment(name, version, typ string) *Deployment
NewService returns default micro kubernetes deployment definition
type DeploymentCondition ¶
type DeploymentCondition struct {
Type string `json:"type"`
Reason string `json:"reason,omitempty"`
Message string `json:"message,omitempty"`
}
DeploymentCondition describes the state of deployment
type DeploymentList ¶
type DeploymentList struct {
Items []Deployment `json:"items"`
}
DeploymentList
type DeploymentSpec ¶
type DeploymentSpec struct {
Replicas int `json:"replicas,omitempty"`
Selector *LabelSelector `json:"selector"`
Template *Template `json:"template,omitempty"`
}
DeploymentSpec defines micro deployment spec
type DeploymentStatus ¶
type DeploymentStatus struct {
Replicas int `json:"replicas,omitempty"`
UpdatedReplicas int `json:"updatedReplicas,omitempty"`
ReadyReplicas int `json:"readyReplicas,omitempty"`
AvailableReplicas int `json:"availableReplicas,omitempty"`
Conditions []DeploymentCondition `json:"conditions,omitempty"`
}
DeploymentStatus is returned when querying deployment
type Event ¶
type Event struct {
Type EventType `json:"type"`
Object json.RawMessage `json:"object"`
}
Event represents a single event to a watched resource.
type LabelSelector ¶
LabelSelector is a label query over a set of resources NOTE: we do not support MatchExpressions at the moment
type LoadBalancerIngress ¶
type LoadBalancerStatus ¶
type LoadBalancerStatus struct {
Ingress []LoadBalancerIngress `json:"ingress,omitempty"`
}
type LogOption ¶
type LogOption func(*LogOptions)
type LogOptions ¶
type Metadata ¶
type Metadata struct {
Name string `json:"name,omitempty"`
Namespace string `json:"namespace,omitempty"`
Version string `json:"version,omitempty"`
Labels map[string]string `json:"labels,omitempty"`
Annotations map[string]string `json:"annotations,omitempty"`
}
Metadata defines api object metadata
type Pod ¶
type Pod struct {
Metadata *Metadata `json:"metadata"`
Spec *PodSpec `json:"spec,omitempty"`
Status *PodStatus `json:"status"`
}
Pod is the top level item for a pod
type PodCondition ¶
type PodCondition struct {
Type string `json:"type"`
Reason string `json:"reason,omitempty"`
Message string `json:"message,omitempty"`
}
PodCondition describes the state of pod
type PodStatus ¶
type PodStatus struct {
Conditions []PodCondition `json:"conditions,omitempty"`
PodIP string `json:"podIP"`
Phase string `json:"phase"`
Reason string `json:"reason"`
}
PodStatus
type Service ¶
type Service struct {
Metadata *Metadata `json:"metadata"`
Spec *ServiceSpec `json:"spec,omitempty"`
Status *ServiceStatus `json:"status,omitempty"`
}
Service is kubernetes service
func NewService ¶
NewService returns default micro kubernetes service definition
type ServicePort ¶
type ServicePort struct {
Name string `json:"name,omitempty"`
Port int `json:"port"`
Protocol string `json:"protocol,omitempty"`
}
ServicePort configures service ports
type ServiceSpec ¶
type ServiceSpec struct {
Type string `json:"type,omitempty"`
Selector map[string]string `json:"selector,omitempty"`
Ports []ServicePort `json:"ports,omitempty"`
}
ServiceSpec provides service configuration
type ServiceStatus ¶
type ServiceStatus struct {
LoadBalancer LoadBalancerStatus `json:"loadBalancer,omitempty"`
}
ServiceStatus
type Template ¶
type Template struct {
Metadata *Metadata `json:"metadata,omitempty"`
PodSpec *PodSpec `json:"spec,omitempty"`
}
Template is micro deployment template
type WatchOption ¶
type WatchOption func(*WatchOptions)
func WatchParams ¶
func WatchParams(p map[string]string) WatchOption
WatchParams used for watch params