postgres

Documentation

Index

• func NewHttpLoadRepository(db *pgxpool.Pool) repository.HttpLoadRepository
• func NewJWTRefreshRepository(db *pgxpool.Pool) repository.JWTRefreshRepository
• func NewLoadRepository(db *pgxpool.Pool) repository.LoadRepository
• func NewUserRepository(db *pgxpool.Pool) repository.UserRepository
• type HttpLoadRepository
  • func (r *HttpLoadRepository) CreateConstant(ctx context.Context, httpLoad *model.ConstantHttpLoad) (*model.ConstantHttpLoad, error)
  • func (r *HttpLoadRepository) CreateFixed(ctx context.Context, httpLoad *model.FixedHttpLoad) (*model.FixedHttpLoad, error)
  • func (r *HttpLoadRepository) CreateRampUp(ctx context.Context, httpLoad *model.RampUpHttpLoad) (*model.RampUpHttpLoad, error)
  • func (r *HttpLoadRepository) DeleteConstant(ctx context.Context, id string) error
  • func (r *HttpLoadRepository) DeleteFixed(ctx context.Context, id string) error
  • func (r *HttpLoadRepository) DeleteRampUp(ctx context.Context, id string) error
  • func (r *HttpLoadRepository) GetConstantById(ctx context.Context, id string) (*model.ConstantHttpLoad, error)
  • func (r *HttpLoadRepository) GetFixedById(ctx context.Context, id string) (*model.FixedHttpLoad, error)
  • func (r *HttpLoadRepository) GetRampUpById(ctx context.Context, id string) (*model.RampUpHttpLoad, error)
• type JWTRefreshRepository
  • func (r *JWTRefreshRepository) Create(ctx context.Context, jwt *model.JWTRefreshToken) (*model.JWTRefreshToken, error)
  • func (r *JWTRefreshRepository) Delete(ctx context.Context, jwtHash string) error
  • func (r *JWTRefreshRepository) Get(ctx context.Context, hash string) (string, error)
  • func (r *JWTRefreshRepository) GetByJWTHash(ctx context.Context, hash string) (*model.JWTRefreshToken, error)
  • func (r *JWTRefreshRepository) Save(ctx context.Context, userID string, hash string, expires time.Time) error
• type LoadRepository
  • func (r *LoadRepository) Create(ctx context.Context, loadJob *model.LoadJob) (*model.LoadJob, error)
  • func (r *LoadRepository) Delete(ctx context.Context, id string) error
  • func (r *LoadRepository) GetById(ctx context.Context, id string) (*model.LoadJob, error)
• type UserRepository
  • func (r *UserRepository) Create(ctx context.Context, user *model.User) (*model.User, error)
  • func (r *UserRepository) GetByComment(ctx context.Context, comment string) (*model.User, error)
  • func (r *UserRepository) GetByUID(ctx context.Context, uid string) (*model.User, error)

Functions

func NewHttpLoadRepository

func NewHttpLoadRepository(db *pgxpool.Pool) repository.HttpLoadRepository

func NewJWTRefreshRepository

func NewJWTRefreshRepository(db *pgxpool.Pool) repository.JWTRefreshRepository

func NewLoadRepository

func NewLoadRepository(db *pgxpool.Pool) repository.LoadRepository

func NewUserRepository

func NewUserRepository(db *pgxpool.Pool) repository.UserRepository

Types

type HttpLoadRepository

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

func (*HttpLoadRepository) CreateConstant

func (r *HttpLoadRepository) CreateConstant(ctx context.Context, httpLoad *model.ConstantHttpLoad) (*model.ConstantHttpLoad, error)

func (*HttpLoadRepository) CreateFixed

func (r *HttpLoadRepository) CreateFixed(ctx context.Context, httpLoad *model.FixedHttpLoad) (*model.FixedHttpLoad, error)

func (*HttpLoadRepository) CreateRampUp

func (r *HttpLoadRepository) CreateRampUp(ctx context.Context, httpLoad *model.RampUpHttpLoad) (*model.RampUpHttpLoad, error)

func (*HttpLoadRepository) DeleteConstant

func (r *HttpLoadRepository) DeleteConstant(ctx context.Context, id string) error

func (*HttpLoadRepository) DeleteFixed

func (r *HttpLoadRepository) DeleteFixed(ctx context.Context, id string) error

func (*HttpLoadRepository) DeleteRampUp

func (r *HttpLoadRepository) DeleteRampUp(ctx context.Context, id string) error

func (*HttpLoadRepository) GetConstantById

func (r *HttpLoadRepository) GetConstantById(ctx context.Context, id string) (*model.ConstantHttpLoad, error)

func (*HttpLoadRepository) GetFixedById

func (r *HttpLoadRepository) GetFixedById(ctx context.Context, id string) (*model.FixedHttpLoad, error)

func (*HttpLoadRepository) GetRampUpById

func (r *HttpLoadRepository) GetRampUpById(ctx context.Context, id string) (*model.RampUpHttpLoad, error)

type JWTRefreshRepository

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

func (*JWTRefreshRepository) Create

func (r *JWTRefreshRepository) Create(ctx context.Context, jwt *model.JWTRefreshToken) (*model.JWTRefreshToken, error)

func (*JWTRefreshRepository) Delete

func (r *JWTRefreshRepository) Delete(ctx context.Context, jwtHash string) error

func (*JWTRefreshRepository) Get

func (r *JWTRefreshRepository) Get(ctx context.Context, hash string) (string, error)

func (*JWTRefreshRepository) GetByJWTHash

func (r *JWTRefreshRepository) GetByJWTHash(ctx context.Context, hash string) (*model.JWTRefreshToken, error)

func (*JWTRefreshRepository) Save

func (r *JWTRefreshRepository) Save(ctx context.Context, userID string,
	hash string, expires time.Time,
) error

type LoadRepository

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

func (*LoadRepository) Create

func (r *LoadRepository) Create(ctx context.Context, loadJob *model.LoadJob) (*model.LoadJob, error)

func (*LoadRepository) Delete

func (r *LoadRepository) Delete(ctx context.Context, id string) error

func (*LoadRepository) GetById

func (r *LoadRepository) GetById(ctx context.Context, id string) (*model.LoadJob, error)

type UserRepository

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

func (*UserRepository) Create

func (r *UserRepository) Create(ctx context.Context, user *model.User) (*model.User, error)

func (*UserRepository) GetByComment

func (r *UserRepository) GetByComment(ctx context.Context, comment string) (*model.User, error)

func (*UserRepository) GetByUID

func (r *UserRepository) GetByUID(ctx context.Context, uid string) (*model.User, error)