pipe

Documentation

Index

• type Listener
• type Net
  • func NewNet() *Net
  • func (pl *Net) Accept() (net.Conn, error)
  • func (pl *Net) AddConn(c net.Conn)
  • func (pl *Net) Addr() net.Addr
  • func (pl *Net) Close() error
  • func (pl *Net) Dial() (net.Conn, error)
  • func (pl *Net) DialContext(_ context.Context) (cclient net.Conn, _ error)
  • func (pl *Net) Network() string
  • func (pl *Net) String() string
• type Pipe
  • func NewBufferPipe(sz int) *Pipe
  • func NewNetPipe(sz int) *Pipe
  • func (bl *Pipe) ClientConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

Types

type Listener

type Listener interface {
	net.Listener

	Dial() (net.Conn, error)
	DialContext(ctx context.Context) (net.Conn, error)
}

type Net

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

func NewNet

func NewNet() *Net

func (*Net) Accept

func (pl *Net) Accept() (net.Conn, error)

func (*Net) AddConn

func (pl *Net) AddConn(c net.Conn)

Add conn forward the given conn to the listener

func (*Net) Addr

func (pl *Net) Addr() net.Addr

func (*Net) Close

func (pl *Net) Close() error

func (*Net) Dial

func (pl *Net) Dial() (net.Conn, error)

func (*Net) DialContext

func (pl *Net) DialContext(_ context.Context) (cclient net.Conn, _ error)

func (*Net) Network

func (pl *Net) Network() string

func (*Net) String

func (pl *Net) String() string

type Pipe

type Pipe struct {
	Listener
}

func NewBufferPipe

func NewBufferPipe(sz int) *Pipe

func NewNetPipe

func NewNetPipe(sz int) *Pipe

func (*Pipe) ClientConn

func (bl *Pipe) ClientConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)