sinks

Documentation

Index

• type CloudPubSubSink
  • func NewCloudPubSubSink(config *config.CloudPubSubSink) (*CloudPubSubSink, error)
  • func (s *CloudPubSubSink) Publish(m *api.Measurement)
• type MQTTSink
  • func NewMQTTSink(c *config.MQTTSink) (*MQTTSink, error)
  • func (s *MQTTSink) Publish(m *api.Measurement)
• type Sink
  • func NewSink(sinkConfig config.Sink) (Sink, error)
• type StdoutSink
  • func NewStdoutSink(config *config.StdoutSink) (*StdoutSink, error)
  • func (s *StdoutSink) Publish(m *api.Measurement)

Types

type CloudPubSubSink

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

CloudPubSubSink publishes measurements to Google Cloud Pub/Sub.

func NewCloudPubSubSink

func NewCloudPubSubSink(config *config.CloudPubSubSink) (*CloudPubSubSink, error)

NewCloudPubSubSink creates new CloudPubSubSink.

func (*CloudPubSubSink) Publish

func (s *CloudPubSubSink) Publish(m *api.Measurement)

Publish is used to push measurement for publication.

type MQTTSink

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

MQTTSink publishes measurements to MQTT.

func NewMQTTSink

func NewMQTTSink(c *config.MQTTSink) (*MQTTSink, error)

NewMQTTSink creates new MQTTSink.

func (*MQTTSink) Publish

func (s *MQTTSink) Publish(m *api.Measurement)

Publish is used to push measurement for publication.

type Sink

type Sink interface {
	Publish(*api.Measurement)
}

Sink represents an object with Publish method for publishing api.Measurement.

func NewSink

func NewSink(sinkConfig config.Sink) (Sink, error)

NewSink creates a new Sink objects based on the config.Sink configuration.

type StdoutSink

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

StdoutSink publishes measurements on standard output.

func NewStdoutSink

func NewStdoutSink(config *config.StdoutSink) (*StdoutSink, error)

NewStdoutSink creates new StdoutSink.

func (*StdoutSink) Publish

func (s *StdoutSink) Publish(m *api.Measurement)

Publish is used to push measurement for publication.