instance

Documentation

Index

• type Mongo
• type MongoCollectionName
• type Prometheus
• type RMQ
• type Redis

Types

type Mongo

type Mongo interface {
	Collection(MongoCollectionName) *mongo.Collection
	Ping(ctx context.Context) error
	RawClient() *mongo.Client
	RawDatabase() *mongo.Database
}

type MongoCollectionName

type MongoCollectionName string

type Prometheus

type Prometheus interface {
	Register(prometheus.Registerer)
	ResponseTimeMilliseconds() prometheus.Histogram
	TwitchChatMessages() prometheus.Histogram
}

type RMQ

type RMQ interface {
	Publish(queueName string, msg amqp.Publishing) error
	Consume(queueName string, consumer string) (*amqp.Channel, <-chan amqp.Delivery, error)
}

type Redis

type Redis interface {
	Ping(ctx context.Context) error
	Subscribe(ctx context.Context, ch chan string, subscribeTo ...string)
	Get(ctx context.Context, key string) (interface{}, error)
	SetEX(ctx context.Context, key string, value interface{}, ttl time.Duration) error
	SetNX(ctx context.Context, key string, value interface{}, ttl time.Duration) (bool, error)
	Pipeline(ctx context.Context) redis.Pipeliner
}