backfill

Documentation

Index

• type Backfill
  • func NewBackfill() *Backfill
  • func NewBackfillWithOptions(opts *Options) (*Backfill, error)
  • func (b *Backfill) Close()
  • func (b *Backfill) StartParser() error
• type Options
  • func (o *Options) BackendBufferSize() uint64
  • func (o *Options) InputBufferSize() uint64
  • func (o *Options) Parse() error
  • func (o *Options) ParseArgIn() error
  • func (o *Options) ParseArgOut() error
  • func (o *Options) ParserBufferSize() uint64
  • func (o *Options) SetBackendBufferSize(value uint64) *Options
  • func (o *Options) SetInputBufferSize(value uint64) *Options
  • func (o *Options) SetParserBufferSize(value uint64) *Options
• type ParserClient
  • func NewParserWithOptions(opts *Options, sc *StorageClient) (*ParserClient, error)
• type StorageClient
  • func NewStorageClientWithOptions(opts *Options) (*StorageClient, error)

Types

type Backfill

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

func NewBackfill

func NewBackfill() *Backfill

func NewBackfillWithOptions

func NewBackfillWithOptions(opts *Options) (*Backfill, error)

func (*Backfill) Close

func (b *Backfill) Close()

func (*Backfill) StartParser

func (b *Backfill) StartParser() error

type Options

type Options struct {
	ArgIn        *string
	ArgInExt     *string
	ArgOut       *string
	ArgBatchSize *uint64
	// contains filtered or unexported fields
}

func (*Options) BackendBufferSize

func (o *Options) BackendBufferSize() uint64

func (*Options) InputBufferSize

func (o *Options) InputBufferSize() uint64

func (*Options) Parse

func (o *Options) Parse() error

func (*Options) ParseArgIn

func (o *Options) ParseArgIn() error

ParseArgIn parse input argument and check if it exists on FS.

func (*Options) ParseArgOut

func (o *Options) ParseArgOut() error

ParseArgOut parse output argument and split into backend conn params.

func (*Options) ParserBufferSize

func (o *Options) ParserBufferSize() uint64

func (*Options) SetBackendBufferSize

func (o *Options) SetBackendBufferSize(value uint64) *Options

func (*Options) SetInputBufferSize

func (o *Options) SetInputBufferSize(value uint64) *Options

func (*Options) SetParserBufferSize

func (o *Options) SetParserBufferSize(value uint64) *Options

type ParserClient

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

func NewParserWithOptions

func NewParserWithOptions(opts *Options, sc *StorageClient) (*ParserClient, error)

type StorageClient

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

func NewStorageClientWithOptions

func NewStorageClientWithOptions(opts *Options) (*StorageClient, error)