smsender

Documentation

Index

• type Sender
  • func NewSender() *Sender
  • func (s *Sender) GetMessagesByIds(ids []string) ([]*model.Message, error)
  • func (s *Sender) GetMessagesChannel() chan *model.MessageJob
  • func (s *Sender) GetSiteURL() *url.URL
  • func (s *Sender) InitWebhooks()
  • func (s *Sender) InitWorkers()
  • func (s *Sender) IsShutdown() bool
  • func (s *Sender) Run()
  • func (s *Sender) RunHTTPServer()
  • func (s *Sender) SearchMessages(params map[string]interface{}) ([]*model.Message, error)
  • func (s *Sender) Shutdown()

Types

type Sender

type Sender struct {
	Router *router.Router
	// HTTP server router
	HTTPRouter *mux.Router
	// contains filtered or unexported fields
}

func NewSender

func NewSender() *Sender

NewSender creates Sender.

func (*Sender) GetMessagesByIds

func (s *Sender) GetMessagesByIds(ids []string) ([]*model.Message, error)

func (*Sender) GetMessagesChannel

func (s *Sender) GetMessagesChannel() chan *model.MessageJob

func (*Sender) GetSiteURL

func (s *Sender) GetSiteURL() *url.URL

func (*Sender) InitWebhooks

func (s *Sender) InitWebhooks()

InitWebhooks initializes the webhooks.

func (*Sender) InitWorkers

func (s *Sender) InitWorkers()

InitWorkers initializes the message workers.

func (*Sender) IsShutdown

func (s *Sender) IsShutdown() bool

IsShutdown returns true if the server is currently shutting down.

func (*Sender) Run

func (s *Sender) Run()

Run performs all startup actions.

func (*Sender) RunHTTPServer

func (s *Sender) RunHTTPServer()

RunHTTPServer starts the HTTP server.

func (*Sender) SearchMessages

func (s *Sender) SearchMessages(params map[string]interface{}) ([]*model.Message, error)

func (*Sender) Shutdown

func (s *Sender) Shutdown()

Shutdown sets shutdown flag and stops all workers.