transport

Nov 7, 2019

Changes in this version

type Transport

+ func (p *Transport) HandleDisaster(handler FrameHandler)

+ func (p *Transport) HandleLease(handler FrameHandler)

+ func (p *Transport) SetRcvLease(ttl time.Duration, n uint32)

Sep 28, 2019

Changes in this version

type URI

+ func (p *URI) IsWebsocket() bool

Jul 28, 2019

Changes in this version

type Conn

+ Flush func() error

+ type TLS struct

+ CertFile string

+ KeyFile string

type Transport

+ func (p *Transport) Flush() error

Jun 12, 2019

Changes in this version

type Transport

+ func (p *Transport) DeliveryFrame(ctx context.Context, frame framing.Frame) (err error)

+ func (p *Transport) ReadFirst(ctx context.Context) (frame framing.Frame, err error)

Jun 9, 2019

Changes in this version

+ var ErrIncompleteHeader = errors.New("incomplete frame header")

+ func IsClosedErr(err error) bool

+ type Conn interface

+ Read func() (Frame, error)

+ SetCounter func(c *Counter)

+ SetDeadline func(deadline time.Time) error

+ Write func(frame Frame) error

+ type Counter struct

+ func NewCounter() *Counter

+ func (p *Counter) ReadBytes() uint64

+ func (p *Counter) WriteBytes() uint64

+ type FrameHandler = func(frame Frame) (err error)

+ type LengthBasedFrameDecoder bufio.Scanner

+ func NewLengthBasedFrameDecoder(r io.Reader) *LengthBasedFrameDecoder

+ func (p *LengthBasedFrameDecoder) Read() (raw []byte, err error)

+ type ServerTransport interface

+ Accept func(acceptor ServerTransportAcceptor)

+ Listen func(onReady ...func()) error

+ type ServerTransportAcceptor = func(ctx context.Context, tp *Transport)

+ type Transport struct

+ func (p *Transport) Close() (err error)

+ func (p *Transport) Connection() Conn

+ func (p *Transport) HandleCancel(handler FrameHandler)

+ func (p *Transport) HandleError(handler FrameHandler)

+ func (p *Transport) HandleError0(handler FrameHandler)

+ func (p *Transport) HandleFNF(handler FrameHandler)

+ func (p *Transport) HandleKeepalive(handler FrameHandler)

+ func (p *Transport) HandleMetadataPush(handler FrameHandler)

+ func (p *Transport) HandlePayload(handler FrameHandler)

+ func (p *Transport) HandleRequestChannel(handler FrameHandler)

+ func (p *Transport) HandleRequestN(handler FrameHandler)

+ func (p *Transport) HandleRequestResponse(handler FrameHandler)

+ func (p *Transport) HandleRequestStream(handler FrameHandler)

+ func (p *Transport) HandleResume(handler FrameHandler)

+ func (p *Transport) HandleResumeOK(handler FrameHandler)

+ func (p *Transport) HandleSetup(handler FrameHandler)

+ func (p *Transport) Send(frame Frame) (err error)

+ func (p *Transport) SetLifetime(lifetime time.Duration)

+ func (p *Transport) Start(ctx context.Context) (err error)

+ type URI struct

+ func ParseURI(uri string) (*URI, error)

+ func (p *URI) MakeClientTransport() (*Transport, error)

+ func (p *URI) MakeServerTransport() (tp ServerTransport, err error)

+ func (p *URI) String() string