clickhouse

Documentation

Index

• func WithQuery(opts ...sqlstore.QueryOption) sqlstore.Option
• type Clickhouse
  • func Open(ctx context.Context, connect string, options ...any) (*Clickhouse, error)
  • func (c *Clickhouse) Close() error
  • func (c *Clickhouse) Connection() (_ *sql.DB, err error)
  • func (c *Clickhouse) Stream(options ...any) (strm eventstream.Streamer, err error)
• type Option
  • func WithInitQuery(initQuery []string) Option

Functions

func WithQuery

func WithQuery(opts ...sqlstore.QueryOption) sqlstore.Option

WithQuery SQL storage option

Types

type Clickhouse

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

Clickhouse storage object

func Open

func Open(ctx context.Context, connect string, options ...any) (*Clickhouse, error)

Open new clickhouse storage stream

func (*Clickhouse) Close

func (c *Clickhouse) Close() error

Close clickhouse connection

func (*Clickhouse) Connection

func (c *Clickhouse) Connection() (_ *sql.DB, err error)

Connection to clickhouse DB

func (*Clickhouse) Stream

func (c *Clickhouse) Stream(options ...any) (strm eventstream.Streamer, err error)

Stream clickhouse processor

type Option

type Option func(store *Clickhouse)

Option of the clickhouse storage

func WithInitQuery

func WithInitQuery(initQuery []string) Option

WithInitQuery which will be executed after connection