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 MemTuple)
• func ProduceAny(ctx api.StreamContext, topic string, data any)
• func ProduceError(ctx api.StreamContext, topic string, err error)
• func ProduceList(ctx api.StreamContext, topic string, list []MemTuple)
• func RemovePub(topic string)
• func Reset()
• type MemTuple
• 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 MemTuple)

func ProduceAny

func ProduceAny(ctx api.StreamContext, topic string, data any)

func ProduceError

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

func ProduceList

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

func RemovePub

func RemovePub(topic string)

func Reset

func Reset()

Reset For testing only

Types

type MemTuple

type MemTuple interface {
	Value(key, table string) (any, bool)
	ToMap() map[string]any
}

type UpdatableTuple

type UpdatableTuple struct {
	MemTuple
	Rowkind string
	Keyval  interface{}
}