Documentation ¶
Index ¶
- func BuildTask(t *TaskStruct) (*pb.EnqueueRequest, error)
- func BuildTaskBuild(t *BuildTaskStruct) (*pb.EnqueueRequest, error)
- func CreateDBManager(conf option.Config) error
- func CreateEventManager(conf option.Config) error
- type BuildTaskStruct
- type ConDB
- type K8SManager
- type MQManager
- type OpentsdbManager
- type TaskStruct
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildTaskBuild ¶
func BuildTaskBuild(t *BuildTaskStruct) (*pb.EnqueueRequest, error)
BuildTaskBuild build task
func CreateDBManager ¶
CreateDBManager get db manager TODO: need to try when happend error, try 4 times
func CreateEventManager ¶
CreateEventManager create event manager
Types ¶
type BuildTaskStruct ¶
BuildTaskStruct build task struct
type K8SManager ¶
type K8SManager struct {
K8SConfig string
}
K8SManager struct
func (*K8SManager) NewKubeConnection ¶
func (k *K8SManager) NewKubeConnection() (*kubernetes.Clientset, error)
NewKubeConnection new k8s config path
type OpentsdbManager ¶
type OpentsdbManager struct {
Endpoint string
}
OpentsdbManager OpentsdbManager
func (*OpentsdbManager) NewOpentsdbManager ¶
func (o *OpentsdbManager) NewOpentsdbManager() (tsdbClient.Client, error)
NewOpentsdbManager NewOpentsdbManager
Click to show internal directories.
Click to hide internal directories.