stream

Documentation

Index

• func CreateTopics(kAdmin admin.KafkaAdmin)
• func Init()
• func InitStreams(builder *kstream.StreamBuilder) []kstream.Stream
• type AccountCredited
  • func (ac AccountCredited) Init()
• type AccountDebited
  • func (ad AccountDebited) Init()

Functions

func CreateTopics

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()