storage

Documentation

Index

• Variables
• type Invoice
• type Options
• type PostgresClient
  • func NewPostgresClient(ctx context.Context, options *Options) (*PostgresClient, error)
  • func (pc *PostgresClient) Create(ctx context.Context, table string, fields []string, invoices []Invoice) error
  • func (pc *PostgresClient) Delete(ctx context.Context, table, userID, fileID string) error
  • func (pc *PostgresClient) ReadByPeriod(ctx context.Context, table string, fields []string, userID, fileID string, ...) ([]Invoice, error)

Variables

var (
	AllFields = []string{
		"user_id",
		"file_id",
		"customer_id",
		"period_start",
		"paid_plan",
		"paid_amount",
		"period_end",
	}
)

Types

type Invoice

type Invoice struct {
	UserID      string
	FileID      string
	CustomerID  uint32
	PeriodStart time.Time
	PaidPlan    string
	PaidAmount  float32
	PeriodEnd   time.Time
}

type Options

type Options struct {
	Host     string
	Port     string
	User     string
	Password string
	DB       string
}

type PostgresClient

type PostgresClient struct {
	Client *pgxpool.Pool
}

func NewPostgresClient

func NewPostgresClient(ctx context.Context, options *Options) (*PostgresClient, error)

func (*PostgresClient) Create

func (pc *PostgresClient) Create(ctx context.Context, table string, fields []string, invoices []Invoice) error

func (*PostgresClient) Delete

func (pc *PostgresClient) Delete(ctx context.Context, table, userID, fileID string) error

func (*PostgresClient) ReadByPeriod

func (pc *PostgresClient) ReadByPeriod(
	ctx context.Context,
	table string,
	fields []string,
	userID, fileID string,
	periodStart, periodEnd time.Time) ([]Invoice, error)