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

codec

package

Go to main page

Versions in this module

v1

v1.0.3

May 16, 2024

v1.0.2

Nov 30, 2023

v1.0.1

Oct 20, 2023

v1.0.0

Oct 17, 2023

Changes in this version

+ const CompressTypeBlockSnappy

+ const CompressTypeGzip

+ const CompressTypeNoop

+ const CompressTypeSnappy

+ const CompressTypeStreamSnappy

+ const CompressTypeZlib

+ const ContextKeyMessage

+ const DefaultReaderSize

+ const SendAndRecv

+ const SendOnly

+ const SerializationTypeFlatBuffer

+ const SerializationTypeForm

+ const SerializationTypeFormData

+ const SerializationTypeGet

+ const SerializationTypeJSON

+ const SerializationTypeNoop

+ const SerializationTypePB

+ const SerializationTypeTextXML

+ const SerializationTypeUnsupported

+ const SerializationTypeXML

+ const ServiceSectionLength

+ var JSONAPI = jsoniter.ConfigCompatibleWithStandardLibrary

+ var Marshaler = protojson.MarshalOptions

+ var Unmarshaler = protojson.UnmarshalOptions

+ func Compress(compressorType int, in []byte) ([]byte, error)

+ func CopyMsg(dst, src Msg)

+ func Decompress(compressorType int, in []byte) ([]byte, error)

+ func GetReaderSize() int

+ func IsSafeFramer(f interface{}) bool

+ func Marshal(serializationType int, body interface{}) ([]byte, error)

+ func NewReader(r io.Reader) io.Reader

+ func NewReaderSize(r io.Reader, size int) io.Reader

+ func PutBackMessage(sourceMsg Msg)

+ func Register(name string, serverCodec Codec, clientCodec Codec)

+ func RegisterCompressor(compressType int, s Compressor)

+ func RegisterSerializer(serializationType int, s Serializer)

+ func SetReaderSize(size int)

+ func Unmarshal(serializationType int, in []byte, body interface{}) error

+ type Body struct

+ Data []byte

+ func (b *Body) Bytes() ([]byte, error)

+ func (b *Body) SetBytes(p []byte) error

+ func (b *Body) String() string

+ type BytesBodyIn interface

+ SetBytes func([]byte) error

+ type BytesBodyOut interface

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

+ type Codec interface

+ Decode func(message Msg, buffer []byte) (body []byte, err error)

+ Encode func(message Msg, body []byte) (buffer []byte, err error)

+ func GetClient(name string) Codec

+ func GetServer(name string) Codec

+ type CommonMeta map[interface{}]interface

+ func (c CommonMeta) Clone() CommonMeta

+ type Compressor interface

+ Compress func(in []byte) (out []byte, err error)

+ Decompress func(in []byte) (out []byte, err error)

+ func GetCompressor(compressType int) Compressor

+ type ContextKey string

+ type FBSerialization struct

+ func (*FBSerialization) Marshal(body interface{}) ([]byte, error)

+ func (*FBSerialization) Unmarshal(in []byte, body interface{}) error

+ type Framer interface

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

+ type FramerBuilder interface

+ New func(io.Reader) Framer

+ type GzipCompress struct

+ func (c *GzipCompress) Compress(in []byte) ([]byte, error)

+ func (c *GzipCompress) Decompress(in []byte) ([]byte, error)

+ type JSONPBSerialization struct

+ func (s *JSONPBSerialization) Marshal(body interface{}) ([]byte, error)

+ func (s *JSONPBSerialization) Unmarshal(in []byte, body interface{}) error

+ type JSONSerialization struct

+ func (s *JSONSerialization) Marshal(body interface{}) ([]byte, error)

+ func (s *JSONSerialization) Unmarshal(in []byte, body interface{}) error

+ type MetaData map[string][]byte

+ func (m MetaData) Clone() MetaData

+ type Msg interface

+ CallType func() RequestType

+ CalleeApp func() string

+ CalleeContainerName func() string

+ CalleeMethod func() string

+ CalleeServer func() string

+ CalleeService func() string

+ CalleeServiceName func() string

+ CalleeSetName func() string

+ CallerApp func() string

+ CallerMethod func() string

+ CallerServer func() string

+ CallerService func() string

+ CallerServiceName func() string

+ ClientMetaData func() MetaData

+ ClientRPCName func() string

+ ClientReqHead func() interface{}

+ ClientRspErr func() error

+ ClientRspHead func() interface{}

+ CommonMeta func() CommonMeta

