multimsg

Documentation

Overview

Package multimsg implements a margaret codec to encode multiple kinds of messages to disk. Currently _legacy_ and _gabbygrove_ but should be easily extendable.

Index

• type AlterableLog
• type MargaretCodec
  • func (c MargaretCodec) Marshal(v interface{}) ([]byte, error)
  • func (c MargaretCodec) NewDecoder(r io.Reader) margaret.Decoder
  • func (c MargaretCodec) NewEncoder(w io.Writer) margaret.Encoder
  • func (c MargaretCodec) Unmarshal(data []byte) (interface{}, error)
• type MessageType
• type MultiMessage
  • func NewMultiMessageFromKeyValRaw(msg refs.KeyValueRaw, raw json.RawMessage) MultiMessage
  • func NewMultiMessageFromLegacy(msg *legacy.StoredMessage) *MultiMessage
  • func (mm MultiMessage) AsGabby() (*gabbygrove.Transfer, bool)
  • func (mm MultiMessage) AsLegacy() (*legacy.StoredMessage, bool)
  • func (mm MultiMessage) AsMetaFeed() (*metafeed.Message, bool)
  • func (mm MultiMessage) MarshalBinary() ([]byte, error)
  • func (mm MultiMessage) Received() time.Time
  • func (mm *MultiMessage) UnmarshalBinary(data []byte) error
• type WrappedLog
  • func NewWrappedLog(in AlterableLog) *WrappedLog
  • func (wl WrappedLog) Append(val interface{}) (int64, error)

Types

type AlterableLog

type AlterableLog interface {
	margaret.Log
	margaret.Alterer
	io.Closer
}

type MargaretCodec

type MargaretCodec struct{}

func (MargaretCodec) Marshal

func (c MargaretCodec) Marshal(v interface{}) ([]byte, error)

func (MargaretCodec) NewDecoder

func (c MargaretCodec) NewDecoder(r io.Reader) margaret.Decoder

func (MargaretCodec) NewEncoder

func (c MargaretCodec) NewEncoder(w io.Writer) margaret.Encoder

func (MargaretCodec) Unmarshal

func (c MargaretCodec) Unmarshal(data []byte) (interface{}, error)

type MessageType

type MessageType byte

const (
	Unknown MessageType = iota
	Legacy
	Gabby
	MetaFeed
)

type MultiMessage

type MultiMessage struct {
	refs.Message
	// contains filtered or unexported fields
}

MultiMessage attempts to support multiple message formats in the same storage layer currently supports Proto and legacy

func NewMultiMessageFromKeyValRaw

func NewMultiMessageFromKeyValRaw(msg refs.KeyValueRaw, raw json.RawMessage) MultiMessage

func NewMultiMessageFromLegacy

func NewMultiMessageFromLegacy(msg *legacy.StoredMessage) *MultiMessage

func (MultiMessage) AsGabby

func (mm MultiMessage) AsGabby() (*gabbygrove.Transfer, bool)

func (MultiMessage) AsLegacy

func (mm MultiMessage) AsLegacy() (*legacy.StoredMessage, bool)

func (MultiMessage) AsMetaFeed

func (mm MultiMessage) AsMetaFeed() (*metafeed.Message, bool)

func (MultiMessage) MarshalBinary

func (mm MultiMessage) MarshalBinary() ([]byte, error)

func (MultiMessage) Received

func (mm MultiMessage) Received() time.Time

func (*MultiMessage) UnmarshalBinary

func (mm *MultiMessage) UnmarshalBinary(data []byte) error

type WrappedLog

type WrappedLog struct {
	AlterableLog
	// contains filtered or unexported fields
}

func NewWrappedLog

func NewWrappedLog(in AlterableLog) *WrappedLog

func (WrappedLog) Append

func (wl WrappedLog) Append(val interface{}) (int64, error)