app

package

v1.2.0 Latest Latest Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openGemini/openGemini

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CreateSerfInstance(conf *serf.Config, clock uint64, members []string, ...) (*serf.Serf, error)
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 (i *ServerInfo) FullVersion() string

Constants ¶

View Source

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

View Source

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

View Source

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

View Source

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

View Source

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

View Source

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

View Source

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

View Source

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

View Source

const VERSION = `openGemini version info:
%s: %s
git: %s %s
os: %s
arch: %s
`

Variables ¶

This section is empty.

Functions ¶

func CreateSerfInstance ¶

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

func HideQueryPassword ¶

func HideQueryPassword(url string) string

func InitParse ¶ added in v1.0.1

func InitParse()

InitParse inits the command line parse flogs

func LogStarting ¶ added in v1.1.0

func LogStarting(name string, info *ServerInfo)

func RemovePIDFile ¶

func RemovePIDFile(pidfile string)

func Run ¶ added in v1.1.0

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

func SetStatsResponse ¶ added in v1.0.0

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 ¶ added in v1.1.0

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

func NewProactiveManager ¶ added in v1.1.0

func NewProactiveManager() *ProactiveManager

func (*ProactiveManager) Close ¶ added in v1.1.0

func (pm *ProactiveManager) Close() error

func (*ProactiveManager) GetQueryList ¶ added in v1.1.0

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

func (*ProactiveManager) KillQuery ¶ added in v1.1.0

func (pm *ProactiveManager) KillQuery(id uint64)

func (*ProactiveManager) Open ¶ added in v1.1.0

func (pm *ProactiveManager) Open() error

func (*ProactiveManager) SetInspectInterval ¶ added in v1.1.0

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

func (*ProactiveManager) WithLogger ¶ added in v1.1.0

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

type Server ¶

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

type ServerInfo ¶ added in v1.1.0

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

func (*ServerInfo) FullVersion ¶ added in v1.1.0

func (i *ServerInfo) FullVersion() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
ts-cli
analyzer
cmd
geminicli
geminiql
ts-data
ts-meta
meta
meta/message
run
ts-monitor
collector
run
ts-server
run
ts-sql
sql
ts-store
run
storage
stream
transport
transport/handler
transport/query

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