sink

package
v0.0.0-...-ab0ce11 Latest Latest
Warning

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

Go to latest
Published: May 9, 2024 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// KafkaScheme indicates the scheme is kafka.
	KafkaScheme = "kafka"
	// KafkaSSLScheme indicates the scheme is kafka+ssl.
	KafkaSSLScheme = "kafka+ssl"
	// BlackHoleScheme indicates the scheme is blackhole.
	BlackHoleScheme = "blackhole"
	// MySQLScheme indicates the scheme is MySQL.
	MySQLScheme = "mysql"
	// MySQLSSLScheme indicates the scheme is MySQL+ssl.
	MySQLSSLScheme = "mysql+ssl"
	// TiDBScheme indicates the scheme is TiDB.
	TiDBScheme = "tidb"
	// TiDBSSLScheme indicates the scheme is TiDB+ssl.
	TiDBSSLScheme = "tidb+ssl"
	// S3Scheme indicates the scheme is s3.
	S3Scheme = "s3"
	// FileScheme indicates the scheme is local fs or NFS.
	FileScheme = "file"
	// GCSScheme indicates the scheme is gcs.
	GCSScheme = "gcs"
	// GSScheme is an alias for "gcs"
	GSScheme = "gs"
	// AzblobScheme indicates the scheme is azure blob storage.\
	AzblobScheme = "azblob"
	// AzureScheme is an alias for "azblob"
	AzureScheme = "azure"
	// CloudStorageNoopScheme indicates the scheme is noop.
	CloudStorageNoopScheme = "noop"
	// PulsarScheme  indicates the scheme is pulsar
	PulsarScheme = "pulsar"
	// PulsarSSLScheme indicates the scheme is pulsar+ssl
	PulsarSSLScheme = "pulsar+ssl"
)

Variables

This section is empty.

Functions

func GetScheme

func GetScheme(url *url.URL) string

GetScheme returns the scheme of the url.

func IsBlackHoleScheme

func IsBlackHoleScheme(scheme string) bool

IsBlackHoleScheme returns true if the scheme belong to blackhole scheme.

func IsMQScheme

func IsMQScheme(scheme string) bool

IsMQScheme returns true if the scheme belong to mq scheme.

func IsMySQLCompatibleScheme

func IsMySQLCompatibleScheme(scheme string) bool

IsMySQLCompatibleScheme returns true if the scheme is compatible with MySQL.

func IsPulsarScheme

func IsPulsarScheme(scheme string) bool

IsPulsarScheme returns true if the scheme belong to pulsar scheme.

func IsStorageScheme

func IsStorageScheme(scheme string) bool

IsStorageScheme returns true if the scheme belong to storage scheme.

Types

type Type

type Type int

Type is the type of sink.

const (
	// RowSink is the type of row sink. It is used to sink row events.
	RowSink Type = iota + 1
	// TxnSink is the type of txn sink. It is used to sink txn events.
	TxnSink
)

func (Type) String

func (t Type) String() string

String returns the string representation of the type.

Directories

Path Synopsis
csv
v2
v2/mock
Package mock_v2 is a generated GoMock package.
Package mock_v2 is a generated GoMock package.

Jump to

Keyboard shortcuts

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