resolver

Documentation

Index

• func StartResolving(namespace string, nameResolutionHistoryPath string, clusterMode bool)
• type ResolvedObjectInfo
• type Resolver
  • func NewFromInCluster(errOut chan error, namespace string) *Resolver
  • func (resolver *Resolver) CheckIsServiceIP(address string) bool
  • func (resolver *Resolver) GetDumpNameResolutionHistoryMap() map[int64]map[string]*ResolvedObjectInfo
  • func (resolver *Resolver) Resolve(name string, timestamp int64) *ResolvedObjectInfo
  • func (resolver *Resolver) RestoreNameResolutionHistory(nameResolutionHistoryPath string)
  • func (resolver *Resolver) SaveResolvedName(key string, resolved string, namespace string, eventType watch.EventType)
  • func (resolver *Resolver) Start(ctx context.Context, nameResolutionHistoryPath string, clusterMode bool)

Functions

func StartResolving

func StartResolving(namespace string, nameResolutionHistoryPath string, clusterMode bool)

Types

type ResolvedObjectInfo

type ResolvedObjectInfo struct {
	FullAddress string
	Namespace   string
}

type Resolver

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

var K8sResolver *Resolver

func NewFromInCluster

func NewFromInCluster(errOut chan error, namespace string) *Resolver

func (*Resolver) CheckIsServiceIP

func (resolver *Resolver) CheckIsServiceIP(address string) bool

func (*Resolver) GetDumpNameResolutionHistoryMap

func (resolver *Resolver) GetDumpNameResolutionHistoryMap() map[int64]map[string]*ResolvedObjectInfo

func (*Resolver) Resolve

func (resolver *Resolver) Resolve(name string, timestamp int64) *ResolvedObjectInfo

func (*Resolver) RestoreNameResolutionHistory

func (resolver *Resolver) RestoreNameResolutionHistory(nameResolutionHistoryPath string)

func (*Resolver) SaveResolvedName

func (resolver *Resolver) SaveResolvedName(key string, resolved string, namespace string, eventType watch.EventType)

func (*Resolver) Start

func (resolver *Resolver) Start(ctx context.Context, nameResolutionHistoryPath string, clusterMode bool)