codec

package

v0.0.0-...-da8027b Latest Latest Go to latest Published: Dec 4, 2020 License: MIT Imports: 6 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/go-gulfstream/es

Documentation ¶

Overview ¶

Package codec is a generated GoMock package.

Index ¶

Variables
type Codec
type DecodeFunc
type DefaultCodec
- func New() *DefaultCodec
type EncodeFunc
type MockCodec
- func NewMockCodec(ctrl *gomock.Controller) *MockCodec
type MockCodecMockRecorder
- func (mr *MockCodecMockRecorder) Decode(ctx, st, payloadType, bytes interface{}) *gomock.Call
- func (mr *MockCodecMockRecorder) Encode(ctx, st, payloadType, payload interface{}) *gomock.Call
type Stream
- func (s *Stream) Payload(name string, enc EncodeFunc, dec DecodeFunc) *Stream

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrNotFound = errors.New("codec not found")

Functions ¶

This section is empty.

Types ¶

type Codec ¶

type Codec interface {
	Encode(ctx context.Context, st stream.Type, payloadType string, payload interface{}) (bytes []byte, err error)
	Decode(ctx context.Context, st stream.Type, payloadType string, bytes []byte) (payload interface{}, err error)
}

type DecodeFunc ¶

type DecodeFunc func(ctx context.Context, payloadType string, bytes []byte) (payload interface{}, err error)

type DefaultCodec ¶

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

func New ¶

func New() *DefaultCodec

func (*DefaultCodec) Decode ¶

func (c *DefaultCodec) Decode(ctx context.Context, st stream.Type, payloadType string, bytes []byte) (payload interface{}, err error)

func (*DefaultCodec) Encode ¶

func (c *DefaultCodec) Encode(ctx context.Context, st stream.Type, payloadType string, payload interface{}) (bytes []byte, err error)

func (*DefaultCodec) Merge ¶

func (c *DefaultCodec) Merge(in ...*DefaultCodec)

func (*DefaultCodec) Stream ¶

func (c *DefaultCodec) Stream(st stream.Type) *Stream

type EncodeFunc ¶

type EncodeFunc func(ctx context.Context, payload interface{}) (bytes []byte, err error)

type MockCodec ¶

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

MockCodec is a mock of Codec interface

func NewMockCodec ¶

func NewMockCodec(ctrl *gomock.Controller) *MockCodec

NewMockCodec creates a new mock instance

func (*MockCodec) Decode ¶

func (m *MockCodec) Decode(ctx context.Context, st stream.Type, payloadType string, bytes []byte) (interface{}, error)

Decode mocks base method

func (*MockCodec) EXPECT ¶

func (m *MockCodec) EXPECT() *MockCodecMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockCodec) Encode ¶

func (m *MockCodec) Encode(ctx context.Context, st stream.Type, payloadType string, payload interface{}) ([]byte, error)

Encode mocks base method

type MockCodecMockRecorder ¶

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

MockCodecMockRecorder is the mock recorder for MockCodec

func (*MockCodecMockRecorder) Decode ¶

func (mr *MockCodecMockRecorder) Decode(ctx, st, payloadType, bytes interface{}) *gomock.Call

Decode indicates an expected call of Decode

func (*MockCodecMockRecorder) Encode ¶

func (mr *MockCodecMockRecorder) Encode(ctx, st, payloadType, payload interface{}) *gomock.Call

Encode indicates an expected call of Encode

type Stream ¶

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

func (*Stream) Payload ¶

func (s *Stream) Payload(name string, enc EncodeFunc, dec DecodeFunc) *Stream

Source Files ¶

View all Source files

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