toolkit

Documentation

Index

• Constants
• func CloseNSQConsumer(client *nsq.Consumer)
• func CloseNSQConsumerList(clientList []*nsq.Consumer)
• func CreateConcurrentNSQConsumer(topicName, channelName string, lookupAddressList []string, ...) []*nsq.Consumer
• func CreateConsumer(cnf *std.ConfigNsqConsumer) (*nsq.Consumer, error)
• func CreateDB(config std.ConfigMysql) *gorm.DB
• func CreateDB_test(config std.ConfigMysql) *gorm.DB
• func CreateNSQConsumer(topicName, channelName string, lookupAddressList []string, ...) *nsq.Consumer
• func CreateProducer(nsqdAddress string) *nsq.Producer
• func Death(will func())
• func GO(goroutine StdGoRoutine)
• func GenerateRangeNum(min, max int) int
• func GetAppFlagFromUid(uid int64) std.AppFlag
• func GetAppTypeFromUid(uid int64) string
• func GetDBIdFromUserID(uid int64) int64
• func GetDBIdsFromUserIDs(uids []int64) []int64
• func GetUserIDFromDBId(appType string, dbId int64) int64
• func InitRedis(config std.ConfigRedis) *redis.Client
• func InitRedisRing(config ...std.ConfigRedis) *redis.Ring
• func MapToSyncMap(m map[interface{}]interface{}) *sync.Map
• func PostRequest(url string, data interface{}) ([]byte, int, error)
• func RandomDateTimeString(strlen int, stype string) string
• func SyncMapToMap(m *sync.Map) map[interface{}]interface{}
• type CassandraHelp
  • func GetCassandraHelp() *CassandraHelp
  • func InitNewCassandraHelp(config std.ConfigCassandra) *CassandraHelp
  • func (c *CassandraHelp) Close()
• type DbClient
  • func ConfigDatabase(c ...std.ConfigMysql) *DbClient
  • func (s *DbClient) Close()
  • func (s *DbClient) Master() *gorm.DB
  • func (s *DbClient) Slave() *gorm.DB
  • func (s *DbClient) TableRead(t string) *gorm.DB
  • func (s *DbClient) TableWrite(t string) *gorm.DB
• type DbSession
  • func BeginDbSession(db *gorm.DB) *DbSession
  • func (s *DbSession) Api() *gorm.DB
  • func (s *DbSession) Commit() *gorm.DB
  • func (s *DbSession) End() *gorm.DB
  • func (s *DbSession) Rollback() *gorm.DB
• type Logger
  • func (Logger Logger) Print(values ...interface{})
• type MemoPool
  • func NewSimpleMemoPool() *MemoPool
  • func (mp *MemoPool) Memoize(key string, caller func() interface{}, timeout uint) interface{}
  • func (mp *MemoPool) UnMemoize(key string)
  • func (mp *MemoPool) UnMemoizeAll()
• type QueueWorker
  • func NewQueueWorker(workers int, onWork WorkAction) *QueueWorker
  • func (sl *QueueWorker) Enqueue(job interface{})
  • func (sl *QueueWorker) Start()
  • func (sl *QueueWorker) Stop()
  • func (sl *QueueWorker) Work(index int)
• type RequestAggregator
  • func NewRequestAggregator(batchSize, workers int, sendRequestFunc SendRequest) *RequestAggregator
  • func (sa *RequestAggregator) Enqueue(req interface{})
  • func (sa *RequestAggregator) Start()
  • func (sa *RequestAggregator) Stop()
• type SendEmail
  • func (self *SendEmail) Start()
• type SendRequest
• type StdGoRoutine
• type TimeMixin
• type WorkAction

Constants

const (
	CreatedAtColumn = "created_at"
	UpdatedAtColumn = "updated_at"
)

Functions

func CloseNSQConsumer

func CloseNSQConsumer(client *nsq.Consumer)

func CloseNSQConsumerList

func CloseNSQConsumerList(clientList []*nsq.Consumer)

func CreateConcurrentNSQConsumer

func CreateConcurrentNSQConsumer(topicName, channelName string, lookupAddressList []string,
	messageHandler nsq.Handler, count int) []*nsq.Consumer

func CreateConsumer

func CreateConsumer(cnf *std.ConfigNsqConsumer) (*nsq.Consumer, error)

func CreateDB

func CreateDB(config std.ConfigMysql) *gorm.DB

func CreateDB_test

func CreateDB_test(config std.ConfigMysql) *gorm.DB

CreateDB 初始化MYSQL实例

func CreateNSQConsumer

func CreateNSQConsumer(topicName, channelName string, lookupAddressList []string,
	messageHandler nsq.Handler) *nsq.Consumer

TODO consumer

func CreateProducer

func CreateProducer(nsqdAddress string) *nsq.Producer

func Death

func Death(will func())

func GO

func GO(goroutine StdGoRoutine)

func GenerateRangeNum

func GenerateRangeNum(min, max int) int

GenerateRangeNum 生成一个区间范围的随机数

