events

Documentation

Index

• type Consumer
  • func NewConsumer(d config.Distributor, nc *nats.Conn, ctx context.Context) (c *Consumer, err error)
  • func (c *Consumer) Subscribe(ctx context.Context)
• type DispatchError
  • func (d *DispatchError) Error() string
• type Publisher
  • func NewPublisher(nc *nats.Conn) (p *Publisher, err error)
• type Webhook
• type WebhookBody

Types

type Consumer

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

func NewConsumer

func NewConsumer(d config.Distributor, nc *nats.Conn, ctx context.Context) (c *Consumer, err error)

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(ctx context.Context)

type DispatchError

type DispatchError struct {
	StatusCode int
	Err        error
}

func (*DispatchError) Error

func (d *DispatchError) Error() string

type Publisher

type Publisher struct {
	Router *mux.Router
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(nc *nats.Conn) (p *Publisher, err error)

type Webhook

type Webhook struct {
	Router    *mux.Router
	Publisher *Publisher
}

type WebhookBody

type WebhookBody struct {
	Event     string
	Timestamp string
	Model     string
	Username  string
	Data      data
	Snapshots snapshot `json:"snapshots"`
}