store

Documentation

Index

• func Unreg(topic string, key string) error
• type Table
  • func Reg(topic string, topicRegex *regexp.Regexp, key string) (*Table, error)
  • func (t *Table) Read(keys []string, values []interface{}) ([]api.SourceTuple, error)

Functions

func Unreg

func Unreg(topic string, key string) error

Unreg unregisters a topic to remove it from memory store

Types

type Table

type Table struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Table has one writer and multiple reader

func Reg

func Reg(topic string, topicRegex *regexp.Regexp, key string) (*Table, error)

Reg registers a topic to save it to memory store Create a new go routine to listen to the topic and save the data to memory

func (*Table) Read

func (t *Table) Read(keys []string, values []interface{}) ([]api.SourceTuple, error)