kafka

Documentation

Index

• type FlavorKafka
  • func (f *FlavorKafka) Inject() bool
  • func (f *FlavorKafka) Plugins() []*core.NamedPlugin

Types

type FlavorKafka

type FlavorKafka struct {
	*local.FlavorLocal

	Kafka kafka.Plugin
	// contains filtered or unexported fields
}

FlavorKafka glues together FlavorLocal plugins with: Kafka plugins (useful for publishing events)

func (*FlavorKafka) Inject

func (f *FlavorKafka) Inject() bool

Inject sets object references

func (*FlavorKafka) Plugins

func (f *FlavorKafka) Plugins() []*core.NamedPlugin

Plugins combines all Plugins in flavor to the list