targetserver

Documentation

Index

• func IsSafeToRetry(err error) bool
• func Reader(r io.Reader) (string, error)
• func ServeRequest(conn net.Conn, kubeClient *cstorv1alpha1.Kubeclient)
• func StartTargetServer(kubeConfig string)

Functions

func IsSafeToRetry

func IsSafeToRetry(err error) bool

IsSafeToRetry will retrun true if error type is EINTR, EAGAIN or EWOULDBLOCK

func Reader

func Reader(r io.Reader) (string, error)

Reader reads the data from wire untill error or endOfData occurs Reader will break only when client is sending \r\n or EOF occured

func ServeRequest

func ServeRequest(conn net.Conn, kubeClient *cstorv1alpha1.Kubeclient)

ServeRequest process the request from the client

func StartTargetServer

func StartTargetServer(kubeConfig string)

StartTargetServer starts the UnixDomainServer