subscriber

Documentation

Index

• type Packet
• type RestRule
• type RuleConfig
• type Subscriber
  • func NewSubscriber(a app.App) *Subscriber
  • func (subscriber *Subscriber) Init() error
  • func (subscriber *Subscriber) InitStateStore() error
  • func (subscriber *Subscriber) LoadConfigFile(filename string) (*RuleConfig, error)
  • func (subscriber *Subscriber) Run() error
• type SubscriptionConfig

Types

type Packet

type Packet struct {
	EventName  string                 `json:"event"`
	Collection string                 `json:"collection"`
	Payload    map[string]interface{} `json:"payload"`
	Meta       map[string]interface{} `json:"meta"`
}

type RestRule

type RestRule struct {
	Method  string            `json:"method"`
	Uri     string            `json:"uri"`
	Headers map[string]string `json:"headers"`
}

type RuleConfig

type RuleConfig struct {
	Subscriptions SubscriptionConfig `json:"subscriptions"`
}

type Subscriber

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

func NewSubscriber

func NewSubscriber(a app.App) *Subscriber

func (*Subscriber) Init

func (subscriber *Subscriber) Init() error

func (*Subscriber) InitStateStore

func (subscriber *Subscriber) InitStateStore() error

func (*Subscriber) LoadConfigFile

func (subscriber *Subscriber) LoadConfigFile(filename string) (*RuleConfig, error)

func (*Subscriber) Run

func (subscriber *Subscriber) Run() error

type SubscriptionConfig

type SubscriptionConfig map[string][]RestRule