db

package
v5.1.10-release+incomp... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2020 License: LGPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL