apns

Documentation

Index

• func MakeHTTPHandler(e Endpoints, logger log.Logger) *mux.Router
• func MakePushEndpoint(svc Service) endpoint.Endpoint
• func MarshalPushInfo(p *PushInfo) ([]byte, error)
• func NewPushService(provider PushCertificateProvider) (*push.Service, error)
• func UnmarshalPushInfo(data []byte, p *PushInfo) error
• type Endpoints
  • func MakeServerEndpoints(s Service) Endpoints
• type Middleware
  • func LoggingMiddleware(logger log.Logger) Middleware
• type Option
  • func WithPushService(svc *push.Service) Option
• type PushCertificateProvider
• type PushInfo
• type PushService
  • func New(db Store, provider PushCertificateProvider, sub pubsub.Subscriber, ...) (*PushService, error)
  • func (svc *PushService) Push(ctx context.Context, deviceUDID string) (string, error)
• type Service
• type Store

Functions

func MakeHTTPHandler

func MakeHTTPHandler(e Endpoints, logger log.Logger) *mux.Router

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 UnmarshalPushInfo

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

Types

type Endpoints

type Endpoints struct {
	PushEndpoint endpoint.Endpoint
}

func MakeServerEndpoints

func MakeServerEndpoints(s Service) 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
	PushMagic string
	Token     string
	MDMTopic  string
}

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) (string, error)

type Service

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

type Store

type Store interface {
	PushInfo(udid string) (*PushInfo, error)
}