plugin

package
v4.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 5, 2026 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClustModeSingle      = 1
	ClustModeCloud       = 2
	ClustModeDistributed = 4
	ClustModeStats       = 8
)

Variables

View Source 
var (
	TsSvcs            = make(service.InsertSvcMap)
	SplSvcs           = make(service.InsertSvcMap)
	MtrSvcs           = make(service.InsertSvcMap)
	TempoSamplesSvcs  = make(service.InsertSvcMap)
	TempoTagsSvcs     = make(service.InsertSvcMap)
	ProfileInsertSvcs = make(service.InsertSvcMap)
	PatternInsertSvcs = make(service.InsertSvcMap)
)
View Source 
var (
	ServiceRegistry registry.ServiceRegistry
	GoCache         numbercache.ICache[uint64]
)
View Source 
var MainNode string

Functions

This section is empty.

Types

type ConfigInitializer 

type ConfigInitializer interface {
	InitializeConfig(conf *config.ClokiBaseSettingServer) error
}

type QrynWriterPlugin 

type QrynWriterPlugin struct {
	Conn           chwrapper.IChClient
	ServicesObject ServicesObject
	Svc            service.IInsertServiceV2
	DBConnWithDSN  chwrapper.IChClient
	DBConnWithXDSN chwrapper.IChClient
	HTTPServer     *http.Server
	// contains filtered or unexported fields
}

func (*QrynWriterPlugin) CreateStaticServiceRegistry 

func (p *QrynWriterPlugin) CreateStaticServiceRegistry(config config.ClokiBaseSettingServer)

func (*QrynWriterPlugin) Initialize 

func (p *QrynWriterPlugin) Initialize(config config.ClokiBaseSettingServer) error

Initialize sets up the plugin with the given configuration.

func (*QrynWriterPlugin) RegisterRoutes 

func (p *QrynWriterPlugin) RegisterRoutes(config config.ClokiBaseSettingServer,
	middlewareFactory controllerv1.MiddlewareConfig,
	middlewareTempoFactory controllerv1.MiddlewareConfig,
	router *mux.Router,
)

RegisterRoutes registers the plugin routes with the provided HTTP ServeMux.

func (*QrynWriterPlugin) StartLogCHSetup 

func (p *QrynWriterPlugin) StartLogCHSetup()

func (*QrynWriterPlugin) StartPushStat 

func (p *QrynWriterPlugin) StartPushStat()

func (*QrynWriterPlugin) Stop 

func (p *QrynWriterPlugin) Stop() error

Stop performs cleanup when the plugin is stopped.

func (*QrynWriterPlugin) StopLogCHSetup 

func (p *QrynWriterPlugin) StopLogCHSetup()

func (*QrynWriterPlugin) StopPushStat 

func (p *QrynWriterPlugin) StopPushStat()

type ServicesObject 

type ServicesObject struct {
	DatabaseNodeMap []model.DataDatabasesMap
	Dbv2Map         []chwrapper.IChClient
	Dbv3Map         []chwrapper.IChClientFactory
	MainNode        string
}

type SetupState 

type SetupState struct {
	Version         string
	Type            string
	Shards          int
	SamplesChannels int
	TSChannels      int
	Preforking      bool
	Forks           int
}

func (SetupState) ToLogLines 

func (s SetupState) ToLogLines() []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.