service

Documentation

Index

• func WaitOnDeleted(servicePrefix, namespace string, sleep, duration time.Duration) (bool, error)
• type List
  • func GetAll(namespace string) (*List, error)
• type LoadBalancer
• type Metadata
• type Port
• type Service
  • func CreateServiceFromFile(filename, name, namespace string) (*Service, error)
  • func CreateServiceFromFileDeleteIfExist(filename, name, namespace string) (*Service, error)
  • func Get(name, namespace string) (*Service, error)
  • func GetAllByPrefix(prefix, namespace string) ([]Service, error)
  • func (s *Service) Delete(retries int) error
  • func (s *Service) GetNodePort(port int) int
  • func (s *Service) Validate(check string, attempts int, sleep, wait time.Duration) bool
  • func (s *Service) WaitForIngress(wait, sleep time.Duration) (*Service, error)
• type Spec
• type Status

Functions

func WaitOnDeleted

func WaitOnDeleted(servicePrefix, namespace string, sleep, duration time.Duration) (bool, error)

WaitOnDeleted returns when a service resource is successfully deleted

Types

type List

type List struct {
	Services []Service `json:"items"`
}

List holds a list of services returned from kubectl get svc

func GetAll

func GetAll(namespace string) (*List, error)

GetAll will return all services in a given namespace

type LoadBalancer

type LoadBalancer struct {
	Ingress []map[string]string `json:"ingress"`
}

LoadBalancer holds the ingress definitions

type Metadata

type Metadata struct {
	CreatedAt time.Time         `json:"creationTimestamp"`
	Labels    map[string]string `json:"labels"`
	Name      string            `json:"name"`
	Namespace string            `json:"namespace"`
}

Metadata holds information like name, namespace, and labels

type Port

type Port struct {
	NodePort   int    `json:"nodePort"`
	Port       int    `json:"port"`
	Protocol   string `json:"protocol"`
	TargetPort int    `json:"targetPort"`
}

Port represents a service port definition

type Service

type Service struct {
	Metadata Metadata `json:"metadata"`
	Spec     Spec     `json:"spec"`
	Status   Status   `json:"status"`
}

Service represents a kubernetes service

func CreateServiceFromFile

func CreateServiceFromFile(filename, name, namespace string) (*Service, error)

CreateServiceFromFile will create a Service from file with a name

func CreateServiceFromFileDeleteIfExist

func CreateServiceFromFileDeleteIfExist(filename, name, namespace string) (*Service, error)

CreateServiceFromFileDeleteIfExist will create a Service from file, deleting any pre-existing service with the same name

func Get

func Get(name, namespace string) (*Service, error)

Get returns the service definition specified in a given namespace

func GetAllByPrefix

func GetAllByPrefix(prefix, namespace string) ([]Service, error)

GetAllByPrefix will return all services in a given namespace that match a prefix

func (*Service) Delete

func (s *Service) Delete(retries int) error

Delete will delete a service in a given namespace

func (*Service) GetNodePort

func (s *Service) GetNodePort(port int) int

GetNodePort will return the node port for a given pod

func (*Service) Validate

func (s *Service) Validate(check string, attempts int, sleep, wait time.Duration) bool

Validate will attempt to run an http.Get against the root service url

func (*Service) WaitForIngress

func (s *Service) WaitForIngress(wait, sleep time.Duration) (*Service, error)

WaitForIngress waits for an Ingress to be provisioned

type Spec

type Spec struct {
	ClusterIP string `json:"clusterIP"`
	Ports     []Port `json:"ports"`
	Type      string `json:"type"`
}

Spec holds information like clusterIP and port

type Status

type Status struct {
	LoadBalancer LoadBalancer `json:"loadBalancer"`
}

Status holds the load balancer definition