pipeline

Documentation

Index

• Variables
• func ForkAndMerge(in *message.MessageChannel, pipelines ...Pipeline) *message.MessageChannel
• func LogMessages(cs ...*message.MessageChannel) *message.MessageChannel
• func Merge(cs ...*message.MessageChannel) *message.MessageChannel
• func Run(cs ...*message.MessageChannel)
• type Pipeline
  • func MakeEQFilter(key string, value string) Pipeline
  • func MakeFeedFetchPipeline(urlPath string) Pipeline
  • func MakeFilterPipeline(test func(message.Message) bool) Pipeline
  • func MakeHTTPSourcePipeline(path string) Pipeline
  • func MakeHTTPSourceResponsePipeline(path string, sub_url string) Pipeline
  • func MakeHTTPipeline(path string, ...) Pipeline
  • func MakeKazaamPipeline(spec string) Pipeline
  • func MakeMatchAnyFilter(path string, values ...string) Pipeline
  • func MakePOSTPipeline(url string) Pipeline
  • func MakePublishPipeline(url string) Pipeline
  • func MakePullPipeline(args ...string) Pipeline
  • func MakePushPipeline(url string) Pipeline
  • func MakeRespondentPipeline(args ...string) Pipeline
  • func MakeScriptPipeline(cmdline ...string) Pipeline
  • func MakeSubscribePipeline(args ...string) Pipeline
  • func MakeSurveyorPipeline(args ...string) Pipeline
  • func MakeSyslog(hostport string, setup func(server *syslog.Server)) Pipeline
  • func MakeSyslogTCP(hostport string) Pipeline
  • func MakeSyslogTCPTLS(hostport string) Pipeline
  • func MakeSyslogUDP(hostport string) Pipeline
  • func MakeSyslogUnix(hostport string) Pipeline
  • func MakeTimer(duration string) Pipeline
  • func (p Pipeline) Call(cs ...*message.MessageChannel) *message.MessageChannel
  • func (p Pipeline) Invoke(args ...core.Any) (core.Any, error)

Variables

var Log = logrus.New()

Functions

func ForkAndMerge

func ForkAndMerge(in *message.MessageChannel, pipelines ...Pipeline) *message.MessageChannel

func LogMessages

func LogMessages(cs ...*message.MessageChannel) *message.MessageChannel

func Merge

func Merge(cs ...*message.MessageChannel) *message.MessageChannel

func Run

func Run(cs ...*message.MessageChannel)

Types

type Pipeline

type Pipeline func(...*message.MessageChannel) *message.MessageChannel

func MakeEQFilter

func MakeEQFilter(key string, value string) Pipeline

func MakeFeedFetchPipeline

func MakeFeedFetchPipeline(urlPath string) Pipeline

func MakeFilterPipeline

func MakeFilterPipeline(test func(message.Message) bool) Pipeline

func MakeHTTPSourcePipeline

func MakeHTTPSourcePipeline(path string) Pipeline

func MakeHTTPSourceResponsePipeline

func MakeHTTPSourceResponsePipeline(path string, sub_url string) Pipeline

func MakeHTTPipeline

func MakeHTTPipeline(path string, sender func(*message.MessageChannel, message.Message) (message.Message, error)) Pipeline

func MakeKazaamPipeline

func MakeKazaamPipeline(spec string) Pipeline

func MakeMatchAnyFilter

func MakeMatchAnyFilter(path string, values ...string) Pipeline

func MakePOSTPipeline

func MakePOSTPipeline(url string) Pipeline

func MakePublishPipeline

func MakePublishPipeline(url string) Pipeline

func MakePullPipeline

func MakePullPipeline(args ...string) Pipeline

func MakePushPipeline

func MakePushPipeline(url string) Pipeline

func MakeRespondentPipeline

func MakeRespondentPipeline(args ...string) Pipeline

func MakeScriptPipeline

func MakeScriptPipeline(cmdline ...string) Pipeline

func MakeSubscribePipeline

func MakeSubscribePipeline(args ...string) Pipeline

func MakeSurveyorPipeline

func MakeSurveyorPipeline(args ...string) Pipeline

func MakeSyslog

func MakeSyslog(hostport string, setup func(server *syslog.Server)) Pipeline

func MakeSyslogTCP

func MakeSyslogTCP(hostport string) Pipeline

func MakeSyslogTCPTLS

func MakeSyslogTCPTLS(hostport string) Pipeline

func MakeSyslogUDP

func MakeSyslogUDP(hostport string) Pipeline

func MakeSyslogUnix

func MakeSyslogUnix(hostport string) Pipeline

func MakeTimer

func MakeTimer(duration string) Pipeline

func (Pipeline) Call

func (p Pipeline) Call(cs ...*message.MessageChannel) *message.MessageChannel

func (Pipeline) Invoke

func (p Pipeline) Invoke(args ...core.Any) (core.Any, error)