ratelimit

Documentation

Index

• func NewNode(flowOpCtx *model.FlowOperationalContext, meta model.MetaNode, ...) model.Node
• type Node
  • func (node *Node) LoadNodeConfig() error
  • func (node *Node) OnInput(msg *model.Message) ([]model.NodeID, error)
  • func (node *Node) WaitForEvent(responseChannel chan model.ReactorEvent)
• type NodeConfig

Functions

func NewNode

func NewNode(flowOpCtx *model.FlowOperationalContext, meta model.MetaNode, ctx *model.Context) model.Node

Types

type Node

type Node struct {
	base.BaseNode
	// contains filtered or unexported fields
}

IF node

func (*Node) LoadNodeConfig

func (node *Node) LoadNodeConfig() error

func (*Node) OnInput

func (node *Node) OnInput(msg *model.Message) ([]model.NodeID, error)

func (*Node) WaitForEvent

func (node *Node) WaitForEvent(responseChannel chan model.ReactorEvent)

type NodeConfig

type NodeConfig struct {
	TimeInterval int64  // Time interval in seconds
	Limit        int    // Limit is expressed in events / time interval
	Action       string // skip,wait
}