database

package
v0.1.0-alpha.3 Latest Latest
Warning

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

Go to latest
Published: Aug 24, 2025 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Collection

type Collection struct {
	ID        int64  `db:"id" json:"id"`
	Name      string `db:"name" json:"name"`
	CreatedAt string `db:"created_at" json:"created_at"`
	UpdatedAt string `db:"updated_at" json:"updated_at"`
}

type CreateEndpointParams

type CreateEndpointParams struct {
	CollectionID int64  `db:"collection_id" json:"collection_id"`
	Name         string `db:"name" json:"name"`
	Method       string `db:"method" json:"method"`
	Url          string `db:"url" json:"url"`
	Headers      string `db:"headers" json:"headers"`
	QueryParams  string `db:"query_params" json:"query_params"`
	RequestBody  string `db:"request_body" json:"request_body"`
}

type CreateHistoryEntryParams

type CreateHistoryEntryParams struct {
	CollectionID    sql.NullInt64  `db:"collection_id" json:"collection_id"`
	CollectionName  sql.NullString `db:"collection_name" json:"collection_name"`
	EndpointName    sql.NullString `db:"endpoint_name" json:"endpoint_name"`
	Method          string         `db:"method" json:"method"`
	Url             string         `db:"url" json:"url"`
	StatusCode      int64          `db:"status_code" json:"status_code"`
	Duration        int64          `db:"duration" json:"duration"`
	ResponseSize    sql.NullInt64  `db:"response_size" json:"response_size"`
	RequestHeaders  sql.NullString `db:"request_headers" json:"request_headers"`
	QueryParams     sql.NullString `db:"query_params" json:"query_params"`
	RequestBody     sql.NullString `db:"request_body" json:"request_body"`
	ResponseBody    sql.NullString `db:"response_body" json:"response_body"`
	ResponseHeaders sql.NullString `db:"response_headers" json:"response_headers"`
	ExecutedAt      string         `db:"executed_at" json:"executed_at"`
}

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 Endpoint

type Endpoint struct {
	ID           int64  `db:"id" json:"id"`
	CollectionID int64  `db:"collection_id" json:"collection_id"`
	Name         string `db:"name" json:"name"`
	Method       string `db:"method" json:"method"`
	Url          string `db:"url" json:"url"`
	Headers      string `db:"headers" json:"headers"`
	QueryParams  string `db:"query_params" json:"query_params"`
	RequestBody  string `db:"request_body" json:"request_body"`
	CreatedAt    string `db:"created_at" json:"created_at"`
	UpdatedAt    string `db:"updated_at" json:"updated_at"`
}

type GetCollectionsPaginatedParams

type GetCollectionsPaginatedParams struct {
	Limit  int64 `db:"limit" json:"limit"`
	Offset int64 `db:"offset" json:"offset"`
}

type GetEndpointCountsByCollectionsRow

type GetEndpointCountsByCollectionsRow struct {
	CollectionID int64 `db:"collection_id" json:"collection_id"`
	Count        int64 `db:"count" json:"count"`
}

type GetHistoryByCollectionParams

type GetHistoryByCollectionParams struct {
	CollectionID sql.NullInt64 `db:"collection_id" json:"collection_id"`
	Limit        int64         `db:"limit" json:"limit"`
	Offset       int64         `db:"offset" json:"offset"`
}

type GetHistoryByCollectionRow

type GetHistoryByCollectionRow struct {
	ID           int64          `db:"id" json:"id"`
	EndpointName sql.NullString `db:"endpoint_name" json:"endpoint_name"`
	StatusCode   int64          `db:"status_code" json:"status_code"`
	ExecutedAt   string         `db:"executed_at" json:"executed_at"`
	Url          string         `db:"url" json:"url"`
	Method       string         `db:"method" json:"method"`
}

type History

type History struct {
	ID              int64          `db:"id" json:"id"`
	CollectionID    sql.NullInt64  `db:"collection_id" json:"collection_id"`
	CollectionName  sql.NullString `db:"collection_name" json:"collection_name"`
	EndpointName    sql.NullString `db:"endpoint_name" json:"endpoint_name"`
	Method          string         `db:"method" json:"method"`
	Url             string         `db:"url" json:"url"`
	StatusCode      int64          `db:"status_code" json:"status_code"`
	Duration        int64          `db:"duration" json:"duration"`
	ResponseSize    sql.NullInt64  `db:"response_size" json:"response_size"`
	RequestHeaders  sql.NullString `db:"request_headers" json:"request_headers"`
	QueryParams     sql.NullString `db:"query_params" json:"query_params"`
	RequestBody     sql.NullString `db:"request_body" json:"request_body"`
	ResponseBody    sql.NullString `db:"response_body" json:"response_body"`
	ResponseHeaders sql.NullString `db:"response_headers" json:"response_headers"`
	ExecutedAt      string         `db:"executed_at" json:"executed_at"`
}

