db

Documentation

Index

• func BuildTask(t *TaskStruct) (*pb.EnqueueRequest, error)
• func CreateDBManager(conf option.Config) error
• func CreateEventManager(conf option.Config) error
• func GetBegin() *gorm.DB
• type ConDB
• type MQManager
  • func (m *MQManager) NewMQManager() (client.MQClient, error)
• type OpentsdbManager
  • func (o *OpentsdbManager) NewOpentsdbManager() (tsdbClient.Client, error)
• type TaskStruct

Functions

func BuildTask

func BuildTask(t *TaskStruct) (*pb.EnqueueRequest, error)

BuildTask build task

func CreateDBManager

func CreateDBManager(conf option.Config) error

CreateDBManager get db manager TODO: need to try when happened error, try 4 times

func CreateEventManager

func CreateEventManager(conf option.Config) error

CreateEventManager create event manager

func GetBegin

func GetBegin() *gorm.DB

GetBegin get db transaction

Types

type ConDB

type ConDB struct {
	ConnectionInfo string
	DBType         string
}

ConDB struct

type MQManager

type MQManager struct {
	EtcdEndpoint  []string
	DefaultServer string
}

MQManager mq manager

func (*MQManager) NewMQManager

func (m *MQManager) NewMQManager() (client.MQClient, error)

NewMQManager new mq manager

type OpentsdbManager

type OpentsdbManager struct {
	Endpoint string
}

OpentsdbManager OpentsdbManager

func (*OpentsdbManager) NewOpentsdbManager

func (o *OpentsdbManager) NewOpentsdbManager() (tsdbClient.Client, error)

NewOpentsdbManager NewOpentsdbManager

type TaskStruct

type TaskStruct struct {
	TaskType string
	TaskBody model.TaskBody
	User     string
}

TaskStruct task struct