Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CompareSegmentIDs ¶
The result will be: 0 if a==b, -1 if a < b, +1 if a > b.
func ParseSegmentID ¶
Types ¶
type ChangedItem ¶
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
Click to show internal directories.
Click to hide internal directories.