encoding

Documentation

Index

• type CodecByte
  • func NewCodecByte() CodecByte
  • func (CodecByte) Decode(x []byte) ([]byte, error)
  • func (CodecByte) Encode(x []byte) ([]byte, error)
• type CodecEvent
  • func NewCodecEvent[M, T any](source, cat string) CodecEvent[M, T]
  • func (c CodecEvent[M, T]) Decode(b []byte) (swarm.Event[M, T], error)
  • func (c CodecEvent[M, T]) Encode(obj swarm.Event[M, T]) ([]byte, error)
• type CodecJson
  • func NewCodecJson[T any]() CodecJson[T]
  • func (CodecJson[T]) Decode(b []byte) (x T, err error)
  • func (CodecJson[T]) Encode(x T) ([]byte, error)
• type CodecPacket
  • func NewCodecPacket() CodecPacket
  • func (CodecPacket) Decode(x []byte) ([]byte, error)
  • func (CodecPacket) Encode(x []byte) ([]byte, error)

Types

type CodecByte

type CodecByte struct{}

Byte identity codec for I/O kernet

func NewCodecByte

func NewCodecByte() CodecByte

func (CodecByte) Decode

func (CodecByte) Decode(x []byte) ([]byte, error)

func (CodecByte) Encode

func (CodecByte) Encode(x []byte) ([]byte, error)

type CodecEvent

type CodecEvent[M, T any] struct {
	// contains filtered or unexported fields
}

Event codec for I/O kernel

func NewCodecEvent

func NewCodecEvent[M, T any](source, cat string) CodecEvent[M, T]

func (CodecEvent[M, T]) Decode

func (c CodecEvent[M, T]) Decode(b []byte) (swarm.Event[M, T], error)

func (CodecEvent[M, T]) Encode

func (c CodecEvent[M, T]) Encode(obj swarm.Event[M, T]) ([]byte, error)

type CodecJson

type CodecJson[T any] struct{}

Json codec for I/O kernel

func NewCodecJson

func NewCodecJson[T any]() CodecJson[T]

func (CodecJson[T]) Decode

func (CodecJson[T]) Decode(b []byte) (x T, err error)

func (CodecJson[T]) Encode

func (CodecJson[T]) Encode(x T) ([]byte, error)

type CodecPacket

type CodecPacket struct{}

Encode Bytes as "JSON packet"

func NewCodecPacket

func NewCodecPacket() CodecPacket

func (CodecPacket) Decode

func (CodecPacket) Decode(x []byte) ([]byte, error)

func (CodecPacket) Encode

func (CodecPacket) Encode(x []byte) ([]byte, error)