postgresql

Documentation

Index

• type Adapter
  • func NewAdapter(dsn string) (*Adapter, error)
  • func NewAdapterFromConfig(cfg sections.PostgreSQLConfigurator) (*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 AdapterEntryPostgreSQLSearch
  • func NewAdapterEntryPostgreSQLSearch() *AdapterEntryPostgreSQLSearch
  • func (ce *AdapterEntryPostgreSQLSearch) Import(entry *journal.Entry) *AdapterEntryPostgreSQLSearch
  • func (ce *AdapterEntryPostgreSQLSearch) StmtSearchParamsPlaceholderAndArgs() (string, []interface{})

Types

type Adapter

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

Adapter adapts journal for PostgreSQL storage

func NewAdapter

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

NewAdapter creates new Adapter for DSN string

func NewAdapterFromConfig

func NewAdapterFromConfig(cfg sections.PostgreSQLConfigurator) (*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 PostgreSQL

func (*Adapter) Insert

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

Insert inserts journal entry into PostgreSQL

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 AdapterEntryPostgreSQLSearch

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

AdapterEntryPostgreSQLSearch defines journal entry structure

func NewAdapterEntryPostgreSQLSearch

func NewAdapterEntryPostgreSQLSearch() *AdapterEntryPostgreSQLSearch

NewAdapterEntryPostgreSQLSearch

func (*AdapterEntryPostgreSQLSearch) Import

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

Import

func (*AdapterEntryPostgreSQLSearch) StmtSearchParamsPlaceholderAndArgs

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

StmtSearchParamsPlaceholderAndArgs