testutil

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: May 18, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package testutil provides mock implementations for testing DNS components.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockDNSService 

type MockDNSService struct {
	mock.Mock
}

MockDNSService implements ports.DNSService for testing.

func (*MockDNSService) CreateRecord 

func (m *MockDNSService) CreateRecord(_ context.Context, record *domain.Record) error

CreateRecord implements ports.DNSService for testing.

func (*MockDNSService) CreateZone 

func (m *MockDNSService) CreateZone(_ context.Context, zone *domain.Zone) error

CreateZone implements ports.DNSService for testing.

func (*MockDNSService) DeleteRecord 

func (m *MockDNSService) DeleteRecord(_ context.Context, recordID string, zoneID string, tenantID string) error

DeleteRecord implements ports.DNSService for testing.

func (*MockDNSService) DeleteZone 

func (m *MockDNSService) DeleteZone(_ context.Context, zoneID string, tenantID string) error

DeleteZone implements ports.DNSService for testing.

func (*MockDNSService) GetRecordsToProbeStreaming 

func (m *MockDNSService) GetRecordsToProbeStreaming(_ context.Context) (ports.RecordIterator, error)

GetRecordsToProbeStreaming implements ports.DNSService for testing.

func (*MockDNSService) HealthCheck 

func (m *MockDNSService) HealthCheck(_ context.Context) map[string]error

HealthCheck implements ports.DNSService for testing.

func (*MockDNSService) ImportZone 

func (m *MockDNSService) ImportZone(_ context.Context, tenantID string, r io.Reader) (*domain.Zone, error)

ImportZone implements ports.DNSService for testing.

func (*MockDNSService) ListAuditLogs 

func (m *MockDNSService) ListAuditLogs(_ context.Context, tenantID string) ([]domain.AuditLog, error)

ListAuditLogs implements ports.DNSService for testing.

func (*MockDNSService) ListRecordsForZone 

func (m *MockDNSService) ListRecordsForZone(_ context.Context, zoneID string, tenantID string) ([]domain.Record, error)

ListRecordsForZone implements ports.DNSService for testing.

func (*MockDNSService) ListZones 

func (m *MockDNSService) ListZones(_ context.Context, tenantID string) ([]domain.Zone, error)

ListZones implements ports.DNSService for testing.

func (*MockDNSService) Resolve 

func (m *MockDNSService) Resolve(_ context.Context, name string, qType domain.RecordType, clientIP string) ([]domain.Record, error)

Resolve implements ports.DNSService for testing.

func (*MockDNSService) UpdateRecord 

func (m *MockDNSService) UpdateRecord(_ context.Context, record *domain.Record) error

UpdateRecord implements ports.DNSService for testing.

func (*MockDNSService) UpdateRecordHealth 

func (m *MockDNSService) UpdateRecordHealth(_ context.Context, recordID string, status domain.HealthStatus, errMsg string) error

UpdateRecordHealth implements ports.DNSService for testing.

type MockRepo 

type MockRepo struct {
	mock.Mock
}

MockRepo implements ports.DNSRepository for testing.

func (*MockRepo) ApplyZoneUpdate 

func (m *MockRepo) ApplyZoneUpdate(_ context.Context, zoneID string, operations []domain.UpdateOperation, changes []domain.ZoneChange) (uint32, error)

ApplyZoneUpdate implements ports.DNSRepository for testing.

func (*MockRepo) BatchCreateRecords 

func (m *MockRepo) BatchCreateRecords(_ context.Context, records []domain.Record) error

BatchCreateRecords implements ports.DNSRepository for testing.

func (*MockRepo) CreateAPIKey 

func (m *MockRepo) CreateAPIKey(_ context.Context, key *domain.APIKey) error

CreateAPIKey implements ports.DNSRepository for testing.

func (*MockRepo) CreateKey 

func (m *MockRepo) CreateKey(_ context.Context, key *domain.DNSSECKey) error

CreateKey implements ports.DNSRepository for testing.

func (*MockRepo) CreateRecord 

func (m *MockRepo) CreateRecord(_ context.Context, record *domain.Record) error

CreateRecord implements ports.DNSRepository for testing.

func (*MockRepo) CreateZone 

func (m *MockRepo) CreateZone(_ context.Context, zone *domain.Zone) error

