mongo

Documentation

Index

• func NewMongoDAO(m *mongodb.Indexer) log.MessageRepository
• type MongoCodec
  • func (m *MongoCodec) BuildQuery(query interface{}, offset, limit int32, sortFields string, sortDesc bool) (interface{}, interface{}, error)
  • func (m *MongoCodec) BuildQueryOptions(query interface{}, offset, limit int32, sortFields string, sortDesc bool) (interface{}, error)
  • func (m *MongoCodec) GetModel(sc configx.Values) (interface{}, bool)
  • func (m *MongoCodec) Unmarshal(indexed interface{}) (interface{}, error)

Functions

func NewMongoDAO

func NewMongoDAO(m *mongodb.Indexer) log.MessageRepository

Types

type MongoCodec

type MongoCodec struct {
	log.BaseCodec
}

func (*MongoCodec) BuildQuery

func (m *MongoCodec) BuildQuery(query interface{}, offset, limit int32, sortFields string, sortDesc bool) (interface{}, interface{}, error)

func (*MongoCodec) BuildQueryOptions

func (m *MongoCodec) BuildQueryOptions(query interface{}, offset, limit int32, sortFields string, sortDesc bool) (interface{}, error)

func (*MongoCodec) GetModel

func (m *MongoCodec) GetModel(sc configx.Values) (interface{}, bool)

func (*MongoCodec) Unmarshal

func (m *MongoCodec) Unmarshal(indexed interface{}) (interface{}, error)