database

Documentation

Overview

The package database handles the methods and definition to manipulate a database.

Index

• func InitialMigration(db *sql.DB) error
• type CreateNonceParams
• type CreateRouteParams
• type DBTX
• type GetNonceParams
• type Nonce
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) CountRoute(ctx context.Context) (int64, error)
  • func (q *Queries) CreateNonce(ctx context.Context, arg CreateNonceParams) error
  • func (q *Queries) CreateRoute(ctx context.Context, arg CreateRouteParams) error
  • func (q *Queries) DeleteNoncesByRef(ctx context.Context, ref sql.NullString) error
  • func (q *Queries) GetNonce(ctx context.Context, arg GetNonceParams) (Nonce, error)
  • func (q *Queries) GetRoute(ctx context.Context, route string) (Route, error)
  • func (q *Queries) GetRouteByUserAddress(ctx context.Context, userAddress string) (Route, error)
  • func (q *Queries) IsPortUsed(ctx context.Context, port int64) (int64, error)
  • func (q *Queries) SetRoute(ctx context.Context, arg SetRouteParams) (string, error)
  • func (q *Queries) UpdateNonce(ctx context.Context, arg UpdateNonceParams) (string, error)
  • func (q *Queries) WithTx(tx *sql.Tx) *Queries
• type Route
• type SetRouteParams
• type UpdateNonceParams

Functions

func InitialMigration

func InitialMigration(db *sql.DB) error

InitialMigration migrate a sqlite3 database if necessary.

Types

type CreateNonceParams

type CreateNonceParams struct {
	Nonce      string
	Expiration time.Time
	Ref        sql.NullString
}

type CreateRouteParams

type CreateRouteParams struct {
	UserAddress string
	Route       string
	Port        int64
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type GetNonceParams

type GetNonceParams struct {
	Nonce      string
	Expiration time.Time
}

type Nonce

type Nonce struct {
	Nonce      string
	Expiration time.Time
	Ref        sql.NullString
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CountRoute

func (q *Queries) CountRoute(ctx context.Context) (int64, error)

func (*Queries) CreateNonce

func (q *Queries) CreateNonce(ctx context.Context, arg CreateNonceParams) error

func (*Queries) CreateRoute

func (q *Queries) CreateRoute(ctx context.Context, arg CreateRouteParams) error

func (*Queries) DeleteNoncesByRef

func (q *Queries) DeleteNoncesByRef(ctx context.Context, ref sql.NullString) error

func (*Queries) GetNonce

func (q *Queries) GetNonce(ctx context.Context, arg GetNonceParams) (Nonce, error)

func (*Queries) GetRoute

func (q *Queries) GetRoute(ctx context.Context, route string) (Route, error)

func (*Queries) GetRouteByUserAddress

func (q *Queries) GetRouteByUserAddress(ctx context.Context, userAddress string) (Route, error)

-

func (*Queries) IsPortUsed

func (q *Queries) IsPortUsed(ctx context.Context, port int64) (int64, error)

func (*Queries) SetRoute

func (q *Queries) SetRoute(ctx context.Context, arg SetRouteParams) (string, error)

func (*Queries) UpdateNonce

func (q *Queries) UpdateNonce(ctx context.Context, arg UpdateNonceParams) (string, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type Route

type Route struct {
	UserAddress string
	Route       string
	Port        int64
}

type SetRouteParams

type SetRouteParams struct {
	Route       string
	Port        int64
	UserAddress string
}

type UpdateNonceParams

type UpdateNonceParams struct {
	Expiration time.Time
	Nonce      string
}