vertica

Documentation

Index

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

Functions

func WithQuery

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

WithQuery SQL storage option

Types

type Option

type Option func(store *Vertica)

Option of the clickhouse storage

func WithInitQuery

func WithInitQuery(initQuery []string) Option

WithInitQuery which will be executed after connection

type Vertica

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

Vertica storage object

func Open

func Open(ctx context.Context, connectURL string, options ...any) (*Vertica, error)

Open new vertica storage

func (*Vertica) Close

func (st *Vertica) Close() error

Close vertica connection

func (*Vertica) Connection

func (st *Vertica) Connection() (_ *sql.DB, err error)

Connection to clickhouse DB

func (*Vertica) Stream

func (st *Vertica) Stream(options ...any) (strm eventstream.Streamer, err error)

Stream vertica processor