app

Documentation

Index

• Constants
• Variables
• func DaemonProcess(d bool) bool
• func GetKey(sessionFile string) string
• func Init(hasCmd bool, configPath string)
• func Release()
• func Usage()
• type Config
• type Context
  • func NewContext() *Context
  • func (ctx *Context) Done() <-chan struct{}
  • func (ctx *Context) Stop()
• type MysqlConfig
• type TcpConfig
• type TcpGroupConfig
• type TcpGroupConfigs
  • func (cs *TcpGroupConfigs) HasName(name string) bool

Constants

const (
	VERSION = "1.0.3"
)

Variables

var (
	Pid        = path.CurrentPath + "/wing-binlog-go.pid"
	DEBUG      = false
	ConfigPath = path.CurrentPath + "/config"
	CachePath  = path.CurrentPath + "/cache"
	LogPath    = path.CurrentPath + "/logs"
)

var (
	ErrorFileNotFound = errors.New("file does not exists")
	ErrorFileParse    = errors.New("config file parse error")
)

Functions

func DaemonProcess

func DaemonProcess(d bool) bool

run as daemon process

func GetKey

func GetKey(sessionFile string) string

get unique key, param if file path if file does not exists, try to create it, and write a unique key return the unique key if exists, read file and return it

func Init

func Init(hasCmd bool, configPath string)

app init config path parse cache path parse log path parse get app config check app is running, if pid file exists, app is running write pid file start pprof set logger

func Release

func Release()

use for main func, defer app.Release release ctx resource

func Usage

func Usage()

show usage

Types

type Config

type Config struct {
	LogLevel      int    `toml:"log_level"`
	PprofListen   string `toml:"pprof_listen"`
	ControlListen string `toml:"control_listen"`
	TimeZone      string `toml:"time_zone"`
	CachePath     string `toml:"cache_path"`
	LogPath       string `toml:"log_path"`
	PidFile       string `toml:"pid_file"`
}

type Context

type Context struct {
	// canal context
	Ctx context.Context
	// canal context func
	Cancel context.CancelFunc
	// pid file path
	PidFile string

	//reloadChan chan string
	//ShowMembersChan chan struct{}
	//ShowMembersRes chan string
	PosChan chan string
	//HttpConfig *HttpConfig
	//TcpConfig *TcpConfig
	MysqlConfig *MysqlConfig
	//ClusterConfig *ClusterConfig
	AppConfig *Config
	// contains filtered or unexported fields
}

context

func NewContext

func NewContext() *Context

new app context

func (*Context) Done

func (ctx *Context) Done() <-chan struct{}

func (*Context) Stop

func (ctx *Context) Stop()

type MysqlConfig

type MysqlConfig struct {
	// mysql service ip and port, like: "127.0.0.1:3306"
	Addr string `toml:"addr"`
	// mysql service user
	User string `toml:"user"`
	// mysql password
	Password string `toml:"password"`
	// mysql default charset
	Charset string `toml:"charset"`
	// mysql binlog client id, it must be unique
	ServerID uint32 `toml:"server_id"`
	// mysql or mariadb
	Flavor string `toml:"flavor"`
	// heartbeat interval, unit is ns, 30000000000  = 30s   1000000000 = 1s
	HeartbeatPeriod time.Duration `toml:"heartbeat_period"`
	// read timeout, unit is ns, 0 is never timeout, 30000000000  = 30s   1000000000 = 1s
	ReadTimeout time.Duration `toml:"read_timeout"`
	// read start form the binlog file
	BinFile string `toml:"bin_file"`
	// read start form the pos
	BinPos uint32 `toml:"bin_pos"`
}

type TcpConfig

type TcpConfig struct {
	Listen    string `toml:"listen"`
	Port      int    `toml:"port"`
	Enable    bool   `toml:"enable"`
	ServiceIp string `toml:"service_ip"`
	Groups    TcpGroupConfigs
}

type TcpGroupConfig

type TcpGroupConfig struct {
	Name   string
	Filter []string
}

type TcpGroupConfigs

type TcpGroupConfigs map[string]TcpGroupConfig

func (*TcpGroupConfigs) HasName

func (cs *TcpGroupConfigs) HasName(name string) bool