Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CloudPubSubSink ¶ added in v0.2.0
type CloudPubSubSink struct {
// contains filtered or unexported fields
}
CloudPubSubSink publishes measurements to Google Cloud Pub/Sub.
func NewCloudPubSubSink ¶ added in v0.2.0
func NewCloudPubSubSink(config *config.CloudPubSubSink) (*CloudPubSubSink, error)
NewCloudPubSubSink creates new CloudPubSubSink.
func (*CloudPubSubSink) Publish ¶ added in v0.2.0
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 ¶
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.
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.
Click to show internal directories.
Click to hide internal directories.