db

package
v0.0.0-...-24d0fbb Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateReportConflictParams 

type CreateReportConflictParams struct {
	ReportID    int64
	Recommender string
	Recommended string
}

type CreateReportDistributeParams 

type CreateReportDistributeParams struct {
	ReportID    int64
	Recommender string
	Asset       string
	Amount      float64
}

type CreateReportRecommendParams 

type CreateReportRecommendParams struct {
	ReportID         int64
	Recommender      string
	Recommended      string
	RecommendedMtlap int64
}

type CreateStateParams 

type CreateStateParams struct {
	UserID int64
	State  string
	Data   map[string]interface{}
	Meta   map[string]interface{}
}

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 Querier 

type Querier interface {
	CreateReport(ctx context.Context, xdr string) (int64, error)
	CreateReportConflict(ctx context.Context, arg CreateReportConflictParams) error
	CreateReportDistribute(ctx context.Context, arg CreateReportDistributeParams) error
	CreateReportRecommend(ctx context.Context, arg CreateReportRecommendParams) error
	CreateState(ctx context.Context, arg CreateStateParams) error
	DeleteReport(ctx context.Context, id int64) error
	GetReport(ctx context.Context, id int64) (Report, error)
	GetReportConflicts(ctx context.Context, reportID int64) ([]ReportConflict, error)
	GetReportDistributes(ctx context.Context, reportID int64) ([]ReportDistribute, error)
	GetReportRecommends(ctx context.Context, reportID int64) ([]ReportRecommend, error)
	GetReports(ctx context.Context, queryLimit int32) ([]Report, error)
	GetState(ctx context.Context, userID int64) (State, error)
	LockReport(ctx context.Context) error
	SetReportHash(ctx context.Context, arg SetReportHashParams) error
	UnlockReport(ctx context.Context) error
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) CreateReport 

func (q *Queries) CreateReport(ctx context.Context, xdr string) (int64, error)

func (*Queries) CreateReportConflict 

func (q *Queries) CreateReportConflict(ctx context.Context, arg CreateReportConflictParams) error

func (*Queries) CreateReportDistribute 

func (q *Queries) CreateReportDistribute(ctx context.Context, arg CreateReportDistributeParams) error

func (*Queries) CreateReportRecommend 

func (q *Queries) CreateReportRecommend(ctx context.Context, arg CreateReportRecommendParams) error

func (*Queries) CreateState 

func (q *Queries) CreateState(ctx context.Context, arg CreateStateParams) error

func (*Queries) DeleteReport 

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

func (*Queries) GetReport 

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

func (*Queries) GetReportConflicts 

func (q *Queries) GetReportConflicts(ctx context.Context, reportID int64) ([]ReportConflict, error)

func (*Queries) GetReportDistributes 

func (q *Queries) GetReportDistributes(ctx context.Context, reportID int64) ([]ReportDistribute, error)

func (*Queries) GetReportRecommends 

func (q *Queries) GetReportRecommends(ctx context.Context, reportID int64) ([]ReportRecommend, error)

func (*Queries) GetReports 

func (q *Queries) GetReports(ctx context.Context, queryLimit int32) ([]Report, error)

func (*Queries) GetState 

func (q *Queries) GetState(ctx context.Context, userID int64) (State, error)

func (*Queries) LockReport 

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

func (*Queries) SetReportHash 

func (q *Queries) SetReportHash(ctx context.Context, arg SetReportHashParams) error

func (*Queries) UnlockReport 

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

func (*Queries) WithTx 

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

type Report 

type Report struct {
	ID        int64
	CreatedAt pgtype.Timestamptz
	DeletedAt pgtype.Timestamptz
	Xdr       string
	Hash      pgtype.Text
	UpdatedAt pgtype.Timestamptz
}

type ReportConflict 

type ReportConflict struct {
	ReportID    int64
	Recommender string
	Recommended string
}

type ReportDistribute 

type ReportDistribute struct {
	ReportID    int64
	Recommender string
	Asset       string
	Amount      float64
}

type ReportRecommend 

type ReportRecommend struct {
	ReportID         int64
	Recommender      string
	Recommended      string
	RecommendedMtlap int64
}

type SetReportHashParams 

type SetReportHashParams struct {
	Hash     pgtype.Text
	ReportID int64
}

type State 

type State struct {
	UserID    int64
	State     string
	Data      map[string]interface{}
	Meta      map[string]interface{}
	CreatedAt pgtype.Timestamptz
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.