storage

package
v0.0.0-...-abb0a12 Latest Latest
Warning

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

Go to latest
Published: Aug 8, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IdPostgresToProto

func IdPostgresToProto(id pgtype.UUID) (proto_id string, err error)

func IdProtoToPostgres

func IdProtoToPostgres(id string) (postgres_id pgtype.UUID, err error)

Types

type Bake

type Bake struct {
	ID         pgtype.UUID
	CreateTime time.Time
	Name       string
	BakeStatus StatusEnum
}

type CreateBakeParams

type CreateBakeParams struct {
	Name       string
	BakeStatus StatusEnum
}

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 Querier

type Querier interface {
	CreateBake(ctx context.Context, arg CreateBakeParams) (Bake, error)
	DeleteBake(ctx context.Context, id pgtype.UUID) error
	GetAllBake(ctx context.Context) ([]Bake, error)
	GetBake(ctx context.Context, id pgtype.UUID) (Bake, error)
	UpdateBake(ctx context.Context, arg UpdateBakeParams) error
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CreateBake

func (q *Queries) CreateBake(ctx context.Context, arg CreateBakeParams) (Bake, error)

func (*Queries) DeleteBake

func (q *Queries) DeleteBake(ctx context.Context, id pgtype.UUID) error

func (*Queries) GetAllBake

func (q *Queries) GetAllBake(ctx context.Context) ([]Bake, error)

func (*Queries) GetBake

func (q *Queries) GetBake(ctx context.Context, id pgtype.UUID) (Bake, error)

func (*Queries) UpdateBake

func (q *Queries) UpdateBake(ctx context.Context, arg UpdateBakeParams) error

func (*Queries) WithTx

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

type Repository

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

func NewRepository

func NewRepository(logger *logrus.Logger, pgURL *url.URL) (*Repository, error)

func (Repository) CreateBake

func (r Repository) CreateBake(ctx context.Context, name string) (*Bake, error)

func (Repository) GetAllBake

func (r Repository) GetAllBake(ctx context.Context) (*[]Bake, error)

func (Repository) GetBake

func (r Repository) GetBake(ctx context.Context, id pgtype.UUID) (*Bake, error)

func (Repository) Ping

func (r Repository) Ping() error

func (Repository) UpdateBake

func (r Repository) UpdateBake(ctx context.Context, id pgtype.UUID, status StatusEnum) error

type StatusEnum

type StatusEnum string
const (
	StatusEnumPreparing StatusEnum = "preparing"
	StatusEnumBaking    StatusEnum = "baking"
	StatusEnumDone      StatusEnum = "done"
)

func (*StatusEnum) Scan

func (e *StatusEnum) Scan(src interface{}) error

type Topping

type Topping struct {
	ID pgtype.UUID
}

type UpdateBakeParams

type UpdateBakeParams struct {
	ID         pgtype.UUID
	BakeStatus StatusEnum
}

Jump to

Keyboard shortcuts

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