webhook

Documentation

Index

• Constants
• type Acknowledger
  • func NewAcknowledger(writer http.ResponseWriter) *Acknowledger
  • func (a *Acknowledger) Ack() error
  • func (a *Acknowledger) Done() <-chan any
  • func (a *Acknowledger) Nack(opts messages.NackOpts) error
• type Opt
  • func WithLogger(logger *slog.Logger) Opt
• type Server
  • func NewServer(port int, opts ...Opt) *Server
  • func (s *Server) Close() error
  • func (s *Server) Consume() (<-chan messages.Message, error)

Constants

const (
	MessageProcessingTimeout = 10 * time.Second
)

Types

type Acknowledger

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

func NewAcknowledger

func NewAcknowledger(writer http.ResponseWriter) *Acknowledger

func (*Acknowledger) Ack

func (a *Acknowledger) Ack() error

func (*Acknowledger) Done

func (a *Acknowledger) Done() <-chan any

func (*Acknowledger) Nack

func (a *Acknowledger) Nack(opts messages.NackOpts) error

type Opt

type Opt func(server *Server)

func WithLogger

func WithLogger(logger *slog.Logger) Opt

type Server

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

func NewServer

func NewServer(port int, opts ...Opt) *Server

func (*Server) Close

func (s *Server) Close() error

func (*Server) Consume

func (s *Server) Consume() (<-chan messages.Message, error)