func GetAppFlagFromUid

func GetAppFlagFromUid(uid int64) std.AppFlag

func GetAppTypeFromUid

func GetAppTypeFromUid(uid int64) string

func GetDBIdFromUserID

func GetDBIdFromUserID(uid int64) int64

func GetDBIdsFromUserIDs

func GetDBIdsFromUserIDs(uids []int64) []int64

func GetUserIDFromDBId

func GetUserIDFromDBId(appType string, dbId int64) int64

func InitRedis

func InitRedis(config std.ConfigRedis) *redis.Client

InitRedis initializes the redis connection. Usage: client := InitRedis(config)

func InitRedisRing

func InitRedisRing(config ...std.ConfigRedis) *redis.Ring

func MapToSyncMap

func MapToSyncMap(m map[interface{}]interface{}) *sync.Map

func PostRequest

func PostRequest(url string, data interface{}) ([]byte, int, error)

func RandomDateTimeString

func RandomDateTimeString(strlen int, stype string) string

func SyncMapToMap

func SyncMapToMap(m *sync.Map) map[interface{}]interface{}

Types

type CassandraHelp

type CassandraHelp struct {
	Session       *gocql.Session
	ClusterConfig *gocql.ClusterConfig
}

func GetCassandraHelp

func GetCassandraHelp() *CassandraHelp

func InitNewCassandraHelp

func InitNewCassandraHelp(config std.ConfigCassandra) *CassandraHelp

func (*CassandraHelp) Close

func (c *CassandraHelp) Close()

Close closes the cassandra session

type DbClient

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

func ConfigDatabase

func ConfigDatabase(c ...std.ConfigMysql) *DbClient

func (*DbClient) Close

func (s *DbClient) Close()

func (*DbClient) Master

func (s *DbClient) Master() *gorm.DB

func (*DbClient) Slave

func (s *DbClient) Slave() *gorm.DB

func (*DbClient) TableRead

func (s *DbClient) TableRead(t string) *gorm.DB

func (*DbClient) TableWrite

func (s *DbClient) TableWrite(t string) *gorm.DB

type DbSession

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

func BeginDbSession

func BeginDbSession(db *gorm.DB) *DbSession

func (*DbSession) Api

func (s *DbSession) Api() *gorm.DB

func (*DbSession) Commit

func (s *DbSession) Commit() *gorm.DB

func (*DbSession) End

func (s *DbSession) End() *gorm.DB

为什么要加 defer sessin.End() 呢，不怕你现在写错，怕以后维护的人写错 为什么要给 goroutine 加 defer recover 呢？ 同理，这不是php或者python，挂了就真挂了

func (*DbSession) Rollback

func (s *DbSession) Rollback() *gorm.DB

type Logger

type Logger struct {
}

Logger customizes the gorm logger.

func (Logger) Print

func (Logger Logger) Print(values ...interface{})

Print uses logrus to log SQL.

type MemoPool

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

func NewSimpleMemoPool

func NewSimpleMemoPool() *MemoPool

func (*MemoPool) Memoize

func (mp *MemoPool) Memoize(key string, caller func() interface{}, timeout uint) interface{}

memorize result return from caller() block, timeout in N seconds

func (*MemoPool) UnMemoize

func (mp *MemoPool) UnMemoize(key string)

func (*MemoPool) UnMemoizeAll

func (mp *MemoPool) UnMemoizeAll()

type QueueWorker

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

func NewQueueWorker

func NewQueueWorker(workers int, onWork WorkAction) *QueueWorker

func (*QueueWorker) Enqueue

func (sl *QueueWorker) Enqueue(job interface{})

func (*QueueWorker) Start

func (sl *QueueWorker) Start()

func (*QueueWorker) Stop

func (sl *QueueWorker) Stop()

func (*QueueWorker) Work

func (sl *QueueWorker) Work(index int)

type RequestAggregator

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

func NewRequestAggregator

func NewRequestAggregator(batchSize, workers int, sendRequestFunc SendRequest) *RequestAggregator

func (*RequestAggregator) Enqueue

func (sa *RequestAggregator) Enqueue(req interface{})

func (*RequestAggregator) Start

func (sa *RequestAggregator) Start()

func (*RequestAggregator) Stop

func (sa *RequestAggregator) Stop()

type SendEmail

type SendEmail struct {
	ToEmail []string
	Subject string
	Body    string
}

func (*SendEmail) Start

func (self *SendEmail) Start()

type SendRequest

type SendRequest func([]interface{}) error

type StdGoRoutine

type StdGoRoutine interface {
	Start()
}

type TimeMixin

type TimeMixin struct {
	CreatedAt time.Time `gorm:"column:created_at;type:TIMESTAMP(6);default:CURRENT_TIMESTAMP(6);index"`
	UpdatedAt time.Time `gorm:"column:updated_at;type:TIMESTAMP(6);default:CURRENT_TIMESTAMP(6);index"`
}

TimeMixin mixin

type WorkAction

type WorkAction func(int)