pi

Documentation

Index

• func GetDeleteHook(p *Pi) db.DeleteHook
• func GetInsertHook(p *Pi) db.InsertHook
• func GetUpdateHook(p *Pi) db.UpdateHook
• func SetGlobalPi(cfg *config.Config)
• type Pi
  • func Global() *Pi
  • func NewPi(cfg *config.Config) *Pi
  • func (p *Pi) GlobalConfig() (globalCfg *config.GlobalConfig)
  • func (p *Pi) ThreadWatchGlobalConfig(cb globalCfgWatcher)

Examples

• NewPi

Functions

func GetDeleteHook

func GetDeleteHook(p *Pi) db.DeleteHook

func GetInsertHook

func GetInsertHook(p *Pi) db.InsertHook

func GetUpdateHook

func GetUpdateHook(p *Pi) db.UpdateHook

func SetGlobalPi

func SetGlobalPi(cfg *config.Config)

Types

type Pi

type Pi struct {
	Db   *db.Database
	Etcd *etcd.Etcd
	// contains filtered or unexported fields
}

func Global

func Global() *Pi

func NewPi

func NewPi(cfg *config.Config) *Pi

Example

package main

import (
	"fmt"

	"openpitrix.io/openpitrix/pkg/config"
	"openpitrix.io/openpitrix/pkg/logger"
	"openpitrix.io/openpitrix/pkg/pi"
)

func main() {
	// TODO: Automatic startup dependent services.
	cfg := config.LoadConf()
	logger.SetLevelByString("debug")
	cfg.Mysql.Host = "localhost"
	cfg.Etcd.Endpoints = "localhost:2379"
	p := pi.NewPi(cfg)
	fmt.Println(p.GlobalConfig())
}

func (*Pi) GlobalConfig

func (p *Pi) GlobalConfig() (globalCfg *config.GlobalConfig)

func (*Pi) ThreadWatchGlobalConfig

func (p *Pi) ThreadWatchGlobalConfig(cb globalCfgWatcher)