Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

etp

package module

Go to main page

Versions in this module

v0

v0.0.7

Sep 1, 2026

Changes in this version

+ const AllCapabilities

+ const CapabilityAck

+ const CapabilityCancel

+ const CapabilityFlowControl

+ const CapabilityGracefulClose

+ const CapabilityHeartbeat

+ const CapabilityNack

+ const CapabilityProtocolEvents

+ const CapabilityRateLimits

+ const CapabilityRequestResponse

+ const CapabilitySlowlorisGuard

+ const CapabilityTransferCommit

+ const CapabilityTransferResume

+ const CapabilityTransferSHA256

+ const CapabilityTransfers

+ const ChannelControl

+ const ChecksumOff

+ const ChecksumTransferSHA256

+ const ContentFile

+ const ContentMedia

+ const DefaultCapabilities

+ const DefaultChunkSize

+ const EventAckTimeout

+ const EventAuthAccepted

+ const EventAuthRejected

+ const EventAuthRequired

+ const EventAuthTimeout

+ const EventChecksumMismatch

+ const EventCloseAckReceived

+ const EventErrorReceived

+ const EventGoAwayReceived

+ const EventHandlerFailed

+ const EventNackReceived

+ const EventProtocolViolation

+ const EventRateLimited

+ const EventSlowloris

+ const EventTransferCanceled

+ const EventTransferFailed

+ const EventTransferUnknown

+ const EventWriteFailed

+ const FlagControl

+ const FlagFirst

+ const FlagLast

+ const FrameData

+ const FrameHello

+ const FrameHelloAck

+ const FrameRequest

+ const FrameResponse

+ const HeaderSize

+ const MaxFrameBytes

+ const MaxPooledFrameBytes

+ const PriorityCritical

+ const RateLimitBytes

+ const RateLimitFrames

+ const RateLimitNone

+ const RateLimitRequests

+ const RoleClient

+ const RoleServer

+ const SchemaEvent

+ const SchemaHello

+ const SchemaTextMessage

+ const SessionClosed

+ const SessionEstablished

+ const SessionFailed

+ const SessionNew

+ const WireVersion

+ var ErrBodyTooLargeForBytes = errors.New("transport: body is not fully in memory")

+ var ErrBodyWriterClosed = errors.New("transport: body writer is closed")

+ var ErrGroupPrefixCount = errors.New("transport: group accepts at most one prefix")

+ var ErrHandlerNil = errors.New("transport: handler is nil")

+ var ErrMiddlewareNil = errors.New("transport: middleware is nil")

+ var ErrNilFrameTransport = errors.New("transport: nil frame transport")

+ var ErrRateLimitIDChanged = errors.New("transport: rate limit id cannot be changed")

+ var ErrRateLimitIDEmpty = errors.New("transport: rate limit id is empty")

+ var ErrRouteAlreadyExists = errors.New("transport: route already exists")

+ var ErrRouteNotFound = errors.New("transport: route not found")

+ var ErrRoutePatternEmpty = errors.New("transport: route pattern is empty")

+ var ErrRouterCompiled = errors.New("transport: router is already compiled")

+ var ErrRouterNotCompiled = errors.New("transport: router is not compiled")

+ func EncodeEventMessageStringWithFieldsInto(dst []byte, event string, data []byte, fields []TransferField) ([]byte, error)

+ func EncodeFrame(frame Frame) ([]byte, error)

+ func EncodeFrameInto(dst []byte, frame Frame) ([]byte, error)

+ func EncodeHelloMessage(hello Hello) []byte

+ func NewRouter() *compiledRouter

+ type Ack = protocol.Ack

+ type Adapter interface

+ Name func() string

+ Serve func(context.Context, *App) error

+ type App struct

+ func New(config Config) *App

+ func (a *App) Compile()

+ func (a *App) Group(prefix ...string) *Group

+ func (a *App) MaxFrameBytes() uint32

+ func (a *App) On(pattern string, handler Handler) error

+ func (a *App) OnAuth(handler AuthHandler) error

+ func (a *App) OnConnect(handler ConnectHandler) error

+ func (a *App) OnDisconnect(handler DisconnectHandler) error

+ func (a *App) OnError(handler ErrorHandler) error

+ func (a *App) OnNotFound(handler Handler) error

+ func (a *App) OnProgress(handler ProgressHandler) error

+ func (a *App) OnProtocolEvent(handler ProtocolEventHandler) error

+ func (a *App) ServeTransport(ctx context.Context, name string, transport protocol.FrameTransport) (*Peer, error)

