extensions

type APNSMessageHandler struct {
	StatsReporters []interfaces.StatsReporter

	PushQueue interfaces.APNSPushQueue
	Topic     string
	Config    *viper.Viper

	InflightMessagesMetadata map[string]interface{}
	Logger                   *log.Logger
	LogStatsInterval         time.Duration

	CacheCleaningInterval int
	IsProduction          bool
	// contains filtered or unexported fields
}

type APNSPushQueue struct {
	Logger *log.Logger
	Config *viper.Viper

	IsProduction bool
	Closed       bool
	// contains filtered or unexported fields
}

type CCSMessageWithMetadata struct {
	gcm.CCSMessage
	Timestamp int64                  `json:"timestamp"`
	Metadata  map[string]interface{} `json:"metadata,omitempty"`
}

type GCMMessageHandler struct {
	StatsReporters []interfaces.StatsReporter

	GCMClient interfaces.GCMClient

	Config *viper.Viper

	InflightMessagesMetadata map[string]interface{}
	Logger                   *log.Entry
	LogStatsInterval         time.Duration

	PingInterval int
	PingTimeout  int

	CacheCleaningInterval int
	IsProduction          bool
	// contains filtered or unexported fields
}

type KafkaConsumer struct {
	Topics              []string
	Brokers             string
	Consumer            interfaces.KafkaConsumerClient
	ConsumerGroup       string
	OffsetResetStrategy string
	Config              *viper.Viper
	ChannelSize         int
	Logger              *logrus.Logger
	FetchMinBytes       int
	FetchWaitMaxMs      int

	SessionTimeout int

	HandleAllMessagesBeforeExiting bool
	// contains filtered or unexported fields
}

type KafkaGCMMessage struct {
	gcm.XMPPMessage
	Metadata   map[string]interface{} `json:"metadata,omitempty"`
	PushExpiry int64                  `json:"push_expiry,omitempty"`
}

type KafkaProducer struct {
	Brokers   string
	Config    *viper.Viper
	Producer  interfaces.KafkaProducerClient
	BatchSize int
	LingerMs  int
	Logger    *log.Logger
	Topic     string
}

type Notification struct {
	DeviceToken string
	Payload     interface{}
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
	PushExpiry  int64                  `json:"push_expiry,omitempty"`
	CollapseID  string                 `json:"collapse_id,omitempty"`
}

type PGClient struct {
	Config  *viper.Viper
	DB      interfaces.DB
	Options *pg.Options
}

type ParsedTopic struct {
	Platform string
	Game     string
}

type StatsD struct {
	Client interfaces.StatsDClient
	Config *viper.Viper
	Logger *logrus.Logger
}

type TimeoutHeap []*timeoutNode