utils

Documentation

Index

• Variables
• func DNSProviderKey(namespace, name string) resources.ObjectKey
• func Match(hostname, domain string) bool
• func MatchSet(hostname string, domains utils.StringSet) int
• func ProcessElements(elems Elements, exec Executor, processors int)
• type DNSEntryObject
  • func DNSEntry(o resources.Object) *DNSEntryObject
  • func (this *DNSEntryObject) DNSEntry() *api.DNSEntry
  • func (this *DNSEntryObject) GetCNameLookupInterval() *int64
  • func (this *DNSEntryObject) GetDNSName() string
  • func (this *DNSEntryObject) GetOwnerId() *string
  • func (this *DNSEntryObject) GetTTL() *int64
  • func (this *DNSEntryObject) GetTargets() []string
  • func (this *DNSEntryObject) Spec() *api.DNSEntrySpec
  • func (this *DNSEntryObject) Status() *api.DNSEntryStatus
  • func (this *DNSEntryObject) StatusField() interface{}
• type DNSOwnerObject
  • func DNSOwner(o resources.Object) *DNSOwnerObject
  • func (this *DNSOwnerObject) DNSOwner() *api.DNSOwner
  • func (this *DNSOwnerObject) GetCount() int
  • func (this *DNSOwnerObject) GetCounts() map[string]int
  • func (this *DNSOwnerObject) GetOwnerId() string
  • func (this *DNSOwnerObject) IsActive() bool
  • func (this *DNSOwnerObject) Spec() *api.DNSOwnerSpec
• type DNSProviderObject
  • func DNSProvider(o resources.Object) *DNSProviderObject
  • func GetDNSProvider(src resources.ResourcesSource, namespace, name string) (*DNSProviderObject, error)
  • func (this *DNSProviderObject) DNSProvider() *api.DNSProvider
  • func (this *DNSProviderObject) SetSelection(included, excluded utils.StringSet, target *api.DNSSelectionStatus) bool
  • func (this *DNSProviderObject) SetState(state, message string, commonMessagePrefix ...string) bool
  • func (this *DNSProviderObject) SetStateWithError(state string, err error) bool
  • func (this *DNSProviderObject) Spec() *api.DNSProviderSpec
  • func (this *DNSProviderObject) Status() *api.DNSProviderStatus
  • func (this *DNSProviderObject) StatusField() interface{}
  • func (this *DNSProviderObject) TypeCode() string
• type Elements
• type Executor
• type LogMessage
  • func NewLogMessage(msg string, args ...interface{}) *LogMessage
  • func (this *LogMessage) Debugf(logger logger.LogContext, add ...interface{}) bool
  • func (this *LogMessage) Errorf(logger logger.LogContext, add ...interface{}) bool
  • func (this *LogMessage) Get() string
  • func (this *LogMessage) Infof(logger logger.LogContext, add ...interface{}) bool
  • func (this *LogMessage) Warnf(logger logger.LogContext, add ...interface{}) bool
• type RateLimiter
  • func NewRateLimiter(min, max, minincr time.Duration) *RateLimiter
  • func (this *RateLimiter) Failed()
  • func (this *RateLimiter) RateLimit() time.Duration
  • func (this *RateLimiter) Succeeded()

Variables

var DNSEntryType = (*api.DNSEntry)(nil)

var DNSOwnerType = (*api.DNSOwner)(nil)

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)

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

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

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

func (this *DNSOwnerObject) GetCount() int

func (*DNSOwnerObject) GetCounts

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) Spec

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

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

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

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

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

func NewRateLimiter

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

func (*RateLimiter) Failed

func (this *RateLimiter) Failed()

func (*RateLimiter) RateLimit

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

func (*RateLimiter) Succeeded

func (this *RateLimiter) Succeeded()