ep

Documentation

Index

• Constants
• type IncomingAmount
• type SalesEventProcessor
  • func NewSalesEventProcessor(noInstances int) SalesEventProcessor
  • func (s *SalesEventProcessor) ProcessEvent(e *client.ResolvedEvent) error
  • func (s *SalesEventProcessor) ProcessEventSalesEventId(e *client.ResolvedEvent) error
  • func (s *SalesEventProcessor) ProcessEventSalesEventId2(e *client.ResolvedEvent) error
• type Test2Processor
  • func NewTest2Processor(noInstances int) Test2Processor
  • func (p *Test2Processor) ProcessEvent(e *client.ResolvedEvent) error

Constants

const (
	SalesEventId  = "SalesEventId"
	SalesEventId2 = "SalesEventId2"
)

const (
	TestEvent1Id  = "TestEvent1Id"
	Test2Event2Id = "Test2Event2Id"
)

Types

type IncomingAmount

type IncomingAmount struct {
	Amount int `json:"amount"`
}

type SalesEventProcessor

type SalesEventProcessor struct {
	eventprocessors.BaseEventProcessor
	// contains filtered or unexported fields
}

func NewSalesEventProcessor

func NewSalesEventProcessor(noInstances int) SalesEventProcessor

func (*SalesEventProcessor) ProcessEvent

func (s *SalesEventProcessor) ProcessEvent(e *client.ResolvedEvent) error

func (*SalesEventProcessor) ProcessEventSalesEventId

func (s *SalesEventProcessor) ProcessEventSalesEventId(e *client.ResolvedEvent) error

func (*SalesEventProcessor) ProcessEventSalesEventId2

func (s *SalesEventProcessor) ProcessEventSalesEventId2(e *client.ResolvedEvent) error

type Test2Processor

type Test2Processor struct {
	eventprocessors.BaseEventProcessor
}

This is to just test out having eventprocessors in command project rather than framework section.

func NewTest2Processor

func NewTest2Processor(noInstances int) Test2Processor

func (*Test2Processor) ProcessEvent

func (p *Test2Processor) ProcessEvent(e *client.ResolvedEvent) error