mocks

package
v1.13.1 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mock_srclient is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeConsumerGroup added in v1.13.1 

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

func NewConsumerGroup added in v1.13.1 

func NewConsumerGroup() *FakeConsumerGroup

func (*FakeConsumerGroup) Close added in v1.13.1 

func (f *FakeConsumerGroup) Close() error

func (*FakeConsumerGroup) Consume added in v1.13.1 

func (f *FakeConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error

func (*FakeConsumerGroup) Errors added in v1.13.1 

func (f *FakeConsumerGroup) Errors() <-chan error

func (*FakeConsumerGroup) Pause added in v1.13.1 

func (f *FakeConsumerGroup) Pause(partitions map[string][]int32)

func (*FakeConsumerGroup) PauseAll added in v1.13.1 

func (f *FakeConsumerGroup) PauseAll()

func (*FakeConsumerGroup) Resume added in v1.13.1 

func (f *FakeConsumerGroup) Resume(partitions map[string][]int32)

func (*FakeConsumerGroup) ResumeAll added in v1.13.1 

func (f *FakeConsumerGroup) ResumeAll()

func (*FakeConsumerGroup) WithCloseFn added in v1.13.1 

func (f *FakeConsumerGroup) WithCloseFn(fn func() error) *FakeConsumerGroup

func (*FakeConsumerGroup) WithConsumeFn added in v1.13.1 

func (f *FakeConsumerGroup) WithConsumeFn(fn func(context.Context, []string, sarama.ConsumerGroupHandler) error) *FakeConsumerGroup

func (*FakeConsumerGroup) WithErrorsFn added in v1.13.1 

func (f *FakeConsumerGroup) WithErrorsFn(fn func() <-chan error) *FakeConsumerGroup

func (*FakeConsumerGroup) WithPauseAllFn added in v1.13.1 

func (f *FakeConsumerGroup) WithPauseAllFn(fn func()) *FakeConsumerGroup

func (*FakeConsumerGroup) WithPauseFn added in v1.13.1 

func (f *FakeConsumerGroup) WithPauseFn(fn func(map[string][]int32)) *FakeConsumerGroup

func (*FakeConsumerGroup) WithResumeAllFn added in v1.13.1 

func (f *FakeConsumerGroup) WithResumeAllFn(fn func()) *FakeConsumerGroup

func (*FakeConsumerGroup) WithResumeFn added in v1.13.1 

func (f *FakeConsumerGroup) WithResumeFn(fn func(map[string][]int32)) *FakeConsumerGroup

type MockISchemaRegistryClient 

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

MockISchemaRegistryClient is a mock of ISchemaRegistryClient interface.

func NewMockISchemaRegistryClient 

func NewMockISchemaRegistryClient(ctrl *gomock.Controller) *MockISchemaRegistryClient

NewMockISchemaRegistryClient creates a new mock instance.

func (*MockISchemaRegistryClient) CachingEnabled 

func (m *MockISchemaRegistryClient) CachingEnabled(value bool)

CachingEnabled mocks base method.

func (*MockISchemaRegistryClient) ChangeSubjectCompatibilityLevel 

func (m *MockISchemaRegistryClient) ChangeSubjectCompatibilityLevel(subject string, compatibility srclient.CompatibilityLevel) (*srclient.CompatibilityLevel, error)

ChangeSubjectCompatibilityLevel mocks base method.

func (*MockISchemaRegistryClient) CodecCreationEnabled 

func (m *MockISchemaRegistryClient) CodecCreationEnabled(value bool)

CodecCreationEnabled mocks base method.

func (*MockISchemaRegistryClient) CreateSchema 

func (m *MockISchemaRegistryClient) CreateSchema(subject, schema string, schemaType srclient.SchemaType, references ...srclient.Reference) (*srclient.Schema, error)

CreateSchema mocks base method.

func (*MockISchemaRegistryClient) DeleteSubject 

func (m *MockISchemaRegistryClient) DeleteSubject(subject string, permanent bool) error

DeleteSubject mocks base method.

func (*MockISchemaRegistryClient) DeleteSubjectByVersion 

func (m *MockISchemaRegistryClient) DeleteSubjectByVersion(subject string, version int, permanent bool) error

DeleteSubjectByVersion mocks base method.

func (*MockISchemaRegistryClient) EXPECT 

func (m *MockISchemaRegistryClient) EXPECT() *MockISchemaRegistryClientMockRecorder

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

func (*MockISchemaRegistryClient) GetCompatibilityLevel 

func (m *MockISchemaRegistryClient) GetCompatibilityLevel(subject string, defaultToGlobal bool) (*srclient.CompatibilityLevel, error)

GetCompatibilityLevel mocks base method.

func (*MockISchemaRegistryClient) GetGlobalCompatibilityLevel 

func (m *MockISchemaRegistryClient) GetGlobalCompatibilityLevel() (*srclient.CompatibilityLevel, error)

GetGlobalCompatibilityLevel mocks base method.

func (*MockISchemaRegistryClient) GetLatestSchema 

func (m *MockISchemaRegistryClient) GetLatestSchema(subject string) (*srclient.Schema, error)

GetLatestSchema mocks base method.

func (*MockISchemaRegistryClient) GetSchema 

func (m *MockISchemaRegistryClient) GetSchema(schemaID int) (*srclient.Schema, error)

GetSchema mocks base method.

func (*MockISchemaRegistryClient) GetSchemaByVersion 

func (m *MockISchemaRegistryClient) GetSchemaByVersion(subject string, version int) (*srclient.Schema, error)

GetSchemaByVersion mocks base method.

func (*MockISchemaRegistryClient) GetSchemaVersions 

func (m *MockISchemaRegistryClient) GetSchemaVersions(subject string) ([]int, error)

GetSchemaVersions mocks base method.

func (*MockISchemaRegistryClient) GetSubjects 

func (m *MockISchemaRegistryClient) GetSubjects() ([]string, error)

GetSubjects mocks base method.

func (*MockISchemaRegistryClient) GetSubjectsIncludingDeleted 

func (m *MockISchemaRegistryClient) GetSubjectsIncludingDeleted() ([]string, error)

GetSubjectsIncludingDeleted mocks base method.

func (*MockISchemaRegistryClient) IsSchemaCompatible 

func (m *MockISchemaRegistryClient) IsSchemaCompatible(subject, schema, version string, schemaType srclient.SchemaType, references ...srclient.Reference) (bool, error)

IsSchemaCompatible mocks base method.

func (*MockISchemaRegistryClient) LookupSchema 

func (m *MockISchemaRegistryClient) LookupSchema(subject, schema string, schemaType srclient.SchemaType, references ...srclient.Reference) (*srclient.Schema, error)

LookupSchema mocks base method.

func (*MockISchemaRegistryClient) ResetCache 

func (m *MockISchemaRegistryClient) ResetCache()

ResetCache mocks base method.

func (*MockISchemaRegistryClient) SetBearerToken 

func (m *MockISchemaRegistryClient) SetBearerToken(token string)

SetBearerToken mocks base method.

func (*MockISchemaRegistryClient) SetCredentials 

func (m *MockISchemaRegistryClient) SetCredentials(username, password string)

SetCredentials mocks base method.

func (*MockISchemaRegistryClient) SetTimeout 

func (m *MockISchemaRegistryClient) SetTimeout(timeout time.Duration)

SetTimeout mocks base method.

type MockISchemaRegistryClientMockRecorder 

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

MockISchemaRegistryClientMockRecorder is the mock recorder for MockISchemaRegistryClient.

func (*MockISchemaRegistryClientMockRecorder) CachingEnabled 

func (mr *MockISchemaRegistryClientMockRecorder) CachingEnabled(value interface{}) *gomock.Call

CachingEnabled indicates an expected call of CachingEnabled.

func (*MockISchemaRegistryClientMockRecorder) ChangeSubjectCompatibilityLevel 

func (mr *MockISchemaRegistryClientMockRecorder) ChangeSubjectCompatibilityLevel(subject, compatibility interface{}) *gomock.Call

ChangeSubjectCompatibilityLevel indicates an expected call of ChangeSubjectCompatibilityLevel.

func (*MockISchemaRegistryClientMockRecorder) CodecCreationEnabled 

func (mr *MockISchemaRegistryClientMockRecorder) CodecCreationEnabled(value interface{}) *gomock.Call

CodecCreationEnabled indicates an expected call of CodecCreationEnabled.

func (*MockISchemaRegistryClientMockRecorder) CreateSchema 

func (mr *MockISchemaRegistryClientMockRecorder) CreateSchema(subject, schema, schemaType interface{}, references ...interface{}) *gomock.Call

CreateSchema indicates an expected call of CreateSchema.

func (*MockISchemaRegistryClientMockRecorder) DeleteSubject 

func (mr *MockISchemaRegistryClientMockRecorder) DeleteSubject(subject, permanent interface{}) *gomock.Call

DeleteSubject indicates an expected call of DeleteSubject.

func (*MockISchemaRegistryClientMockRecorder) DeleteSubjectByVersion 

func (mr *MockISchemaRegistryClientMockRecorder) DeleteSubjectByVersion(subject, version, permanent interface{}) *gomock.Call

DeleteSubjectByVersion indicates an expected call of DeleteSubjectByVersion.

func (*MockISchemaRegistryClientMockRecorder) GetCompatibilityLevel 

func (mr *MockISchemaRegistryClientMockRecorder) GetCompatibilityLevel(subject, defaultToGlobal interface{}) *gomock.Call

GetCompatibilityLevel indicates an expected call of GetCompatibilityLevel.

func (*MockISchemaRegistryClientMockRecorder) GetGlobalCompatibilityLevel 

func (mr *MockISchemaRegistryClientMockRecorder) GetGlobalCompatibilityLevel() *gomock.Call

GetGlobalCompatibilityLevel indicates an expected call of GetGlobalCompatibilityLevel.

func (*MockISchemaRegistryClientMockRecorder) GetLatestSchema 

func (mr *MockISchemaRegistryClientMockRecorder) GetLatestSchema(subject interface{}) *gomock.Call

GetLatestSchema indicates an expected call of GetLatestSchema.

func (*MockISchemaRegistryClientMockRecorder) GetSchema 

func (mr *MockISchemaRegistryClientMockRecorder) GetSchema(schemaID interface{}) *gomock.Call

GetSchema indicates an expected call of GetSchema.

func (*MockISchemaRegistryClientMockRecorder) GetSchemaByVersion 

func (mr *MockISchemaRegistryClientMockRecorder) GetSchemaByVersion(subject, version interface{}) *gomock.Call

GetSchemaByVersion indicates an expected call of GetSchemaByVersion.

func (*MockISchemaRegistryClientMockRecorder) GetSchemaVersions 

func (mr *MockISchemaRegistryClientMockRecorder) GetSchemaVersions(subject interface{}) *gomock.Call

GetSchemaVersions indicates an expected call of GetSchemaVersions.

func (*MockISchemaRegistryClientMockRecorder) GetSubjects 

func (mr *MockISchemaRegistryClientMockRecorder) GetSubjects() *gomock.Call

GetSubjects indicates an expected call of GetSubjects.

func (*MockISchemaRegistryClientMockRecorder) GetSubjectsIncludingDeleted 

func (mr *MockISchemaRegistryClientMockRecorder) GetSubjectsIncludingDeleted() *gomock.Call

GetSubjectsIncludingDeleted indicates an expected call of GetSubjectsIncludingDeleted.

func (*MockISchemaRegistryClientMockRecorder) IsSchemaCompatible 

func (mr *MockISchemaRegistryClientMockRecorder) IsSchemaCompatible(subject, schema, version, schemaType interface{}, references ...interface{}) *gomock.Call

IsSchemaCompatible indicates an expected call of IsSchemaCompatible.

func (*MockISchemaRegistryClientMockRecorder) LookupSchema 

func (mr *MockISchemaRegistryClientMockRecorder) LookupSchema(subject, schema, schemaType interface{}, references ...interface{}) *gomock.Call

LookupSchema indicates an expected call of LookupSchema.

func (*MockISchemaRegistryClientMockRecorder) ResetCache 

func (mr *MockISchemaRegistryClientMockRecorder) ResetCache() *gomock.Call

ResetCache indicates an expected call of ResetCache.

func (*MockISchemaRegistryClientMockRecorder) SetBearerToken 

func (mr *MockISchemaRegistryClientMockRecorder) SetBearerToken(token interface{}) *gomock.Call

SetBearerToken indicates an expected call of SetBearerToken.

func (*MockISchemaRegistryClientMockRecorder) SetCredentials 

func (mr *MockISchemaRegistryClientMockRecorder) SetCredentials(username, password interface{}) *gomock.Call

SetCredentials indicates an expected call of SetCredentials.

func (*MockISchemaRegistryClientMockRecorder) SetTimeout 

func (mr *MockISchemaRegistryClientMockRecorder) SetTimeout(timeout interface{}) *gomock.Call

SetTimeout indicates an expected call of SetTimeout.

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.