source

package
v0.12.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package source is a generated GoMock package.

Package source is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client added in v0.8.1 

type Client interface {
	Close()
	CommitRecords(ctx context.Context, rs ...*kgo.Record) error
	OptValue(opt any) any
	PollFetches(ctx context.Context) kgo.Fetches
}

Client is a franz-go kafka client.

type Config 

type Config struct {
	sdk.DefaultSourceMiddleware
	common.Config

	// Topics is a comma separated list of Kafka topics to read from.
	Topics []string `json:"topics" validate:"required"`
	// ReadFromBeginning determines from whence the consumer group should begin
	// consuming when it finds a partition without a committed offset. If this
	// options is set to true it will start with the first message in that
	// partition.
	ReadFromBeginning bool `json:"readFromBeginning"`
	// GroupID defines the consumer group id.
	GroupID string `json:"groupID"`
	// RetryGroupJoinErrors determines whether the connector will continually retry on group join errors.
	RetryGroupJoinErrors bool `json:"retryGroupJoinErrors" default:"true"`
}

func (*Config) Validate 

func (c *Config) Validate(ctx context.Context) error

type Consumer 

type Consumer interface {
	// Consume returns the next message from the configured topic. Waits until a
	// message is available or until the context is canceled.
	Consume(context.Context) (*Record, error)
	// Ack commits the offset to Kafka.
	Ack(context.Context) error
	// Close this consumer and the associated resources.
	Close(context.Context) error
}

Consumer is a kafka consumer.

type FranzConsumer 

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

func NewFranzConsumer 

func NewFranzConsumer(ctx context.Context, cfg Config) (*FranzConsumer, error)

func (*FranzConsumer) Ack 

func (c *FranzConsumer) Ack(ctx context.Context) error

func (*FranzConsumer) Close 

func (c *FranzConsumer) Close(ctx context.Context) error

func (*FranzConsumer) Consume 

func (c *FranzConsumer) Consume(ctx context.Context) (*Record, error)

type MockClient added in v0.8.1 

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

MockClient is a mock of Client interface.

func NewMockClient added in v0.8.1 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) Close added in v0.8.1 

func (m *MockClient) Close()

Close mocks base method.

func (*MockClient) CommitRecords added in v0.8.1 

func (m *MockClient) CommitRecords(ctx context.Context, rs ...*kgo.Record) error

CommitRecords mocks base method.

func (*MockClient) EXPECT added in v0.8.1 

func (m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) OptValue added in v0.8.1 

func (m *MockClient) OptValue(opt any) any

OptValue mocks base method.

func (*MockClient) PollFetches added in v0.8.1 

func (m *MockClient) PollFetches(ctx context.Context) kgo.Fetches

PollFetches mocks base method.

type MockClientCloseCall added in v0.8.1 

type MockClientCloseCall struct {
	*gomock.Call
}

MockClientCloseCall wrap *gomock.Call

func (*MockClientCloseCall) Do added in v0.8.1 

func (c *MockClientCloseCall) Do(f func()) *MockClientCloseCall

Do rewrite *gomock.Call.Do

func (*MockClientCloseCall) DoAndReturn added in v0.8.1 

func (c *MockClientCloseCall) DoAndReturn(f func()) *MockClientCloseCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientCloseCall) Return added in v0.8.1 

func (c *MockClientCloseCall) Return() *MockClientCloseCall

Return rewrite *gomock.Call.Return

type MockClientCommitRecordsCall added in v0.8.1 

type MockClientCommitRecordsCall struct {
	*gomock.Call
}

MockClientCommitRecordsCall wrap *gomock.Call

func (*MockClientCommitRecordsCall) Do added in v0.8.1 

func (c *MockClientCommitRecordsCall) Do(f func(context.Context, ...*kgo.Record) error) *MockClientCommitRecordsCall

Do rewrite *gomock.Call.Do

func (*MockClientCommitRecordsCall) DoAndReturn added in v0.8.1 

func (c *MockClientCommitRecordsCall) DoAndReturn(f func(context.Context, ...*kgo.Record) error) *MockClientCommitRecordsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientCommitRecordsCall) Return added in v0.8.1 

func (c *MockClientCommitRecordsCall) Return(arg0 error) *MockClientCommitRecordsCall

