server

Documentation

Index

• type Server
  • func NewServer(addr string, qf queue.QueueFactory) (s *Server)
  • func (s *Server) AddService(pp services.PushService, workers int, squash services.SquashConfig) (err error)
  • func (s *Server) CountPush(serviceID string, success bool, duration time.Duration)
  • func (s *Server) ReplaceToken(serviceID, token, replacement string)
  • func (s *Server) Serve() (err error)
  • func (s *Server) Shutdown(ctx context.Context) (err error)
  • func (s *Server) TokenInvalid(serviceID, token string)

Types

type Server

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

Server ...

func NewServer

func NewServer(addr string, qf queue.QueueFactory) (s *Server)

NewServer ...

func (*Server) AddService

func (s *Server) AddService(pp services.PushService, workers int, squash services.SquashConfig) (err error)

AddService ...

func (*Server) CountPush

func (s *Server) CountPush(serviceID string, success bool, duration time.Duration)

CountPush ...

func (*Server) ReplaceToken

func (s *Server) ReplaceToken(serviceID, token, replacement string)

ReplaceToken ...

func (*Server) Serve

func (s *Server) Serve() (err error)

Serve ...

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) (err error)

Shutdown ...

func (*Server) TokenInvalid

func (s *Server) TokenInvalid(serviceID, token string)

TokenInvalid ...