database

package

Go to main page

Versions in this module

v1

v1.27.1

Oct 27, 2026

v1.27.0

Oct 14, 2026

Changes in this version

type Querier

+ UsersGetAdmin func(ctx context.Context) (*User, error)

type Queries

+ func (q *Queries) UsersGetAdmin(ctx context.Context) (*User, error)

v1.26.0

Oct 9, 2026

Changes in this version

type Event

+ Data [][]byte

type EventsCreateParams

+ Data [][]byte

v1.25.0

Jun 14, 2026

Changes in this version

+ const HTTPMethodAny

+ const ProtoCategoryDNS

+ const ProtoCategoryFTP

+ const ProtoCategoryHTTP

+ const ProtoCategorySMTP

+ const ProtoDNS

+ const ProtoFTP

+ const ProtoHTTP

+ const ProtoHTTPS

+ const ProtoSMTP

+ var DNSStrategiesAll = func() []string { ... }()

+ var DNSTypesAll = func() []string { ... }()

+ var ErrNoRows = pgx.ErrNoRows

+ var HTTPMethods = []string

+ var ProtoCategoriesAll = []string

+ func Migrate(dsn string) (uint, error)

+ func ProtoCategoryContains(protocols []string, category string) bool

+ func ProtoToCategory(proto string) string

+ func RunInTx[T any](ctx context.Context, db *DB, ...) (*T, error)

+ type AuditActorMetadata = map[string]any

+ type AuditRecord struct

+ Action AuditRecordActionType

+ ActorID *int64

+ ActorMetadata AuditActorMetadata

+ ActorName string

+ CreatedAt time.Time

+ ID int64

+ Resource AuditResource

+ ResourceType AuditRecordResourceType

+ Source AuditRecordSourceType

+ UUID uuid.UUID

+ type AuditRecordActionType string

+ const AuditRecordActionTypeCreate

+ const AuditRecordActionTypeDelete

+ const AuditRecordActionTypeUpdate

+ func AllAuditRecordActionTypeValues() []AuditRecordActionType

+ func (e *AuditRecordActionType) Scan(src interface{}) error

+ type AuditRecordResourceType string

+ const AuditRecordResourceTypeDNSRecord

+ const AuditRecordResourceTypeHTTPRoute

+ const AuditRecordResourceTypePayload

+ const AuditRecordResourceTypeUser

+ func AllAuditRecordResourceTypeValues() []AuditRecordResourceType

+ func (e *AuditRecordResourceType) Scan(src interface{}) error

+ type AuditRecordSourceType string

+ const AuditRecordSourceTypeAPI

+ const AuditRecordSourceTypeLark

+ const AuditRecordSourceTypeSlack

+ const AuditRecordSourceTypeTelegram

+ func AllAuditRecordSourceTypeValues() []AuditRecordSourceType

+ func (e *AuditRecordSourceType) Scan(src interface{}) error

+ type AuditRecordsCreateParams struct

+ Action AuditRecordActionType

+ ActorID *int64

+ ActorMetadata AuditActorMetadata

+ ActorName string

+ Resource AuditResource

+ ResourceType AuditRecordResourceType

+ Source AuditRecordSourceType

+ type AuditRecordsListParams struct

+ Action string

+ ActorID *int64

+ ActorName string

+ FromAt *time.Time

+ PageLimit int64

+ PageOffset int64

+ ResourceType string

+ ToAt *time.Time

+ type AuditResource = json.RawMessage

+ type DB struct

+ func NewWithDSN(dsn string) (*DB, error)

+ func (db *DB) RunInTx(ctx context.Context, fn txFunc) error

+ func (db DB) DB() *sql.DB