CreateZone implements ports.DNSRepository for testing.

func (*MockRepo) CreateZoneWithRecords 

func (m *MockRepo) CreateZoneWithRecords(_ context.Context, zone *domain.Zone, records []domain.Record) error

CreateZoneWithRecords implements ports.DNSRepository for testing.

func (*MockRepo) DeleteAPIKey 

func (m *MockRepo) DeleteAPIKey(_ context.Context, tenantID string, id string) error

DeleteAPIKey implements ports.DNSRepository for testing.

func (*MockRepo) DeleteRecord 

func (m *MockRepo) DeleteRecord(_ context.Context, recordID string, zoneID string, tenantID string) error

DeleteRecord implements ports.DNSRepository for testing.

func (*MockRepo) DeleteRecordSpecific 

func (m *MockRepo) DeleteRecordSpecific(_ context.Context, zoneID string, name string, qType domain.RecordType, content string) error

DeleteRecordSpecific implements ports.DNSRepository for testing.

func (*MockRepo) DeleteRecordsByName 

func (m *MockRepo) DeleteRecordsByName(_ context.Context, zoneID string, name string) error

DeleteRecordsByName implements ports.DNSRepository for testing.

func (*MockRepo) DeleteRecordsByNameAndType 

func (m *MockRepo) DeleteRecordsByNameAndType(_ context.Context, zoneID string, name string, qType domain.RecordType) error

DeleteRecordsByNameAndType implements ports.DNSRepository for testing.

func (*MockRepo) DeleteRecordsForZone 

func (m *MockRepo) DeleteRecordsForZone(_ context.Context, zoneID string) error

DeleteRecordsForZone implements ports.DNSRepository for testing.

func (*MockRepo) DeleteZone 

func (m *MockRepo) DeleteZone(_ context.Context, zoneID string, tenantID string) error

DeleteZone implements ports.DNSRepository for testing.

func (*MockRepo) GetAPIKeyByHash 

func (m *MockRepo) GetAPIKeyByHash(_ context.Context, keyHash string) (*domain.APIKey, error)

GetAPIKeyByHash implements ports.DNSRepository for testing.

func (*MockRepo) GetAuditLogs 

func (m *MockRepo) GetAuditLogs(_ context.Context, tenantID string) ([]domain.AuditLog, error)

GetAuditLogs implements ports.DNSRepository for testing.

func (*MockRepo) GetDNSKEYs 

func (m *MockRepo) GetDNSKEYs(_ context.Context, zoneName string) ([]domain.Record, error)

GetDNSKEYs implements ports.DNSRepository for testing.

func (*MockRepo) GetIPsForName 

func (m *MockRepo) GetIPsForName(_ context.Context, name string, clientIP string) ([]string, error)

GetIPsForName implements ports.DNSRepository for testing.

func (*MockRepo) GetIXFRChain 

func (m *MockRepo) GetIXFRChain(_ context.Context, zoneID string, fromSerial uint32, toSerial uint32) ([]domain.IXFRChunk, error)

GetIXFRChain implements ports.DNSRepository for testing.

func (*MockRepo) GetRecord 

func (m *MockRepo) GetRecord(_ context.Context, id string, zoneID string, tenantID string) (*domain.Record, error)

GetRecord implements ports.DNSRepository for testing.

func (*MockRepo) GetRecords 

func (m *MockRepo) GetRecords(_ context.Context, name string, qType domain.RecordType, clientIP string) ([]domain.Record, error)

GetRecords implements ports.DNSRepository for testing.

func (*MockRepo) GetRecordsByNames 

func (m *MockRepo) GetRecordsByNames(_ context.Context, names []string, qType domain.RecordType, clientIP string) (map[string][]domain.Record, error)

GetRecordsByNames implements ports.DNSRepository for testing.

func (*MockRepo) GetRecordsToProbeStreaming 

func (m *MockRepo) GetRecordsToProbeStreaming(_ context.Context) (ports.RecordIterator, error)

GetRecordsToProbeStreaming implements ports.DNSRepository for testing.

func (*MockRepo) GetZone 

func (m *MockRepo) GetZone(_ context.Context, name string) (*domain.Zone, error)

GetZone implements ports.DNSRepository for testing.

func (*MockRepo) GetZoneLongestMatch 

