service

Documentation

Index

• type Client
  • func NewClient(clientset kubernetes.Interface) *Client
  • func (c *Client) Delete(ctx context.Context, name, namespace string) (err error)
  • func (c *Client) FindNode(ctx context.Context, namespace string, pod *v1.Pod) (*NodeInfo, *v1.Service, error)
  • func (c *Client) GetNodes(ctx context.Context, namespace, labelSelector string) (nodes []NodeInfo, err error)
  • func (c *Client) Set(ctx context.Context, name, namespace string, o Options) (svc *v1.Service, err error)
• type NodeInfo
• type Options
• type Port
• type Ports
• type Spec
  • func (s *Spec) ToK8S() v1.ServiceSpec

Types

type Client

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

Client manages communication with the Kubernetes Service.

func NewClient

func NewClient(clientset kubernetes.Interface) *Client

NewClient constructs a new Client.

func (*Client) Delete

func (c *Client) Delete(ctx context.Context, name, namespace string) (err error)

Delete deletes Service

func (*Client) FindNode

func (c *Client) FindNode(ctx context.Context, namespace string, pod *v1.Pod) (*NodeInfo, *v1.Service, error)

func (*Client) GetNodes

func (c *Client) GetNodes(ctx context.Context, namespace, labelSelector string) (nodes []NodeInfo, err error)

GetNodes returns list of nodes in the namespace with labelSelector. Nodes are filtered by api port. Endpoint is constructed from ClusterIP and api port.

func (*Client) Set

func (c *Client) Set(ctx context.Context, name, namespace string, o Options) (svc *v1.Service, err error)

Set updates Service or creates it if it does not exist

type NodeInfo

type NodeInfo struct {
	Name     string
	Endpoint string
}

type Options

type Options struct {
	Annotations map[string]string
	Labels      map[string]string
	ServiceSpec Spec
}

Options holds optional parameters for the Client.

type Port

type Port struct {
	Name        string
	AppProtocol string
	Nodeport    int32
	Port        int32
	Protocol    string
	TargetPort  string
}

Port represents service's port

type Ports

type Ports []Port

Ports represents service's ports

type Spec

type Spec struct {
	ClusterIP                     string
	ExternalIPs                   []string
	ExternalName                  string
	ExternalTrafficPolicy         string
	LoadBalancerIP                string
	LoadBalancerSourceRanges      []string
	Ports                         Ports
	PublishNotReadyAddresses      bool
	Selector                      map[string]string
	SessionAffinity               string
	SessionAffinityTimeoutSeconds int32
	Type                          string
}

Spec represents Kubernetes ServiceSpec

func (*Spec) ToK8S

func (s *Spec) ToK8S() v1.ServiceSpec

ToK8S converts ServiceSpec to Kuberntes client object