+ type DBTX interface

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Query func(context.Context, string, ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row

+ type DNSRecord struct

+ CreatedAt time.Time

+ ID *int64

+ Index int

+ LastAccessedAt *time.Time

+ LastAnswer []string

+ Name string

+ PayloadID int64

+ Strategy DNSStrategy

+ TTL int

+ Type DNSRecordType

+ Values []string

+ func (r DNSRecord) Qtype() uint16

+ type DNSRecordType string

+ const DNSRecordTypeA

+ const DNSRecordTypeAAAA

+ const DNSRecordTypeCAA

+ const DNSRecordTypeCNAME

+ const DNSRecordTypeMX

+ const DNSRecordTypeNS

+ const DNSRecordTypeTXT

+ func AllDNSRecordTypeValues() []DNSRecordType

+ func (e *DNSRecordType) Scan(src interface{}) error

+ type DNSRecordsCreateParams struct

+ LastAccessedAt *time.Time

+ LastAnswer []string

+ Name string

+ PayloadID int64

+ Strategy DNSStrategy

+ TTL int

+ Type DNSRecordType

+ Values []string

+ type DNSRecordsGetByPayloadNameAndTypeParams struct

+ Name string

+ PayloadID int64

+ Type DNSRecordType

+ type DNSRecordsUpdateParams struct

+ ID *int64

+ LastAccessedAt *time.Time

+ LastAnswer []string

+ Name string

+ PayloadID int64

+ Strategy DNSStrategy

+ TTL int

+ Type DNSRecordType

+ Values []string

+ type DNSStrategy string

+ const DNSStrategyAll

+ const DNSStrategyRebind

+ const DNSStrategyRoundRobin

+ func AllDNSStrategyValues() []DNSStrategy

+ func (e *DNSStrategy) Scan(src interface{}) error

+ type Event struct

+ CreatedAt time.Time

+ ID int64

+ Meta EventsMeta

+ PayloadID int64

+ Protocol string

+ R []byte

+ RW []byte

+ ReceivedAt time.Time

+ RemoteAddr string

+ UUID uuid.UUID

+ W []byte

+ type EventsCreateParams struct

+ Meta EventsMeta

+ PayloadID int64

+ Protocol string

+ R []byte

+ RW []byte

+ ReceivedAt time.Time

+ RemoteAddr string

+ UUID uuid.UUID

+ W []byte

+ type EventsGetByPayloadAndIndexRow struct

+ Event Event

+ Index int64

+ type EventsListByPayloadIDParams struct

+ Limit int64

+ Offset int64

+ PayloadID int64

+ type EventsListByPayloadIDRow struct

+ Event Event

+ Index int64

+ type EventsMeta struct

+ DNS *dnsx.Meta

+ FTP *ftpx.Meta

+ GeoIP *geoipx.Meta

+ HTTP *httpx.Meta

+ SMTP *smtpx.Meta

+ Secure bool

+ type HTTPHeaders = map[string][]string

+ type HTTPRoute struct

+ Body []byte

+ Code int

+ CreatedAt time.Time

+ Headers HTTPHeaders

+ ID int64

+ Index int

+ IsDynamic bool

+ Method string

+ Path string

+ PayloadID int64

+ type HTTPRoutesCreateParams struct

+ Body []byte

+ Code int

+ Headers HTTPHeaders

+ IsDynamic bool

+ Method string

+ Path string

+ PayloadID int64

+ type HTTPRoutesGetByPayloadMethodAndPathParams struct

+ Method string

+ Path string

+ PayloadID int64

+ type HTTPRoutesUpdateParams struct

+ Body []byte

+ Code int

+ Headers HTTPHeaders

+ ID int64

+ IsDynamic bool

+ Method string

+ Path string

+ PayloadID int64

+ type NullAuditRecordActionType struct

+ AuditRecordActionType AuditRecordActionType

+ Valid bool

+ func (ns *NullAuditRecordActionType) Scan(value interface{}) error

+ func (ns NullAuditRecordActionType) Value() (driver.Value, error)

+ type NullAuditRecordResourceType struct

+ AuditRecordResourceType AuditRecordResourceType

+ Valid bool

+ func (ns *NullAuditRecordResourceType) Scan(value interface{}) error

+ func (ns NullAuditRecordResourceType) Value() (driver.Value, error)

+ type NullAuditRecordSourceType struct

+ AuditRecordSourceType AuditRecordSourceType

+ Valid bool

+ func (ns *NullAuditRecordSourceType) Scan(value interface{}) error

+ func (ns NullAuditRecordSourceType) Value() (driver.Value, error)

+ type NullDNSRecordType struct

+ DNSRecordType DNSRecordType

+ Valid bool

+ func (ns *NullDNSRecordType) Scan(value interface{}) error

+ func (ns NullDNSRecordType) Value() (driver.Value, error)

+ type NullDNSStrategy struct

+ DNSStrategy DNSStrategy

+ Valid bool

+ func (ns *NullDNSStrategy) Scan(value interface{}) error

+ func (ns NullDNSStrategy) Value() (driver.Value, error)

+ type Payload struct

+ CreatedAt time.Time

+ ID int64

+ Name string

+ NotifyProtocols []string

+ StoreEvents bool

+ Subdomain string

+ UserID int64

+ type PayloadsCreateParams struct

+ Name string

+ NotifyProtocols []string

+ StoreEvents bool

+ Subdomain string

+ UserID int64

+ type PayloadsFindByUserAndNameParams struct

+ Limit int64

+ Name string

+ Offset int64

+ UserID int64

+ type PayloadsUpdateParams struct

+ ID int64

+ Name string

+ NotifyProtocols []string

+ StoreEvents bool

+ Subdomain string

+ UserID int64

+ type Querier interface

+ AuditRecordsCreate func(ctx context.Context, arg AuditRecordsCreateParams) (*AuditRecord, error)

+ AuditRecordsGetByID func(ctx context.Context, id int64) (*AuditRecord, error)

+ AuditRecordsList func(ctx context.Context, arg AuditRecordsListParams) ([]*AuditRecord, error)

+ DNSRecordsCreate func(ctx context.Context, arg DNSRecordsCreateParams) (*DNSRecord, error)

+ DNSRecordsDelete func(ctx context.Context, id *int64) error

+ DNSRecordsDeleteAllByPayloadID func(ctx context.Context, payloadID int64) ([]*DNSRecord, error)

+ DNSRecordsDeleteAllByPayloadIDAndName func(ctx context.Context, payloadID int64, name string) ([]*DNSRecord, error)

+ DNSRecordsGetByID func(ctx context.Context, id *int64) (*DNSRecord, error)

+ DNSRecordsGetByPayloadID func(ctx context.Context, payloadID int64) ([]*DNSRecord, error)

+ DNSRecordsGetByPayloadIDAndIndex func(ctx context.Context, payloadID int64, index int) (*DNSRecord, error)

+ DNSRecordsGetByPayloadNameAndType func(ctx context.Context, arg DNSRecordsGetByPayloadNameAndTypeParams) (*DNSRecord, error)

+ DNSRecordsGetCountByPayloadID func(ctx context.Context, payloadID int64) (int64, error)

+ DNSRecordsUpdate func(ctx context.Context, arg DNSRecordsUpdateParams) (*DNSRecord, error)

+ EventsCreate func(ctx context.Context, arg EventsCreateParams) (*Event, error)

+ EventsGetByID func(ctx context.Context, id int64) (*Event, error)

+ EventsGetByPayloadAndIndex func(ctx context.Context, payloadID int64, index int64) (*EventsGetByPayloadAndIndexRow, error)

+ EventsListByPayloadID func(ctx context.Context, arg EventsListByPayloadIDParams) ([]*EventsListByPayloadIDRow, error)

+ HTTPRoutesCreate func(ctx context.Context, arg HTTPRoutesCreateParams) (*HTTPRoute, error)

+ HTTPRoutesDelete func(ctx context.Context, id int64) error

+ HTTPRoutesDeleteAllByPayloadID func(ctx context.Context, payloadID int64) ([]*HTTPRoute, error)

+ HTTPRoutesDeleteAllByPayloadIDAndPath func(ctx context.Context, payloadID int64, path string) ([]*HTTPRoute, error)

+ HTTPRoutesGetByID func(ctx context.Context, id int64) (*HTTPRoute, error)

+ HTTPRoutesGetByPayloadID func(ctx context.Context, payloadID int64) ([]*HTTPRoute, error)

+ HTTPRoutesGetByPayloadIDAndIndex func(ctx context.Context, payloadID int64, index int) (*HTTPRoute, error)

+ HTTPRoutesGetByPayloadMethodAndPath func(ctx context.Context, arg HTTPRoutesGetByPayloadMethodAndPathParams) (*HTTPRoute, error)

+ HTTPRoutesUpdate func(ctx context.Context, arg HTTPRoutesUpdateParams) (*HTTPRoute, error)

+ PayloadsCreate func(ctx context.Context, arg PayloadsCreateParams) (*Payload, error)

+ PayloadsDelete func(ctx context.Context, id int64) (*Payload, error)

+ PayloadsDeleteByNamePart func(ctx context.Context, userID int64, name string) ([]*Payload, error)

+ PayloadsFindByUserAndName func(ctx context.Context, arg PayloadsFindByUserAndNameParams) ([]*Payload, error)

+ PayloadsFindByUserID func(ctx context.Context, userID int64) ([]*Payload, error)

+ PayloadsGetAllSubdomains func(ctx context.Context) ([]string, error)

+ PayloadsGetByID func(ctx context.Context, id int64) (*Payload, error)

+ PayloadsGetBySubdomain func(ctx context.Context, subdomain string) (*Payload, error)

+ PayloadsGetByUserAndName func(ctx context.Context, userID int64, name string) (*Payload, error)

+ PayloadsUpdate func(ctx context.Context, arg PayloadsUpdateParams) (*Payload, error)

+ UsersCreate func(ctx context.Context, arg UsersCreateParams) (*User, error)

+ UsersDelete func(ctx context.Context, id int64) error

+ UsersGetByAPIToken func(ctx context.Context, token string) (*User, error)

+ UsersGetByID func(ctx context.Context, id int64) (*User, error)

+ UsersGetByLarkID func(ctx context.Context, id string) (*User, error)

+ UsersGetByName func(ctx context.Context, name string) (*User, error)

+ UsersGetBySlackID func(ctx context.Context, id string) (*User, error)

+ UsersGetByTelegramID func(ctx context.Context, id int64) (*User, error)

+ UsersList func(ctx context.Context) ([]*User, error)

+ UsersUpdate func(ctx context.Context, arg UsersUpdateParams) (*User, error)

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) AuditRecordsCreate(ctx context.Context, arg AuditRecordsCreateParams) (*AuditRecord, error)

