db

Documentation

Index

• type AddCandidateRecordParams
• type CandidateRecord
• type DBTX
• type Dataset
• type GetCandidateRecordBySourceParams
• type GetCandidateRecordsByPersonIDParams
• type GetCandidateRecordsByPersonIDRow
• type GetCandidateRecordsParams
• type GetCandidateRecordsRow
• type Proxy
• type Publication
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) AddCandidateRecord(ctx context.Context, arg AddCandidateRecordParams) (string, error)
  • func (q *Queries) CountPersonCandidateRecords(ctx context.Context, query []byte) (int64, error)
  • func (q *Queries) GetCandidateRecord(ctx context.Context, id string) (CandidateRecord, error)
  • func (q *Queries) GetCandidateRecordBySource(ctx context.Context, arg GetCandidateRecordBySourceParams) (CandidateRecord, error)
  • func (q *Queries) GetCandidateRecords(ctx context.Context, arg GetCandidateRecordsParams) ([]GetCandidateRecordsRow, error)
  • func (q *Queries) GetCandidateRecordsByPersonID(ctx context.Context, arg GetCandidateRecordsByPersonIDParams) ([]GetCandidateRecordsByPersonIDRow, error)
  • func (q *Queries) HasCandidateRecords(ctx context.Context) (bool, error)
  • func (q *Queries) PersonHasCandidateRecords(ctx context.Context, query []byte) (bool, error)
  • func (q *Queries) SetCandidateRecordStatus(ctx context.Context, arg SetCandidateRecordStatusParams) (string, error)
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type SetCandidateRecordStatusParams

Types

type AddCandidateRecordParams

type AddCandidateRecordParams struct {
	ID             string
	SourceName     string
	SourceID       string
	SourceMetadata []byte
	Type           string
	Metadata       []byte
}

type CandidateRecord

type CandidateRecord struct {
	ID             string
	SourceName     string
	SourceID       string
	SourceMetadata []byte
	Type           string
	Status         string
	Metadata       []byte
	DateCreated    pgtype.Timestamptz
	StatusDate     pgtype.Timestamptz
	StatusPersonID *string
	ImportedID     *string
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type Dataset

type Dataset struct {
	SnapshotID string
	ID         string
	Data       []byte
	DateFrom   pgtype.Timestamptz
	DateUntil  pgtype.Timestamptz
}

type GetCandidateRecordBySourceParams

type GetCandidateRecordBySourceParams struct {
	SourceName string
	SourceID   string
}

type GetCandidateRecordsByPersonIDParams

type GetCandidateRecordsByPersonIDParams struct {
	NewOnly bool
	Query   []byte
	Offset  int32
	Limit   int32
}

type GetCandidateRecordsByPersonIDRow

type GetCandidateRecordsByPersonIDRow struct {
	ID             string
	SourceName     string
	SourceID       string
	SourceMetadata []byte
	Type           string
	Status         string
	Metadata       []byte
	DateCreated    pgtype.Timestamptz
	StatusDate     pgtype.Timestamptz
	StatusPersonID *string
	ImportedID     *string
	Total          int64
}

type GetCandidateRecordsParams

type GetCandidateRecordsParams struct {
	Offset int32
	Limit  int32
}

type GetCandidateRecordsRow

type GetCandidateRecordsRow struct {
	ID             string
	SourceName     string
	SourceID       string
	SourceMetadata []byte
	Type           string
	Status         string
	Metadata       []byte
	DateCreated    pgtype.Timestamptz
	StatusDate     pgtype.Timestamptz
	StatusPersonID *string
	ImportedID     *string
	Total          int64
}

type Proxy

type Proxy struct {
	ProxyPersonID string
	PersonID      string
	DateCreated   pgtype.Timestamptz
}

type Publication

type Publication struct {
	SnapshotID string
	ID         string
	Data       []byte
	DateFrom   pgtype.Timestamptz
	DateUntil  pgtype.Timestamptz
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) AddCandidateRecord

func (q *Queries) AddCandidateRecord(ctx context.Context, arg AddCandidateRecordParams) (string, error)

func (*Queries) CountPersonCandidateRecords

func (q *Queries) CountPersonCandidateRecords(ctx context.Context, query []byte) (int64, error)

func (*Queries) GetCandidateRecord

func (q *Queries) GetCandidateRecord(ctx context.Context, id string) (CandidateRecord, error)

func (*Queries) GetCandidateRecordBySource

func (q *Queries) GetCandidateRecordBySource(ctx context.Context, arg GetCandidateRecordBySourceParams) (CandidateRecord, error)

func (*Queries) GetCandidateRecords

func (q *Queries) GetCandidateRecords(ctx context.Context, arg GetCandidateRecordsParams) ([]GetCandidateRecordsRow, error)

func (*Queries) GetCandidateRecordsByPersonID

func (q *Queries) GetCandidateRecordsByPersonID(ctx context.Context, arg GetCandidateRecordsByPersonIDParams) ([]GetCandidateRecordsByPersonIDRow, error)

func (*Queries) HasCandidateRecords

func (q *Queries) HasCandidateRecords(ctx context.Context) (bool, error)

func (*Queries) PersonHasCandidateRecords

func (q *Queries) PersonHasCandidateRecords(ctx context.Context, query []byte) (bool, error)

func (*Queries) SetCandidateRecordStatus

func (q *Queries) SetCandidateRecordStatus(ctx context.Context, arg SetCandidateRecordStatusParams) (string, error)

func (*Queries) WithTx

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

type SetCandidateRecordStatusParams

type SetCandidateRecordStatusParams struct {
	Status         string
	StatusPersonID *string
	ImportedID     *string
	ID             string
}