sinks

Documentation

Index

• type DataSink
• type SinkDriver

Types

type DataSink

type DataSink interface {
	Connect(context context.Context) error
	SetExpectedSchema(schema []schema.StreamSchema)
	GetType() SinkDriver
	Write(m *message.Message) error
	Stop()
}

type SinkDriver

type SinkDriver string

const (
	StdOutSinkType    SinkDriver = "stdout"
	WebSocketSinkType SinkDriver = "websocket"
	KafkaSinkType     SinkDriver = "kafka"
	PostgresSinkType  SinkDriver = "postgres"
	MongoDBSinkType   SinkDriver = "mongodb"
	NatsSinkType      SinkDriver = "nats"
	RabbitMqSinkType  SinkDriver = "rabbitmq"
	RedisSinkType     SinkDriver = "redis"
	ClickHouse        SinkDriver = "clickhouse"
)