message

Aug 6, 2018

Changes in this version

+ func ToBytes(m types.Message) []byte

Aug 6, 2018

Changes in this version

+ func GetAllBytes(m types.Message) [][]byte

+ func SetAllMetadata(m types.Message, meta types.Metadata)

+ type Part struct

+ func NewPart(data []byte) *Part

+ func (p *Part) Copy() types.Part

+ func (p *Part) DeepCopy() types.Part

+ func (p *Part) Get() []byte

+ func (p *Part) JSON() (interface{}, error)

+ func (p *Part) Metadata() types.Metadata

+ func (p *Part) Set(data []byte) types.Part

+ func (p *Part) SetJSON(jObj interface{}) error

+ func (p *Part) SetMetadata(meta types.Metadata) types.Part

type Type

+ func (m *Type) Copy() types.Message

Aug 2, 2018

Changes in this version

+ func CloneGeneric(root interface{}) (interface{}, error)

Jul 31, 2018

Changes in this version

+ var ErrBadMessageBytes = errors.New("serialised message bytes were in unexpected format")

+ var ErrBlockCorrupted = errors.New("serialised messages block was in unexpected format")

+ var ErrMessagePartNotExist = errors.New("target message part does not exist")

+ func Lock(msg types.Message, part int) types.Message

+ type Type struct

+ func FromBytes(b []byte) (*Type, error)

+ func New(parts [][]byte) *Type

+ func (m *Type) Append(b ...[]byte) int

+ func (m *Type) Bytes() []byte

+ func (m *Type) CreatedAt() time.Time

+ func (m *Type) DeepCopy() types.Message

+ func (m *Type) DeleteMetadata(key string)

+ func (m *Type) Get(index int) []byte

+ func (m *Type) GetAll() [][]byte

+ func (m *Type) GetJSON(part int) (interface{}, error)

+ func (m *Type) GetMetadata(key string) string

+ func (m *Type) Iter(f func(i int, b []byte) error) error

+ func (m *Type) IterMetadata(f func(k, v string) error) error

+ func (m *Type) LazyCondition(label string, cond types.Condition) bool

+ func (m *Type) Len() int

+ func (m *Type) Set(index int, b []byte)

+ func (m *Type) SetAll(p [][]byte)

+ func (m *Type) SetJSON(part int, jObj interface{}) error

+ func (m *Type) SetMetadata(key, value string)

+ func (m *Type) ShallowCopy() types.Message