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)

	CurrentStreamCount() prometheus.Gauge
	TotalStreamDurationSeconds() prometheus.Histogram
}

type RMQ

type RMQ interface {
	Publish(queueName string, msg amqp.Publishing) error
}

type Redis

type Redis interface {
	Ping(ctx context.Context) error
	Get(ctx context.Context, key string) (interface{}, error)
	Subscribe(ctx context.Context, ch chan string, subscribeTo ...string)
	Publish(ctx context.Context, channel string, content string) error
	SetNX(ctx context.Context, key string, value string, ttl time.Duration) (bool, error)
	SetEX(ctx context.Context, key string, value string, ttl time.Duration) error
	Expire(ctx context.Context, key string, ttl time.Duration) error
	Del(ctx context.Context, key string) error
}