spdy

package

Go to main page

Versions in this module

v1

v1.4.2

Sep 1, 2025

v1.4.0

Apr 12, 2025

Changes in this version

+ const TransferLeadershipRequest

v1.3.1

Jan 2, 2025

v1.3.0

Nov 12, 2024

Changes in this version

+ const CrashRequest

+ const RaftMsgRequest

v1.3.0-rc.1

Sep 2, 2024

v1.2.0

Feb 29, 2024

Changes in this version

type FSM

+ func (fsm *FSM) Close()

v1.1.2

Oct 30, 2023

v1.1.1

Nov 7, 2023

Changes in this version

+ const SegregateNodeRequest

v1.1.0

Sep 28, 2023

v1.1.0-rc1

Aug 31, 2023

v1.0.1

Mar 29, 2023

Changes in this version

+ func SetTCPDialTimeout(timeout time.Duration)

+ func TCPDialTimeout() time.Duration

v1.0.0

Feb 23, 2023

Changes in this version

+ const PtRequest

+ const WriteStreamPointsRequest

+ type BuffWriter interface

+ Flush func() error

type RRCServer

+ func (s *RRCServer) Open() error

+ func (s *RRCServer) Run()

v0

v0.2.0

Dec 7, 2022

v0.1.0

Sep 27, 2022

Changes in this version

+ const ACK_FLAG

+ const AbortRequest

+ const CLOSED_STATE

+ const CLOSE_TYPE

+ const DATA_ACK_FLAG

+ const DATA_TYPE

+ const DDLRequest

+ const ESTABLISHED_STATE

+ const Echo

+ const FIN_FLAG

+ const FIN_RECV_STATE

+ const FIN_SENT_STATE

+ const FSM_ERROR

+ const FaultPartial

+ const FullFlag

+ const HEADER_SIZE

+ const INIT_STATE

+ const INTERNAL_ERROR

+ const MULTIPLIEXED_CONN_SESSION_ID

+ const MetaRequest

+ const Partial

+ const ProtocolHeaderSize

+ const ProtocolVersion

+ const Prototype

+ const RECV_ACK_EVENT

+ const RECV_DATA_ACK_EVENT

+ const RECV_DATA_EVENT

+ const RECV_FIN_EVENT

+ const RECV_RST_EVENT

+ const RECV_SYN_EVENT

+ const RST_FLAG

+ const ReqFlag

+ const RspFlag

+ const SEND_ACK_EVENT

+ const SEND_DATA_ACK_EVENT

+ const SEND_DATA_EVENT

+ const SEND_FIN_EVENT

+ const SEND_RST_EVENT

+ const SEND_SYN_EVENT

+ const SIZE_OF_CONNID

+ const SIZE_OF_FLAGS

+ const SIZE_OF_LENGTH

+ const SIZE_OF_TYPE

+ const SIZE_OF_VERSION

+ const SPDY_VERSION

+ const SYN_FLAG

+ const SYN_RECV_STATE

+ const SYN_SENT_STATE

+ const SelectRequest

+ const SizeOfProtocolFlags

+ const SizeOfProtocolLength

+ const SizeOfProtocolSequence

+ const SizeOfProtocolType

+ const SizeOfProtocolVersion

+ const SysCtrlRequest

+ const UNKNOWN_EVENT

+ const UNKNOWN_STATE

+ const UNKNOWN_TYPE

+ const Unknown

+ const WritePointsRequest

+ var ErrorInvalidProtocolType = NewInternalError(INTERNAL_ERROR, "invalid protocol type")

+ var ErrorInvalidProtocolVersion = NewInternalError(INTERNAL_ERROR, "invalid protocol version")

+ var ErrorUnexpectedRequest = NewInternalError(INTERNAL_ERROR, "unexpected request")

+ var ErrorUnexpectedResponse = NewInternalError(INTERNAL_ERROR, "unexpected response")

+ func ConnPoolSize() int

+ func DefaultConfiguration() config.Spdy

+ func HandleError(err error)

+ func MultiplexedSessionFuture(f func() (*MultiplexedSession, error)) func() (*MultiplexedSession, error)

+ func SetDefaultConfiguration(cfg config.Spdy)

+ type BaseError struct

+ func (e *BaseError) Code() uint32

+ func (e *BaseError) Error() string

+ type BaseEventHandler struct

+ func (base *BaseEventHandler) InitDerive(session *MultiplexedSession, derive EventHandler)

+ func (base *BaseEventHandler) Session() *MultiplexedSession

+ func (base *BaseEventHandler) WarpRequester(sequence uint64, data []byte) (Requester, error)

