Versions in this module Expand all Collapse all v1 v1.15.1 Jun 9, 2025 Changes in this version + type FakeConsumerGroup struct + func NewConsumerGroup() *FakeConsumerGroup + func (f *FakeConsumerGroup) Close() error + func (f *FakeConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error + func (f *FakeConsumerGroup) Errors() <-chan error + func (f *FakeConsumerGroup) Pause(partitions map[string][]int32) + func (f *FakeConsumerGroup) PauseAll() + func (f *FakeConsumerGroup) Resume(partitions map[string][]int32) + func (f *FakeConsumerGroup) ResumeAll() + func (f *FakeConsumerGroup) WithCloseFn(fn func() error) *FakeConsumerGroup + func (f *FakeConsumerGroup) WithConsumeFn(fn func(context.Context, []string, sarama.ConsumerGroupHandler) error) *FakeConsumerGroup + func (f *FakeConsumerGroup) WithErrorsFn(fn func() <-chan error) *FakeConsumerGroup + func (f *FakeConsumerGroup) WithPauseAllFn(fn func()) *FakeConsumerGroup + func (f *FakeConsumerGroup) WithPauseFn(fn func(map[string][]int32)) *FakeConsumerGroup + func (f *FakeConsumerGroup) WithResumeAllFn(fn func()) *FakeConsumerGroup + func (f *FakeConsumerGroup) WithResumeFn(fn func(map[string][]int32)) *FakeConsumerGroup + type MockISchemaRegistryClient struct + func NewMockISchemaRegistryClient(ctrl *gomock.Controller) *MockISchemaRegistryClient + func (m *MockISchemaRegistryClient) CachingEnabled(value bool) + func (m *MockISchemaRegistryClient) ChangeSubjectCompatibilityLevel(subject string, compatibility srclient.CompatibilityLevel) (*srclient.CompatibilityLevel, error) + func (m *MockISchemaRegistryClient) CodecCreationEnabled(value bool) + func (m *MockISchemaRegistryClient) CreateSchema(subject, schema string, schemaType srclient.SchemaType, ...) (*srclient.Schema, error) + func (m *MockISchemaRegistryClient) DeleteSubject(subject string, permanent bool) error + func (m *MockISchemaRegistryClient) DeleteSubjectByVersion(subject string, version int, permanent bool) error + func (m *MockISchemaRegistryClient) EXPECT() *MockISchemaRegistryClientMockRecorder + func (m *MockISchemaRegistryClient) GetCompatibilityLevel(subject string, defaultToGlobal bool) (*srclient.CompatibilityLevel, error) + func (m *MockISchemaRegistryClient) GetGlobalCompatibilityLevel() (*srclient.CompatibilityLevel, error) + func (m *MockISchemaRegistryClient) GetLatestSchema(subject string) (*srclient.Schema, error) + func (m *MockISchemaRegistryClient) GetSchema(schemaID int) (*srclient.Schema, error) + func (m *MockISchemaRegistryClient) GetSchemaByVersion(subject string, version int) (*srclient.Schema, error) + func (m *MockISchemaRegistryClient) GetSchemaVersions(subject string) ([]int, error) + func (m *MockISchemaRegistryClient) GetSubjects() ([]string, error) + func (m *MockISchemaRegistryClient) GetSubjectsIncludingDeleted() ([]string, error) + func (m *MockISchemaRegistryClient) IsSchemaCompatible(subject, schema, version string, schemaType srclient.SchemaType, ...) (bool, error) + func (m *MockISchemaRegistryClient) LookupSchema(subject, schema string, schemaType srclient.SchemaType, ...) (*srclient.Schema, error) + func (m *MockISchemaRegistryClient) ResetCache() + func (m *MockISchemaRegistryClient) SetBearerToken(token string) + func (m *MockISchemaRegistryClient) SetCredentials(username, password string) + func (m *MockISchemaRegistryClient) SetTimeout(timeout time.Duration) + type MockISchemaRegistryClientMockRecorder struct + func (mr *MockISchemaRegistryClientMockRecorder) CachingEnabled(value interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) ChangeSubjectCompatibilityLevel(subject, compatibility interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) CodecCreationEnabled(value interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) CreateSchema(subject, schema, schemaType interface{}, references ...interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) DeleteSubject(subject, permanent interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) DeleteSubjectByVersion(subject, version, permanent interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetCompatibilityLevel(subject, defaultToGlobal interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetGlobalCompatibilityLevel() *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetLatestSchema(subject interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetSchema(schemaID interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetSchemaByVersion(subject, version interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetSchemaVersions(subject interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetSubjects() *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) GetSubjectsIncludingDeleted() *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) IsSchemaCompatible(subject, schema, version, schemaType interface{}, references ...interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) LookupSchema(subject, schema, schemaType interface{}, references ...interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) ResetCache() *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) SetBearerToken(token interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) SetCredentials(username, password interface{}) *gomock.Call + func (mr *MockISchemaRegistryClientMockRecorder) SetTimeout(timeout interface{}) *gomock.Call
Go to main page