run

Documentation

Index

• func NewRunCmd(ctx context.Context, streams streams.IO) *cobra.Command
• type Options
  • func NewOptions(ioStreams streams.IO) *Options
  • func (o *Options) Complete(ctx context.Context, args []string) error
  • func (o *Options) Run(ctx context.Context) error

Functions

func NewRunCmd

func NewRunCmd(ctx context.Context, streams streams.IO) *cobra.Command

NewRunCmd configures a new cobra command that both imports (backfills) data from a postgres instance and watches the WAL to sync data continuously

Types

type Options

type Options struct {
	importercmd.Options

	MetricsAddr string
}

Options holds options for the postgres connector

func NewOptions

func NewOptions(ioStreams streams.IO) *Options

NewOptions returns initialized Options

func (*Options) Complete

func (o *Options) Complete(ctx context.Context, args []string) error

Complete fills out default values before running

func (*Options) Run

func (o *Options) Run(ctx context.Context) error

Run does a backfill and then watches for changes