testing

Documentation

Index

• Constants
• func NewRefInfo(options ...RefInfoOption) *refmappers.RefInfo
• type MockResetOffsetRefMapper
  • func (m *MockResetOffsetRefMapper) MapRef(resetOffset *kafkav1alpha1.ResetOffset) (*refmappers.RefInfo, error)
• type MockResetOffsetRefMapperFactory
  • func (f *MockResetOffsetRefMapperFactory) Create(ctx context.Context) refmappers.ResetOffsetRefMapper
• type RefInfoOption

Constants

const (
	ConnectionPoolKey    = "TestConnectionPoolKey"
	DataPlaneNamespace   = "TestDataPlaneNamespace"
	DataPlaneLabelKey1   = "TestDataPlaneLabelKey1"
	DataPlaneLabelValue1 = "TestDataPlaneLabelValue1"
	DataPlaneLabelKey2   = "TestDataPlaneLabelKey2"
	DataPlaneLabelValue2 = "TestDataPlaneLabelValue2"
)

Functions

func NewRefInfo

func NewRefInfo(options ...RefInfoOption) *refmappers.RefInfo

NewRefInfo creates a custom NewRefInfo

Types

type MockResetOffsetRefMapper

type MockResetOffsetRefMapper struct {
	mock.Mock
}

func (*MockResetOffsetRefMapper) MapRef

func (m *MockResetOffsetRefMapper) MapRef(resetOffset *kafkav1alpha1.ResetOffset) (*refmappers.RefInfo, error)

type MockResetOffsetRefMapperFactory

type MockResetOffsetRefMapperFactory struct {
	mock.Mock
}

func (*MockResetOffsetRefMapperFactory) Create

func (f *MockResetOffsetRefMapperFactory) Create(ctx context.Context) refmappers.ResetOffsetRefMapper

type RefInfoOption

type RefInfoOption func(refInfo *refmappers.RefInfo)

RefInfoOption allow for customizing a RefInfo