client

Documentation

Index

• Constants
• func Destroy()
• func Init(server, hostName string, tls bool, mux uint8, cas []string) error
• func SetUUID(uid string)
• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Dial(_, _ string) (net.Conn, error)
  • func (c *Client) Proxy(ctx context.Context, req *transport.Request, localAddr chan<- string, ...) error
  • func (c *Client) String() string
• type ConnNode
• type ConnQueue
  • func NewConnQueue(size int, params *Params) *ConnQueue
  • func (q *ConnQueue) Add(conn *ConnWrapper)
  • func (q *ConnQueue) Destroy()
  • func (q *ConnQueue) Dial() (*ConnWrapper, error)
  • func (q *ConnQueue) GetClient() (proxy.ProxyClient, func() error, error)
  • func (q *ConnQueue) GetConn() (*ConnWrapper, func() error, error)
  • func (q *ConnQueue) GetConnOutSide() (*ConnWrapper, func() error, error)
  • func (q *ConnQueue) Init() error
• type ConnWrapper
  • func NewConnWrapper(p *Params) (*ConnWrapper, error)
  • func (w *ConnWrapper) Close() error
  • func (w *ConnWrapper) Done() error
  • func (w *ConnWrapper) Use()
• type ConnWrappers
  • func (w ConnWrappers) LogStatus()
  • func (w ConnWrappers) PickLRU() *ConnWrapper
• type Forwarder
  • func NewForwarder(ctx context.Context, s proxy.Proxy_ProxyClient, w io.Writer, r io.Reader) *Forwarder
  • func (f *Forwarder) CopySRCtoTarget() (err error)
  • func (f *Forwarder) CopyTargetToSRC() (err error)
  • func (f *Forwarder) Start(req *transport.Request, localAddrChan chan<- string) error
• type Params
  • func NewParams(addr string, opts ...grpc.DialOption) *Params

Constants

const TransportName = "proxy"

Functions

func Destroy

func Destroy()

func Init

func Init(server, hostName string, tls bool, mux uint8, cas []string) error

func SetUUID

func SetUUID(uid string)

Types

type Client

type Client struct {
	proxy.ProxyClient
	DoneFunc func() error
}

func NewClient

func NewClient() (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Dial

func (c *Client) Dial(_, _ string) (net.Conn, error)

func (*Client) Proxy

func (c *Client) Proxy(ctx context.Context, req *transport.Request, localAddr chan<- string, w io.Writer, r io.Reader) error

func (*Client) String

func (c *Client) String() string

type ConnNode

type ConnNode struct {
	Conn *ConnWrapper
	Next *ConnNode
}

type ConnQueue

type ConnQueue struct {
	Params *Params
	Size   int
	Conn   ConnWrappers
	// contains filtered or unexported fields
}

func NewConnQueue

func NewConnQueue(size int, params *Params) *ConnQueue

func (*ConnQueue) Add

func (q *ConnQueue) Add(conn *ConnWrapper)

func (*ConnQueue) Destroy

func (q *ConnQueue) Destroy()

Destroy force disconnect all the connections

func (*ConnQueue) Dial

func (q *ConnQueue) Dial() (*ConnWrapper, error)

Dial dials new grpc connection with saved params

func (*ConnQueue) GetClient

func (q *ConnQueue) GetClient() (proxy.ProxyClient, func() error, error)

GetClient gets a grpc client from connection

func (*ConnQueue) GetConn

func (q *ConnQueue) GetConn() (*ConnWrapper, func() error, error)

GetConn gets a grpc connection from the pool, also moves the cursor

func (*ConnQueue) GetConnOutSide

func (q *ConnQueue) GetConnOutSide() (*ConnWrapper, func() error, error)

GetConnOutSide gets a connection outside the pool

func (*ConnQueue) Init

func (q *ConnQueue) Init() error

type ConnWrapper

type ConnWrapper struct {
	*grpc.ClientConn
	InUse uint32
}

func NewConnWrapper

func NewConnWrapper(p *Params) (*ConnWrapper, error)

func (*ConnWrapper) Close

func (w *ConnWrapper) Close() error

func (*ConnWrapper) Done

func (w *ConnWrapper) Done() error

func (*ConnWrapper) Use

func (w *ConnWrapper) Use()

type ConnWrappers

type ConnWrappers []*ConnWrapper

func (ConnWrappers) LogStatus

func (w ConnWrappers) LogStatus()

func (ConnWrappers) PickLRU

func (w ConnWrappers) PickLRU() *ConnWrapper

type Forwarder

type Forwarder struct {
	Ctx       context.Context
	Stream    proxy.Proxy_ProxyClient
	Writer    io.Writer
	Reader    io.Reader
	LocalAddr chan string
}

func NewForwarder

func NewForwarder(ctx context.Context, s proxy.Proxy_ProxyClient, w io.Writer, r io.Reader) *Forwarder

func (*Forwarder) CopySRCtoTarget

func (f *Forwarder) CopySRCtoTarget() (err error)

func (*Forwarder) CopyTargetToSRC

func (f *Forwarder) CopyTargetToSRC() (err error)

func (*Forwarder) Start

func (f *Forwarder) Start(req *transport.Request, localAddrChan chan<- string) error

type Params

type Params struct {
	Addr string
	Opts []grpc.DialOption
}

func NewParams

func NewParams(addr string, opts ...grpc.DialOption) *Params