bundledImpl

Documentation

Index

• type DummyEvent
  • func (de DummyEvent) Process(reader io.Reader, customParams interface{}) bool
  • func (de DummyEvent) Setup(customParams interface{}) bool
• type KafkaEmitEvent
  • func (kee KafkaEmitEvent) Process(reader io.Reader, customParams interface{}) bool
  • func (kee KafkaEmitEvent) Setup(customParams interface{}) bool

Types

type DummyEvent

type DummyEvent struct {
}

func (DummyEvent) Process

func (de DummyEvent) Process(reader io.Reader, customParams interface{}) bool

func (DummyEvent) Setup

func (de DummyEvent) Setup(customParams interface{}) bool

type KafkaEmitEvent

type KafkaEmitEvent struct {
	Data     map[string]interface{}
	Tmpl     *template.Template
	Producer *kafka.Producer
	Topic    string
}

func (KafkaEmitEvent) Process

func (kee KafkaEmitEvent) Process(reader io.Reader, customParams interface{}) bool

func (KafkaEmitEvent) Setup

func (kee KafkaEmitEvent) Setup(customParams interface{}) bool