plugins

Documentation

Index

• type Hello
  • func NewHello(name string) *Hello
  • func (r *Hello) Close() error
  • func (r *Hello) Init(service interfaces.Service) error
  • func (h *Hello) Process(descriptor interface{}) (interface{}, error)
• type RSS
  • func NewRSS() *RSS
  • func (r *RSS) Close() error
  • func (r *RSS) Init(service interfaces.Service) error
  • func (r *RSS) Process(data interface{}) (interface{}, error)
• type RSSSource
• type Source
• type Twitter
  • func (t *Twitter) Close() error
  • func (t *Twitter) Init(service interfaces.Service) error
  • func (t *Twitter) Process(source interface{}) (interface{}, error)
• type TwitterSource

Types

type Hello

type Hello struct {
	interfaces.Service
	Name string
}

func NewHello

func NewHello(name string) *Hello

func (*Hello) Close

func (r *Hello) Close() error

func (*Hello) Init

func (r *Hello) Init(service interfaces.Service) error

func (*Hello) Process

func (h *Hello) Process(descriptor interface{}) (interface{}, error)

type RSS

type RSS struct {
	interfaces.Service
}

func NewRSS

func NewRSS() *RSS

func (*RSS) Close

func (r *RSS) Close() error

func (*RSS) Init

func (r *RSS) Init(service interfaces.Service) error

func (*RSS) Process

func (r *RSS) Process(data interface{}) (interface{}, error)

type RSSSource

type RSSSource struct {
	ID      string   `json:"id"`
	Name    string   `json:"name"`
	Folder  string   `json:"folder, omitempty"`
	Urls    []string `json:"urls, omitempty"`
	Timeout int      `json:"timeout"`
}

type Source

type Source struct {
}

type Twitter

type Twitter struct {
	interfaces.Service
}

func (*Twitter) Close

func (t *Twitter) Close() error

func (*Twitter) Init

func (t *Twitter) Init(service interfaces.Service) error

func (*Twitter) Process

func (t *Twitter) Process(source interface{}) (interface{}, error)

type TwitterSource

type TwitterSource struct {
}