postgres

Documentation

Index

• func GetConnParams(host, db, table, user, pwd string) map[string]string
• type DriverPostgres
  • func (d DriverPostgres) CreateTable() error
  • func (d DriverPostgres) DropTable() error
  • func (d DriverPostgres) GetLastRootList(limit int) ([]*tracefall.Log, error)
  • func (d DriverPostgres) GetLastThreadList(limit int) ([]*tracefall.Log, error)
  • func (d DriverPostgres) GetLog(id uuid.UUID) (tracefall.ResponseLog, error)
  • func (d DriverPostgres) GetThread(id uuid.UUID) (tracefall.ResponseThread, error)
  • func (d DriverPostgres) InstallIndex() error
  • func (d *DriverPostgres) Open(params map[string]string) (interface{}, error)
  • func (d DriverPostgres) RemoveByTags(tags tracefall.Tags) (tracefall.ResponseCmd, error)
  • func (d DriverPostgres) RemoveThread(id uuid.UUID) (tracefall.ResponseCmd, error)
  • func (d DriverPostgres) Send(l *tracefall.Log) (tracefall.ResponseCmd, error)
  • func (d DriverPostgres) Truncate(ind string) (tracefall.ResponseCmd, error)
• type Params

Functions

func GetConnParams

func GetConnParams(host, db, table, user, pwd string) map[string]string

Types

type DriverPostgres

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

func (DriverPostgres) CreateTable

func (d DriverPostgres) CreateTable() error

Create table for tracer

func (DriverPostgres) DropTable

func (d DriverPostgres) DropTable() error

Erase table

func (DriverPostgres) GetLastRootList

func (d DriverPostgres) GetLastRootList(limit int) ([]*tracefall.Log, error)

func (DriverPostgres) GetLastThreadList

func (d DriverPostgres) GetLastThreadList(limit int) ([]*tracefall.Log, error)

func (DriverPostgres) GetLog

func (d DriverPostgres) GetLog(id uuid.UUID) (tracefall.ResponseLog, error)

func (DriverPostgres) GetThread

func (d DriverPostgres) GetThread(id uuid.UUID) (tracefall.ResponseThread, error)

func (DriverPostgres) InstallIndex

func (d DriverPostgres) InstallIndex() error

Create table for tracer

func (*DriverPostgres) Open

func (d *DriverPostgres) Open(params map[string]string) (interface{}, error)

func (DriverPostgres) RemoveByTags

func (d DriverPostgres) RemoveByTags(tags tracefall.Tags) (tracefall.ResponseCmd, error)

func (DriverPostgres) RemoveThread

func (d DriverPostgres) RemoveThread(id uuid.UUID) (tracefall.ResponseCmd, error)

func (DriverPostgres) Send

func (d DriverPostgres) Send(l *tracefall.Log) (tracefall.ResponseCmd, error)

func (DriverPostgres) Truncate

func (d DriverPostgres) Truncate(ind string) (tracefall.ResponseCmd, error)

type Params

type Params struct {
	Host, User, Password, DbName, TableName string
}