sink

package

v1.6.3 Latest Latest Go to latest Published: Jul 9, 2019 License: BSD-3-Clause Imports: 23 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

Repository

github.com/fluidstackio/nomad-firehose

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

type HttpSink
- func NewHttp() (*HttpSink, error)
- func (s *HttpSink) Put(data []byte) error
- func (s *HttpSink) Start() error
- func (s *HttpSink) Stop()
type KafkaSink
- func NewKafka() (*KafkaSink, error)
- func (s *KafkaSink) Put(data []byte) error
- func (s *KafkaSink) Start() error
- func (s *KafkaSink) Stop()
type KinesisSink
- func NewKinesis() (*KinesisSink, error)
- func (s *KinesisSink) Put(data []byte) error
- func (s *KinesisSink) Start() error
- func (s *KinesisSink) Stop()
type MongodbSink
- func NewMongodb() (*MongodbSink, error)
- func (s *MongodbSink) Put(data []byte) error
- func (s *MongodbSink) Start() error
- func (s *MongodbSink) Stop()
type NSQSink
- func NewNSQ() (*NSQSink, error)
- func (s *NSQSink) Put(data []byte) error
- func (s *NSQSink) Start() error
- func (s *NSQSink) Stop()
type RabbitmqSink
- func NewRabbitmq() (*RabbitmqSink, error)
- func (s *RabbitmqSink) Put(data []byte) error
- func (s *RabbitmqSink) Start() error
- func (s *RabbitmqSink) Stop()
type RedisSink
- func NewRedis() (*RedisSink, error)
- func (s *RedisSink) Put(data []byte) error
- func (s *RedisSink) Start() error
- func (s *RedisSink) Stop()
type SQSSink
- func NewSQS(groupId string) (*SQSSink, error)
- func (s *SQSSink) Put(data []byte) error
- func (s *SQSSink) Start() error
- func (s *SQSSink) Stop()
type Sink
- func GetSink(resourceName string) (Sink, error)
type StdoutSink
- func NewStdout() (*StdoutSink, error)
- func (s *StdoutSink) Put(data []byte) error
- func (s *StdoutSink) Start() error
- func (s *StdoutSink) Stop()
type SyslogSink
- func NewSyslog() (*SyslogSink, error)
- func (s *SyslogSink) Put(data []byte) error
- func (s *SyslogSink) Start() error
- func (s *SyslogSink) Stop()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type HttpSink ¶ added in v1.4.0

type HttpSink struct {
	// contains filtered or unexported fields
}

HttpSink ...

func NewHttp ¶ added in v1.4.0

func NewHttp() (*HttpSink, error)

NewHttp ...

func (*HttpSink) Put ¶ added in v1.4.0

func (s *HttpSink) Put(data []byte) error

Put ..

func (*HttpSink) Start ¶ added in v1.4.0

func (s *HttpSink) Start() error

Start ...

func (*HttpSink) Stop ¶ added in v1.4.0

func (s *HttpSink) Stop()

Stop ...

type KafkaSink ¶ added in v0.2.0

type KafkaSink struct {
	// Kafka brokers to send metrics to
	Brokers []string
	// Kafka topic
	Topic string
	// contains filtered or unexported fields
}

KafkaSink ...

func NewKafka ¶ added in v0.2.0

func NewKafka() (*KafkaSink, error)

NewKafka ...

func (*KafkaSink) Put ¶ added in v0.2.0

func (s *KafkaSink) Put(data []byte) error

Put ..

func (*KafkaSink) Start ¶ added in v0.2.0

func (s *KafkaSink) Start() error

Start ...

func (*KafkaSink) Stop ¶ added in v0.2.0

func (s *KafkaSink) Stop()

Stop ...

type KinesisSink ¶

type KinesisSink struct {
	// contains filtered or unexported fields
}

KinesisSink ...

func NewKinesis ¶

func NewKinesis() (*KinesisSink, error)

NewKinesis ...

func (*KinesisSink) Put ¶

func (s *KinesisSink) Put(data []byte) error

Put ..

func (*KinesisSink) Start ¶

func (s *KinesisSink) Start() error

Start ...

func (*KinesisSink) Stop ¶

func (s *KinesisSink) Stop()

Stop ...

type MongodbSink ¶ added in v1.2.0

