Documentation
¶
Index ¶
- type Apt
- type Base
- type Feeder
- func NewAptFeeder(conf map[string]string) (Feeder, error)
- func NewFeeder(rule string, name string, conf map[string]string, bus EventBus.Bus, id int32) (Feeder, error)
- func NewFileFeeder(conf map[string]string) (Feeder, error)
- func NewFolderFeeder(conf map[string]string) (Feeder, error)
- func NewRSSFeeder(conf map[string]string) (Feeder, error)
- func NewSlackFeeder(conf map[string]string) (Feeder, error)
- func NewTimerFeeder(conf map[string]string) (Feeder, error)
- func NewTwitterFeeder(conf map[string]string) (Feeder, error)
- func NewWebFeeder(conf map[string]string) (Feeder, error)
- type FeederFactory
- type File
- type Folder
- type RSS
- type Slack
- type Timer
- type Twitter
- type Web
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Apt ¶ added in v1.11.3
type Apt struct {
Base
// contains filtered or unexported fields
}
Apt is a Feeder that creates a stream from a Apt feed
type Base ¶
type Base struct {
// contains filtered or unexported fields
}
Base is inherited from the feeders
func (*Base) GetIdentifier ¶
GetIdentifier returns the Node identifier ID used in the bus
type Feeder ¶
type Feeder interface {
Name() string
Rule() string
Start()
Stop()
IsRunning() bool
GetIdentifier() string
OnEvent(e *data.Event)
// contains filtered or unexported methods
}
Feeder defines Base methods of the object
func NewAptFeeder ¶ added in v1.11.3
NewAptFeeder is the registered method to instantiate a AptFeeder
func NewFeeder ¶
func NewFeeder(rule string, name string, conf map[string]string, bus EventBus.Bus, id int32) (Feeder, error)
NewFeeder creates a new registered Feeder from it's name
func NewFileFeeder ¶
NewFileFeeder is the registered method to instantiate a FileFeeder
func NewFolderFeeder ¶ added in v0.10.0
NewFolderFeeder is the registered method to instantiate a FolderFeeder
func NewRSSFeeder ¶
NewRSSFeeder is the registered method to instantiate a RSSFeeder
func NewSlackFeeder ¶ added in v0.9.1
NewSlackFeeder is the registered method to instantiate a SlackFeeder
func NewTimerFeeder ¶ added in v1.1.7
NewTimerFeeder is the registered method to instantiate a TimerFeeder
func NewTwitterFeeder ¶
NewTwitterFeeder is the registered method to instantiate a TwitterFeeder https://developer.twitter.com/en/docs/tweets/filter-realtime/guides/basic-stream-parameters
type FeederFactory ¶
FeederFactory identifies a function to instantiate a Feeder using the Factory
type File ¶
type File struct {
Base
// contains filtered or unexported fields
}
File is a Feeder that creates a stream from a file
type Folder ¶ added in v0.10.0
type Folder struct {
Base
// contains filtered or unexported fields
}
Folder is a Feeder that creates a stream from a folder
type RSS ¶
type RSS struct {
Base
// contains filtered or unexported fields
}
RSS is a Feeder that creates a stream from a RSS feed
type Slack ¶ added in v0.9.1
type Slack struct {
Base
Team string
User string
TeamID string
UserID string
BotID string
// contains filtered or unexported fields
}
Slack is a Feeder that get events from Slack
type Timer ¶ added in v1.1.7
type Timer struct {
Base
// contains filtered or unexported fields
}
Timer is a Feeder that triggers the pipeline using a timer
type Twitter ¶
type Twitter struct {
Base
// contains filtered or unexported fields
}
Twitter is a Feeder that feeds a pipeline with tweets
Source Files