service

Documentation

Index

• func Health(c echo.Context) error
• type Auth
  • func NewAuth(key string) *Auth
  • func (auth *Auth) Middleware() echo.MiddlewareFunc
  • func (auth *Auth) Validate(key string, c echo.Context) (bool, error)
• type Message
• type Server
  • func (s *Server) Start(addr string) error
• type Service
  • func New(cap uint, subscriber string) *Service
  • func (s *Service) ForwardMessages()
  • func (s *Service) HandleConsumerResponse(resp *http.Response, err error, sleeper *retry.Sleeper)
  • func (s *Service) SendMessage() (*http.Response, error)
  • func (s *Service) Server(auth *Auth) *Server
  • func (s *Service) StoreMessage(c echo.Context) error

Functions

func Health

func Health(c echo.Context) error

Types

type Auth

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

func NewAuth

func NewAuth(key string) *Auth

func (*Auth) Middleware

func (auth *Auth) Middleware() echo.MiddlewareFunc

func (*Auth) Validate

func (auth *Auth) Validate(key string, c echo.Context) (bool, error)

type Message

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

type Server

type Server struct {
	*Service
	*echo.Echo
}

func (*Server) Start

func (s *Server) Start(addr string) error

type Service

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

func New

func New(cap uint, subscriber string) *Service

func (*Service) ForwardMessages

func (s *Service) ForwardMessages()

func (*Service) HandleConsumerResponse

func (s *Service) HandleConsumerResponse(
	resp *http.Response,
	err error,
	sleeper *retry.Sleeper,
)

func (*Service) SendMessage

func (s *Service) SendMessage() (*http.Response, error)

func (*Service) Server

func (s *Service) Server(auth *Auth) *Server

func (*Service) StoreMessage

func (s *Service) StoreMessage(c echo.Context) error