bsonex

README

bsonex

fast and easy to use bson package.

Documentation

Index

• func Marshal(in interface{}) (out []byte, err error)
• func NewEncoder(w io.Writer) *gbson.Encoder
• func NewToSearchValue(v interface{}) (b toSearchValue, err error)
• func ReadOne(r io.Reader) (one []byte, err error)
• func Unmarshal(in []byte, out interface{}) (err error)
• type BSON
  • func (b BSON) FastContains(v toSearchValue) bool
  • func (b BSON) Lookup(key string) (val Value)
  • func (b BSON) Map() (m M, err error)
  • func (b BSON) MustToJson() (s []byte)
  • func (b BSON) String() string
  • func (b BSON) ToJson() (s []byte, err error)
  • func (b BSON) ToValueMap() (vals map[string]interface{})
  • func (b BSON) Unmarshal(out interface{}) (err error)
• type BSONEX
  • func (b *BSONEX) Offset() int64
  • func (b *BSONEX) RunnerID() int
  • func (b *BSONEX) Size() int
  • func (b BSONEX) String() string
• type Binary
  • func (b Binary) MarshalJSON() (bs []byte, err error)
• type Decoder
  • func NewDecoder(r io.Reader) *Decoder
  • func (d *Decoder) Decode(v interface{}) (err error)
  • func (d *Decoder) Do(parallel int, f func(b BSONEX) error) (err error)
  • func (d *Decoder) ForEach(f func(b BSONEX) error) (err error)
  • func (d *Decoder) ReadOne() (one BSON, err error)
• type M
• type Value
  • func (v Value) ArrayOf(i int) Value
  • func (v Value) Binary() Binary
  • func (v Value) Bool() bool
  • func (v Value) DBPointer() gbson.DBPointer
  • func (v Value) Document() BSON
  • func (v Value) Float64() float64
  • func (v Value) Int32() int32
  • func (v Value) Int64() int64
  • func (v Value) IsEmpty() bool
  • func (v Value) IsMaxKey() bool
  • func (v Value) IsMinKey() bool
  • func (v Value) IsNull() bool
  • func (v Value) IsUndefined() bool
  • func (v Value) Kind() byte
  • func (v Value) MongoTimestamp() gbson.MongoTimestamp
  • func (v Value) Objid() gbson.ObjectId
  • func (v Value) RawValue() []byte
  • func (v Value) Regexp() gbson.RegEx
  • func (v Value) Str() string
  • func (v Value) String() string
  • func (v Value) Time() time.Time
  • func (v Value) Type() byte
  • func (v Value) Uint32() uint32
  • func (v Value) Uint64() uint64
  • func (v Value) Value() interface{}

Functions

func Marshal

func Marshal(in interface{}) (out []byte, err error)

func NewEncoder

func NewEncoder(w io.Writer) *gbson.Encoder

func NewToSearchValue

func NewToSearchValue(v interface{}) (b toSearchValue, err error)

func ReadOne

func ReadOne(r io.Reader) (one []byte, err error)

func Unmarshal

func Unmarshal(in []byte, out interface{}) (err error)

Types

type BSON

type BSON []byte

func (BSON) FastContains

func (b BSON) FastContains(v toSearchValue) bool

Contains 可以在未解析BSON的时候先快速判断一下是否包含待查找的内容， 避免执行每个文档都执行Unmarshal加快查找速度。 需要注意的是这里查找并不精确，必要的情况下仍然需要再次Unmarshal再确认一次。

func (BSON) Lookup

func (b BSON) Lookup(key string) (val Value)

func (BSON) Map

func (b BSON) Map() (m M, err error)

func (BSON) MustToJson

func (b BSON) MustToJson() (s []byte)

func (BSON) String

func (b BSON) String() string

func (BSON) ToJson

func (b BSON) ToJson() (s []byte, err error)

func (BSON) ToValueMap

func (b BSON) ToValueMap() (vals map[string]interface{})

func (BSON) Unmarshal

func (b BSON) Unmarshal(out interface{}) (err error)

type BSONEX

type BSONEX struct {
	BSON
	// contains filtered or unexported fields
}

func (*BSONEX) Offset

func (b *BSONEX) Offset() int64

func (*BSONEX) RunnerID

func (b *BSONEX) RunnerID() int

func (*BSONEX) Size

func (b *BSONEX) Size() int

func (BSONEX) String

func (b BSONEX) String() string

type Binary

type Binary struct {
	gbson.Binary
}

func (Binary) MarshalJSON

func (b Binary) MarshalJSON() (bs []byte, err error)

type Decoder

type Decoder struct {
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(r io.Reader) *Decoder

func (*Decoder) Decode

func (d *Decoder) Decode(v interface{}) (err error)

func (*Decoder) Do

func (d *Decoder) Do(parallel int, f func(b BSONEX) error) (err error)

func (*Decoder) ForEach

func (d *Decoder) ForEach(f func(b BSONEX) error) (err error)

func (*Decoder) ReadOne

func (d *Decoder) ReadOne() (one BSON, err error)

type M

type M map[string]interface{}

type Value

type Value struct {
	// contains filtered or unexported fields
}

func (Value) ArrayOf

func (v Value) ArrayOf(i int) Value

func (Value) Binary

func (v Value) Binary() Binary

func (Value) Bool

func (v Value) Bool() bool

func (Value) DBPointer

func (v Value) DBPointer() gbson.DBPointer

func (Value) Document

func (v Value) Document() BSON

func (Value) Float64

func (v Value) Float64() float64

func (Value) Int32

func (v Value) Int32() int32

func (Value) Int64

func (v Value) Int64() int64

func (Value) IsEmpty

func (v Value) IsEmpty() bool

func (Value) IsMaxKey

func (v Value) IsMaxKey() bool

func (Value) IsMinKey

func (v Value) IsMinKey() bool

func (Value) IsNull

func (v Value) IsNull() bool

func (Value) IsUndefined

func (v Value) IsUndefined() bool

func (Value) Kind

func (v Value) Kind() byte

func (Value) MongoTimestamp

func (v Value) MongoTimestamp() gbson.MongoTimestamp

func (Value) Objid

func (v Value) Objid() gbson.ObjectId

func (Value) RawValue

func (v Value) RawValue() []byte

func (Value) Regexp

func (v Value) Regexp() gbson.RegEx

func (Value) Str

func (v Value) Str() string

func (Value) String

func (v Value) String() string

func (Value) Time

func (v Value) Time() time.Time

func (Value) Type

func (v Value) Type() byte

func (Value) Uint32

func (v Value) Uint32() uint32

func (Value) Uint64

func (v Value) Uint64() uint64

func (Value) Value

func (v Value) Value() interface{}