clickhouse

Documentation

Index

• func NewClickHouseSinkPlugin(config Config, ctx *stream_context.Context) sinks.DataSink
• type Config
• type SinkPlugin
  • func (p *SinkPlugin) Connect(ctx context.Context) error
  • func (p *SinkPlugin) GetType() sinks.SinkDriver
  • func (p *SinkPlugin) SetExpectedSchema(sCh []schema.StreamSchema)
  • func (p *SinkPlugin) Stop()
  • func (p *SinkPlugin) Write(m *message.Message) error

Functions

func NewClickHouseSinkPlugin

func NewClickHouseSinkPlugin(config Config, ctx *stream_context.Context) sinks.DataSink

Types

type Config

type Config struct {
	Host     string `json:"host" yaml:"host"`
	Port     int    `json:"port" yaml:"port"`
	Database string `json:"database" yaml:"database"`
	User     string `json:"user" yaml:"user"`
	Password string `json:"password" yaml:"password"`
}

type SinkPlugin

type SinkPlugin struct {
	// contains filtered or unexported fields
}

func (*SinkPlugin) Connect

func (p *SinkPlugin) Connect(ctx context.Context) error

func (*SinkPlugin) GetType

func (p *SinkPlugin) GetType() sinks.SinkDriver

func (*SinkPlugin) SetExpectedSchema

func (p *SinkPlugin) SetExpectedSchema(sCh []schema.StreamSchema)

func (*SinkPlugin) Stop

func (p *SinkPlugin) Stop()

func (*SinkPlugin) Write

func (p *SinkPlugin) Write(m *message.Message) error