apns

Documentation

Index

• func MakePushEndpoint(svc Service) endpoint.Endpoint
• func MarshalPushInfo(p *PushInfo) ([]byte, error)
• func NewPushService(provider PushCertificateProvider) (*push.Service, error)
• func RegisterHTTPHandlers(r *mux.Router, e Endpoints, options ...httptransport.ServerOption)
• func UnmarshalPushInfo(data []byte, p *PushInfo) error
• type Endpoints
  • func MakeServerEndpoints(s Service, outer endpoint.Middleware, others ...endpoint.Middleware) Endpoints
• type Middleware
  • func LoggingMiddleware(logger log.Logger) Middleware
• type Option
  • func WithPushService(svc *push.Service) Option
• type PushCertificateProvider
• type PushInfo
• type PushOption
  • func WithExpiration(t time.Time) PushOption
• type PushService
  • func New(db Store, provider PushCertificateProvider, sub pubsub.Subscriber, ...) (*PushService, error)
  • func (svc *PushService) Push(ctx context.Context, deviceUDID string, opts ...PushOption) (string, error)
• type Service
• type Store
• type Worker
  • func NewWorker(db WorkerStore, subscriber pubsub.Subscriber, logger log.Logger) *Worker
  • func (w *Worker) Run(ctx context.Context) error
• type WorkerStore

Functions

func MakePushEndpoint

func MakePushEndpoint(svc Service) endpoint.Endpoint

func MarshalPushInfo

func MarshalPushInfo(p *PushInfo) ([]byte, error)

func NewPushService

func NewPushService(provider PushCertificateProvider) (*push.Service, error)

func RegisterHTTPHandlers

func RegisterHTTPHandlers(r *mux.Router, e Endpoints, options ...httptransport.ServerOption)

func UnmarshalPushInfo

func UnmarshalPushInfo(data []byte, p *PushInfo) error

Types

type Endpoints

type Endpoints struct {
	PushEndpoint endpoint.Endpoint
}

func MakeServerEndpoints

func MakeServerEndpoints(s Service, outer endpoint.Middleware, others ...endpoint.Middleware) Endpoints

type Middleware

type Middleware func(Service) Service

func LoggingMiddleware

func LoggingMiddleware(logger log.Logger) Middleware

type Option

type Option func(*PushService)

func WithPushService

func WithPushService(svc *push.Service) Option

type PushCertificateProvider

type PushCertificateProvider interface {
	PushCertificate() (*tls.Certificate, error)
}

type PushInfo

type PushInfo struct {
	UDID      string `db:"udid"`
	PushMagic string `db:"push_magic"`
	Token     string `db:"token"`
	MDMTopic  string `db:"mdm_topic"`
}

type PushOption

type PushOption func(*pushOpts)

PushOption adds optional parameters to the Push method.

func WithExpiration

func WithExpiration(t time.Time) PushOption

WithExpiration sets the expiration of the APNS message. Apple will retry delivery until this time. The default behavior only tries once.

type PushService

type PushService struct {
	// contains filtered or unexported fields
}

func New

func New(db Store, provider PushCertificateProvider, sub pubsub.Subscriber, opts ...Option) (*PushService, error)

func (*PushService) Push

func (svc *PushService) Push(ctx context.Context, deviceUDID string, opts ...PushOption) (string, error)

type Service

type Service interface {
	Push(ctx context.Context, udid string, opts ...PushOption) (string, error)
}

type Store

type Store interface {
	PushInfo(ctx context.Context, udid string) (*PushInfo, error)
}

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(db WorkerStore, subscriber pubsub.Subscriber, logger log.Logger) *Worker

func (*Worker) Run

func (w *Worker) Run(ctx context.Context) error

type WorkerStore

type WorkerStore interface {
	Save(context.Context, *PushInfo) error
}