endpoint

Documentation

Index

• Constants
• Variables
• func GetLocal(submSpec *types.SubmarinerSpecification, k8sClient kubernetes.Interface, ...) (*types.SubmarinerEndpoint, error)
• func GetLocalIP() string
• func GetLocalIPForDestination(dst string) string
• type PublicIPWatcher
  • func NewPublicIPWatcher(config *PublicIPWatcherConfig) *PublicIPWatcher
  • func (p *PublicIPWatcher) Run(stopCh <-chan struct{})
• type PublicIPWatcherConfig

Constants

const DefaultMonitorInterval = 20 * time.Second

Variables

var IPv4RE = regexp.MustCompile(`(?:\d{1,3}\.){3}\d{1,3}`)

Functions

func GetLocal

func GetLocal(submSpec *types.SubmarinerSpecification, k8sClient kubernetes.Interface,
	airGappedDeployment bool,
) (*types.SubmarinerEndpoint, error)

func GetLocalIP

func GetLocalIP() string

func GetLocalIPForDestination

func GetLocalIPForDestination(dst string) string

Types

type PublicIPWatcher

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

func NewPublicIPWatcher

func NewPublicIPWatcher(config *PublicIPWatcherConfig) *PublicIPWatcher

func (*PublicIPWatcher) Run

func (p *PublicIPWatcher) Run(stopCh <-chan struct{})

type PublicIPWatcherConfig

type PublicIPWatcherConfig struct {
	SubmSpec      *types.SubmarinerSpecification
	Interval      time.Duration
	K8sClient     kubernetes.Interface
	Endpoints     v1.EndpointInterface
	LocalEndpoint types.SubmarinerEndpoint
}