Versions in this module Expand all Collapse all v4 v4.1.2 Oct 25, 2022 Changes in this version + func DiscardAttribute(br resp.BufferedReader, o *resp.Opts) error + func Flatten(i interface{}, o *resp.Opts) ([]string, error) + func Marshal(w io.Writer, i interface{}, o *resp.Opts) error + func NextMessageIs(br resp.BufferedReader, p Prefix) (bool, error) + func Unmarshal(br resp.BufferedReader, rcv interface{}, o *resp.Opts) error + type ArrayHeader struct + NumElems int + StreamedArrayHeader bool + func (h *ArrayHeader) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (h ArrayHeader) MarshalRESP(w io.Writer, o *resp.Opts) error + type AttributeHeader struct + NumPairs int + func (h *AttributeHeader) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (h AttributeHeader) MarshalRESP(w io.Writer, o *resp.Opts) error + type BigNumber struct + I *big.Int + func (b *BigNumber) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b BigNumber) MarshalRESP(w io.Writer, o *resp.Opts) error + type BlobError struct + B []byte + func (e *BlobError) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (e BlobError) Error() string + func (e BlobError) MarshalRESP(w io.Writer, o *resp.Opts) error + type BlobString struct + S string + StreamedStringHeader bool + func (b *BlobString) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b BlobString) MarshalRESP(w io.Writer, o *resp.Opts) error + type BlobStringBytes struct + B []byte + StreamedStringHeader bool + func (b *BlobStringBytes) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b BlobStringBytes) MarshalRESP(w io.Writer, o *resp.Opts) error + type BlobStringWriter struct + LR resp.LenReader + func (b BlobStringWriter) MarshalRESP(w io.Writer, o *resp.Opts) error + type Boolean struct + B bool + func (b *Boolean) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b Boolean) MarshalRESP(w io.Writer, o *resp.Opts) error + type Double struct + F float64 + func (d *Double) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (d Double) MarshalRESP(w io.Writer, o *resp.Opts) error + type MapHeader struct + NumPairs int + StreamedMapHeader bool + func (h *MapHeader) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (h MapHeader) MarshalRESP(w io.Writer, o *resp.Opts) error + type Null struct + func (*Null) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (Null) MarshalRESP(w io.Writer, o *resp.Opts) error + type Number struct + N int64 + func (n *Number) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (n Number) MarshalRESP(w io.Writer, o *resp.Opts) error + type Prefix byte + var ArrayHeaderPrefix Prefix = '*' + var AttributeHeaderPrefix Prefix = '|' + var BigNumberPrefix Prefix = '(' + var BlobErrorPrefix Prefix = '!' + var BlobStringPrefix Prefix = '$' + var BooleanPrefix Prefix = '#' + var DoublePrefix Prefix = ',' + var MapHeaderPrefix Prefix = '%' + var NullPrefix Prefix = '_' + var NumberPrefix Prefix = ':' + var PushHeaderPrefix Prefix = '>' + var SetHeaderPrefix Prefix = '~' + var SimpleErrorPrefix Prefix = '-' + var SimpleStringPrefix Prefix = '+' + var StreamedAggregatedTypeEndPrefix Prefix = '.' + var StreamedStringChunkPrefix Prefix = ';' + var VerbatimStringPrefix Prefix = '=' + func (p Prefix) String() string + type PushHeader struct + NumElems int + func (h *PushHeader) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (h PushHeader) MarshalRESP(w io.Writer, o *resp.Opts) error + type RawMessage []byte + func (rm *RawMessage) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (rm RawMessage) IsEmpty() bool + func (rm RawMessage) IsNull() bool + func (rm RawMessage) IsStreamedHeader() bool + func (rm RawMessage) MarshalRESP(w io.Writer, o *resp.Opts) error + func (rm RawMessage) UnmarshalInto(rcv interface{}, o *resp.Opts) error + type SetHeader struct + NumElems int + StreamedSetHeader bool + func (h *SetHeader) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (h SetHeader) MarshalRESP(w io.Writer, o *resp.Opts) error + type SimpleError struct + S string + func (e *SimpleError) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (e SimpleError) Error() string + func (e SimpleError) MarshalRESP(w io.Writer, o *resp.Opts) error + type SimpleString struct + S string + func (ss *SimpleString) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (ss SimpleString) MarshalRESP(w io.Writer, o *resp.Opts) error + type StreamedAggregatedElement struct + End bool + Receiver interface{} + func (s *StreamedAggregatedElement) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + type StreamedAggregatedTypeEnd struct + func (s *StreamedAggregatedTypeEnd) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (s StreamedAggregatedTypeEnd) MarshalRESP(w io.Writer, o *resp.Opts) error + type StreamedStringChunk struct + S string + func (b *StreamedStringChunk) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b StreamedStringChunk) MarshalRESP(w io.Writer, o *resp.Opts) error + type StreamedStringChunkBytes struct + B []byte + func (b *StreamedStringChunkBytes) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b StreamedStringChunkBytes) MarshalRESP(w io.Writer, o *resp.Opts) error + type StreamedStringReader struct + W io.Writer + func (r *StreamedStringReader) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + type StreamedStringWriter struct + R io.Reader + func (sw StreamedStringWriter) MarshalRESP(w io.Writer, o *resp.Opts) error + type VerbatimString struct + Format string + S string + func (b *VerbatimString) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b VerbatimString) MarshalRESP(w io.Writer, o *resp.Opts) error + type VerbatimStringBytes struct + B []byte + Format []byte + func (b *VerbatimStringBytes) UnmarshalRESP(br resp.BufferedReader, o *resp.Opts) error + func (b VerbatimStringBytes) MarshalRESP(w io.Writer, o *resp.Opts) error