clickhouse

Documentation

Index

• type Adapter
  • func NewAdapter(dsn string) (*Adapter, error)
  • func NewAdapterFromConfig(cfg sections.ClickHouseConfigurator) (*Adapter, error)
  • func (j *Adapter) FindAll(entry *journal.Entry) ([]*journal.Entry, error)
  • func (j *Adapter) Insert(entry *journal.Entry) error
• type AdapterEntry
  • func NewAdapterEntry() *AdapterEntry
  • func (ce *AdapterEntry) AsUntypedSlice() []interface{}
  • func (ce *AdapterEntry) Export() *journal.Entry
  • func (ce *AdapterEntry) Fields() string
  • func (ce *AdapterEntry) Import(entry *journal.Entry) *AdapterEntry
  • func (ce *AdapterEntry) Scan(rows *databasesql.Rows) error
  • func (ce *AdapterEntry) StmtParamsPlaceholder() string
  • func (ce *AdapterEntry) String() string
• type AdapterEntryClickHouseSearch
  • func NewAdapterEntryClickHouseSearch() *AdapterEntryClickHouseSearch
  • func (ce *AdapterEntryClickHouseSearch) Import(entry *journal.Entry) *AdapterEntryClickHouseSearch
  • func (ce *AdapterEntryClickHouseSearch) StmtSearchParamsPlaceholderAndArgs() (string, []interface{})

Types

type Adapter

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

Adapter adapts journal for ClickHouse storage

func NewAdapter

func NewAdapter(dsn string) (*Adapter, error)

NewAdapter creates new Adapter for DSN string

func NewAdapterFromConfig

func NewAdapterFromConfig(cfg sections.ClickHouseConfigurator) (*Adapter, error)

NewAdapterFromConfig creates new Adapter from config

func (*Adapter) FindAll

func (j *Adapter) FindAll(entry *journal.Entry) ([]*journal.Entry, error)

FindAll finds entries in ClickHouse

func (*Adapter) Insert

func (j *Adapter) Insert(entry *journal.Entry) error

Insert inserts journal entry into ClickHouse

type AdapterEntry

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

AdapterEntry defines journal entry structure

func NewAdapterEntry

func NewAdapterEntry() *AdapterEntry

NewAdapterEntry creates new AdapterEntry

func (*AdapterEntry) AsUntypedSlice

func (ce *AdapterEntry) AsUntypedSlice() []interface{}

AsUntypedSlice returns slice of fields

func (*AdapterEntry) Export

func (ce *AdapterEntry) Export() *journal.Entry

Export exports data to journal entry

func (*AdapterEntry) Fields

func (ce *AdapterEntry) Fields() string

Fields returns string representation of the fields

func (*AdapterEntry) Import

func (ce *AdapterEntry) Import(entry *journal.Entry) *AdapterEntry

Import imports data from journal entry

func (*AdapterEntry) Scan

func (ce *AdapterEntry) Scan(rows *databasesql.Rows) error

Scan scans date from

func (*AdapterEntry) StmtParamsPlaceholder

func (ce *AdapterEntry) StmtParamsPlaceholder() string

StmtParamsPlaceholder returns string representation of a placeholders for fields

func (*AdapterEntry) String

func (ce *AdapterEntry) String() string

String is a stringifier

type AdapterEntryClickHouseSearch

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

AdapterEntryClickHouseSearch defines journal entry structure

func NewAdapterEntryClickHouseSearch

func NewAdapterEntryClickHouseSearch() *AdapterEntryClickHouseSearch

NewAdapterEntryClickHouseSearch

func (*AdapterEntryClickHouseSearch) Import

func (ce *AdapterEntryClickHouseSearch) Import(entry *journal.Entry) *AdapterEntryClickHouseSearch

Import

func (*AdapterEntryClickHouseSearch) StmtSearchParamsPlaceholderAndArgs

func (ce *AdapterEntryClickHouseSearch) StmtSearchParamsPlaceholderAndArgs() (string, []interface{})

StmtSearchParamsPlaceholderAndArgs