utils

Documentation

Index

• Variables
• func CreateLogFile(dir string, name string) (io.Writer, error)
• func GenerateID() string
• type BuildKubeClientOptions
• type Command
  • func (_c *Command) AddCommand(cmd string)
  • func (_c *Command) AddEnv(key string, value string)
  • func (_c *Command) Bin(path string)
  • func (_c *Command) Create() *exec.Cmd
• type FileCreator
  • func (_f *FileCreator) Create(dir string, name string) (io.Writer, error)
• type GRPC
  • func (_g GRPC) Dial(target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• type Kubernetes
  • func (_k *Kubernetes) BuildClient(opt BuildKubeClientOptions) (*kubernetes.Clientset, error)
  • func (_k *Kubernetes) BuildClientWithToken(host string, ca string, token string) (*kubernetes.Clientset, error)
  • func (_k *Kubernetes) BuildPodDefinition(namespace string, name string, version string, id string, port string, ...) (*v1.Pod, error)
  • func (_k Kubernetes) BuildServiceDefinition(namespace string, name string, id string, port string, serviceType string) (*v1.Service, error)
  • func (_k Kubernetes) CreatePod(client *kubernetes.Clientset, def *v1.Pod) (*v1.Pod, error)
  • func (_k Kubernetes) CreateService(client *kubernetes.Clientset, def *v1.Service) (*v1.Service, error)
  • func (_k Kubernetes) KillPod(client *kubernetes.Clientset, namespace string, name string) error
  • func (_k Kubernetes) KillService(client *kubernetes.Clientset, namespace string, name string) error
  • func (_k Kubernetes) WaitForPod(client *kubernetes.Clientset, pod *v1.Pod, phase string) error
• type Port
  • func (_p Port) GetAvailable() (string, error)
• type Proto
  • func (_p Proto) New(cc *grpc.ClientConn) v1.ServiceClient

Variables

var TimeNow = func() time.Time { return time.Now() }

TimeNow returns the current time

Functions

func CreateLogFile

func CreateLogFile(dir string, name string) (io.Writer, error)

func GenerateID

func GenerateID() string

Types

type BuildKubeClientOptions

type BuildKubeClientOptions struct {
	KubeconfigPath string
	Host           string
	B64CRT         string
	Token          string
}

type Command

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

func (*Command) AddCommand

func (_c *Command) AddCommand(cmd string)

func (*Command) AddEnv

func (_c *Command) AddEnv(key string, value string)

func (*Command) Bin

func (_c *Command) Bin(path string)

func (*Command) Create

func (_c *Command) Create() *exec.Cmd

Create builds exec.Cmd

type FileCreator

type FileCreator struct{}

FileCreator expose ability to operate on fs

func (*FileCreator) Create

func (_f *FileCreator) Create(dir string, name string) (io.Writer, error)

Create creates file in directory with mode = os.ModePerm

type GRPC

type GRPC struct{}

GRPC expose abilities on grpc connection

func (GRPC) Dial

func (_g GRPC) Dial(target string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

Dial returns a connection grpc server

type Kubernetes

type Kubernetes struct{}

Kubernetes expose abilities on run on kube cluster

func (*Kubernetes) BuildClient

func (_k *Kubernetes) BuildClient(opt BuildKubeClientOptions) (*kubernetes.Clientset, error)

BuildClient returns a kubernetes client based on path to kubeconfig

func (*Kubernetes) BuildClientWithToken

func (_k *Kubernetes) BuildClientWithToken(host string, ca string, token string) (*kubernetes.Clientset, error)

BuildClient returns a kubernetes client based on path to kubeconfig

func (*Kubernetes) BuildPodDefinition

func (_k *Kubernetes) BuildPodDefinition(namespace string, name string, version string, id string, port string, volume string, volumeClaimName string, volumeMoutnPath string) (*v1.Pod, error)

func (Kubernetes) BuildServiceDefinition

func (_k Kubernetes) BuildServiceDefinition(namespace string, name string, id string, port string, serviceType string) (*v1.Service, error)

func (Kubernetes) CreatePod

func (_k Kubernetes) CreatePod(client *kubernetes.Clientset, def *v1.Pod) (*v1.Pod, error)

CreatePod applies a pod definitions on given client

func (Kubernetes) CreateService

func (_k Kubernetes) CreateService(client *kubernetes.Clientset, def *v1.Service) (*v1.Service, error)

CreateService applies a pod definitions on given client

func (Kubernetes) KillPod

func (_k Kubernetes) KillPod(client *kubernetes.Clientset, namespace string, name string) error

KillPod deletes kubernetes service

func (Kubernetes) KillService

func (_k Kubernetes) KillService(client *kubernetes.Clientset, namespace string, name string) error

KillService deletes kubernetes service

func (Kubernetes) WaitForPod

func (_k Kubernetes) WaitForPod(client *kubernetes.Clientset, pod *v1.Pod, phase string) error

WaitForPod waits til pod reaches given phase

type Port

type Port struct{}

Port expose ability to generate random available port on local machine

func (Port) GetAvailable

func (_p Port) GetAvailable() (string, error)

GetAvailable returns available port on local machine

type Proto

type Proto struct{}

Proto expose abilities to create new service client

func (Proto) New

func (_p Proto) New(cc *grpc.ClientConn) v1.ServiceClient

New creates new service for given connection