pubsub

Documentation

Index

• Constants
• func CloseSourceConsumerChannel(topic string, sourceId string)
• func CreatePub(topic string)
• func CreateSub(wildcard string, regex *regexp.Regexp, sourceId string, bufferLength int) chan api.SourceTuple
• func Produce(ctx api.StreamContext, topic string, data map[string]interface{})
• func ProduceError(ctx api.StreamContext, topic string, err error)
• func ProduceUpdatable(ctx api.StreamContext, topic string, data map[string]interface{}, ...)
• func RemovePub(topic string)
• func Reset()
• type UpdatableTuple

Constants

const IdProperty = "topic"

Functions

func CloseSourceConsumerChannel

func CloseSourceConsumerChannel(topic string, sourceId string)

func CreatePub

func CreatePub(topic string)

func CreateSub

func CreateSub(wildcard string, regex *regexp.Regexp, sourceId string, bufferLength int) chan api.SourceTuple

func Produce

func Produce(ctx api.StreamContext, topic string, data map[string]interface{})

func ProduceError

func ProduceError(ctx api.StreamContext, topic string, err error)

func ProduceUpdatable

func ProduceUpdatable(ctx api.StreamContext, topic string, data map[string]interface{}, rowkind string, keyval interface{})

func RemovePub

func RemovePub(topic string)

func Reset

func Reset()

Reset For testing only

Types

type UpdatableTuple

type UpdatableTuple struct {
	*api.DefaultSourceTuple
	Rowkind string
	Keyval  interface{}
}