batch_processor

Documentation

Index

• Constants
• Variables
• func RandName() string
• func StoreAdd(key string, v interface{})
• func StoreDel(key string)
• type Event
• type Processor
  • func NewProcessor() *Processor
  • func (p *Processor) Add(notification string, event interface{})
  • func (p *Processor) AddAfter(notification string, t time.Duration, event interface{})
  • func (p *Processor) Run()

Constants

const (
	CREATE_PORT        = "create-port"
	REMOVE_PORT        = "remove-port"
	CREATE_PROTOCOL    = "create-protocol"
	REMOVE_PROTOCOL    = "remove-protocol"
	CREATE_RICH        = "create-richRule"
	CREATE_FORWARD     = "create-forward"
	CREATE_SERVICE     = "create-service"
	ENABLE_MASQUERADE  = "enable-masquerade"
	DISABLE_MASQUERADE = "disable-masquerade"
	RELOAD_FIREWALD    = "reload"
	FLUSH_SETTING      = "flush"
	SET_DEFAULT_ZONE   = "set-default-zone"
	DiscoverHost       = "discover_host"
)

Variables

var Store map[string]interface{}

var T = time.Second * 5

Functions

func RandName

func RandName() string

func StoreAdd

func StoreAdd(key string, v interface{})

func StoreDel

func StoreDel(key string)

Types

type Event

type Event struct {
	EventName string
	Host      string
	TaskName  string
	Task      interface{}
	// contains filtered or unexported fields
}

type Processor

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

var P *Processor

func NewProcessor

func NewProcessor() *Processor

func (*Processor) Add

func (p *Processor) Add(notification string, event interface{})

func (*Processor) AddAfter

func (p *Processor) AddAfter(notification string, t time.Duration, event interface{})

func (*Processor) Run

func (p *Processor) Run()