processor

Documentation

Index

• func GetDataProductStream(js jetstream.JetStream, prodType string) []string
• type Processor

Functions

func GetDataProductStream

func GetDataProductStream(js jetstream.JetStream, prodType string) []string

Types

type Processor

type Processor interface {
	Start()                          // Load state for sched eg: jetstream
	Subscribe()                      // Subscribe subject (sync)
	Process(cons jetstream.Consumer) // Consume the messages
}