tasks

Documentation

Index

• Constants
• func IndexCollectProjects(opts IndexMigrateOptions, out *[]string) conc.Task
• func IndexMigrate(opts IndexMigrateOptions) conc.Task
• func IndexMigrateNeo(opts IndexMigrateOptions) conc.Task
• func PrintMemUsageAndGC(label string)
• func ProjectExportCompressedData(opts ProjectMigrateOptions) conc.Task
• func ProjectMigrate(opts ProjectMigrateOptions) conc.Task
• func ProjectUploadCompressedData(opts ProjectMigrateOptions) conc.Task
• type IndexMigrateOptions
  • func (opts IndexMigrateOptions) Workspace() string
• type ProjectMigrateOptions
  • func (opts ProjectMigrateOptions) FilenameLocal() string
  • func (opts ProjectMigrateOptions) FilenameRemote() string

Constants

const (
	ExtCompressedNDJSON = ".ndjson.gz"
)

Functions

func IndexCollectProjects

func IndexCollectProjects(opts IndexMigrateOptions, out *[]string) conc.Task

func IndexMigrate

func IndexMigrate(opts IndexMigrateOptions) conc.Task

func IndexMigrateNeo

func IndexMigrateNeo(opts IndexMigrateOptions) conc.Task

func PrintMemUsageAndGC

func PrintMemUsageAndGC(label string)

func ProjectExportCompressedData

func ProjectExportCompressedData(opts ProjectMigrateOptions) conc.Task

func ProjectMigrate

func ProjectMigrate(opts ProjectMigrateOptions) conc.Task

func ProjectUploadCompressedData

func ProjectUploadCompressedData(opts ProjectMigrateOptions) conc.Task

Types

type IndexMigrateOptions

type IndexMigrateOptions struct {
	ESClient         *elastic.Client
	COSClient        *cos.Client
	NoDelete         bool
	Dir              string
	Index            string
	BatchSize        int
	Concurrency      int
	CompressionLevel int
}

func (IndexMigrateOptions) Workspace

func (opts IndexMigrateOptions) Workspace() string

type ProjectMigrateOptions

type ProjectMigrateOptions struct {
	IndexMigrateOptions
	Project string
}

func (ProjectMigrateOptions) FilenameLocal

func (opts ProjectMigrateOptions) FilenameLocal() string

func (ProjectMigrateOptions) FilenameRemote

func (opts ProjectMigrateOptions) FilenameRemote() string