util

Documentation

Index

• Constants
• func GetContextWithThisTimeout(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc)
• func GetContextWithTimeout(ctx context.Context) (context.Context, context.CancelFunc)
• func QuoteBytes(buf []byte) string
• func QuoteString(str string) string
• func RandomString(n int) string
• func SanitizeSQL(sql string, args ...interface{}) (string, error)
• func SendNotification(ctx context.Context, projectId string, topic string, data map[string]string) error
• func WriteError(w http.ResponseWriter, statusCode int, errorMessage string)
• func WriteInternalServerError(w http.ResponseWriter)
• func WriteJson(w http.ResponseWriter, res interface{})
• func WriteOK(w http.ResponseWriter)
• func WriteStatus(w http.ResponseWriter, statusCode int)
• func WriteUnauthorized(w http.ResponseWriter)
• type DatabaseLogger
  • func (d *DatabaseLogger) Log(ctx context.Context, level pgx.LogLevel, msg string, ...)
• type Part
• type Query
  • func NewQuery(sql string) (*Query, error)
  • func (q *Query) Sanitize(args ...interface{}) (string, error)
• type Result

Constants

const (
	CONTEXT_TIMEOUT = 5 * time.Second
)

Functions

func GetContextWithThisTimeout

func GetContextWithThisTimeout(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

func GetContextWithTimeout

func GetContextWithTimeout(ctx context.Context) (context.Context, context.CancelFunc)

func QuoteBytes

func QuoteBytes(buf []byte) string

func QuoteString

func QuoteString(str string) string

func RandomString

func RandomString(n int) string

func SanitizeSQL

func SanitizeSQL(sql string, args ...interface{}) (string, error)

SanitizeSQL replaces placeholder values with args. It quotes and escapes args as necessary. This function is only safe when standard_conforming_strings is on.

func SendNotification

func SendNotification(
	ctx context.Context,
	projectId string,
	topic string,
	data map[string]string,
) error

func WriteError

func WriteError(w http.ResponseWriter, statusCode int, errorMessage string)

func WriteInternalServerError

func WriteInternalServerError(w http.ResponseWriter)

func WriteJson

func WriteJson(w http.ResponseWriter, res interface{})

func WriteOK

func WriteOK(w http.ResponseWriter)

func WriteStatus

func WriteStatus(w http.ResponseWriter, statusCode int)

func WriteUnauthorized

func WriteUnauthorized(w http.ResponseWriter)

Types

type DatabaseLogger

type DatabaseLogger struct{}

func (*DatabaseLogger) Log

func (d *DatabaseLogger) Log(ctx context.Context, level pgx.LogLevel, msg string, data map[string]interface{})

type Part

type Part interface{}

Part is either a string or an int. A string is raw SQL. An int is a argument placeholder.

type Query

type Query struct {
	Parts []Part
}

func NewQuery

func NewQuery(sql string) (*Query, error)

func (*Query) Sanitize

func (q *Query) Sanitize(args ...interface{}) (string, error)

type Result

type Result struct {
	Ok     bool         `json:"ok"`
	Err    *string      `json:"error,omitempty"`
	Result *interface{} `json:"result,omitempty"`
}