func (m *MockRepo) GetZoneLongestMatch(_ context.Context, qName string) (*domain.Zone, error)

GetZoneLongestMatch implements ports.DNSRepository for testing.

func (*MockRepo) ListAPIKeys 

func (m *MockRepo) ListAPIKeys(_ context.Context, tenantID string) ([]domain.APIKey, error)

ListAPIKeys implements ports.DNSRepository for testing.

func (*MockRepo) ListKeysForZone 

func (m *MockRepo) ListKeysForZone(_ context.Context, zoneID string) ([]domain.DNSSECKey, error)

ListKeysForZone implements ports.DNSRepository for testing.

func (*MockRepo) ListRecordsForZone 

func (m *MockRepo) ListRecordsForZone(_ context.Context, zoneID string, tenantID string) ([]domain.Record, error)

ListRecordsForZone implements ports.DNSRepository for testing.

func (*MockRepo) ListRecordsForZoneStreaming 

func (m *MockRepo) ListRecordsForZoneStreaming(_ context.Context, zoneID string, tenantID string) (ports.RecordIterator, error)

ListRecordsForZoneStreaming implements ports.DNSRepository for testing.

func (*MockRepo) ListZoneChanges 

func (m *MockRepo) ListZoneChanges(_ context.Context, zoneID string, fromSerial uint32) ([]domain.ZoneChange, error)

ListZoneChanges implements ports.DNSRepository for testing.

func (*MockRepo) ListZones 

func (m *MockRepo) ListZones(_ context.Context, tenantID string) ([]domain.Zone, error)

ListZones implements ports.DNSRepository for testing.

func (*MockRepo) Ping 

func (m *MockRepo) Ping(_ context.Context) error

Ping implements ports.DNSRepository for testing.

func (*MockRepo) RecordZoneChange 

func (m *MockRepo) RecordZoneChange(_ context.Context, change *domain.ZoneChange) error

RecordZoneChange implements ports.DNSRepository for testing.

func (*MockRepo) SaveAuditLog 

func (m *MockRepo) SaveAuditLog(_ context.Context, log *domain.AuditLog) error

SaveAuditLog implements ports.DNSRepository for testing.

func (*MockRepo) UpdateKey 

func (m *MockRepo) UpdateKey(_ context.Context, key *domain.DNSSECKey) error

UpdateKey implements ports.DNSRepository for testing.

func (*MockRepo) UpdateRecord 

func (m *MockRepo) UpdateRecord(_ context.Context, record *domain.Record) error

UpdateRecord implements ports.DNSRepository for testing.

func (*MockRepo) UpdateRecordHealth 

func (m *MockRepo) UpdateRecordHealth(ctx context.Context, recordID string, status domain.HealthStatus, errMsg string) error

UpdateRecordHealth implements ports.DNSRepository for testing.

type MockRoutingEngine 

type MockRoutingEngine struct {
	Announced        bool
	WithdrawCount    int
	AnnounceAttempts int
	WithdrawAttempts int
	FailAnnounce     bool
	FailWithdraw     bool
}

MockRoutingEngine implements ports.RoutingEngine for testing.

func (*MockRoutingEngine) Announce 

func (m *MockRoutingEngine) Announce(_ context.Context, _ string) error

Announce implements ports.RoutingEngine for testing.

func (*MockRoutingEngine) Start 

func (m *MockRoutingEngine) Start(_ context.Context, _, _ uint32, _ string) error

Start implements ports.RoutingEngine for testing.

func (*MockRoutingEngine) Stop 

func (m *MockRoutingEngine) Stop() error

Stop implements ports.RoutingEngine for testing.

func (*MockRoutingEngine) Withdraw 

func (m *MockRoutingEngine) Withdraw(_ context.Context, _ string) error

Withdraw implements ports.RoutingEngine for testing.

type MockVIPManager 

type MockVIPManager struct {
	Bound    bool
	FailBind bool
}

MockVIPManager implements ports.VIPManager for testing.

func (*MockVIPManager) Bind 

func (m *MockVIPManager) Bind(_ context.Context, _, _ string) error

Bind implements ports.VIPManager for testing.

func (*MockVIPManager) Unbind 

func (m *MockVIPManager) Unbind(_ context.Context, _, _ string) error

Unbind implements ports.VIPManager for testing.

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.