core

package
v0.14.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 7, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildDBReader added in v0.5.0 

func BuildDBReader(connURL *url.URL) (data.DBReaderConn, error)

func Execute added in v0.11.0 

func Execute(ctx context.Context, concurrency int, config *data.StreamConfig, datastream *data.DataStream, reader data.DBReaderConn, writer data.DataWriter) error

Types

type Config 

type Config struct {
	Source       string             `json:"source,omitempty" yaml:"source,omitempty"`
	Dest         string             `json:"dest,omitempty" yaml:"dest,omitempty"`
	SourceConn   *Connection        `json:"-" yaml:"-"`
	DestConn     *Connection        `json:"-" yaml:"-"`
	StreamConfig *data.StreamConfig `json:"stream_config,omitempty" yaml:"stream_config,omitempty"`
}

func NewConfig 

func NewConfig(source, dest string, streamConfig *data.StreamConfig) *Config

func SetupConfig added in v0.13.0 

func SetupConfig(sConfig *data.StreamConfig) (*Config, error)

type Connection 

type Connection struct {
	Url       string
	ParsedUrl *url.URL
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.