persistence

Documentation

Index

• Variables
• func GetS3Client() *s3.S3
• func GetS3Uploader() *s3manager.Uploader
• func InitStatsd(port, namespace string) (*statsd.Client, error)
• func MaybeSendStatsdGauge(name string, value float64, tags []string, rate float64) error
• func MaybeSendStatsdTiming(name string, value time.Duration, tags []string, rate float64) error
• func MustGetPGSession() *sql.DB
• func PrunePG(pg *sql.DB, pruneDuration time.Duration) (int, int, error)
• func Statsd() *statsd.Client

Variables

var DB *sql.DB

var (
	StatsdClientNotInitialized = errors.New("statsd client not initialized")
)

Functions

func GetS3Client

func GetS3Client() *s3.S3

func GetS3Uploader

func GetS3Uploader() *s3manager.Uploader

func InitStatsd

func InitStatsd(port, namespace string) (*statsd.Client, error)

func MaybeSendStatsdGauge

func MaybeSendStatsdGauge(name string, value float64, tags []string, rate float64) error

func MaybeSendStatsdTiming

func MaybeSendStatsdTiming(name string, value time.Duration, tags []string, rate float64) error

func MustGetPGSession

func MustGetPGSession() *sql.DB

func PrunePG

func PrunePG(pg *sql.DB, pruneDuration time.Duration) (int, int, error)

func Statsd

func Statsd() *statsd.Client