sink

Documentation

Index

• Constants
• func GetScheme(url *url.URL) string
• func IsBlackHoleScheme(scheme string) bool
• func IsMQScheme(scheme string) bool
• func IsMySQLCompatibleScheme(scheme string) bool
• func IsPulsarScheme(scheme string) bool
• func IsStorageScheme(scheme string) bool
• type Type
  • func (t Type) String() string

Constants

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"
	// PulsarHTTPScheme indicates the schema is pulsar with http protocol
	PulsarHTTPScheme = "pulsar+http"
	// PulsarHTTPSScheme indicates the schema is pulsar with https protocol
	PulsarHTTPSScheme = "pulsar+https"
)

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.