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 MockDecoderMockRecorder
  • func (mr *MockDecoderMockRecorder) Decode(ctx, b any) *gomock.Call
• 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 MockEncoderMockRecorder
  • func (mr *MockEncoderMockRecorder) Encode(ctx, sd any) *gomock.Call

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 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) *gomock.Call

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 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) *gomock.Call

Encode indicates an expected call of Encode.