stream

Documentation

Index

• func GetDefaultSubscriptionConfig(topic *pubsub.Topic, retentionDuration time.Duration) pubsub.SubscriptionConfig
• func PublishProtoToTopic(m proto.Message, encoding pubsub.SchemaEncoding, topic *pubsub.Topic) (*string, error)
• func PublishToTopic(m interface{}, topic *pubsub.Topic) (*string, error)
• type BrokerDevice
• type SimpleMessage

Functions

func GetDefaultSubscriptionConfig

func GetDefaultSubscriptionConfig(topic *pubsub.Topic, retentionDuration time.Duration) pubsub.SubscriptionConfig

GetDefaultSubscriptionConfig TODO fill in better defaults - make duration deployment dependant

func PublishProtoToTopic

func PublishProtoToTopic(m proto.Message, encoding pubsub.SchemaEncoding, topic *pubsub.Topic) (*string, error)

func PublishToTopic

func PublishToTopic(m interface{}, topic *pubsub.Topic) (*string, error)

PublishToTopic just wraps json marshalling of an interface and Publish to a google pubsub Topic returning the result of the Publish method

Types

type BrokerDevice

type BrokerDevice struct {
	Source    string
	DeviceUID string
}

type SimpleMessage

type SimpleMessage struct {
	BrokerDevice
	Payload []byte
	Time    time.Time
}