desc

package
v0.0.0-...-3f86ab2 Latest Latest
Warning

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

Go to latest
Published: Aug 3, 2022 License: Apache-2.0 Imports: 0 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Batch

type Batch struct {
	Size   int
	Offset int
}

type Check

type Check struct {
	Level string
}

type CheckLevel

type CheckLevel byte
const (
	CheckLevelNone CheckLevel = iota
	CheckLevelCount
	CheckLevelSampling
	CheckLevelEachRow
)

type Description

type Description struct {
	Batch
	Source
	Sink
	Notify
	Check
	Metrics
	Log
}

type Log

type Log struct {
	Level string
	Path  string
}

type LogLevel

type LogLevel byte

type Metrics

type Metrics struct {
}

type Notify

type Notify struct {
	NotifyKinds
}

type NotifyKinds

type NotifyKinds byte
const (
	NotifyFail         NotifyKinds = 0x01 << 0
	NotifySuccess      NotifyKinds = 0x01 << 1
	NotifyBatchFail    NotifyKinds = 0x01 << 2
	NotifyBatchSuccess NotifyKinds = 0x01 << 3
	NotifyCheckFail    NotifyKinds = 0x01 << 4
	NotifyCheckSuccess NotifyKinds = 0x01 << 5
)

type Sink

type Sink struct {
	Kind  string
	DSL   string
	Retry int
	// Database                 string
	Table                    string
	GenerateTable            bool
	CreateIndex              bool
	CleanHistoryData         bool
	RemoveWatermarkIfSucceed bool
	Extra                    any
}

type Source

type Source struct {
	Kind  string
	DSL   string
	Retry int
	Extra any
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL