feedback

Jan 26, 2017

Changes in this version

+ const APNS

+ const GCM

+ func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration) bool

+ type Handler struct

+ Config *viper.Viper

+ FeedbackCache map[string]map[string]int

+ FlushInterval time.Duration

+ Logger zap.Logger

+ MarathonDB *extensions.PGClient

+ func NewHandler(config *viper.Viper, logger zap.Logger, pendingMessagesWG *sync.WaitGroup, ...) (*Handler, error)

+ func (h *Handler) HandleMessages(msgChan *chan []byte)

+ type Listener struct

+ Config *viper.Viper

+ ConfigFile string

+ FeedbackHandler *Handler

+ GracefulShutdownTimeout int

+ Logger zap.Logger

+ PendingMessagesWG *sync.WaitGroup

+ Queue interfaces.Queue

+ func NewListener(configFile string, logger zap.Logger) (*Listener, error)

+ func (l *Listener) Start()

+ type Message struct

+ DeviceToken string

+ Err map[string]interface{}

+ Error string

+ ErrorDescription string

+ From string

+ ID string

+ MessageID string

+ MessageType string

+ Metadata map[string]interface{}