+ func (q *Queries) AuditRecordsGetByID(ctx context.Context, id int64) (*AuditRecord, error)

+ func (q *Queries) AuditRecordsList(ctx context.Context, arg AuditRecordsListParams) ([]*AuditRecord, error)

+ func (q *Queries) DNSRecordsCreate(ctx context.Context, arg DNSRecordsCreateParams) (*DNSRecord, error)

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

+ func (q *Queries) DNSRecordsDeleteAllByPayloadID(ctx context.Context, payloadID int64) ([]*DNSRecord, error)

+ func (q *Queries) DNSRecordsDeleteAllByPayloadIDAndName(ctx context.Context, payloadID int64, name string) ([]*DNSRecord, error)

+ func (q *Queries) DNSRecordsGetByID(ctx context.Context, id *int64) (*DNSRecord, error)

+ func (q *Queries) DNSRecordsGetByPayloadID(ctx context.Context, payloadID int64) ([]*DNSRecord, error)

+ func (q *Queries) DNSRecordsGetByPayloadIDAndIndex(ctx context.Context, payloadID int64, index int) (*DNSRecord, error)

+ func (q *Queries) DNSRecordsGetByPayloadNameAndType(ctx context.Context, arg DNSRecordsGetByPayloadNameAndTypeParams) (*DNSRecord, error)

