ingest

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 7, 2021 License: GPL-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConnectToPostgres added in v1.0.3

func ConnectToPostgres(params ConnectionParams) (*pgxpool.Pool, error)

Types

type ConnectionParams

type ConnectionParams struct {
	User, Pass, Host, Port, Name string
}

type Ingester

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

func NewIngester

func NewIngester() (*Ingester, error)

func (*Ingester) Digest

func (i *Ingester) Digest(entity parse.Entity) error

func (*Ingester) Disconnect

func (i *Ingester) Disconnect() error

func (*Ingester) Flush

func (i *Ingester) Flush() error

func (*Ingester) Init

func (i *Ingester) Init() error

type InsertEntityParams

type InsertEntityParams struct {
	Authors, Tags             []int
	PublisherId, CollectionId int
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL