utils

package
v0.10.3 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2021 License: Apache-2.0, BSD-3-Clause, MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DNSEntryType = (*api.DNSEntry)(nil)
View Source 
var DNSHostedZonePolicyType = (*api.DNSHostedZonePolicy)(nil)
View Source 
var DNSOwnerType = (*api.DNSOwner)(nil)
View Source 
var DNSProviderType = (*api.DNSProvider)(nil)

Functions

func DNSProviderKey 

func DNSProviderKey(namespace, name string) resources.ObjectKey

func Match 

func Match(hostname, domain string) bool

func MatchSet 

func MatchSet(hostname string, domains utils.StringSet) int

func ProcessElements 

func ProcessElements(elems Elements, exec Executor, processors int)

func SetLastUpdateTime added in v0.7.21 

func SetLastUpdateTime(lastUptimeTime **metav1.Time)

SetLastUpdateTime sets the time wrapper to the current UTC time.

Types

type DNSEntryObject 

type DNSEntryObject struct {
	resources.Object
}

func DNSEntry 

func DNSEntry(o resources.Object) *DNSEntryObject

func (*DNSEntryObject) DNSEntry 

func (this *DNSEntryObject) DNSEntry() *api.DNSEntry

func (*DNSEntryObject) GetCNameLookupInterval 

func (this *DNSEntryObject) GetCNameLookupInterval() *int64

func (*DNSEntryObject) GetDNSName 

func (this *DNSEntryObject) GetDNSName() string

func (*DNSEntryObject) GetOwnerId 

func (this *DNSEntryObject) GetOwnerId() *string

func (*DNSEntryObject) GetTTL 

func (this *DNSEntryObject) GetTTL() *int64

func (*DNSEntryObject) GetTargets 

func (this *DNSEntryObject) GetTargets() []string

func (*DNSEntryObject) Spec 

func (this *DNSEntryObject) Spec() *api.DNSEntrySpec

func (*DNSEntryObject) Status 

func (this *DNSEntryObject) Status() *api.DNSEntryStatus

func (*DNSEntryObject) StatusField added in v0.7.12 

func (this *DNSEntryObject) StatusField() interface{}

type DNSHostedZonePolicyObject added in v0.10.3 

type DNSHostedZonePolicyObject struct {
	resources.Object
}

func DNSHostedZonePolicy added in v0.10.3 

func DNSHostedZonePolicy(o resources.Object) *DNSHostedZonePolicyObject

func (*DNSHostedZonePolicyObject) DNSHostedZonePolicyObject added in v0.10.3 

func (this *DNSHostedZonePolicyObject) DNSHostedZonePolicyObject() *api.DNSHostedZonePolicy

func (*DNSHostedZonePolicyObject) Spec added in v0.10.3 

func (this *DNSHostedZonePolicyObject) Spec() *api.DNSHostedZonePolicySpec

func (*DNSHostedZonePolicyObject) Status added in v0.10.3 

func (this *DNSHostedZonePolicyObject) Status() *api.DNSHostedZonePolicyStatus

type DNSOwnerObject 

type DNSOwnerObject struct {
	resources.Object
}

func DNSOwner 

func DNSOwner(o resources.Object) *DNSOwnerObject

func (*DNSOwnerObject) DNSOwner 

func (this *DNSOwnerObject) DNSOwner() *api.DNSOwner

func (*DNSOwnerObject) GetCount added in v0.7.12 

func (this *DNSOwnerObject) GetCount() int

func (*DNSOwnerObject) GetCounts added in v0.7.12 

func (this *DNSOwnerObject) GetCounts() map[string]int

func (*DNSOwnerObject) GetOwnerId 

func (this *DNSOwnerObject) GetOwnerId() string

func (*DNSOwnerObject) IsActive 

func (this *DNSOwnerObject) IsActive() bool

func (*DNSOwnerObject) IsEnabled added in v0.10.3 

func (this *DNSOwnerObject) IsEnabled() bool

func (*DNSOwnerObject) Spec 

func (this *DNSOwnerObject) Spec() *api.DNSOwnerSpec

func (*DNSOwnerObject) ValidUntil added in v0.10.3 

func (this *DNSOwnerObject) ValidUntil() *metav1.Time

type DNSProviderObject 

type DNSProviderObject struct {
	resources.Object
}

func DNSProvider 

func DNSProvider(o resources.Object) *DNSProviderObject

func GetDNSProvider 