+ func (q *Queries) DNSRecordsGetCountByPayloadID(ctx context.Context, payloadID int64) (int64, error)

+ func (q *Queries) DNSRecordsUpdate(ctx context.Context, arg DNSRecordsUpdateParams) (*DNSRecord, error)

+ func (q *Queries) EventsCreate(ctx context.Context, arg EventsCreateParams) (*Event, error)

+ func (q *Queries) EventsGetByID(ctx context.Context, id int64) (*Event, error)

+ func (q *Queries) EventsGetByPayloadAndIndex(ctx context.Context, payloadID int64, index int64) (*EventsGetByPayloadAndIndexRow, error)

+ func (q *Queries) EventsListByPayloadID(ctx context.Context, arg EventsListByPayloadIDParams) ([]*EventsListByPayloadIDRow, error)

+ func (q *Queries) HTTPRoutesCreate(ctx context.Context, arg HTTPRoutesCreateParams) (*HTTPRoute, error)

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

+ func (q *Queries) HTTPRoutesDeleteAllByPayloadID(ctx context.Context, payloadID int64) ([]*HTTPRoute, error)

+ func (q *Queries) HTTPRoutesDeleteAllByPayloadIDAndPath(ctx context.Context, payloadID int64, path string) ([]*HTTPRoute, error)

+ func (q *Queries) HTTPRoutesGetByID(ctx context.Context, id int64) (*HTTPRoute, error)

+ func (q *Queries) HTTPRoutesGetByPayloadID(ctx context.Context, payloadID int64) ([]*HTTPRoute, error)

