encoder

Documentation

Index

• func DecodeMessage[T any](data []byte) (T, error)
• func EncodeMessage(message any) ([]byte, error)
• func ReadMessage(conn net.Conn) ([]byte, error)
• func WriteHeartbeatRequest(conn net.Conn) error
• func WriteHeartbeatResponse(conn net.Conn, id string) error
• func WriteMessage(conn net.Conn, msg []byte) error

Functions

func DecodeMessage

func DecodeMessage[T any](data []byte) (T, error)

DecodeMessage decodes a message.

func EncodeMessage

func EncodeMessage(message any) ([]byte, error)

EncodeMessage encodes a message.

func ReadMessage

func ReadMessage(conn net.Conn) ([]byte, error)

ReadMessage reads a message.

func WriteHeartbeatRequest

func WriteHeartbeatRequest(conn net.Conn) error

WriteHeartbeatRequest writes a heartbeat request.

func WriteHeartbeatResponse

func WriteHeartbeatResponse(conn net.Conn, id string) error

WriteHeartbeatResponse writes a heartbeat response.

func WriteMessage

func WriteMessage(conn net.Conn, msg []byte) error

WriteMessage writes a message.