func GetDNSProvider(src resources.ResourcesSource, namespace, name string) (*DNSProviderObject, error)

func (*DNSProviderObject) DNSProvider 

func (this *DNSProviderObject) DNSProvider() *api.DNSProvider

func (*DNSProviderObject) SetSelection 

func (this *DNSProviderObject) SetSelection(included, excluded utils.StringSet, target *api.DNSSelectionStatus) bool

func (*DNSProviderObject) SetState 

func (this *DNSProviderObject) SetState(state, message string, commonMessagePrefix ...string) bool

func (*DNSProviderObject) SetStateWithError added in v0.7.8 

func (this *DNSProviderObject) SetStateWithError(state string, err error) bool

func (*DNSProviderObject) Spec 

func (this *DNSProviderObject) Spec() *api.DNSProviderSpec

func (*DNSProviderObject) Status 

func (this *DNSProviderObject) Status() *api.DNSProviderStatus

func (*DNSProviderObject) StatusField added in v0.7.12 

func (this *DNSProviderObject) StatusField() interface{}

func (*DNSProviderObject) TypeCode 

func (this *DNSProviderObject) TypeCode() string

type Elements 

type Elements []resources.Object

type Executor 

type Executor func(resources.Object)

type LogMessage 

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

func NewLogMessage 

func NewLogMessage(msg string, args ...interface{}) *LogMessage

func (*LogMessage) Debugf 

func (this *LogMessage) Debugf(logger logger.LogContext, add ...interface{}) bool

func (*LogMessage) Errorf 

func (this *LogMessage) Errorf(logger logger.LogContext, add ...interface{}) bool

func (*LogMessage) Get 

func (this *LogMessage) Get() string

func (*LogMessage) Infof 

func (this *LogMessage) Infof(logger logger.LogContext, add ...interface{}) bool

func (*LogMessage) Warnf 

func (this *LogMessage) Warnf(logger logger.LogContext, add ...interface{}) bool

type RateLimiter added in v0.7.9 

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

func NewRateLimiter added in v0.7.9 

func NewRateLimiter(min, max, minincr time.Duration) *RateLimiter

func (*RateLimiter) Failed added in v0.7.9 

func (this *RateLimiter) Failed()

func (*RateLimiter) RateLimit added in v0.7.9 

func (this *RateLimiter) RateLimit() time.Duration

func (*RateLimiter) Succeeded added in v0.7.9 

func (this *RateLimiter) Succeeded()

type Schedule added in v0.10.3 

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

func NewSchedule added in v0.10.3 

func NewSchedule(ctx context.Context, exec ScheduleExecutor) *Schedule

func (*Schedule) Delete added in v0.10.3 

func (this *Schedule) Delete(key ScheduleKey)

func (*Schedule) List added in v0.10.3 

func (this *Schedule) List() []ScheduleKey

func (*Schedule) ListSchedule added in v0.10.3 

func (this *Schedule) ListSchedule() []ScheduleEntry

func (*Schedule) Reset added in v0.10.3 

func (this *Schedule) Reset()

func (*Schedule) Schedule added in v0.10.3 

func (this *Schedule) Schedule(key ScheduleKey, due time.Time)

func (*Schedule) ScheduleAfter added in v0.10.3 

func (this *Schedule) ScheduleAfter(key ScheduleKey, due time.Duration)

type ScheduleEntry added in v0.10.3 

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

func (ScheduleEntry) Due added in v0.10.3 

func (this ScheduleEntry) Due() time.Time

func (ScheduleEntry) Key added in v0.10.3 

func (this ScheduleEntry) Key() ScheduleKey

func (ScheduleEntry) String added in v0.10.3 

func (this ScheduleEntry) String() string

type ScheduleExecutor added in v0.10.3 

type ScheduleExecutor interface {
	Execute(key ScheduleKey)
}

type ScheduleExecutorFunction added in v0.10.3 

type ScheduleExecutorFunction func(key ScheduleKey)

func (ScheduleExecutorFunction) Execute added in v0.10.3 

func (this ScheduleExecutorFunction) Execute(key ScheduleKey)

type ScheduleKey added in v0.10.3 

type ScheduleKey interface{}

type Timer added in v0.10.3 

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

func NewTimer added in v0.10.3 

func NewTimer(ctx context.Context, exec func(*Timer)) *Timer

func (*Timer) Next added in v0.10.3 

func (this *Timer) Next(d time.Duration)

func (*Timer) Stop added in v0.10.3 

func (this *Timer) Stop()

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.