subscribe

Documentation

Index

• type Subscribe
  • func ParseSubscribeHandler(d *caddyfile.Dispenser) (*Subscribe, error)
  • func (Subscribe) CaddyModule() caddy.ModuleInfo
  • func (s *Subscribe) Provision(ctx caddy.Context) error
  • func (s *Subscribe) Subscribe(conn *nats.Conn) error
  • func (s *Subscribe) Unsubscribe(conn *nats.Conn) error

Types

type Subscribe

type Subscribe struct {
	Subject    string `json:"subject,omitempty"`
	Method     string `json:"method,omitempty"`
	URL        string `json:"path,omitempty"`
	QueueGroup string `json:"queue_group,omitempty"`
	// contains filtered or unexported fields
}

func ParseSubscribeHandler

func ParseSubscribeHandler(d *caddyfile.Dispenser) (*Subscribe, error)

ParseSubscribeHandler parses the subscribe directive. Syntax:

subscribe subjectPattern HTTPMethod HTTPURL {
    [queue queueGroupName]
}

func (Subscribe) CaddyModule

func (Subscribe) CaddyModule() caddy.ModuleInfo

func (*Subscribe) Provision

func (s *Subscribe) Provision(ctx caddy.Context) error

func (*Subscribe) Subscribe

func (s *Subscribe) Subscribe(conn *nats.Conn) error

func (*Subscribe) Unsubscribe

func (s *Subscribe) Unsubscribe(conn *nats.Conn) error