tools

package
v0.0.0-...-7efdb2d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2016 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MAX_POOL_SIZE = 20
)

Functions

func GetGuid

func GetGuid() string

@Title Generate guid @Description Generate guid @Success string

func GetMd5String

func GetMd5String(s string) string

@Title Generate md5 @Description Generate 32-bit string md5 @Success string

func Session

func Session() *mgo.Session

func SplitRange

func SplitRange(rangestr string) (int64, int64, error)

@Title Split Range @Description split range to start and end @Success int64 int 64 error

func StructToMap

func StructToMap(obj interface{}) map[string]interface{}

@Title StructToMap @Description change struct to map[string]interface{} @Success map[string]interface{}

Types

type Filehelper

type Filehelper struct{}

func (*Filehelper) ReadFile

func (f *Filehelper) ReadFile(filename string) ([]byte, error)

func (*Filehelper) UploadFileToMongo

func (f *Filehelper) UploadFileToMongo(filemode models.Filemodel) (string, error)

func (*Filehelper) WriteFile

func (f *Filehelper) WriteFile(filename string, file []byte) (string, error)

type MongoConnectionPool

type MongoConnectionPool struct{}

type MongoGridFSHelper

type MongoGridFSHelper struct{}

func (*MongoGridFSHelper) DeleteFileById

func (m *MongoGridFSHelper) DeleteFileById(objectId string) error

func (*MongoGridFSHelper) GetFileById

func (m *MongoGridFSHelper) GetFileById(collectionname string, objectId string) (rangemode interface{}, err error)

func (*MongoGridFSHelper) UploadFile

func (m *MongoGridFSHelper) UploadFile(filemode models.Filemodel) (objectId string, err error)

type MongoHelper

type MongoHelper struct{}

func (*MongoHelper) Create

func (m *MongoHelper) Create(collectionname string, object interface{}) (objectId string, err error)

func (*MongoHelper) DeleteDoc

func (m *MongoHelper) DeleteDoc(collectionname string, objectId string) error

func (*MongoHelper) GetAll

func (m *MongoHelper) GetAll(collectionname string) (result [][]byte, err error)

func (*MongoHelper) GetFieldByFilter

func (m *MongoHelper) GetFieldByFilter(collectionname string, filters map[string]interface{}) (result []byte, err error)

func (*MongoHelper) GetOneByFilter

func (m *MongoHelper) GetOneByFilter(collectionname string, filters map[string]string) (result []byte, err error)

func (*MongoHelper) GetOneById

func (m *MongoHelper) GetOneById(collectionname string, objectId string) (result []byte, err error)

func (*MongoHelper) GetSomeByFilter

func (m *MongoHelper) GetSomeByFilter(collectionname string, filters bson.M) (result [][]byte, err error)

func (*MongoHelper) PullItem

func (m *MongoHelper) PullItem(collectionname string, objectId string, fildName string, object interface{}) error

func (*MongoHelper) PushItem

func (m *MongoHelper) PushItem(collectionname string, objectId string, fildName string, object interface{}) error

func (*MongoHelper) Update

func (m *MongoHelper) Update(collectionname string, filters map[string]interface{}) error

func (*MongoHelper) UpdateById

func (m *MongoHelper) UpdateById(collectionname string, objectId string, object interface{}) error

type Neo4jHelper

type Neo4jHelper struct{}

func (*Neo4jHelper) CommitNodeByQuery

func (r *Neo4jHelper) CommitNodeByQuery(query neoism.CypherQuery) error

func (*Neo4jHelper) CreateNode

func (r *Neo4jHelper) CreateNode(properties map[string]interface{}, label string) (int, error)

func (*Neo4jHelper) CreateRelationship

func (r *Neo4jHelper) CreateRelationship(startid int, endid int, relationship string) (int, error)

func (*Neo4jHelper) DeleteNode

func (r *Neo4jHelper) DeleteNode(nodeid int) error

func (*Neo4jHelper) DeleteRelationship

func (r *Neo4jHelper) DeleteRelationship(relationshipid int) error

func (*Neo4jHelper) GetNode

func (r *Neo4jHelper) GetNode(nodeid int) (*neoism.Node, error)

func (*Neo4jHelper) UpdateNode

func (r *Neo4jHelper) UpdateNode(nodeid int, properties map[string]interface{}) error

type RedisHelper

type RedisHelper struct{}

func (*RedisHelper) GetVByK

func (r *RedisHelper) GetVByK(key interface{}, returntype string) (value interface{}, err error)

func (*RedisHelper) SetKV

func (r *RedisHelper) SetKV(key interface{}, value interface{}) error

func (*RedisHelper) SetKVBySETEX

func (r *RedisHelper) SetKVBySETEX(key interface{}, value interface{}, time int) error

type ResultHelp

type ResultHelp struct{}

func (*ResultHelp) CheckErr

func (r *ResultHelp) CheckErr(err error) error

func (*ResultHelp) NewErr

func (r *ResultHelp) NewErr(err string) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL