mongo

Documentation

Index

• Variables
• type Client
  • func NewMongoClient(config *types.StorageConfig) (*Client, error)
  • func (c Client) Aggregate(collectionName string, pipeline interface{}) (*types.FindResult, error)
  • func (c Client) CreateIndexes(collectionName string, data interface{}) ([]string, error)
  • func (c Client) DropIndexes(collectionName string) ([]interface{}, error)
  • func (c Client) Duplicate(method string, request types.IRequest, data interface{})
  • func (c Client) DuplicateProcessor()
  • func (c Client) Find(collectionName string, selector map[string]interface{}, ...) (*types.FindResult, error)
  • func (c Client) FindOne(collectionName string, selector map[string]interface{}) (map[string]interface{}, error)
  • func (c Client) GetCollection(collectionName string) *mongo.Collection
  • func (c Client) GetIndexes(collectionName string) ([]interface{}, error)
  • func (c Client) Insert(collectionName string, doc interface{}) (*mongo.InsertOneResult, error)
  • func (c Client) InsertMany(collectionName string, docs []interface{}) (*mongo.InsertManyResult, error)
  • func (c Client) Remove(collectionName string, selector map[string]interface{}) error
  • func (c Client) Update(collectionName string, selector map[string]interface{}, update interface{}) (*mongo.UpdateResult, error)
  • func (c Client) Upsert(collectionName string, selector map[string]interface{}, update interface{}) error
• type DuplicateData
• type DuplicateRequest
• type IndexData
• type IndexElement
• type IndexesData

Variables

var DuplicateCh chan DuplicateRequest

Types

type Client

type Client struct {
	Config *types.StorageConfig
	Host   *mongo.Client
	Ctx    context.Context
}

func NewMongoClient

func NewMongoClient(config *types.StorageConfig) (*Client, error)

func (Client) Aggregate

func (c Client) Aggregate(collectionName string, pipeline interface{}) (*types.FindResult, error)

func (Client) CreateIndexes

func (c Client) CreateIndexes(collectionName string, data interface{}) ([]string, error)

func (Client) DropIndexes

func (c Client) DropIndexes(collectionName string) ([]interface{}, error)

func (Client) Duplicate

func (c Client) Duplicate(method string, request types.IRequest, data interface{})

func (Client) DuplicateProcessor

func (c Client) DuplicateProcessor()

func (Client) Find

func (c Client) Find(collectionName string, selector map[string]interface{}, inputOptions *types.Options, includeFields []string) (*types.FindResult, error)

func (Client) FindOne

func (c Client) FindOne(collectionName string, selector map[string]interface{}) (map[string]interface{}, error)

func (Client) GetCollection

func (c Client) GetCollection(collectionName string) *mongo.Collection

func (Client) GetIndexes

func (c Client) GetIndexes(collectionName string) ([]interface{}, error)

func (Client) Insert

func (c Client) Insert(collectionName string, doc interface{}) (*mongo.InsertOneResult, error)

func (Client) InsertMany

func (c Client) InsertMany(collectionName string, docs []interface{}) (*mongo.InsertManyResult, error)

func (Client) Remove

func (c Client) Remove(collectionName string, selector map[string]interface{}) error

func (Client) Update

func (c Client) Update(collectionName string, selector map[string]interface{}, update interface{}) (*mongo.UpdateResult, error)

func (Client) Upsert

func (c Client) Upsert(collectionName string, selector map[string]interface{}, update interface{}) error

type DuplicateData

type DuplicateData struct {
	Method    string      `json:"method"`
	Data      interface{} `json:"data"`
	Processed interface{} `json:"processed"`
}

type DuplicateRequest

type DuplicateRequest struct {
	Method string        `json:"method"`
	Data   DuplicateData `json:"data"`
}

type IndexData

type IndexData struct {
	Keys   []bson.M `bson:"keys" json:"keys"`
	Unique bool     `bson:"unique" json:"unique"`
}

type IndexElement

type IndexElement struct {
	Key   string      `json:"key" bson:"key"`
	Value interface{} `json:"value" bson:"value"`
}

type IndexesData

type IndexesData []IndexData