middleware

package

v0.0.1 Latest Latest Go to latest Published: Feb 19, 2019 License: BSD-3-Clause Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mrwinstead/laminar

Links

Open Source Insights

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
type ProcessingHandler
- func (ph *ProcessingHandler) ProcessCallback() goka.ProcessCallback
type ProcessingHandlerOption

Constants ¶

View Source

const (
	ContextKeyRawMessage = iota
)

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL