controller

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: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	InsertServiceRegistry registry.ServiceRegistry
	ClusteringService     *clustering.LogClusterer
)

Functions

func ClusterLines

func ClusterLines(lines []string, fingerprints []uint64, timestamps []int64)

func Init

func Init(opts InitOpts)

func RunCleanup

func RunCleanup()

func RunFlush

func RunFlush()

func RunSync

func RunSync()

func Stop

func Stop()

Types

type InitOpts

type InitOpts struct {
	Service   registry.ServiceRegistry
	Conns     chwrapper.IChClientFactory
	IsCluster bool
}

type PatternsSynchronizer

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

func (*PatternsSynchronizer) GetPatternIDs

func (p *PatternsSynchronizer) GetPatternIDs() ([][2]uint64, error)

func (*PatternsSynchronizer) GetPatterns

func (p *PatternsSynchronizer) GetPatterns(patternIds []uint64) ([]clustering.PatternInfo, error)

Jump to

Keyboard shortcuts

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