+ func (a *App) ServeTransportWithRemote(ctx context.Context, name string, remote string, ...) (*Peer, error)

+ func (a *App) Use(pattern string, middleware Middleware) error

+ type AuthAccept = protocol.AuthAccept

+ type AuthAttribute = protocol.AuthAttribute

+ type AuthConfig = protocol.AuthConfig

+ type AuthHandler func(context.Context, *Peer, protocol.AuthRequest) (protocol.AuthResult, error)

+ type AuthReject = protocol.AuthReject

+ type AuthRequest = protocol.AuthRequest

+ type AuthResult = protocol.AuthResult

+ type Body interface

+ Bytes func() ([]byte, error)

+ IsInline func() bool

+ Open func() (io.ReadCloser, error)

+ Size func() int64

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

+ func NewBytesBody(data []byte) Body

+ type Cancel = protocol.Cancel

+ type ChecksumMode = protocol.ChecksumMode

+ type CloseConfig = protocol.CloseConfig

+ type CloseMessage = protocol.CloseMessage

+ type Config struct

+ MaxMemoryBody int64

+ MaxPooledBodyBytes int

+ OnError ErrorHandler

+ RateLimitIdentityTTL time.Duration

+ Session protocol.SessionConfig

+ type ConnectHandler func(context.Context, *Peer) error

+ type Context struct

+ App *App

+ Body Body

+ Event string

+ Fields []Field

+ Peer *Peer

+ RequestID uint64

+ TransferID uint64

+ func (c *Context) BodyView() ([]byte, bool)

+ func (c *Context) Bytes() ([]byte, error)

+ func (c *Context) EventCopy() string

+ func (c *Context) Field(name string) string

+ func (c *Context) Respond(opts SendOptions) (MessageHandle, error)

+ type DeadlineStream = protocol.DeadlineStream

+ type DisconnectHandler func(context.Context, *Peer, error)

+ type ErrorHandler func(*Context, error)

+ type ErrorMessage = protocol.ErrorMessage

+ type EventMessage = protocol.EventMessage

+ type EventMessageView = protocol.EventMessageView

+ func DecodeEventMessageView(payload []byte) (EventMessageView, error)

+ type Field = protocol.TransferField

+ type FlowControlConfig = protocol.FlowControlConfig

+ type Frame = protocol.Frame

+ func DecodeFrameView(data []byte) (Frame, error)

+ func NewFrame(frameType uint8, schemaID uint32, payload []byte) Frame

+ type FrameLease = protocol.FrameLease

+ func InitFrameLease(lease *FrameLease, data []byte, releaser FrameLeaseReleaser) *FrameLease

+ func NewFrameLease(data []byte, release func([]byte)) *FrameLease

+ type FrameLeaseReleaser = protocol.FrameLeaseReleaser

+ type FrameLimitTransport = protocol.FrameLimitTransport

+ type FrameTransport = protocol.FrameTransport

+ type FrameTransportAdapter struct

+ AdapterName string

+ Transport protocol.FrameTransport

+ func (a FrameTransportAdapter) Name() string

+ func (a FrameTransportAdapter) Serve(ctx context.Context, app *App) error

+ type GoAway = protocol.GoAway

+ type Group struct

+ func (g *Group) Group(prefix ...string) *Group

+ func (g *Group) On(pattern string, handler Handler) error

+ func (g *Group) Use(pattern string, middleware Middleware) error

+ type Handler func(*Context) error

+ type HandlerConfig = protocol.HandlerConfig

+ type Header = protocol.Header

+ func DecodeHeader(data []byte) (Header, error)

+ type HeartbeatConfig = protocol.HeartbeatConfig

+ type Hello = protocol.Hello

+ type IncomingTransferAborter = protocol.IncomingTransferAborter

+ type IncomingTransferContextCloser = protocol.IncomingTransferContextCloser

+ type IncomingTransferContextWriter = protocol.IncomingTransferContextWriter

+ type IncomingTransferInfo = protocol.IncomingTransferInfo

+ type IncomingTransferSuspender = protocol.IncomingTransferSuspender

+ type IncomingTransferWriter = protocol.IncomingTransferWriter

+ type LeasedFrameTransport = protocol.LeasedFrameTransport

+ type MessageHandle = protocol.MessageHandle

+ type MessageOptions = protocol.MessageOptions

+ type Middleware func(Handler) Handler

+ type MultiStreamTransport = protocol.MultiStreamTransport

+ func NewMultiStreamTransport(config MultiStreamTransportConfig) *MultiStreamTransport

