dao

Documentation

Index

• Constants
• func Format(inter interface{}, f func(i interface{}) map[string]interface{}) (interface{}, int)
• func GetObjectID(id interface{}) (primitive.ObjectID, error)
• func NewEsIndex() *index
• type CacheMapObj
• type CacheObj
• type Collection
• type ComCacheObj
  • func (t *ComCacheObj) Decode(data []byte, i interface{}) error
  • func (t *ComCacheObj) DecodePipe(obj CacheObj) error
  • func (t *ComCacheObj) Encode(i interface{}) ([]byte, error)
  • func (s *ComCacheObj) GetError() error
  • func (s *ComCacheObj) GetStringCmd() (*redis.StringCmd, error)
  • func (s *ComCacheObj) HasError() bool
  • func (s *ComCacheObj) SetStringCmd(sc *redis.StringCmd)
• type CommonDoc
  • func (c *CommonDoc) AddRecord(u LogUser, msg string) []*Record
  • func (u *CommonDoc) GetC() string
  • func (c *CommonDoc) SetCreator(lu LogUser)
• type DocInter
• type ESDao
• type ListDoc
• type LogUser
• type Record
  • func NewRecord(date time.Time, acc, name, msg string) *Record
• type SearchDaoList
  • func (sdl SearchDaoList) Add(sd ESDao) error

Constants

const (
	PropFormatEmpty = ""
	PropFormatTime  = "epoch_second"
)

Functions

func Format

func Format(inter interface{}, f func(i interface{}) map[string]interface{}) (interface{}, int)

func GetObjectID

func GetObjectID(id interface{}) (primitive.ObjectID, error)

func NewEsIndex

func NewEsIndex() *index

Types

type CacheMapObj

type CacheMapObj interface {
	GetKey() string
	EncodeMap() (map[string]string, error)
	DecodeMap(map[string]string) error
}

type CacheObj

type CacheObj interface {
	GetKey() string
	Encode() ([]byte, error)
	SetStringCmd(sc *redis.StringCmd)
	Decode([]byte) error
	DecodePipe() error
	GetError() error
	HasError() bool
}

type Collection

type Collection interface {
	GetC() string
}

type ComCacheObj

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

func (*ComCacheObj) Decode

func (t *ComCacheObj) Decode(data []byte, i interface{}) error

func (*ComCacheObj) DecodePipe

func (t *ComCacheObj) DecodePipe(obj CacheObj) error

func (*ComCacheObj) Encode

func (t *ComCacheObj) Encode(i interface{}) ([]byte, error)

func (*ComCacheObj) GetError

func (s *ComCacheObj) GetError() error

func (*ComCacheObj) GetStringCmd

func (s *ComCacheObj) GetStringCmd() (*redis.StringCmd, error)

func (*ComCacheObj) HasError

func (s *ComCacheObj) HasError() bool

func (*ComCacheObj) SetStringCmd

func (s *ComCacheObj) SetStringCmd(sc *redis.StringCmd)

type CommonDoc

type CommonDoc struct {
	Records []*Record
}

func (*CommonDoc) AddRecord

func (c *CommonDoc) AddRecord(u LogUser, msg string) []*Record

func (*CommonDoc) GetC

func (u *CommonDoc) GetC() string

func (*CommonDoc) SetCreator

func (c *CommonDoc) SetCreator(lu LogUser)

type DocInter

type DocInter interface {
	Collection
	GetDoc() interface{}
	GetID() interface{}
	SetCreator(u LogUser)
	AddRecord(u LogUser, msg string) []*Record
	GetIndexes() []mongo.IndexModel
}

type ESDao

type ESDao interface {
	GetType() string
	GetJsonBody() (string, error)
	GetID() string
	GetMapping() string
}

type ListDoc

type ListDoc interface {
	GetID() string
	GetC() string
	GetList(slice interface{}) []ListDoc
	BeforeSave() error
}

type LogUser

type LogUser interface {
	GetName() string
	GetAccount() string
}

type Record

type Record struct {
	Datetime time.Time
	Summary  string
	Account  string
	Name     string
}

func NewRecord

func NewRecord(date time.Time, acc, name, msg string) *Record

type SearchDaoList

type SearchDaoList []ESDao

func (SearchDaoList) Add

func (sdl SearchDaoList) Add(sd ESDao) error