inputs

Documentation

Index

• Variables
• func Exists(connType string) (exists bool)
• func Make(connType string) interface{}
• func Recovery(service models.Service)
• type Cli
  • func (x Cli) Read(inputMsgs chan<- models.Message, service models.Service)
• type File
  • func (x File) Read(inputMsgs chan<- models.Message, service models.Service)
• type Input
• type Rss
  • func (x Rss) Read(inputMsgs chan<- models.Message, service models.Service)
• type Scheduler
  • func (x Scheduler) Read(inputMsgs chan<- models.Message, service models.Service)
• type Slack
  • func (x Slack) Read(inputMsgs chan<- models.Message, service models.Service)
• type Twitter
  • func (x Twitter) Read(inputMsgs chan<- models.Message, service models.Service)
• type Webhook
  • func (x Webhook) Read(inputMsgs chan<- models.Message, service models.Service)

Variables

var List = make(map[string]reflect.Type)

List of Inputs

Functions

func Exists

func Exists(connType string) (exists bool)

Exists function

func Make

func Make(connType string) interface{}

MakeService

func Recovery

func Recovery(service models.Service)

Recovery

Types

type Cli

type Cli struct {
}

Cli struct

func (Cli) Read

func (x Cli) Read(inputMsgs chan<- models.Message, service models.Service)

Read function

type File

type File struct {
}

func (File) Read

func (x File) Read(inputMsgs chan<- models.Message, service models.Service)

Read function

type Input

type Input interface {
	Read(inputMsgs chan<- models.Message, service models.Service)
}

Input interface

type Rss

type Rss struct {
}

func (Rss) Read

func (x Rss) Read(inputMsgs chan<- models.Message, service models.Service)

type Scheduler

type Scheduler struct {
}

Exec struct

func (Scheduler) Read

func (x Scheduler) Read(inputMsgs chan<- models.Message, service models.Service)

Input function

type Slack

type Slack struct {
}

Slack struct

func (Slack) Read

func (x Slack) Read(inputMsgs chan<- models.Message, service models.Service)

Read function

type Twitter

type Twitter struct {
}

Twitter Struct representing the

func (Twitter) Read

func (x Twitter) Read(inputMsgs chan<- models.Message, service models.Service)

Input Input to the Twitter stream api

type Webhook

type Webhook struct {
}

func (Webhook) Read

func (x Webhook) Read(inputMsgs chan<- models.Message, service models.Service)