eventsubscribers

Documentation

Index

• func DatabaseChecker(connection Pingable) healthcheck.CheckerFunc
• func MojangApiTexturesProviderResponseChecker(dispatcher Subscriber, resetDuration time.Duration) healthcheck.CheckerFunc
• func MojangBatchUuidsProviderQueueLengthChecker(dispatcher Subscriber, maxLength int) healthcheck.CheckerFunc
• func MojangBatchUuidsProviderResponseChecker(dispatcher Subscriber, resetDuration time.Duration) healthcheck.CheckerFunc
• type Logger
  • func (l *Logger) ConfigureWithDispatcher(d Subscriber)
• type Pingable
• type Reporter
• type ReporterFunc
  • func (f ReporterFunc) Enable(reporter slf.StatsReporter)
• type StatsReporter
  • func (s *StatsReporter) ConfigureWithDispatcher(d Subscriber)
• type Subscriber

Functions

func DatabaseChecker

func DatabaseChecker(connection Pingable) healthcheck.CheckerFunc

func MojangApiTexturesProviderResponseChecker

func MojangApiTexturesProviderResponseChecker(dispatcher Subscriber, resetDuration time.Duration) healthcheck.CheckerFunc

func MojangBatchUuidsProviderQueueLengthChecker

func MojangBatchUuidsProviderQueueLengthChecker(dispatcher Subscriber, maxLength int) healthcheck.CheckerFunc

func MojangBatchUuidsProviderResponseChecker

func MojangBatchUuidsProviderResponseChecker(dispatcher Subscriber, resetDuration time.Duration) healthcheck.CheckerFunc

Types

type Logger

type Logger struct {
	slf.Logger
}

func (*Logger) ConfigureWithDispatcher

func (l *Logger) ConfigureWithDispatcher(d Subscriber)

type Pingable

type Pingable interface {
	Ping() error
}

type Reporter

type Reporter interface {
	Enable(reporter slf.StatsReporter)
}

type ReporterFunc

type ReporterFunc func(reporter slf.StatsReporter)

func (ReporterFunc) Enable

func (f ReporterFunc) Enable(reporter slf.StatsReporter)

type StatsReporter

type StatsReporter struct {
	slf.StatsReporter
	Prefix string
	// contains filtered or unexported fields
}

func (*StatsReporter) ConfigureWithDispatcher

func (s *StatsReporter) ConfigureWithDispatcher(d Subscriber)

TODO: rework all reporters in the same style as it was there: https://github.com/elyby/chrly/blob/1543e98b/di/db.go#L48-L52

type Subscriber

type Subscriber interface {
	dispatcher.Subscriber
}