socket

Documentation

Index

• func GetIO(sess *yamux.Session) (*cbor.Encoder, *cbor.Decoder)
• func GetStreamIO(c *yamux.Stream) (*cbor.Encoder, *cbor.Decoder)
• func Read(dec *cbor.Decoder, obj interface{})
• func ReadMap(src map[string]interface{}, dest interface{})
• func Write(enc *cbor.Encoder, obj interface{})

Functions

func GetIO

func GetIO(sess *yamux.Session) (*cbor.Encoder, *cbor.Decoder)

GetIO Open a yamux connection and returns encoder and decoder

func GetStreamIO

func GetStreamIO(c *yamux.Stream) (*cbor.Encoder, *cbor.Decoder)

GetStreamIO Creates encoder and decoder for yamux stream

func Read

func Read(dec *cbor.Decoder, obj interface{})

Read decodes the value to obj

func ReadMap

func ReadMap(src map[string]interface{}, dest interface{})

ReadMap decodes src to dest interface

func Write

func Write(enc *cbor.Encoder, obj interface{})

Write encodes the given obj