apns

Documentation

Index

• Variables
• func New(router router.Router, sender connector.Sender, config Config, ...) (connector.ResponsiveConnector, error)
• func NewSender(config Config) (connector.Sender, error)
• func NewSenderUsingPusher(pusher Pusher, appTopic string) (connector.Sender, error)
• type ApnsEvent
• type Aps
• type Config
• type Payload
• type Pusher

Variables

var (
	ErrRetryFailed = errors.New("Retry failed")
)

Functions

func New

func New(router router.Router, sender connector.Sender, config Config, kafkaProducer kafka.Producer, subUnsubKafkaReportingTopic, apnsKafkaReportingTopic string) (connector.ResponsiveConnector, error)

New creates a new connector.ResponsiveConnector without starting it

func NewSender

func NewSender(config Config) (connector.Sender, error)

func NewSenderUsingPusher

func NewSenderUsingPusher(pusher Pusher, appTopic string) (connector.Sender, error)

Types

type ApnsEvent

type ApnsEvent struct {
	ID      string                 `json:"id"`
	Time    string                 `json:"time"`
	Type    string                 `json:"type"`
	Payload kafka.PushEventPayload `json:"payload"`
}

type Aps

type Aps struct {
	Alert            interface{} `json:"alert,omitempty"`
	Badge            interface{} `json:"badge,omitempty"`
	Category         string      `json:"category,omitempty"`
	ContentAvailable int         `json:"content-available,omitempty"`
	MutableContent   int         `json:"mutable-content,omitempty"`
	Sound            string      `json:"sound,omitempty"`
	ThreadID         string      `json:"thread-id,omitempty"`
	URLArgs          []string    `json:"url-args,omitempty"`
}

type Config

type Config struct {
	Enabled             *bool
	Production          *bool
	CertificateFileName *string
	CertificateBytes    *[]byte
	CertificatePassword *string
	AppTopic            *string
	Workers             *int
	Prefix              *string
	IntervalMetrics     *bool
}

Config is used for configuring the APNS module.

type Payload

type Payload struct {
	Deeplink string `json:"deeplink"`
	Topic    string `json:"topic"`
	Aps      Aps    `json:"aps"`
}

This is a copy of the apns2 format in order to decapsulate the data from the gobbler message.

type Pusher

type Pusher interface {
	Push(*apns2.Notification) (*apns2.Response, error)
}