transport

Documentation

Index

• Variables
• type Conn
• type HandleFunc
• type ResponseWriter
• type Transport
  • func NewTransport(conn Conn, handler HandleFunc) *Transport
  • func (t *Transport) Abandon()
  • func (t *Transport) Close()
  • func (t *Transport) IsClosed() bool
  • func (t *Transport) Read(p []byte) (n int, err error)
  • func (t *Transport) Spawn() error
  • func (t *Transport) Sync() error
  • func (t *Transport) Write(msg proto.Message) error

Variables

var (
	ErrorSendChannelClosed = errors.New("Send channel is closed")
	ErrorWriteToClosed     = errors.New("Writing to a closed transport")
)

Types

type Conn

type Conn interface {
	io.Reader
	io.Writer
	Close() error
}

type HandleFunc

type HandleFunc func(ResponseWriter, proto.Message) error

type ResponseWriter

type ResponseWriter interface {
	Write(proto.Message) error
	Close()
}

type Transport

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

func NewTransport

func NewTransport(conn Conn, handler HandleFunc) *Transport

func (*Transport) Abandon

func (t *Transport) Abandon()

Abandons connection and closes the transport.

func (*Transport) Close

func (t *Transport) Close()

Closes transport **AND** underlying connection.

func (*Transport) IsClosed

func (t *Transport) IsClosed() bool

func (*Transport) Read

func (t *Transport) Read(p []byte) (n int, err error)

func (*Transport) Spawn

func (t *Transport) Spawn() error

func (*Transport) Sync

func (t *Transport) Sync() error

func (*Transport) Write

func (t *Transport) Write(msg proto.Message) error