db

Documentation

Index

• func BuildTask(t *TaskStruct) (*pb.EnqueueRequest, error)
• type ConDB
  • func (d *ConDB) GetDBManager() (db.Manager, error)
• type MQManager
  • func (m *MQManager) NewMQManager() (pb.TaskQueueClient, error)
• type TaskStruct

Functions

func BuildTask

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

BuildTask build task

Types

type ConDB

type ConDB struct {
	ConnectionInfo string
	DBType         string
}

ConDB struct

func (*ConDB) GetDBManager

func (d *ConDB) GetDBManager() (db.Manager, error)

GetDBManager get db manager TODO: need to try when happend error, try 4 times

type MQManager

type MQManager struct {
	Endpoint string
}

MQManager mq manager

func (*MQManager) NewMQManager

func (m *MQManager) NewMQManager() (pb.TaskQueueClient, error)

NewMQManager new mq manager

type TaskStruct

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

TaskStruct task struct