+ type BaseRequester struct

+ func (base *BaseRequester) FinishAnalyze()

+ func (base *BaseRequester) InitDerive(session *MultiplexedSession, sequence uint64, derive Requester)

+ func (base *BaseRequester) Request(request interface{}) error

+ func (base *BaseRequester) Sequence() uint64

+ func (base *BaseRequester) Session() *MultiplexedSession

+ func (base *BaseRequester) StartAnalyze(span *tracing.Span)

+ type BaseResponser struct

+ func (base *BaseResponser) Apply() error

+ func (base *BaseResponser) Close() error

+ func (base *BaseResponser) FinishAnalyze()

+ func (base *BaseResponser) InitDerive(session *MultiplexedSession, sequence uint64, derive Responser)

+ func (base *BaseResponser) IsFull() bool

+ func (base *BaseResponser) Response(response interface{}, full bool) error

+ func (base *BaseResponser) Sequence() uint64

+ func (base *BaseResponser) Session() *MultiplexedSession

+ func (base *BaseResponser) StartAnalyze(span *tracing.Span)

+ type Closer interface

+ Close func() error

+ type Codec interface

+ Decode func([]byte) (interface{}, error)

+ Encode func([]byte, interface{}) ([]byte, error)

+ type DataACK struct

+ func NewDataACK(handler func(), size int64) *DataACK

+ func (a *DataACK) Block() error

+ func (a *DataACK) Close()

+ func (a *DataACK) Disable()

+ func (a *DataACK) Dispatch()

+ func (a *DataACK) Enable()

+ func (a *DataACK) Incr()

+ func (a *DataACK) SetBlockTimeout(timeout time.Duration)

+ func (a *DataACK) SetRole(role SessionRole)

+ func (a *DataACK) SignalOn()

+ type EventHandler interface

+ CreateRequester func(uint64) (Requester, error)

+ Handle func(Requester, Responser) error

+ Session func() *MultiplexedSession

+ WarpRequester func(uint64, []byte) (Requester, error)

+ type EventHandlerFactory interface

+ CreateEventHandler func(session *MultiplexedSession) EventHandler

+ EventHandlerType func() uint8

+ type FSM struct

+ func NewFSM(state state) *FSM

+ func (fsm *FSM) Build(start *FSMState, event event, next *FSMState, action FSMEventAction)

+ func (fsm *FSM) ForceSetState(state state)

+ func (fsm *FSM) ProcessEvent(event event, data []byte) error

+ func (fsm *FSM) State() state

+ type FSMError struct

+ func NewFSMError(event event, state state) *FSMError

+ func (e *FSMError) Error() string

+ func (e *FSMError) Event() event

+ func (e *FSMError) State() state

+ type FSMEventAction func(event, *FSMTransition, []byte) error

+ type FSMState struct

+ func NewFSMState(state state, enterAction FSMStateAction, exitAction FSMStateAction) *FSMState

+ func (s *FSMState) State() state

+ type FSMStateAction func(event, *FSMTransition) error

+ type FSMTransition struct

+ func NewFSMTransition(start *FSMState, event event, next *FSMState, action FSMEventAction) *FSMTransition

+ type Flags uint16

+ type InternalError struct

+ func NewInternalError(code uint32, msg string) *InternalError

+ func (e *InternalError) Error() string

+ func (e *InternalError) Msg() string

+ type MultiplexedConnection struct

+ func NewMultiplexedConnection(cfg config.Spdy, underlying io.ReadWriteCloser, client bool) *MultiplexedConnection

+ func (c *MultiplexedConnection) AcceptSession() func() (*MultiplexedSession, error)

+ func (c *MultiplexedConnection) AllocData(n int) []byte

+ func (c *MultiplexedConnection) Close() error

+ func (c *MultiplexedConnection) FreeData(data []byte)

+ func (c *MultiplexedConnection) IsClosed() bool

+ func (c *MultiplexedConnection) ListenAndServed() error

+ func (c *MultiplexedConnection) LocalAddr() net.Addr

+ func (c *MultiplexedConnection) NumOfSession() int

+ func (c *MultiplexedConnection) OpenSession() func() (*MultiplexedSession, error)

+ func (c *MultiplexedConnection) RemoteAddr() net.Addr

+ func (c *MultiplexedConnection) Write(hdr []byte, data []byte) error

+ type MultiplexedError interface

+ Code func() uint32

+ Error func() string

+ type MultiplexedServer struct

+ func (s *MultiplexedServer) Error() error

+ func (s *MultiplexedServer) Start() error

