client

Documentation

Index

• type ExporterClient
  • func NewExporter(db fdb.Database, targetURL string, grpcPort int, caFile string, ...) (exp *ExporterClient, err error)
  • func (exp *ExporterClient) AssignSources(pmap *finder.PartitionMap) (exportPlan map[string]exportGroup, err error)
  • func (exp *ExporterClient) ScheduleFetch(exportPlan map[string]exportGroup) (err error)
  • func (exp *ExporterClient) ScheduleFetchByNode(eg exportGroup, dryRun bool) (err error)
• type ExporterOption
  • func Collect(collectDir string) ExporterOption
  • func Compress(compress bool) ExporterOption
  • func Dryrun(dryRun bool) ExporterOption
  • func ExportFormat(format string) ExporterOption
  • func Logger(logger *zap.Logger) ExporterOption
  • func ReaderThreads(readerThreads int) ExporterOption
  • func Sample(sample int) ExporterOption

Types

type ExporterClient

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

func NewExporter

func NewExporter(db fdb.Database,
	targetURL string,
	grpcPort int,
	caFile string,
	opts ...ExporterOption,
) (exp *ExporterClient, err error)

func (*ExporterClient) AssignSources

func (exp *ExporterClient) AssignSources(pmap *finder.PartitionMap) (exportPlan map[string]exportGroup, err error)

func (*ExporterClient) ScheduleFetch

func (exp *ExporterClient) ScheduleFetch(exportPlan map[string]exportGroup) (err error)

func (*ExporterClient) ScheduleFetchByNode

func (exp *ExporterClient) ScheduleFetchByNode(eg exportGroup, dryRun bool) (err error)

type ExporterOption

type ExporterOption func(exp *ExporterClient)

func Collect

func Collect(collectDir string) ExporterOption

func Compress

func Compress(compress bool) ExporterOption

func Dryrun

func Dryrun(dryRun bool) ExporterOption

func ExportFormat

func ExportFormat(format string) ExporterOption

func Logger

func Logger(logger *zap.Logger) ExporterOption

func ReaderThreads

func ReaderThreads(readerThreads int) ExporterOption

func Sample

func Sample(sample int) ExporterOption