aggtrigger

Documentation

Index

• func NewTrigger(conf map[string]interface{}) (trigger.Trigger, error)
• type Config
• type OnDiskAggTrigger
  • func (s *OnDiskAggTrigger) Fire(keyPath string, records []trigger.Record)

Functions

func NewTrigger

func NewTrigger(conf map[string]interface{}) (trigger.Trigger, error)

NewTrigger returns a new on-disk aggregate trigger based on the configuration.

Types

type Config

type Config struct {
	Destinations []string `json:"destinations"`
	Filter       string   `json:"filter"`
}

Config is the configuration for OnDiskAggTrigger you can define in marketstore's config file under triggers extension.

type OnDiskAggTrigger

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

OnDiskAggTrigger is the main trigger.

func (*OnDiskAggTrigger) Fire

func (s *OnDiskAggTrigger) Fire(keyPath string, records []trigger.Record)

Fire implements trigger interface.