test

Documentation

Index

• type MyEventConsumerInterceptorAdaptor
  • func NewMyEventConsumerInterceptorAdaptor() MyEventConsumerInterceptorAdaptor
  • func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) HandleError(consumedTopic messaging.Topic, receivedMessage messaging.Message, err error) bool
  • func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePostProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
  • func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreParsing(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
  • func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
  • func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) ProcessingCompletedNormally(consumedTopic messaging.Topic, receivedMessage messaging.Message)
• type MyEventProcessor
  • func NewMyEventProcessor(ctx context.Context) (MyEventProcessor, error)
  • func (mep MyEventProcessor) ProcessMessage(ctx context.Context, consumedTopic messaging.Topic, ...) error

Types

type MyEventConsumerInterceptorAdaptor

type MyEventConsumerInterceptorAdaptor struct {
	IncomingMessagePreParsingCalled         bool
	IncomingMessagePreProcessMessageCalled  bool
	IncomingMessagePostProcessMessageCalled bool
	HandleErrorCalled                       bool
	ProcessingCompletedNormallyCalled       bool
}

MyEventConsumerInterceptorAdaptor is an implementation og EventConsumerAdaptor similar to EventConsumerInterceptorAdaptor, but testing purposes

func NewMyEventConsumerInterceptorAdaptor

func NewMyEventConsumerInterceptorAdaptor() MyEventConsumerInterceptorAdaptor

NewMyEventConsumerInterceptorAdaptor functions as a constructor for MyEventConsumerInterceptorAdaptor, returning a new instance of MyEventConsumerInterceptorAdaptor with all 'called'-variables set to false

func (*MyEventConsumerInterceptorAdaptor) HandleError

func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) HandleError(consumedTopic messaging.Topic, receivedMessage messaging.Message, err error) bool

HandleError is a test implementation of EventConsumerInterceptor's HandleError

func (*MyEventConsumerInterceptorAdaptor) IncomingMessagePostProcessMessage

func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePostProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool

IncomingMessagePostProcessMessage is a test implementation of EventConsumerInterceptor's IncomingMessagePostProcessMessage

func (*MyEventConsumerInterceptorAdaptor) IncomingMessagePreParsing

func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreParsing(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool

IncomingMessagePreParsing is a test implementation of EventConsumerInterceptor's IncomingMessagePreParsing

func (*MyEventConsumerInterceptorAdaptor) IncomingMessagePreProcessMessage

func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool

IncomingMessagePreProcessMessage is a test implementation of EventConsumerInterceptor's IncomingMessagePreProcessMessage

func (*MyEventConsumerInterceptorAdaptor) ProcessingCompletedNormally

func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) ProcessingCompletedNormally(consumedTopic messaging.Topic, receivedMessage messaging.Message)

ProcessingCompletedNormally is a test implementation of EventConsumerInterceptor's ProcessingCompletedNormally

type MyEventProcessor

type MyEventProcessor struct{}

MyEventProcessor is a struct representing MyEventProcessor which processes events received from Kafka, and returns a new message based on this processing

func NewMyEventProcessor

func NewMyEventProcessor(ctx context.Context) (MyEventProcessor, error)

NewMyEventProcessor functions as a constructor for MyEventProcessor that returns a new instance of MyEventProcessor

func (MyEventProcessor) ProcessMessage

func (mep MyEventProcessor) ProcessMessage(
	ctx context.Context,
	consumedTopic messaging.Topic,
	receivedMessage messaging.Message,
	messageProcessedTopic *messaging.Topic,
	outgoingMessage *messaging.Message,
) error

ProcessMessage accepts messages from Kafka and outputs an OperationOutcome resource to a different Topic