app

Documentation

Index

• Constants
• Variables
• func CreateSerfInstance(conf *serf.Config, clock uint64, members []string, ...) (*serf.Serf, error)
• func FullVersion(app string) string
• func HideQueryPassword(url string) string
• func InitParse()
• func LogStarting(name string, info *ServerInfo)
• func RemovePIDFile(pidfile string)
• func Run(args []string, commands ...*Command)
• func SetStatsResponse(pusher *statisticsPusher.StatisticsPusher, w http.ResponseWriter, ...)
• func WritePIDFile(pidfile string) error
• type Command
  • func NewCommand() *Command
  • func (cmd *Command) Close() error
  • func (cmd *Command) InitConfig(conf config.Config, path string) error
  • func (cmd *Command) Run(args ...string) error
• type Options
  • func ParseFlags(usage func(), args ...string) (Options, error)
• type ProactiveManager
  • func NewProactiveManager() *ProactiveManager
  • func (pm *ProactiveManager) Close() error
  • func (pm *ProactiveManager) GetQueryList(cnt int) []uint64
  • func (pm *ProactiveManager) KillQuery(id uint64)
  • func (pm *ProactiveManager) Open() error
  • func (pm *ProactiveManager) SetInspectInterval(interval time.Duration)
  • func (pm *ProactiveManager) WithLogger(logger *logger.Logger)
• type Server
• type ServerInfo
  • func (si *ServerInfo) FullVersion() string
  • func (si *ServerInfo) StatVersion() string

Constants

const METALOGO = `` /* 391-byte string literal not displayed */

const MONITORLOGO = `` /* 552-byte string literal not displayed */

const MainUsage = `` /* 339-byte string literal not displayed */

const RunUsage = `` /* 175-byte string literal not displayed */

const SQLLOGO = `` /* 300-byte string literal not displayed */

const STORELOGO = `` /* 439-byte string literal not displayed */

const TSDATALOGO = `` /* 367-byte string literal not displayed */

const TSSERVER = `` /* 505-byte string literal not displayed */

Variables

var (
	Version   string
	GitCommit string
	GitBranch string
	BuildTime string
)

Version information, the value is set by the build script

Functions

func CreateSerfInstance

func CreateSerfInstance(conf *serf.Config, clock uint64, members []string, preNodes []*serf.PreviousNode) (*serf.Serf, error)

func FullVersion

func FullVersion(app string) string

FullVersion returns the full version string.

func HideQueryPassword

func HideQueryPassword(url string) string

func InitParse

func InitParse()

InitParse inits the command line parse flogs

func LogStarting

func LogStarting(name string, info *ServerInfo)

func RemovePIDFile

func RemovePIDFile(pidfile string)

func Run

func Run(args []string, commands ...*Command)

func SetStatsResponse

func SetStatsResponse(pusher *statisticsPusher.StatisticsPusher, w http.ResponseWriter, r *http.Request)

func WritePIDFile

func WritePIDFile(pidfile string) error

Types

type Command

type Command struct {
	Logo          string
	Usage         string
	Pidfile       string
	Logger        *logger.Logger
	Command       *cobra.Command
	Info          ServerInfo
	Version       string
	Server        Server
	Config        config.Config
	NewServerFunc func(config.Config, ServerInfo, *logger.Logger) (Server, error)

	AfterOpen func()
}

Command represents the command executed by "ts-xxx run".

func NewCommand

func NewCommand() *Command

func (*Command) Close

func (cmd *Command) Close() error

func (*Command) InitConfig

func (cmd *Command) InitConfig(conf config.Config, path string) error

func (*Command) Run

func (cmd *Command) Run(args ...string) error

type Options

type Options struct {
	ConfigPath string
	PIDFile    string
	Join       string
	Hostname   string
}

Options represents the command line options that can be parsed.

func ParseFlags

func ParseFlags(usage func(), args ...string) (Options, error)

type ProactiveManager

type ProactiveManager struct {
	// contains filtered or unexported fields
}

func NewProactiveManager

func NewProactiveManager() *ProactiveManager

func (*ProactiveManager) Close

func (pm *ProactiveManager) Close() error

func (*ProactiveManager) GetQueryList

func (pm *ProactiveManager) GetQueryList(cnt int) []uint64

func (*ProactiveManager) KillQuery

func (pm *ProactiveManager) KillQuery(id uint64)

func (*ProactiveManager) Open

func (pm *ProactiveManager) Open() error

func (*ProactiveManager) SetInspectInterval

func (pm *ProactiveManager) SetInspectInterval(interval time.Duration)

func (*ProactiveManager) WithLogger

func (pm *ProactiveManager) WithLogger(logger *logger.Logger)

type Server

type Server interface {
	Open() error
	Close() error
	Err() <-chan error
}

type ServerInfo

type ServerInfo struct {
	App       config.App
	Version   string
	Commit    string
	Branch    string
	BuildTime string
}

func (*ServerInfo) FullVersion

func (si *ServerInfo) FullVersion() string

func (*ServerInfo) StatVersion

func (si *ServerInfo) StatVersion() string