nats

Documentation

Index

• type Queue
  • func New(url string, enabled bool) (*Queue, error)
  • func (p *Queue) Publish(event *queue.Event) error
  • func (p *Queue) Subscribe(ctx context.Context) (<-chan *queue.Event, error)

Types

type Queue

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

func New

func New(url string, enabled bool) (*Queue, error)

func (*Queue) Publish

func (p *Queue) Publish(event *queue.Event) error

func (*Queue) Subscribe

func (p *Queue) Subscribe(ctx context.Context) (<-chan *queue.Event, error)