interfaces

type APNSPushQueue interface {
	ResponseChannel() chan *structs.ResponseWithMetadata
	Configure() error
	Push(*apns2.Notification)
	Close()
}

type DB interface {
	Exec(interface{}, ...interface{}) (*types.Result, error)
	ExecOne(interface{}, ...interface{}) (*types.Result, error)
	Query(interface{}, interface{}, ...interface{}) (*types.Result, error)
	Close() error
}

type FeedbackReporter interface {
	SendFeedback(game string, platform string, feedback []byte)
}

type GCMClient interface {
	SendXMPP(gcm.XMPPMessage) (string, int, error)
	Close() error
}

type InvalidTokenHandler interface {
	HandleToken(token string, game string, platform string) error
}

type KafkaConsumerClient interface {
	SubscribeTopics([]string, kafka.RebalanceCb) error
	Events() chan kafka.Event
	Assign([]kafka.TopicPartition) error
	Unassign() error
	Close() error
}

type KafkaMessage struct {
	Game  string
	Topic string
	Value []byte
}

type KafkaProducerClient interface {
	Events() chan kafka.Event
	ProduceChannel() chan *kafka.Message
}

type MessageHandler interface {
	HandleMessages(msg KafkaMessage)
	HandleResponses()
	LogStats()
	CleanMetadataCache()
}

type Queue interface {
	MessagesChannel() *chan KafkaMessage
	ConsumeLoop() error
	StopConsuming()
	PendingMessagesWaitGroup() *sync.WaitGroup
}

type StatsDClient interface {
	Incr(string, []string, float64) error
	Gauge(string, float64, []string, float64) error
	Count(string, int64, []string, float64) error
	Timing(string, time.Duration, []string, float64) error
	Close() error
}

type StatsReporter interface {
	InitializeFailure(game string, platform string)
	HandleNotificationSent(game string, platform string)
	HandleNotificationSuccess(game string, platform string)
	HandleNotificationFailure(game string, platform string, err *errors.PushError)
	ReportGoStats(numGoRoutines int, allocatedAndNotFreed, heapObjects, nextGCBytes, pauseGCNano uint64)
	ReportMetricGauge(metric string, value float64, game string, platform string)
	ReportMetricCount(metric string, value int64, game string, platform string)
}