+ type MultiStreamTransportConfig = protocol.MultiStreamTransportConfig

+ type Nack = protocol.Nack

+ type NegotiatedFrameTransport = protocol.NegotiatedFrameTransport

+ type PayloadLimitConfig = protocol.PayloadLimitConfig

+ type Peer struct

+ func (p *Peer) Adapter() string

+ func (p *Peer) Close() error

+ func (p *Peer) Context() context.Context

+ func (p *Peer) Identity() protocol.SessionIdentity

+ func (p *Peer) RateLimitID() string

+ func (p *Peer) RemoteAddr() string

+ func (p *Peer) Request(ctx context.Context, opts SendOptions) (MessageHandle, error)

+ func (p *Peer) Respond(ctx context.Context, requestID uint64, opts SendOptions) (MessageHandle, error)

+ func (p *Peer) Send(ctx context.Context, opts SendOptions) (MessageHandle, error)

+ func (p *Peer) Session() *protocol.Session

+ func (p *Peer) SetRateLimitID(id string) error

+ type Progress = protocol.Progress

+ type ProgressHandler func(context.Context, *Peer, protocol.Progress)

+ type ProtocolEvent = protocol.ProtocolEvent

+ type ProtocolEventHandler func(context.Context, *Peer, protocol.ProtocolEvent)

+ type RateLimitAdvertisement = protocol.RateLimitAdvertisement

+ func DefaultRateLimitAdvertisement() RateLimitAdvertisement

+ type RateLimitConfig = protocol.RateLimitConfig

+ type ReceiveConfig = protocol.ReceiveConfig

+ type RequestHandler = protocol.RequestHandler

+ type ResponseHandler = protocol.ResponseHandler

+ type ResumeConfig = protocol.ResumeConfig

+ type ResumeTransferOptions = protocol.ResumeTransferOptions

+ type Router interface

+ Group func(prefix ...string) *Group

+ On func(event string, handler Handler) error

+ Use func(pattern string, middleware Middleware) error

+ type SchedulerConfig = protocol.SchedulerConfig

+ type SendOptions struct

+ AckTimeout time.Duration

+ Body Body

+ ChunkSize int

+ ContentType uint32

+ Data []byte

+ Event string

+ Field string

+ Fields []Field

+ Index uint32

+ Name string

+ Reader io.Reader

+ RetryLimit int

+ Size uint64

+ type SendQueueConfig = protocol.SendQueueConfig

+ type Session = protocol.Session

+ func NewSession(t FrameTransport) *Session

+ func NewSessionWithConfig(t FrameTransport, config SessionConfig) *Session

+ type SessionConfig = protocol.SessionConfig

+ func DefaultClientConfig() SessionConfig

+ func DefaultServerConfig() SessionConfig

+ func DefaultSessionConfig(role string) SessionConfig

+ func NormalizeSessionConfig(config SessionConfig) SessionConfig

+ type SessionIdentity = protocol.SessionIdentity

+ type SessionState = protocol.SessionState

+ type SlowlorisConfig = protocol.SlowlorisConfig

+ func DefaultSlowlorisConfig() SlowlorisConfig

+ type StreamTransport = protocol.StreamTransport

+ func NewStreamTransport(conn net.Conn) *StreamTransport

+ func NewStreamTransportForStream(stream DeadlineStream, guard SlowlorisConfig) *StreamTransport

+ func NewStreamTransportWithSlowlorisGuard(conn net.Conn, guard SlowlorisConfig) *StreamTransport

+ type TextHandler = protocol.TextHandler

+ type TransferBegin = protocol.TransferBegin

+ type TransferField = protocol.TransferField

+ type TransferHandle = protocol.TransferHandle

+ type TransferHandler = protocol.TransferHandler

+ type TransferOptions = protocol.TransferOptions

+ type TransferPart = protocol.TransferPart

+ type TransferResume = protocol.TransferResume

+ type TransferResumeDecision = protocol.TransferResumeDecision

+ type TransferResumeStore = protocol.TransferResumeStore

+ type TransferResumeView = protocol.TransferResumeView

+ type TransferState = protocol.TransferState

+ type TransferStateMessage = protocol.TransferStateMessage

+ type Window = protocol.Window

v0.0.6

Jul 26, 2026

v0.0.5

Jul 26, 2026

v0.0.4

Jul 21, 2026

v0.0.3

Jul 21, 2026

v0.0.2

Jun 26, 2026

v0.0.1

Jun 26, 2026