index_backup

package
v1.29.8 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2025 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CompareSegmentIDs

func CompareSegmentIDs(id1, id2 string) int

The result will be: 0 if a==b, -1 if a < b, +1 if a > b.

func New

func ParseSegmentID

func ParseSegmentID(fileName string) string

Types

type ChangedItem

type ChangedItem struct {
	IndexUUID string
	SegmentID string
	FilePath  string
	FileName  string
	Timestamp time.Time
}

type Config

type Config struct {
	Elasticsearch          string `config:"elasticsearch"`
	Index                  string `config:"index"`
	UploadToS3             bool   `config:"upload_to_s3"`
	UploadToFSRepo         bool   `config:"upload_to_fs_repo"`
	LocalRepoPath          string `config:"local_repo_path"`
	UploadIntervalInSecond int    `config:"upload_interval_in_second"`

	S3 struct {
		Async    bool   `config:"async"`
		Server   string `config:"server"`
		Location string `config:"location"`
		Bucket   string `config:"bucket"`
	} `config:"s3"`
}

type IndexBackupProcessor

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

func (*IndexBackupProcessor) AddFileToWatch

func (processor *IndexBackupProcessor) AddFileToWatch(path string)

func (*IndexBackupProcessor) Name

func (processor *IndexBackupProcessor) Name() string

func (*IndexBackupProcessor) Process

func (processor *IndexBackupProcessor) Process(ctx *pipeline.Context) error

func (IndexBackupProcessor) Stop

func (processor IndexBackupProcessor) Stop() error

Jump to

Keyboard shortcuts

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