storage

Documentation

Index

• Variables
• func HandlePSQLError(err error) error
• type GoPg
  • func NewGoPg() *GoPg
  • func (s *GoPg) GetUser(ctx context.Context, id string) (User, error)
  • func (s *GoPg) GetUsers() ([]User, error)
• type GoPq
  • func NewGoPq() *GoPq
  • func (s *GoPq) GetUser(ctx context.Context, id string) (User, error)
  • func (s *GoPq) GetUsers() ([]User, error)
• type User

Variables

var (
	// ErrAlreadyExists ErrAlreadyExists
	ErrAlreadyExists = errors.New("object already exists")

	// ErrDoesNotExist ErrDoesNotExist
	ErrDoesNotExist = errors.New("object does not exist")

	// ErrQueryIsCanceled ErrQueryIsCanceled
	ErrQueryIsCanceled = errors.New("query is canceled")
)

Functions

func HandlePSQLError

func HandlePSQLError(err error) error

HandlePSQLError handlePSQLError https://github.com/brocaar/lora-app-server/blob/master/internal/storage/errors.go#L41

Types

type GoPg

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

GoPg GoPg

func NewGoPg

func NewGoPg() *GoPg

NewGoPg NewGoPg

func (*GoPg) GetUser

func (s *GoPg) GetUser(ctx context.Context, id string) (User, error)

GetUser GetUser

func (*GoPg) GetUsers

func (s *GoPg) GetUsers() ([]User, error)

GetUsers GetUsers

type GoPq

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

GoPq GoPq

func NewGoPq

func NewGoPq() *GoPq

NewGoPq NewGoPq

func (*GoPq) GetUser

func (s *GoPq) GetUser(ctx context.Context, id string) (User, error)

GetUser GetUser

func (*GoPq) GetUsers

func (s *GoPq) GetUsers() ([]User, error)

GetUsers GetUsers

type User

type User struct {
	ID       string `json:"id"`
	Username string `json:"username"`
	Email    string `json:"email"`
}

User User