outputs

package

v0.1.0 Latest Latest Go to latest Published: Feb 6, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Console struct {
}

Console outputs tweets json to console

func (c *Console) Init() error

Init initializes console output

func (c *Console) Start(tweetChannel chan *twitter.Tweet)

Start starts the console output listening to a channel of tweets

func (c *Console) Stop()

Stop prints a final message before exiting

type Kafka struct {
	Config interface{}
	// contains filtered or unexported fields
}

Kafka sends tweet to Kafka

func (k *Kafka) Init() error

Init initializes an async Kafka producer

func (k *Kafka) Start(tweetChannel chan *twitter.Tweet)

Start starts the output to Kafka

func (k *Kafka) Stop()

Stop closes the Kafka producer on interrupt

type Output interface {
	Init() error
	Start(chan *twitter.Tweet)
	Stop()
}

Output defines an output

func InitializeOutput(outputName string, outputConfig interface{},
	tweets chan *twitter.Tweet) (Output, error)

InitializeOutput initializes and starts the output worker