ginflux

Oct 19, 2019

Changes in this version

type Database

+ func (d *Database) QueryRaw(str string, bean ...interface{}) (s *Search, err error)

Aug 21, 2019

Changes in this version

+ func SetTimeZone()

Aug 2, 2019

Changes in this version

type JSONTime

+ func Must2JSONTimeAddr(in string) *JSONTime

+ func (p JSONTime) Addr() *JSONTime

Jul 17, 2019

Changes in this version

+ var ErrTimeout = errors.New("从池中获取连接超时")

Jul 16, 2019

Changes in this version

+ var DefOpts = Options

type Options

+ GetTimeout time.Duration

+ HttpConf ic.HTTPConfig

+ MaxOpen int

+ MinOpen int

Jul 16, 2019

Changes in this version

+ const Custom

+ const Field

+ const FieldJSON

+ const FieldName

+ const TAG

+ const TAGKey

+ const TAGTime

+ const TimeZone

+ const Version

+ var ErrEmpty = errors.New("empty")

+ var ErrInUsing = errors.New("连接正在使用,不能共享")

+ var ErrMaxOpen = errors.New("连接数超出最大限制")

+ var LintGonicMapper = GonicMapper

+ func BytesToString(b []byte) string

+ func CamelString(s string) string

+ func IsSliceContainsStr(sl []string, str string) bool

+ func ObjectName(obj interface{}) string

+ func SnakeString(s string) string

+ func StringToBytes(s string) []byte

+ func ToStr(value interface{}, args ...int) (s string)

+ type CacheMapper struct

+ func NewCacheMapper(mapper IMapper) *CacheMapper

+ func (m *CacheMapper) Obj2Table(o string) string

+ func (m *CacheMapper) Table2Obj(t string) string

+ type Conversion interface

+ FromDB func(data []byte) error

+ ToDB func() (b []byte, err error)

+ type Database struct

+ func (d *Database) Insert(bean interface{}) error

+ func (d *Database) Query(str string, bean ...interface{}) (s *Search, err error)

+ func (d *Database) SetBatchPointConf(batchPointConf ic.BatchPointsConfig) *Database

+ func (d *Database) SetBpsFunc(bpsFunc bpsActionFunc) *Database

+ func (d *Database) SetName(name string) *Database

+ type Engine struct

+ func NewEngine(opts Options) (eg *Engine, err error)

+ func (e *Engine) Acquire() (cl *OClient, err error)

+ func (e *Engine) DB(name string) *Database

+ func (e *Engine) NewDB(name string) (dbInstance *Database, err error)

+ func (e *Engine) NewSession() (session *Session, err error)

+ func (e *Engine) Session() *Session

+ func (e *Engine) SyncDB(beans ...RetentionPolicy) (err error)

+ type GonicMapper map[string]bool

+ func (mapper GonicMapper) Obj2Table(name string) string

+ func (mapper GonicMapper) Table2Obj(name string) string

+ type IMapper interface

+ Obj2Table func(string) string

+ Table2Obj func(string) string

+ type InterfaceTable interface

+ Measurement func() string

+ type InterfaceTime interface

+ Time func() time.Time

+ type JSONTime time.Time

+ func ToDatetime(in string) (JSONTime, error)

+ func (p *JSONTime) Convert2Time() time.Time

+ func (p *JSONTime) FromDB(data []byte) error

+ func (p *JSONTime) GobDecode(data []byte) error

+ func (p *JSONTime) Scan(v interface{}) error

+ func (p *JSONTime) SetByTime(timeVal time.Time)

+ func (p *JSONTime) Time() time.Time

+ func (p *JSONTime) ToDB() (b []byte, err error)

+ func (p *JSONTime) UnmarshalJSON(data []byte) error

+ func (p JSONTime) GobEncode() ([]byte, error)

+ func (p JSONTime) MarshalJSON() ([]byte, error)

+ func (p JSONTime) String() string

+ func (p JSONTime) Value() (driver.Value, error)

+ type Map map[string]interface

+ type MapString map[string]string

+ type OClient struct

+ func (o *OClient) GetInfluxClient() ic.Client

+ func (o *OClient) Release()

+ type OPool struct

+ func NewOPool(opt Options) *OPool

+ func (o *OPool) Acquire() (cl *OClient, err error)

+ func (o *OPool) CurrentOpen() int64

+ func (o *OPool) Increment(n int64)

+ type Options struct

+ type PrefixMapper struct

+ Mapper IMapper

+ Prefix string

+ func NewPrefixMapper(mapper IMapper, prefix string) PrefixMapper

+ func (mapper PrefixMapper) Obj2Table(name string) string

+ func (mapper PrefixMapper) Table2Obj(name string) string

+ type RetentionPolicy struct

+ DBName string

+ Default bool

+ Duration string

+ RPName string

+ Replication int

+ ShardDuration string

+ type SameMapper struct

+ func (m SameMapper) Obj2Table(o string) string

+ func (m SameMapper) Table2Obj(t string) string

+ type Search struct

+ Database *Database

+ Err error

+ Result *ic.Response

+ type Session struct

+ func (s *Session) Client() *OClient

+ func (s *Session) CreateDB(name string) error

+ func (s *Session) CreateRetentionPolicy(rp RetentionPolicy) error

+ func (s *Session) NewDB(name string) (dbInstance *Database)

+ func (s *Session) Release()

+ func (s *Session) SetClient(client *OClient) *Session

+ type SnakeMapper struct

+ func (mapper SnakeMapper) Obj2Table(name string) string

+ func (mapper SnakeMapper) Table2Obj(name string) string

+ type StringVal string

+ func (s StringVal) Bind(fieldValue *reflect.Value) (err error)

+ func (s StringVal) MapInterfaceToStruct(dstVal *reflect.Value) (err error)

+ type StructBean struct

+ func NewStructBean(bean interface{}) *StructBean

+ func (s *StructBean) Point() models.Point

+ type SuffixMapper struct

+ Mapper IMapper

+ Suffix string

+ func NewSuffixMapper(mapper IMapper, suffix string) SuffixMapper

+ func (mapper SuffixMapper) Obj2Table(name string) string

+ func (mapper SuffixMapper) Table2Obj(name string) string