stream

package
Version: v1.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 25, 2022 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateTopics added in v1.2.53

func CreateTopics(kAdmin admin.KafkaAdmin)

func Init

func Init()

func InitStreams

func InitStreams(builder *kstream.StreamBuilder) []kstream.Stream

Types

type AccountCredited

type AccountCredited struct {
	Upstream             kstream.Stream
	AccountDetailTable   kstream.GlobalTable
	CustomerProfileTable kstream.GlobalTable
	KeyEncoder           func() encoding.Encoder
	MessageEncoder       func() encoding.Encoder
}

func (AccountCredited) Init

func (ac AccountCredited) Init()

type AccountDebited

type AccountDebited struct {
	Upstream             kstream.Stream
	AccountDetailTable   kstream.GlobalTable
	CustomerProfileTable kstream.GlobalTable
	KeyEncoder           func() encoding.Encoder
	MessageEncoder       func() encoding.Encoder
}

func (AccountDebited) Init

func (ad AccountDebited) Init()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL