avro

Documentation

Overview

Package avro is a generated GoMock package.

Package avro is a generated GoMock package.

Index

• func NewDecodeProcessor(logger log.CtxLogger) sdk.Processor
• func NewEncodeProcessor(logger log.CtxLogger) sdk.Processor
• type MockDecoder
  • func NewMockDecoder(ctrl *gomock.Controller) *MockDecoder
  • func (m *MockDecoder) Decode(ctx context.Context, b opencdc.RawData) (opencdc.StructuredData, error)
  • func (m *MockDecoder) EXPECT() *MockDecoderMockRecorder
• type MockDecoderDecodeCall
  • func (c *MockDecoderDecodeCall) Do(f func(context.Context, opencdc.RawData) (opencdc.StructuredData, error)) *MockDecoderDecodeCall
  • func (c *MockDecoderDecodeCall) DoAndReturn(f func(context.Context, opencdc.RawData) (opencdc.StructuredData, error)) *MockDecoderDecodeCall
  • func (c *MockDecoderDecodeCall) Return(arg0 opencdc.StructuredData, arg1 error) *MockDecoderDecodeCall
• type MockDecoderMockRecorder
  • func (mr *MockDecoderMockRecorder) Decode(ctx, b any) *MockDecoderDecodeCall
• type MockEncoder
  • func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder
  • func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder
  • func (m *MockEncoder) Encode(ctx context.Context, sd opencdc.StructuredData) (opencdc.RawData, error)
• type MockEncoderEncodeCall
  • func (c *MockEncoderEncodeCall) Do(f func(context.Context, opencdc.StructuredData) (opencdc.RawData, error)) *MockEncoderEncodeCall
  • func (c *MockEncoderEncodeCall) DoAndReturn(f func(context.Context, opencdc.StructuredData) (opencdc.RawData, error)) *MockEncoderEncodeCall
  • func (c *MockEncoderEncodeCall) Return(arg0 opencdc.RawData, arg1 error) *MockEncoderEncodeCall
• type MockEncoderMockRecorder
  • func (mr *MockEncoderMockRecorder) Encode(ctx, sd any) *MockEncoderEncodeCall

Functions

func NewDecodeProcessor

func NewDecodeProcessor(logger log.CtxLogger) sdk.Processor

func NewEncodeProcessor

func NewEncodeProcessor(logger log.CtxLogger) sdk.Processor

Types

type MockDecoder

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

MockDecoder is a mock of decoder interface.

func NewMockDecoder

func NewMockDecoder(ctrl *gomock.Controller) *MockDecoder

NewMockDecoder creates a new mock instance.

func (*MockDecoder) Decode

func (m *MockDecoder) Decode(ctx context.Context, b opencdc.RawData) (opencdc.StructuredData, error)

Decode mocks base method.

func (*MockDecoder) EXPECT

func (m *MockDecoder) EXPECT() *MockDecoderMockRecorder

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

type MockDecoderDecodeCall

type MockDecoderDecodeCall struct {
	*gomock.Call
}

MockDecoderDecodeCall wrap *gomock.Call

func (*MockDecoderDecodeCall) Do

func (c *MockDecoderDecodeCall) Do(f func(context.Context, opencdc.RawData) (opencdc.StructuredData, error)) *MockDecoderDecodeCall

Do rewrite *gomock.Call.Do

func (*MockDecoderDecodeCall) DoAndReturn

func (c *MockDecoderDecodeCall) DoAndReturn(f func(context.Context, opencdc.RawData) (opencdc.StructuredData, error)) *MockDecoderDecodeCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDecoderDecodeCall) Return

func (c *MockDecoderDecodeCall) Return(arg0 opencdc.StructuredData, arg1 error) *MockDecoderDecodeCall

Return rewrite *gomock.Call.Return

type MockDecoderMockRecorder

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

MockDecoderMockRecorder is the mock recorder for MockDecoder.

func (*MockDecoderMockRecorder) Decode

func (mr *MockDecoderMockRecorder) Decode(ctx, b any) *MockDecoderDecodeCall

Decode indicates an expected call of Decode.

type MockEncoder

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

MockEncoder is a mock of encoder interface.

func NewMockEncoder

func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder

NewMockEncoder creates a new mock instance.

func (*MockEncoder) EXPECT

func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder

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

func (*MockEncoder) Encode

func (m *MockEncoder) Encode(ctx context.Context, sd opencdc.StructuredData) (opencdc.RawData, error)

Encode mocks base method.

type MockEncoderEncodeCall

type MockEncoderEncodeCall struct {
	*gomock.Call
}

MockEncoderEncodeCall wrap *gomock.Call

func (*MockEncoderEncodeCall) Do

func (c *MockEncoderEncodeCall) Do(f func(context.Context, opencdc.StructuredData) (opencdc.RawData, error)) *MockEncoderEncodeCall

Do rewrite *gomock.Call.Do

func (*MockEncoderEncodeCall) DoAndReturn

func (c *MockEncoderEncodeCall) DoAndReturn(f func(context.Context, opencdc.StructuredData) (opencdc.RawData, error)) *MockEncoderEncodeCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockEncoderEncodeCall) Return

func (c *MockEncoderEncodeCall) Return(arg0 opencdc.RawData, arg1 error) *MockEncoderEncodeCall

Return rewrite *gomock.Call.Return

type MockEncoderMockRecorder

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

MockEncoderMockRecorder is the mock recorder for MockEncoder.

func (*MockEncoderMockRecorder) Encode

func (mr *MockEncoderMockRecorder) Encode(ctx, sd any) *MockEncoderEncodeCall

Encode indicates an expected call of Encode.