db

package
v0.0.0-...-b14e2d8 Latest Latest
Warning

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

Go to latest
Published: Dec 24, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(log *logrus.Logger) app.Sinker

Types

type Configuration

type Configuration struct {
	Host     string `toml:"host" default:"172.17.0.2" comment:"Postgres host"`
	Port     int    `toml:"port" default:"5432" comment:"Postgres port"`
	User     string `toml:"user" default:"postgres" comment:"Postgres user"`
	Password string `toml:"password" default:"mysecretpassword" comment:"Postgres password"`
	Dbname   string `toml:"dbName" default:"postgres" comment:"Postgres dbName"`
}

Configuration settings for Postgres DB sinking

type PostGreSinker

type PostGreSinker struct {
	Log *logrus.Logger
	// contains filtered or unexported fields
}

func (*PostGreSinker) Init

func (s *PostGreSinker) Init(ctx context.Context, params interface{}) error

func (*PostGreSinker) Sink

func (s *PostGreSinker) Sink(ctx context.Context, t time.Time, data []app.FlightData) error

Jump to

Keyboard shortcuts

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