Versions in this module Expand all Collapse all v2 v2.0.0 Jul 8, 2024 Changes in this version + const AppGracefulShutdown + const AppLoggerLevel + const BaseRulesOutNets + const ContinueAfterTimeout + const ContinueOnFailure + const DnsDialDuration + const DnsNameservers + const DnsPort + const DnsProto + const DnsReadDuration + const DnsRetries + const DnsRetriesTmo + const DnsWriteDuration + const ESrcDNS + const ESrcNetWatcher + const ESrcSgBakend + const ExitOnSuccess + const FqdnStrategy + const HcDnsRefresher + const HcNetConfWatcher + const HcNftApplier + const HcSyncStatus + const HealthcheckEnable + const MetricsEnable + const NetNS + const NetlinkWatcherLinger + const NftablesCollectorMinFrequency + const ProfileEnable + const SGroupsAPIpathPrefix + const SGroupsAddress + const SGroupsAuthnType + const SGroupsDialDuration + const SGroupsSyncStatusInterval + const SGroupsSyncStatusPush + const SGroupsTLScertFile + const SGroupsTLSprivKeyFile + const SGroupsTLSserverCAs + const SGroupsTLSserverName + const SGroupsTLSserverVerify + const SGroupsUseJsonCodec + const ServicesDefDialDuration + const TelemetryEndpoint + const UserAgent + var ConfigFile string + var ErrDomainAddressQuerierCacheClosed = errors.New("dns address querier cache is closed") + var NewTiedSubj = observer.NewTiedSubj + func AgentSubject() observer.Subject + func SetupAgentSubject() + func SetupContext() + func SetupDnsResolver(ctx context.Context) error + func SetupLogger() error + func SetupMetrics(ctx context.Context) error + func WhenSetupTelemtryServer(ctx context.Context, f func(*server.APIServer) error) error + type AgentMetrics struct + func GetAgentMetrics() *AgentMetrics + func (am *AgentMetrics) ObserveApplyConfig() + func (am *AgentMetrics) ObserveError(errSource string) + type AgentSubjectClosed struct + type DomainAddressQuerier interface + A func(ctx context.Context, domain string) DomainAddresses + AAAA func(ctx context.Context, domain string) DomainAddresses + func GetDnsResolver() DomainAddressQuerier + func NewDomainAddressQuerier(ctx context.Context) (DomainAddressQuerier, error) + type DomainAddressQuerierCacheWrapper interface + A func(ctx context.Context, domain string) DomainAddresses + AAAA func(ctx context.Context, domain string) DomainAddresses + Close func() error + func NewDomainAddressQuerierCache(o DomainAddressQuerier) DomainAddressQuerierCacheWrapper + type DomainAddresses struct + At time.Time + Err error + IPs []net.IP + TTL time.Duration + type FqdnRulesStrategy string + const FqdnRulesStartegyDNS + func (FqdnRulesStrategy) Variants() []FqdnRulesStrategy + func (o FqdnRulesStrategy) Eq(other FqdnRulesStrategy) bool + type NetlinkError struct + type NetlinkEventSource struct + NetNS string + Subject observer.Subject + func (w *NetlinkEventSource) Close() error + func (w *NetlinkEventSource) Run(ctx context.Context) error + type NetlinkUpdates struct + Updates []nl.WatcherMsg + type SGClient = sgAPI.ClosableClient + func NewSGClient(ctx context.Context) (ret *SGClient, err error) + type SyncStatusError struct + func (e SyncStatusError) Cause() error + type SyncStatusEventSource struct + CheckInterval time.Duration + SGClient SGClient + Subject observer.Subject + UsePushModel bool + func (ss *SyncStatusEventSource) Run(ctx context.Context) error + type SyncStatusValue struct
Go to main page