Versions in this module Expand all Collapse all v0 v0.0.1 Feb 19, 2019 Changes in this version + const ErrorHandlingContinue + const ErrorHandlingDeleteValue + const ErrorHandlingFailProcessor + type CodecAfterEncodeFunc func(ctx context.Context, data []byte) ([]byte, error) + type CodecBeforeDecodeFunc func(ctx context.Context) ([]byte, context.Context, error) + type MiddlewareContext interface + RawMessage func() []byte + type MiddlewareEnablingCodec interface + DecodeEx func(ctx context.Context, rawMessage []byte) (interface{}, error) + EncodeEx func(ctx context.Context, msg interface{}) ([]byte, error) + type ProcessingAfterFunc func(ctx MiddlewareContext, fromLog, toLog interface{}) (interface{}, error) + type ProcessingBeforeFunc func(ctx MiddlewareContext, msg interface{}) (context.Context, error) + type ProcessingErrorHandler func(ctx MiddlewareContext, err error) uint + type ProcessingFinalizer func(ctx MiddlewareContext, err error, msg interface{}) + type ProcessingHandler interface + ProcessCallback func() goka.ProcessCallback