core

Nov 25, 2020

Changes in this version

type BufferedFrame

+ StreamID func() uint32

Nov 8, 2020

Changes in this version

+ func ResetFrameHeader(b []byte, streamID uint32, frameType FrameType, fg FrameFlag)

+ func WriteFrameHeader(w io.Writer, streamID uint32, frameType FrameType, fg FrameFlag) error

+ type BufferedFrame interface

+ HasFlag func(FrameFlag) bool

+ Validate func() error

type Frame

+ Header func() FrameHeader

+ Len func() int

type WriteableFrame

+ HandleDone func(func())

Aug 23, 2020

Changes in this version

+ const FlagComplete

+ const FlagFollow

+ const FlagIgnore

+ const FlagLease

+ const FlagMetadata

+ const FlagNext

+ const FlagRespond

+ const FlagResume

+ const FrameHeaderLen

+ var ErrFrameLengthExceed = errors.New("rsocket: frame length is greater than 24bits")

+ var ErrHandlerExist = errors.New("rsocket: handler exists already")

+ var ErrHandlerNil = errors.New("rsocket: handler cannot be nil")

+ var ErrInvalidContext = errors.New("rsocket: invalid context")

+ var ErrInvalidEmitter = errors.New("rsocket: invalid emitter")

+ var ErrInvalidFrame = errors.New("rsocket: invalid frame")

+ var ErrInvalidFrameLength = errors.New("rsocket: invalid frame length")

+ var ErrInvalidTransport = errors.New("rsocket: invalid Transport")

+ var ErrReleasedResource = errors.New("rsocket: resource has been released")

+ var ErrSendFull = errors.New("rsocket: frame send channel is full")

+ type CustomError interface

+ ErrorCode func() ErrorCode

+ ErrorData func() []byte

+ type ErrorCode uint32

+ const ErrorCodeApplicationError

+ const ErrorCodeCanceled

+ const ErrorCodeConnectionClose

+ const ErrorCodeConnectionError

+ const ErrorCodeInvalid

+ const ErrorCodeInvalidSetup

+ const ErrorCodeRejected

+ const ErrorCodeRejectedResume

+ const ErrorCodeRejectedSetup

+ const ErrorCodeUnsupportedSetup

+ func (e ErrorCode) String() string

+ type Frame interface

+ Validate func() error

+ type FrameFlag uint16

+ func (f FrameFlag) Check(flag FrameFlag) bool

+ func (f FrameFlag) String() string

+ type FrameHeader [FrameHeaderLen]byte

+ func NewFrameHeader(streamID uint32, frameType FrameType, fg FrameFlag) FrameHeader

+ func ParseFrameHeader(bs []byte) FrameHeader

+ func (h FrameHeader) Bytes() []byte

+ func (h FrameHeader) Flag() FrameFlag

+ func (h FrameHeader) Resumable() bool

+ func (h FrameHeader) StreamID() uint32

+ func (h FrameHeader) String() string

+ func (h FrameHeader) Type() FrameType

+ func (h FrameHeader) WriteTo(w io.Writer) (int64, error)

+ type FrameType uint8

+ const FrameTypeCancel

+ const FrameTypeError

+ const FrameTypeExt

+ const FrameTypeKeepalive

+ const FrameTypeLease

+ const FrameTypeMetadataPush

+ const FrameTypePayload

+ const FrameTypeRequestChannel

+ const FrameTypeRequestFNF

+ const FrameTypeRequestN

+ const FrameTypeRequestResponse

+ const FrameTypeRequestStream

+ const FrameTypeReserved

+ const FrameTypeResume

+ const FrameTypeResumeOK

+ const FrameTypeSetup

+ func (f FrameType) String() string

+ type TrafficCounter struct

+ func NewTrafficCounter() *TrafficCounter

+ func (p TrafficCounter) IncReadBytes(n int)

+ func (p TrafficCounter) IncWriteBytes(n int)

+ func (p TrafficCounter) ReadBytes() uint64

+ func (p TrafficCounter) WriteBytes() uint64

+ type Version [2]uint16

+ var DefaultVersion Version = [2]uint16{ ... }

+ func NewVersion(major, minor uint16) Version

+ func (p Version) Bytes() []byte

+ func (p Version) Equals(version Version) bool

+ func (p Version) GreaterThan(version Version) bool

+ func (p Version) LessThan(version Version) bool

+ func (p Version) Major() uint16

+ func (p Version) Minor() uint16

+ func (p Version) String() string

+ func (p Version) WriteTo(w io.Writer) (n int64, err error)

+ type WriteableFrame interface

+ Done func() (closed bool)

+ DoneNotify func() <-chan struct{}

+ Header func() FrameHeader

+ Len func() int