Return rewrite *gomock.Call.Return

type MockClientMockRecorder added in v0.8.1 

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) Close added in v0.8.1 

func (mr *MockClientMockRecorder) Close() *MockClientCloseCall

Close indicates an expected call of Close.

func (*MockClientMockRecorder) CommitRecords added in v0.8.1 

func (mr *MockClientMockRecorder) CommitRecords(ctx any, rs ...any) *MockClientCommitRecordsCall

CommitRecords indicates an expected call of CommitRecords.

func (*MockClientMockRecorder) OptValue added in v0.8.1 

func (mr *MockClientMockRecorder) OptValue(opt any) *MockClientOptValueCall

OptValue indicates an expected call of OptValue.

func (*MockClientMockRecorder) PollFetches added in v0.8.1 

func (mr *MockClientMockRecorder) PollFetches(ctx any) *MockClientPollFetchesCall

PollFetches indicates an expected call of PollFetches.

type MockClientOptValueCall added in v0.8.1 

type MockClientOptValueCall struct {
	*gomock.Call
}

MockClientOptValueCall wrap *gomock.Call

func (*MockClientOptValueCall) Do added in v0.8.1 

func (c *MockClientOptValueCall) Do(f func(any) any) *MockClientOptValueCall

Do rewrite *gomock.Call.Do

func (*MockClientOptValueCall) DoAndReturn added in v0.8.1 

func (c *MockClientOptValueCall) DoAndReturn(f func(any) any) *MockClientOptValueCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientOptValueCall) Return added in v0.8.1 

func (c *MockClientOptValueCall) Return(arg0 any) *MockClientOptValueCall

Return rewrite *gomock.Call.Return

type MockClientPollFetchesCall added in v0.8.1 

type MockClientPollFetchesCall struct {
	*gomock.Call
}

MockClientPollFetchesCall wrap *gomock.Call

func (*MockClientPollFetchesCall) Do added in v0.8.1 

func (c *MockClientPollFetchesCall) Do(f func(context.Context) kgo.Fetches) *MockClientPollFetchesCall

Do rewrite *gomock.Call.Do

func (*MockClientPollFetchesCall) DoAndReturn added in v0.8.1 

func (c *MockClientPollFetchesCall) DoAndReturn(f func(context.Context) kgo.Fetches) *MockClientPollFetchesCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientPollFetchesCall) Return added in v0.8.1 

func (c *MockClientPollFetchesCall) Return(arg0 kgo.Fetches) *MockClientPollFetchesCall

Return rewrite *gomock.Call.Return

type MockConsumer 

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

MockConsumer is a mock of Consumer interface.

func NewMockConsumer 

func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer

NewMockConsumer creates a new mock instance.

func (*MockConsumer) Ack 

func (m *MockConsumer) Ack(arg0 context.Context) error

Ack mocks base method.

func (*MockConsumer) Close 

func (m *MockConsumer) Close(arg0 context.Context) error

Close mocks base method.

func (*MockConsumer) Consume 

func (m *MockConsumer) Consume(arg0 context.Context) (*Record, error)

Consume mocks base method.

func (*MockConsumer) EXPECT 

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

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

type MockConsumerMockRecorder 

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

MockConsumerMockRecorder is the mock recorder for MockConsumer.

func (*MockConsumerMockRecorder) Ack 

func (mr *MockConsumerMockRecorder) Ack(arg0 any) *gomock.Call

Ack indicates an expected call of Ack.

func (*MockConsumerMockRecorder) Close 

func (mr *MockConsumerMockRecorder) Close(arg0 any) *gomock.Call

Close indicates an expected call of Close.

func (*MockConsumerMockRecorder) Consume 

func (mr *MockConsumerMockRecorder) Consume(arg0 any) *gomock.Call

Consume indicates an expected call of Consume.

type Position 

type Position struct {
	GroupID   string
	Topic     string
	Partition int32
	Offset    int64
}

func ParseSDKPosition 

func ParseSDKPosition(sdkPos opencdc.Position) (Position, error)

func (Position) ToSDKPosition 

func (p Position) ToSDKPosition() opencdc.Position

type Record 

type Record kgo.Record

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.