webhook

Documentation

Index

• Variables
• type Consumer
  • func NewConsumer(nc *nats.Conn, opts ...ConsumerOpt) *Consumer
  • func (c *Consumer) Start(ctx context.Context) error
• type ConsumerOpt
  • func WithHTTPClient(client *http.Client) ConsumerOpt

Variables

var (
	ErrInvalidWebhookURL = errors.New("invalid webhook url")
)

Types

type Consumer

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

func NewConsumer

func NewConsumer(nc *nats.Conn, opts ...ConsumerOpt) *Consumer

func (*Consumer) Start

func (c *Consumer) Start(ctx context.Context) error

type ConsumerOpt

type ConsumerOpt func(c *Consumer)

func WithHTTPClient

func WithHTTPClient(client *http.Client) ConsumerOpt