middleware

Documentation

Index

• Constants
• func BuildHandleError(l log.Logger) laminar.ProcessingErrorHandler
• func NewCodec(rootContext context.Context, userCodec laminar.MiddlewareEnablingCodec, ...) goka.Codec
• func NewProcessingHandler(wrapped goka.ProcessCallback, l log.Logger, opts ...ProcessingHandlerOption) laminar.ProcessingHandler
• type Codec
  • func (i *Codec) Decode(data []byte) (interface{}, error)
  • func (i *Codec) Encode(valueIface interface{}) ([]byte, error)
• type CodecOption
  • func WithCodecAfterEncodeFunc(after laminar.CodecAfterEncodeFunc) CodecOption
  • func WithCodecBeforeDecodeFunc(before laminar.CodecBeforeDecodeFunc) CodecOption
• type Context
  • func NewMiddlewareContext(gCtx goka.Context, rawMessage []byte) *Context
  • func (ec *Context) Context() context.Context
  • func (ec *Context) Delete()
  • func (ec *Context) Emit(topic goka.Stream, key string, value interface{})
  • func (ec *Context) Fail(err error)
  • func (ec *Context) Join(topic goka.Table) interface{}
  • func (ec *Context) Key() string
  • func (ec *Context) Lookup(topic goka.Table, key string) interface{}
  • func (ec *Context) Loopback(key string, value interface{})
  • func (ec *Context) Offset() int64
  • func (ec *Context) Partition() int32
  • func (ec *Context) RawMessage() []byte
  • func (ec *Context) SetValue(value interface{})
  • func (ec *Context) Timestamp() time.Time
  • func (ec *Context) Topic() goka.Stream
  • func (ec *Context) Value() interface{}
• type ProcessingHandler
  • func (ph *ProcessingHandler) ProcessCallback() goka.ProcessCallback
• type ProcessingHandlerOption
  • func ProcessingHandlerAfter(f laminar.ProcessingAfterFunc) ProcessingHandlerOption
  • func ProcessingHandlerBefore(f laminar.ProcessingBeforeFunc) ProcessingHandlerOption
  • func ProcessingHandlerError(f laminar.ProcessingErrorHandler) ProcessingHandlerOption
  • func ProcessingHandlerFinalizer(f laminar.ProcessingFinalizer) ProcessingHandlerOption

Constants

const (
	ContextKeyRawMessage = iota
)

Functions

func BuildHandleError

func BuildHandleError(l log.Logger) laminar.ProcessingErrorHandler

func NewCodec

func NewCodec(rootContext context.Context, userCodec laminar.MiddlewareEnablingCodec,
	opts ...CodecOption) goka.Codec

func NewProcessingHandler

func NewProcessingHandler(wrapped goka.ProcessCallback, l log.Logger, opts ...ProcessingHandlerOption,
) laminar.ProcessingHandler

Types

type Codec

type Codec struct {
	// contains filtered or unexported fields
}

func (*Codec) Decode

func (i *Codec) Decode(data []byte) (interface{}, error)

func (*Codec) Encode

func (i *Codec) Encode(valueIface interface{}) ([]byte, error)

type CodecOption

type CodecOption func(i *Codec)

func WithCodecAfterEncodeFunc

func WithCodecAfterEncodeFunc(after laminar.CodecAfterEncodeFunc) CodecOption

func WithCodecBeforeDecodeFunc

func WithCodecBeforeDecodeFunc(before laminar.CodecBeforeDecodeFunc) CodecOption

type Context

type Context struct {
	// contains filtered or unexported fields
}

func NewMiddlewareContext

func NewMiddlewareContext(gCtx goka.Context, rawMessage []byte) *Context

func (*Context) Context

func (ec *Context) Context() context.Context

func (*Context) Delete

func (ec *Context) Delete()

func (*Context) Emit

func (ec *Context) Emit(topic goka.Stream, key string, value interface{})

func (*Context) Fail

func (ec *Context) Fail(err error)

func (*Context) Join

func (ec *Context) Join(topic goka.Table) interface{}

func (*Context) Key

func (ec *Context) Key() string

func (*Context) Lookup

func (ec *Context) Lookup(topic goka.Table, key string) interface{}

func (*Context) Loopback

func (ec *Context) Loopback(key string, value interface{})

func (*Context) Offset

func (ec *Context) Offset() int64

func (*Context) Partition

func (ec *Context) Partition() int32

func (*Context) RawMessage

func (ec *Context) RawMessage() []byte

func (*Context) SetValue

func (ec *Context) SetValue(value interface{})

func (*Context) Timestamp

func (ec *Context) Timestamp() time.Time

func (*Context) Topic

func (ec *Context) Topic() goka.Stream

func (*Context) Value

func (ec *Context) Value() interface{}

type ProcessingHandler

type ProcessingHandler struct {
	// contains filtered or unexported fields
}

func (*ProcessingHandler) ProcessCallback

func (ph *ProcessingHandler) ProcessCallback() goka.ProcessCallback

type ProcessingHandlerOption

type ProcessingHandlerOption func(mh *ProcessingHandler)

func ProcessingHandlerAfter

func ProcessingHandlerAfter(f laminar.ProcessingAfterFunc) ProcessingHandlerOption

func ProcessingHandlerBefore

func ProcessingHandlerBefore(f laminar.ProcessingBeforeFunc) ProcessingHandlerOption

func ProcessingHandlerError

func ProcessingHandlerError(f laminar.ProcessingErrorHandler) ProcessingHandlerOption

func ProcessingHandlerFinalizer

func ProcessingHandlerFinalizer(f laminar.ProcessingFinalizer) ProcessingHandlerOption