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 any
• func Produce(ctx api.StreamContext, topic string, data api.Tuple)
• func ProduceList(ctx api.StreamContext, topic string, list []api.Tuple)
• func ProduceUpdatable(ctx api.StreamContext, topic string, data api.Tuple, rowkind string, ...)
• 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 any

func Produce

func Produce(ctx api.StreamContext, topic string, data api.Tuple)

func ProduceList

func ProduceList(ctx api.StreamContext, topic string, list []api.Tuple)

func ProduceUpdatable

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

func RemovePub

func RemovePub(topic string)

func Reset

func Reset()

Reset For testing only

Types

type UpdatableTuple

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