+ CompressType func() int

+ Context func() context.Context

+ Dyeing func() bool

+ DyeingKey func() string

+ EnvName func() string

+ EnvTransfer func() string

+ FrameHead func() interface{}

+ LocalAddr func() net.Addr

+ Logger func() interface{}

+ Namespace func() string

+ RemoteAddr func() net.Addr

+ RequestID func() uint32

+ RequestTimeout func() time.Duration

+ SerializationType func() int

+ ServerMetaData func() MetaData

+ ServerRPCName func() string

+ ServerReqHead func() interface{}

+ ServerRspErr func() *errs.Error

+ ServerRspHead func() interface{}

+ SetName func() string

+ StreamFrame func() interface{}

+ StreamID func() uint32

+ WithCallType func(RequestType)

+ WithCalleeApp func(string)

+ WithCalleeContainerName func(string)

+ WithCalleeMethod func(string)

+ WithCalleeServer func(string)

+ WithCalleeService func(string)

+ WithCalleeServiceName func(string)

+ WithCalleeSetName func(string)

+ WithCallerApp func(string)

+ WithCallerMethod func(string)

+ WithCallerServer func(string)

+ WithCallerService func(string)

+ WithCallerServiceName func(string)

+ WithClientMetaData func(MetaData)

+ WithClientRPCName func(string)

+ WithClientReqHead func(interface{})

+ WithClientRspErr func(error)

+ WithClientRspHead func(interface{})

+ WithCommonMeta func(CommonMeta)

+ WithCompressType func(int)

+ WithDyeing func(bool)

+ WithDyeingKey func(string)

+ WithEnvName func(string)

+ WithEnvTransfer func(string)

+ WithFrameHead func(interface{})

+ WithLocalAddr func(addr net.Addr)

+ WithLogger func(interface{})

+ WithNamespace func(string)

+ WithRemoteAddr func(addr net.Addr)

+ WithRequestID func(uint32)

+ WithRequestTimeout func(time.Duration)

+ WithSerializationType func(int)

+ WithServerMetaData func(MetaData)

+ WithServerRPCName func(string)

+ WithServerReqHead func(interface{})

+ WithServerRspErr func(error)

+ WithServerRspHead func(interface{})

+ WithSetName func(string)

+ WithStreamFrame func(interface{})

+ WithStreamID func(uint32)

+ func EnsureMessage(ctx context.Context) (context.Context, Msg)

+ func Message(ctx context.Context) Msg

+ func WithCloneContextAndMessage(ctx context.Context) (context.Context, Msg)

+ func WithCloneMessage(ctx context.Context) (context.Context, Msg)

+ func WithNewMessage(ctx context.Context) (context.Context, Msg)

+ type NoopCompress struct

+ func (c *NoopCompress) Compress(in []byte) ([]byte, error)

+ func (c *NoopCompress) Decompress(in []byte) ([]byte, error)

+ type NoopSerialization struct

+ func (s *NoopSerialization) Marshal(body interface{}) ([]byte, error)

+ func (s *NoopSerialization) Unmarshal(in []byte, body interface{}) error

+ type PBSerialization struct

+ func (s *PBSerialization) Marshal(body interface{}) ([]byte, error)

+ func (s *PBSerialization) Unmarshal(in []byte, body interface{}) error

+ type RequestType int

+ type SafeFramer interface

+ IsSafe func() bool

+ type Serializer interface

+ Marshal func(body interface{}) (out []byte, err error)

+ Unmarshal func(in []byte, body interface{}) error

+ func GetSerializer(serializationType int) Serializer

+ type SnappyBlockCompressor struct

+ func NewSnappyBlockCompressor() *SnappyBlockCompressor

+ func (c *SnappyBlockCompressor) Compress(in []byte) ([]byte, error)

+ func (c *SnappyBlockCompressor) Decompress(in []byte) ([]byte, error)

+ type SnappyCompress struct

+ func NewSnappyCompressor() *SnappyCompress

+ func (c *SnappyCompress) Compress(in []byte) ([]byte, error)

+ func (c *SnappyCompress) Decompress(in []byte) ([]byte, error)

+ type XMLSerialization struct

+ func (*XMLSerialization) Marshal(body interface{}) ([]byte, error)

+ func (*XMLSerialization) Unmarshal(in []byte, body interface{}) error

+ type ZlibCompress struct

+ func (c *ZlibCompress) Compress(in []byte) ([]byte, error)

+ func (c *ZlibCompress) Decompress(in []byte) ([]byte, error)