stdout

Documentation

Index

• Constants
• func New(provider abstract.ProviderType) ...
• func NewSinker(lgr log.Logger, config *StdoutDestination, registry metrics.Registry) abstract.Sinker
• type EmptySource
  • func (*EmptySource) AllIncludes() []string
  • func (*EmptySource) FulfilledIncludes(tID abstract.TableID) []string
  • func (s *EmptySource) GetProviderType() abstract.ProviderType
  • func (s *EmptySource) Include(tID abstract.TableID) bool
  • func (EmptySource) IsSource()
  • func (s *EmptySource) Validate() error
  • func (EmptySource) WithDefaults()
• type Provider
  • func (p *Provider) Sink(middlewares.Config) (abstract.Sinker, error)
  • func (p *Provider) Type() abstract.ProviderType
• type StdoutDestination
  • func (d *StdoutDestination) BuffererConfig() bufferer.BuffererConfig
  • func (d *StdoutDestination) CleanupMode() model.CleanupType
  • func (d *StdoutDestination) GetProviderType() abstract.ProviderType
  • func (StdoutDestination) IsDestination()
  • func (d *StdoutDestination) Transformer() map[string]string
  • func (d *StdoutDestination) Validate() error
  • func (StdoutDestination) WithDefaults()

Constants

const ProviderType = abstract.ProviderType("empty")

const ProviderTypeStdout = abstract.ProviderType("stdout")

Functions

func New

func New(provider abstract.ProviderType) func(lgr log.Logger, registry metrics.Registry, cp coordinator.Coordinator, transfer *model.Transfer) providers.Provider

func NewSinker

func NewSinker(lgr log.Logger, config *StdoutDestination, registry metrics.Registry) abstract.Sinker

Types

type EmptySource

type EmptySource struct{}

func (*EmptySource) AllIncludes

func (*EmptySource) AllIncludes() []string

func (*EmptySource) FulfilledIncludes

func (*EmptySource) FulfilledIncludes(tID abstract.TableID) []string

func (*EmptySource) GetProviderType

func (s *EmptySource) GetProviderType() abstract.ProviderType

func (*EmptySource) Include

func (s *EmptySource) Include(tID abstract.TableID) bool

func (EmptySource) IsSource

func (EmptySource) IsSource()

func (*EmptySource) Validate

func (s *EmptySource) Validate() error

func (EmptySource) WithDefaults

func (EmptySource) WithDefaults()

type Provider

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

func (*Provider) Sink

func (p *Provider) Sink(middlewares.Config) (abstract.Sinker, error)

func (*Provider) Type

func (p *Provider) Type() abstract.ProviderType

type StdoutDestination

type StdoutDestination struct {
	ShowData          bool
	TransformerConfig map[string]string
	TriggingCount     int
	TriggingSize      uint64
	TriggingInterval  time.Duration
}

func (*StdoutDestination) BuffererConfig

func (d *StdoutDestination) BuffererConfig() bufferer.BuffererConfig

func (*StdoutDestination) CleanupMode

func (d *StdoutDestination) CleanupMode() model.CleanupType

func (*StdoutDestination) GetProviderType

func (d *StdoutDestination) GetProviderType() abstract.ProviderType

func (StdoutDestination) IsDestination

func (StdoutDestination) IsDestination()

func (*StdoutDestination) Transformer

func (d *StdoutDestination) Transformer() map[string]string

func (*StdoutDestination) Validate

func (d *StdoutDestination) Validate() error

func (StdoutDestination) WithDefaults

func (StdoutDestination) WithDefaults()