type ListEndpointsPaginatedParams

type ListEndpointsPaginatedParams struct {
	CollectionID int64 `db:"collection_id" json:"collection_id"`
	Limit        int64 `db:"limit" json:"limit"`
	Offset       int64 `db:"offset" json:"offset"`
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CountCollections

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

func (*Queries) CountEndpointsByCollection

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

func (*Queries) CountHistoryByCollection

func (q *Queries) CountHistoryByCollection(ctx context.Context, collectionID sql.NullInt64) (int64, error)

func (*Queries) CreateCollection

func (q *Queries) CreateCollection(ctx context.Context, name string) (Collection, error)

func (*Queries) CreateEndpoint

func (q *Queries) CreateEndpoint(ctx context.Context, arg CreateEndpointParams) (Endpoint, error)

func (*Queries) CreateHistoryEntry

func (q *Queries) CreateHistoryEntry(ctx context.Context, arg CreateHistoryEntryParams) (History, error)

func (*Queries) DeleteCollection

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

func (*Queries) DeleteEndpoint

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

func (*Queries) DeleteHistoryEntry

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

func (*Queries) DeleteOldHistory

func (q *Queries) DeleteOldHistory(ctx context.Context) error

func (*Queries) GetCollection

func (q *Queries) GetCollection(ctx context.Context, id int64) (Collection, error)

func (*Queries) GetCollections

func (q *Queries) GetCollections(ctx context.Context) ([]Collection, error)

func (*Queries) GetCollectionsPaginated

func (q *Queries) GetCollectionsPaginated(ctx context.Context, arg GetCollectionsPaginatedParams) ([]Collection, error)

func (*Queries) GetEndpoint

func (q *Queries) GetEndpoint(ctx context.Context, id int64) (Endpoint, error)

func (*Queries) GetEndpointCountsByCollections

func (q *Queries) GetEndpointCountsByCollections(ctx context.Context) ([]GetEndpointCountsByCollectionsRow, error)

func (*Queries) GetHistoryByCollection

func (q *Queries) GetHistoryByCollection(ctx context.Context, arg GetHistoryByCollectionParams) ([]GetHistoryByCollectionRow, error)

func (*Queries) GetHistoryById

func (q *Queries) GetHistoryById(ctx context.Context, id int64) (History, error)

func (*Queries) ListEndpointsByCollection

func (q *Queries) ListEndpointsByCollection(ctx context.Context, collectionID int64) ([]Endpoint, error)

func (*Queries) ListEndpointsPaginated

func (q *Queries) ListEndpointsPaginated(ctx context.Context, arg ListEndpointsPaginatedParams) ([]Endpoint, error)

func (*Queries) UpdateCollectionName

func (q *Queries) UpdateCollectionName(ctx context.Context, arg UpdateCollectionNameParams) (Collection, error)

func (*Queries) UpdateEndpoint

func (q *Queries) UpdateEndpoint(ctx context.Context, arg UpdateEndpointParams) (Endpoint, error)

func (*Queries) UpdateEndpointName

func (q *Queries) UpdateEndpointName(ctx context.Context, arg UpdateEndpointNameParams) (Endpoint, error)

func (*Queries) WithTx

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

type UpdateCollectionNameParams

type UpdateCollectionNameParams struct {
	Name string `db:"name" json:"name"`
	ID   int64  `db:"id" json:"id"`
}

type UpdateEndpointNameParams

type UpdateEndpointNameParams struct {
	Name string `db:"name" json:"name"`
	ID   int64  `db:"id" json:"id"`
}

type UpdateEndpointParams

type UpdateEndpointParams struct {
	Name        string `db:"name" json:"name"`
	Method      string `db:"method" json:"method"`
	Url         string `db:"url" json:"url"`
	Headers     string `db:"headers" json:"headers"`
	QueryParams string `db:"query_params" json:"query_params"`
	RequestBody string `db:"request_body" json:"request_body"`
	ID          int64  `db:"id" json:"id"`
}

Jump to

Keyboard shortcuts

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