data

May 29, 2025

Changes in this version

+ type DBExec interface

+ ExecuteCommand func(ctx context.Context, sql_command string) (string, error)

Mar 2, 2025

Changes in this version

+ const RFC3339MicroNoTZ

+ const RFC3339MicroTZ

Feb 9, 2025

Changes in this version

+ func TypeAlias(columnType string) string

Feb 6, 2025

Changes in this version

+ func GeneratePKCS8StringSupress(key *rsa.PrivateKey) string

+ func ParsePEMPrivateKey(pemKey string) (*rsa.PrivateKey, error)

Jan 9, 2025

Changes in this version

type Column

+ Type string

Jan 4, 2025

Changes in this version

+ type BatchWriter interface

+ WriteBatch func(batch Batch) error

type DataWriter

+ CreateBatchWriter func() BatchWriter

type StreamConfig

+ BatchCount int

+ func (sc *StreamConfig) GetBatchCount() int

Jan 1, 2025

Changes in this version

+ type MultiStreamConfig struct

+ Tables []StreamConfig

Dec 31, 2024

Changes in this version

+ type RawStreamConfig struct

+ BatchSize int

+ Filename TemplateString

+ type TemplateString struct

+ Raw string

+ func (t *TemplateString) UnmarshalYAML(unmarshal func(interface{}) error) error

Dec 30, 2024

Changes in this version

type StreamConfig

+ BatchSize int

+ func (sc *StreamConfig) GetBatchSize() int

Dec 30, 2024

Changes in this version

+ func ParseAndExecuteTemplate(data []byte, config *StreamConfig) ([]byte, error)

type StreamConfig

+ func BuildConfig(data []byte, cliArgs *StreamConfig) (*StreamConfig, error)

+ func (sc *StreamConfig) OverrideValues(cliArgs *StreamConfig)

+ func (sc *StreamConfig) Validate() error

Dec 17, 2024

Changes in this version

+ func SortKeys(params []string)

+ type Param struct

+ Type string

+ Value string

type StreamConfig

+ ParamKeys []string

Dec 5, 2024

Changes in this version

+ func ConvertSQLServerUUID(sqlBytes []byte) []byte

type DataStream

+ IsSqlServer bool

Nov 12, 2024

Changes in this version

+ type DBReaderConn interface

+ Close func() error

+ CreateDataStream func(cs *url.URL, config *StreamConfig) (*DataStream, error)

+ ExecuteDataStream func(ctx context.Context, ds *DataStream, config *StreamConfig) error

Nov 5, 2024

Changes in this version

+ const RFC3339NanoNoTZ

+ func GetMVRVars(prefix string) map[string]any

+ type Batch struct

+ Rows [][]any

+ type Column struct

+ DatabaseType string

+ Length int64

+ Name string

+ Nullable bool

+ Position int

+ Precision int64

+ Scale int64

+ ScanType string

+ func OverrideColumns(original []Column, overrides []Column) []Column

+ type DataStream struct

+ BatchChan chan Batch

+ BatchSize int

+ Columns []Column

+ DestColumns []Column

+ Mux sync.Mutex

+ TotalRows int

+ func (ds *DataStream) BatchesToWriter(wg *sync.WaitGroup, writer DataWriter)

+ type DataWriter interface

+ Close func() error

+ Flush func() error

+ WriteRow func(row []any) error

+ type StreamConfig struct

+ Columns []Column

+ Compression string

+ Filename *string

+ Format string

+ Params map[string]interface{}

+ SQL string

+ StreamName string

+ func NewStreamConfigFromYaml(data []byte) (*StreamConfig, error)