publishers

Documentation

Index

• func ApplyCassandraConfiguration(publisher *wmap.PublishWorkflowMapNode)
• func ApplyInfluxDBConfiguration(publisher *wmap.PublishWorkflowMapNode)
• type Publisher
  • func NewDefaultCassandraPublisher() (pub Publisher)
  • func NewDefaultInfluxDBPublisher() (pub Publisher)
  • func NewDefaultPublisher() Publisher

Functions

func ApplyCassandraConfiguration

func ApplyCassandraConfiguration(publisher *wmap.PublishWorkflowMapNode)

ApplyCassandraConfiguration is a helper which applies the Cassandra related settings from the command line flags and applies them to a snap workflow.

func ApplyInfluxDBConfiguration

func ApplyInfluxDBConfiguration(publisher *wmap.PublishWorkflowMapNode)

ApplyInfluxDBConfiguration is a helper which applies the InfluxDB related settings from the command line flags and applies them to a snap workflow.

Types

type Publisher

type Publisher struct {
	PluginName string
	Publisher  *wmap.PublishWorkflowMapNode
}

Publisher stores default publisher object

func NewDefaultCassandraPublisher

func NewDefaultCassandraPublisher() (pub Publisher)

NewDefaultCassandraPublisher constructs new cassandra snap publisher.

func NewDefaultInfluxDBPublisher

func NewDefaultInfluxDBPublisher() (pub Publisher)

NewDefaultInfluxDBPublisher constructs new snap influxdb publisher.

func NewDefaultPublisher

func NewDefaultPublisher() Publisher

NewDefaultPublisher construct new snap publisher object based on default flag in configuration.