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)

	CurrentJobCount() prometheus.Gauge
	TotalJobDurationSeconds() 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)
}