type MongodbSink struct {
	// contains filtered or unexported fields
}

MongodbSink ...

func NewMongodb ¶ added in v1.2.0

func NewMongodb() (*MongodbSink, error)

NewMongodb ...

func (*MongodbSink) Put ¶ added in v1.2.0

func (s *MongodbSink) Put(data []byte) error

Put ..

func (*MongodbSink) Start ¶ added in v1.2.0

func (s *MongodbSink) Start() error

Start ...

func (*MongodbSink) Stop ¶ added in v1.2.0

func (s *MongodbSink) Stop()

Stop ...

type NSQSink ¶ added in v0.2.0

type NSQSink struct {
	// contains filtered or unexported fields
}

func NewNSQ ¶ added in v0.2.0

func NewNSQ() (*NSQSink, error)

func (*NSQSink) Put ¶ added in v0.2.0

func (s *NSQSink) Put(data []byte) error

func (*NSQSink) Start ¶ added in v0.2.0

func (s *NSQSink) Start() error

func (*NSQSink) Stop ¶ added in v0.2.0

func (s *NSQSink) Stop()

type RabbitmqSink ¶

type RabbitmqSink struct {
	// contains filtered or unexported fields
}

RabbitmqSink ...

func NewRabbitmq ¶

func NewRabbitmq() (*RabbitmqSink, error)

NewRabbitmq ...

func (*RabbitmqSink) Put ¶

func (s *RabbitmqSink) Put(data []byte) error

Put ..

func (*RabbitmqSink) Start ¶

func (s *RabbitmqSink) Start() error

Start ...

func (*RabbitmqSink) Stop ¶

func (s *RabbitmqSink) Stop()

Stop ...

type RedisSink ¶ added in v0.4.0

type RedisSink struct {
	// contains filtered or unexported fields
}

RedisSink ...

func NewRedis ¶ added in v0.4.0

func NewRedis() (*RedisSink, error)

NewStdout ...

func (*RedisSink) Put ¶ added in v0.4.0

func (s *RedisSink) Put(data []byte) error

Put ..

func (*RedisSink) Start ¶ added in v0.4.0

func (s *RedisSink) Start() error

Start ...

func (*RedisSink) Stop ¶ added in v0.4.0

func (s *RedisSink) Stop()

Stop ...

type SQSSink ¶ added in v1.6.0

type SQSSink struct {
	// contains filtered or unexported fields
}

SQS ...

func NewSQS ¶ added in v1.6.0

func NewSQS(groupId string) (*SQSSink, error)

NNewSQS ...

func (*SQSSink) Put ¶ added in v1.6.0

func (s *SQSSink) Put(data []byte) error

Put ..

func (*SQSSink) Start ¶ added in v1.6.0

func (s *SQSSink) Start() error

Start ...

func (*SQSSink) Stop ¶ added in v1.6.0

func (s *SQSSink) Stop()

Stop ...

type Sink ¶ added in v0.1.1

type Sink interface {
	Start() error
	Stop()
	Put(data []byte) error
}

Sink ...

func GetSink ¶ added in v0.1.1

func GetSink(resourceName string) (Sink, error)

GetSink ...

type StdoutSink ¶

type StdoutSink struct {
	// contains filtered or unexported fields
}

StdoutSink ...

func NewStdout ¶

func NewStdout() (*StdoutSink, error)

NewStdout ...

func (*StdoutSink) Put ¶

func (s *StdoutSink) Put(data []byte) error

Put ..

func (*StdoutSink) Start ¶

func (s *StdoutSink) Start() error

Start ...

func (*StdoutSink) Stop ¶

func (s *StdoutSink) Stop()

Stop ...

type SyslogSink ¶ added in v1.5.0

type SyslogSink struct {
	// contains filtered or unexported fields
}

func NewSyslog ¶ added in v1.5.0

func NewSyslog() (*SyslogSink, error)

NewSyslog ...

func (*SyslogSink) Put ¶ added in v1.5.0

func (s *SyslogSink) Put(data []byte) error

Put ..

func (*SyslogSink) Start ¶ added in v1.5.0

func (s *SyslogSink) Start() error

Start ...

func (*SyslogSink) Stop ¶ added in v1.5.0

func (s *SyslogSink) Stop()

Stop ...

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL