Documentation ¶
Index ¶
- type Adapter
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
Adapter adapts journal for ClickHouse storage
func NewAdapter ¶
NewAdapter creates new Adapter for DSN string
func NewAdapterFromConfig ¶
func NewAdapterFromConfig(cfg sections.ClickHouseConfigurator) (*Adapter, error)
NewAdapterFromConfig creates new Adapter from config
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
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