Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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
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

ttheader

package

Go to main page

Versions in this module

v0

v0.1.3

Nov 27, 2024

Changes in this version

+ const ClusterShardID

+ const FrameType

+ const FrameTypeData

+ const FrameTypeHeader

+ const FrameTypeInvalid

+ const FrameTypeMeta

+ const FrameTypeTrailer

+ func IsStreaming(bytes []byte) bool

type HeaderFlags

+ const HeaderFlagsStreaming

type ProtocolID

+ const ProtocolIDProtobufStruct

+ const ProtocolIDThriftStruct

v0.1.2

Sep 10, 2024

v0.1.1

Aug 29, 2024

Changes in this version

+ const ConnectTimeout

+ const DDPTag

+ const DestAddress

+ const Env

+ const FlagsMask

+ const FromCluster

+ const FromIDC

+ const FromMethod

+ const FromService

+ const GDPRToken

+ const HTTPContentType

+ const HeaderConnectionReadyToReset

+ const HeaderIDLServiceName

+ const HeaderProcessAtTime

+ const HeaderTransPerfTConnEnd

+ const HeaderTransPerfTConnStart

+ const HeaderTransPerfTRecvEnd

+ const HeaderTransPerfTRecvStart

+ const HeaderTransPerfTSendStart

+ const HeaderTransRemoteAddr

+ const HeaderTransToCluster

+ const HeaderTransToIDC

+ const LBType

+ const LogID

+ const MagicMask

+ const MaxFrameSize

+ const MaxHeaderSize

+ const MeshHeaderLenMask

+ const MeshHeaderMagic

+ const MeshVersion

+ const MethodMask

+ const MsgType

+ const RPCTimeout

+ const RawRingHashKey

+ const ReadTimeout

+ const RingHashKey

+ const ShortConnection

+ const Size16

+ const Size32

+ const SpanContext

+ const StressTag

+ const TTHeaderMagic

+ const TTHeaderMetaSize

+ const ToCluster

+ const ToIDC

+ const ToMethod

+ const ToService

+ const TransportType

+ const WithMeshHeader

+ func Bytes2Uint16(bytes []byte, off int) (uint16, error)

+ func Bytes2Uint16NoCheck(bytes []byte) uint16

+ func Bytes2Uint32NoCheck(bytes []byte) uint32

+ func Bytes2Uint8(bytes []byte, off int) (uint8, error)

+ func Encode(ctx context.Context, param EncodeParam, out bufiox.Writer) (totalLenField []byte, err error)

+ func EncodeToBytes(ctx context.Context, param EncodeParam) (buf []byte, err error)

+ func IsTTHeader(flagBuf []byte) bool

+ func ReadString2BLen(bytes []byte, off int) (string, int, error)

+ func WriteByte(val byte, out bufiox.Writer) error

+ func WriteString(val string, out bufiox.Writer) (int, error)

+ func WriteString2BLen(val string, out bufiox.Writer) (int, error)

+ func WriteUint16(val uint16, out bufiox.Writer) error

+ func WriteUint32(val uint32, out bufiox.Writer) error

+ type DecodeParam struct

+ Flags HeaderFlags

+ HeaderLen int

+ IntInfo map[uint16]string

+ PayloadLen int

+ ProtocolID ProtocolID

+ SeqID int32

+ StrInfo map[string]string

+ func Decode(ctx context.Context, in bufiox.Reader) (param DecodeParam, err error)

+ func DecodeFromBytes(ctx context.Context, bs []byte) (param DecodeParam, err error)

+ type EncodeParam struct

+ Flags HeaderFlags

+ IntInfo map[uint16]string

+ ProtocolID ProtocolID

+ SeqID int32

+ StrInfo map[string]string

+ type HeaderFlags uint16

+ const HeaderFlagDuplexReverse

+ const HeaderFlagSASL

+ const HeaderFlagSupportOutOfOrder

+ type InfoIDType uint8

+ const InfoIDACLToken

+ const InfoIDIntKeyValue

+ const InfoIDKeyValue

+ const InfoIDPadding

+ type ProtocolID uint8

+ const ProtocolIDDefault

+ const ProtocolIDKitexProtobuf

+ const ProtocolIDThriftBinary

+ const ProtocolIDThriftCompact

+ const ProtocolIDThriftCompactV2