+ func (s *MultiplexedServer) Stop()

+ type MultiplexedSession struct

+ func NewMultiplexedSession(cfg config.Spdy, conn *MultiplexedConnection, id uint64) *MultiplexedSession

+ func (s *MultiplexedSession) Close() error

+ func (s *MultiplexedSession) Connection() *MultiplexedConnection

+ func (s *MultiplexedSession) DisableDataACK()

+ func (s *MultiplexedSession) EnableDataACK()

+ func (s *MultiplexedSession) GenerateNextSequence() uint64

+ func (s *MultiplexedSession) Handle(flags uint16, data []byte) error

+ func (s *MultiplexedSession) ID() uint64

+ func (s *MultiplexedSession) IsClosed() bool

+ func (s *MultiplexedSession) Open(ackSig chan struct{}) error

+ func (s *MultiplexedSession) RecvAck() error

+ func (s *MultiplexedSession) RecvData(data []byte) error

+ func (s *MultiplexedSession) RecvDataACK() error

+ func (s *MultiplexedSession) RecvFin() error

+ func (s *MultiplexedSession) RecvRst() error

+ func (s *MultiplexedSession) RecvSyn() error

+ func (s *MultiplexedSession) Select() ([]byte, error)

+ func (s *MultiplexedSession) Send(data []byte) error

+ func (s *MultiplexedSession) SendAck(data []byte) error

+ func (s *MultiplexedSession) SendDataACK(data []byte) error

+ func (s *MultiplexedSession) SendFin(data []byte) error

+ func (s *MultiplexedSession) SendRst(data []byte) error

+ func (s *MultiplexedSession) SendSyn(data []byte, ackRecvSig chan struct{}) error

+ func (s *MultiplexedSession) SetOnClose(fn func())

+ func (s *MultiplexedSession) SetTimeout(d time.Duration)

+ func (s *MultiplexedSession) State() state

+ func (s *MultiplexedSession) TriggerOnClose()

+ type MultiplexedSessionPool struct

+ func NewMultiplexedSessionPool(cfg config.Spdy, network string, address string) *MultiplexedSessionPool

+ func (c *MultiplexedSessionPool) Available() bool

+ func (c *MultiplexedSessionPool) Close()

+ func (c *MultiplexedSessionPool) Dial() error

+ func (c *MultiplexedSessionPool) Get() (*MultiplexedSession, error)

+ func (c *MultiplexedSessionPool) IsClosed() bool

+ func (c *MultiplexedSessionPool) Put(session *MultiplexedSession)

+ func (c *MultiplexedSessionPool) SetStatisticsJob(job *statistics.SpdyJob)

+ func (c *MultiplexedSessionPool) Wait()

+ type ProtocolHeader []byte

+ func (h ProtocolHeader) Flags() uint16

+ func (h ProtocolHeader) Length() uint32

+ func (h ProtocolHeader) Sequence() uint64

+ func (h ProtocolHeader) String() string

+ func (h ProtocolHeader) Type() uint8

+ func (h ProtocolHeader) Version() uint8

+ type RRCServer struct

+ func NewRRCServer(cfg config.Spdy, network string, address string) *RRCServer

+ func (s *RRCServer) Error() error

+ func (s *RRCServer) RegisterEHF(factory EventHandlerFactory)

+ func (s *RRCServer) Start() error

+ func (s *RRCServer) Stop()

+ type Reactor struct

+ func (r *Reactor) Close()

+ func (r *Reactor) Error() error

+ func (r *Reactor) HandleEvents()

+ type Requester interface

+ Data func() interface{}

+ FinishAnalyze func()

+ Request func(interface{}) error

+ Sequence func() uint64

+ Session func() *MultiplexedSession

+ SetData func(interface{})

+ StartAnalyze func(span *tracing.Span)

+ Type func() uint8

+ WarpResponser func() Responser

+ type Responser interface

+ Apply func() error

+ Callback func(interface{}) error

+ FinishAnalyze func()

+ Response func(interface{}, bool) error

+ Sequence func() uint64

+ Session func() *MultiplexedSession

+ StartAnalyze func(span *tracing.Span)

+ Type func() uint8

+ type Selector interface

+ Select func() ([]byte, bool)

+ type SessionRole string

+ const RoleClient

+ const RoleServer

+ type TimerPool struct

+ func NewTimePool() *TimerPool

+ func (p *TimerPool) GetTimer(timeout time.Duration) *time.Timer

+ func (p *TimerPool) PutTimer(timer *time.Timer)

+ type TransitionTable struct

+ func NewTransitionTable() *TransitionTable

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL