cache

Documentation

Index

• func GetAwsSession() *session.Session
• func GetCron() *cron.Cron
• func GetDiscord() *discordgo.Session
• func GetEDiscord(botID string) *discordgo.Session
• func GetEDiscordGateway(botID string) *discordgo.Session
• func GetHealthchecksIO() *healthchecksio.Client
• func GetKafkaConsumer() sarama.Consumer
• func GetKafkaConsumerGroup() *consumergroup.ConsumerGroup
• func GetKafkaProducer() sarama.SyncProducer
• func GetLastFm() *lastfm.Api
• func GetLocalizationBundle() *i18n.Bundle
• func GetLogger() *logrus.Entry
• func GetMinio() *minio.Client
• func GetMongo() *mongo.Database
• func GetRedisClient() *redis.Client
• func GetTracer() opentracing.Tracer
• func HasLogger() bool
• func SetAwsSession(s *session.Session)
• func SetCron(s *cron.Cron)
• func SetDiscord(s *discordgo.Session)
• func SetHealthchecksIO(c *healthchecksio.Client)
• func SetKafkaConsumer(s sarama.Consumer)
• func SetKafkaConsumerGroup(s *consumergroup.ConsumerGroup)
• func SetKafkaProducer(s sarama.SyncProducer)
• func SetLastfFm(s *lastfm.Api)
• func SetLocalizationBundle(s *i18n.Bundle)
• func SetLogger(s *logrus.Entry)
• func SetMinio(s *minio.Client)
• func SetMongo(c *mongo.Database)
• func SetRedisClient(s *redis.Client)
• func SetTracer(s opentracing.Tracer)

Functions

func GetAwsSession

func GetAwsSession() *session.Session

GetAwsSession returns a cached aws session

func GetCron

func GetCron() *cron.Cron

GetCron returns a cached cron handler

func GetDiscord

func GetDiscord() *discordgo.Session

GetDiscord returns a cached discordgo session

func GetEDiscord

func GetEDiscord(botID string) *discordgo.Session

GetEDiscord gets or create a discord session for an Event reads the discord bot token from DISCORD_BOT_TOKEN_<bot user id>

func GetEDiscordGateway

func GetEDiscordGateway(botID string) *discordgo.Session

GetEDiscordGateway gets or create a discord session for an Event, and opens a new gateway for it Should only be used for testing!!! (normally we receive events from the Gateway process) reads the discord bot token from DISCORD_BOT_TOKEN_<bot user id>

func GetHealthchecksIO

func GetHealthchecksIO() *healthchecksio.Client

GetHealthchecksIO returns a cached healthchecks.io client

func GetKafkaConsumer

func GetKafkaConsumer() sarama.Consumer

GetKafkaConsumer returns a cached Kafka Consumer client

func GetKafkaConsumerGroup

func GetKafkaConsumerGroup() *consumergroup.ConsumerGroup

GetKafkaConsumerGroup returns a cached Kafka Consumer Group client

func GetKafkaProducer

func GetKafkaProducer() sarama.SyncProducer

GetKafkaProducer returns a cached Kafka Producer client

func GetLastFm

func GetLastFm() *lastfm.Api

GetLastFm returns a cached lastfm client

func GetLocalizationBundle

func GetLocalizationBundle() *i18n.Bundle

GetLocalizationBundle returns a cached localization bundle

func GetLogger

func GetLogger() *logrus.Entry

GetLogger returns a cached logrus entry

func GetMinio

func GetMinio() *minio.Client

GetMinio returns a cached minio client

func GetMongo

func GetMongo() *mongo.Database

GetMongo returns a cached MongoDB Client

func GetRedisClient

func GetRedisClient() *redis.Client

GetRedisClient returns a cached redis client

func GetTracer

func GetTracer() opentracing.Tracer

GetTracer returns a cached tracer

func HasLogger

func HasLogger() bool

HasLogger returns true if we have a logger cached

func SetAwsSession

func SetAwsSession(s *session.Session)

SetAwsSession caches an aws session for future use

func SetCron

func SetCron(s *cron.Cron)

SetCron caches a cron handler for future use

func SetDiscord

func SetDiscord(s *discordgo.Session)

SetDiscord caches a discordgo session for future use

func SetHealthchecksIO

func SetHealthchecksIO(c *healthchecksio.Client)

SetHealthchecksIO caches an healthchecks.io client for future use

func SetKafkaConsumer

func SetKafkaConsumer(s sarama.Consumer)

SetKafkaConsumer caches a Kafka Consumer client for future use

func SetKafkaConsumerGroup

func SetKafkaConsumerGroup(s *consumergroup.ConsumerGroup)

SetKafkaConsumerGroup caches a Kafka Consumer Group clieent for future use

func SetKafkaProducer

func SetKafkaProducer(s sarama.SyncProducer)

SetKafkaProducer caches a Kafka Producer client for future use

func SetLastfFm

func SetLastfFm(s *lastfm.Api)

SetLastfFm caches a lastfm client for future use

func SetLocalizationBundle

func SetLocalizationBundle(s *i18n.Bundle)

SetLocalizationBundle caches a localization bundle for future use

func SetLogger

func SetLogger(s *logrus.Entry)

SetLogger caches a logrus entry for future use

func SetMinio

func SetMinio(s *minio.Client)

SetMinio caches a minio client for future use

func SetMongo

func SetMongo(c *mongo.Database)

SetMongo caches a MongoDB Client for future use

func SetRedisClient

func SetRedisClient(s *redis.Client)

SetRedisClient caches a redis client for future use

func SetTracer

func SetTracer(s opentracing.Tracer)

SetTracer caches a tracer for future use