memphis-functions.go

Nov 23, 2023

Changes in this version

+ func CreateFunction(eventHandler EventHandlerFunction)

+ type EventHandlerFunction func([]byte, map[string]string, map[string]string) ([]byte, map[string]string, error)

+ type MemphisEvent struct

+ Inputs map[string]string

+ Messages []MemphisMsg

+ type MemphisMsg struct

+ Headers map[string]string

+ Payload string

+ type MemphisMsgWithError struct

+ Error string

+ Headers map[string]string

+ Payload string

+ type MemphisOutput struct

+ FailedMessages []MemphisMsgWithError

+ Messages []MemphisMsg