client

Documentation

Index

• type ImporterClient
  • func NewImporter(db fdb.Database, targetURL string, grpcPort int, caFile string, ...) (exp *ImporterClient, err error)
  • func (exp *ImporterClient) AssignTargets() (importPlan map[string]importGroup, err error)
  • func (exp *ImporterClient) ScheduleImport(importPlan map[string]importGroup) (err error)
  • func (exp *ImporterClient) ScheduleImportByNode(eg importGroup, dryRun bool) (err error)
• type ImporterOption
  • func Dryrun(dryRun bool) ImporterOption
  • func Logger(logger *zap.Logger) ImporterOption
  • func Sample(sample bool) ImporterOption
  • func WriterThreads(writerThreads int) ImporterOption

Types

type ImporterClient

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

func NewImporter

func NewImporter(db fdb.Database,
	targetURL string,
	grpcPort int,
	caFile string,
	opts ...ImporterOption,
) (exp *ImporterClient, err error)

func (*ImporterClient) AssignTargets

func (exp *ImporterClient) AssignTargets() (importPlan map[string]importGroup, err error)

func (*ImporterClient) ScheduleImport

func (exp *ImporterClient) ScheduleImport(importPlan map[string]importGroup) (err error)

func (*ImporterClient) ScheduleImportByNode

func (exp *ImporterClient) ScheduleImportByNode(eg importGroup, dryRun bool) (err error)

type ImporterOption

type ImporterOption func(exp *ImporterClient)

func Dryrun

func Dryrun(dryRun bool) ImporterOption

func Logger

func Logger(logger *zap.Logger) ImporterOption

func Sample

func Sample(sample bool) ImporterOption

func WriterThreads

func WriterThreads(writerThreads int) ImporterOption