+ func (q *Queries) HTTPRoutesGetByPayloadIDAndIndex(ctx context.Context, payloadID int64, index int) (*HTTPRoute, error)

+ func (q *Queries) HTTPRoutesGetByPayloadMethodAndPath(ctx context.Context, arg HTTPRoutesGetByPayloadMethodAndPathParams) (*HTTPRoute, error)

+ func (q *Queries) HTTPRoutesUpdate(ctx context.Context, arg HTTPRoutesUpdateParams) (*HTTPRoute, error)

+ func (q *Queries) PayloadsCreate(ctx context.Context, arg PayloadsCreateParams) (*Payload, error)

+ func (q *Queries) PayloadsDelete(ctx context.Context, id int64) (*Payload, error)

+ func (q *Queries) PayloadsDeleteByNamePart(ctx context.Context, userID int64, name string) ([]*Payload, error)

+ func (q *Queries) PayloadsFindByUserAndName(ctx context.Context, arg PayloadsFindByUserAndNameParams) ([]*Payload, error)

+ func (q *Queries) PayloadsFindByUserID(ctx context.Context, userID int64) ([]*Payload, error)

+ func (q *Queries) PayloadsGetAllSubdomains(ctx context.Context) ([]string, error)

+ func (q *Queries) PayloadsGetByID(ctx context.Context, id int64) (*Payload, error)

+ func (q *Queries) PayloadsGetBySubdomain(ctx context.Context, subdomain string) (*Payload, error)

+ func (q *Queries) PayloadsGetByUserAndName(ctx context.Context, userID int64, name string) (*Payload, error)

+ func (q *Queries) PayloadsUpdate(ctx context.Context, arg PayloadsUpdateParams) (*Payload, error)

+ func (q *Queries) UsersCreate(ctx context.Context, arg UsersCreateParams) (*User, error)

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

+ func (q *Queries) UsersGetByAPIToken(ctx context.Context, token string) (*User, error)

+ func (q *Queries) UsersGetByID(ctx context.Context, id int64) (*User, error)

+ func (q *Queries) UsersGetByLarkID(ctx context.Context, id string) (*User, error)

+ func (q *Queries) UsersGetByName(ctx context.Context, name string) (*User, error)

+ func (q *Queries) UsersGetBySlackID(ctx context.Context, id string) (*User, error)

+ func (q *Queries) UsersGetByTelegramID(ctx context.Context, id int64) (*User, error)

+ func (q *Queries) UsersList(ctx context.Context) ([]*User, error)

+ func (q *Queries) UsersUpdate(ctx context.Context, arg UsersUpdateParams) (*User, error)

+ func (q *Queries) WithTx(tx pgx.Tx) *Queries

+ type User struct

+ APIToken *string

+ CreatedAt time.Time

+ CreatedBy *int64

+ ID int64

+ IsAdmin bool

+ LarkID *string

+ Name string

+ SlackID *string

+ TelegramID *int64

+ type UsersCreateParams struct

+ APIToken *string

+ CreatedBy *int64

+ IsAdmin bool

+ LarkID *string

+ Name string

+ SlackID *string

+ TelegramID *int64

+ type UsersUpdateParams struct

+ APIToken *string

+ CreatedBy *int64

+ ID int64

+ IsAdmin bool

+ LarkID *string

+ Name string

+ SlackID *string

+ TelegramID *int64

v1.24.0

Jan 7, 2026

v1.23.1

Aug 24, 2025

v1.23.0

Aug 21, 2025

v1.22.0

Aug 12, 2025

v1.21.2

Aug 12, 2025

v1.21.1

Aug 5, 2025

v1.21.0

Aug 5, 2025

v1.20.0

Aug 3, 2025

v1.19.4

Aug 1, 2025

v1.19.3

Jul 31, 2025

v1.19.2

Jul 23, 2025

v1.19.1

Jul 22, 2025

v1.19.0

Jul 21, 2025

v1.18.1

Jun 20, 2025

v1.18.0

Jun 20, 2025

v1.17.0

Feb 12, 2025

v1.16.0

Nov 3, 2024

v1.15.1

Nov 1, 2024

v1.15.0

Nov 1, 2024

v1.14.0

Jul 21, 2024

v1.13.1

Jul 16, 2024

v1.13.0

Jul 16, 2024

v1.12.2

Jun 18, 2024

v1.12.1

Jun 18, 2024

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