Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gateway

package

Go to main page

Versions in this module

v0

v0.7.0

Mar 12, 2022

Changes in this version

+ var PathProbesReceivedMeta = MetricMeta

+ var PathProbesSendErrorsMeta = MetricMeta

+ var PathProbesSentMeta = MetricMeta

+ var PrefixFetchErrorsMeta = MetricMeta

+ var RemoteChangesMeta = MetricMeta

+ var RemoteDiscoveryErrorsMeta = MetricMeta

+ var RoutingChainAliveSessionsMeta = MetricMeta

+ var RoutingChainHealthyMeta = MetricMeta

+ var RoutingChainSessionChangesMeta = MetricMeta

+ var RoutingChainStateChangesMeta = MetricMeta

+ var SessionIsHealthyMeta = MetricMeta

+ var SessionPathChangesMeta = MetricMeta

+ var SessionProbeRepliesMeta = MetricMeta

+ var SessionProbesMeta = MetricMeta

+ var SessionStateChangesMeta = MetricMeta

+ func CreateEngineMetrics(m *Metrics) control.EngineMetrics

+ func PathUpdateInterval(ctx context.Context) time.Duration

+ func StartIngress(ctx context.Context, scionNetwork *snet.SCIONNetwork, dataAddr *net.UDPAddr, ...) error

+ type DataPlaneRunner interface

+ NewDataPlaneSessionFactory func(scionNetwork *snet.SCIONNetwork, dataClientIP net.IP, metrics *Metrics, ...) control.DataplaneSessionFactory

+ NewRoutingTableFactory func() control.RoutingTableFactory

+ StartIngress func(scionNetwork *snet.SCIONNetwork, dataAddr *net.UDPAddr, ...) error

type Gateway

+ RouteSourceIPv4 net.IP

+ RouteSourceIPv6 net.IP

+ RoutingTableReader control.RoutingTableReader

+ RoutingTableSwapper control.RoutingTableSwapper

+ TunnelName string

+ type Loader struct

+ Publisher Publisher

+ RoutingPolicyFile string

+ SessionPoliciesFile string

+ SessionPolicyParser control.SessionPolicyParser

+ Trigger <-chan struct{}

+ func (l *Loader) Close(ctx context.Context) error

+ func (l *Loader) Run(ctx context.Context) error

type Metrics

+ PathProbesReceived *prometheus.CounterVec

+ PathProbesSendErrors *prometheus.CounterVec

+ PathProbesSent *prometheus.CounterVec

+ PrefixFetchErrors *prometheus.CounterVec

+ RemoteDiscoveryErrors *prometheus.CounterVec

+ RemotesChanges *prometheus.CounterVec

+ RoutingChainAliveSessions *prometheus.GaugeVec

+ RoutingChainHealthy *prometheus.GaugeVec

+ RoutingChainSessionChanges *prometheus.CounterVec

+ RoutingChainStateChanges *prometheus.CounterVec

+ SCIONNetworkMetrics snet.SCIONNetworkMetrics

+ SCIONPacketConnMetrics snet.SCIONPacketConnMetrics

+ SCMPErrors metrics.Counter

+ SessionIsHealthy *prometheus.GaugeVec

+ SessionPathChanges *prometheus.CounterVec

+ SessionProbeReplies *prometheus.CounterVec

+ SessionProbes *prometheus.CounterVec

+ SessionStateChanges *prometheus.CounterVec

+ type ProbeConnFactory struct

+ Dispatcher *reconnect.DispatcherService

+ LocalIA addr.IA

+ LocalIP net.IP

+ func (f ProbeConnFactory) New(ctx context.Context) (net.PacketConn, error)

+ type Publisher interface

+ Publish func(control.SessionPolicies, *routing.Policy)

type RoutingTableFactory

+ RoutePublisherFactory control.PublisherFactory

+ type SelectAdvertisedRoutes struct

+ ConfigPublisher *control.ConfigPublisher

+ func (a *SelectAdvertisedRoutes) AdvertiseList(from, to addr.IA) ([]netaddr.IPPrefix, error)

+ type TunnelReader struct

+ DeviceOpener control.DeviceOpener

+ Metrics dataplane.IPForwarderMetrics

+ Router control.RoutingTableReader

+ func (r *TunnelReader) GetDeviceOpenerWithAsyncReader(ctx context.Context) control.DeviceOpener

v0.6.0

Dec 4, 2020

Changes in this version

+ var FrameBytesReceivedTotalMeta = MetricMeta

+ var FrameBytesSentTotalMeta = MetricMeta

+ var FramesDiscardedTotalMeta = MetricMeta

+ var FramesReceivedTotalMeta = MetricMeta

+ var FramesSentTotalMeta = MetricMeta

+ var IPPktBytesLocalReceivedTotalMeta = MetricMeta

+ var IPPktBytesLocalSentTotalMeta = MetricMeta

+ var IPPktBytesReceivedTotalMeta = MetricMeta

+ var IPPktBytesSentTotalMeta = MetricMeta

+ var IPPktsDiscardedTotalMeta = MetricMeta

+ var IPPktsLocalReceivedTotalMeta = MetricMeta

+ var IPPktsLocalSentTotalMeta = MetricMeta

+ var IPPktsReceivedTotalMeta = MetricMeta

+ var IPPktsSentTotalMeta = MetricMeta

+ var PathsMonitoredMeta = MetricMeta

+ var PrefixesAcceptedMeta = MetricMeta

+ var PrefixesAdvertisedMeta = MetricMeta

+ var PrefixesRejectedMeta = MetricMeta

+ var ReceiveExternalErrorsTotalMeta = MetricMeta

+ var ReceiveLocalErrorsTotalMeta = MetricMeta

+ var RemotesMeta = MetricMeta

+ var SendExternalErrorsTotalMeta = MetricMeta

+ var SendLocalErrorsTotalMeta = MetricMeta

+ var SessionPathsAvailableMeta = MetricMeta

+ func CreateIngressMetrics(m *Metrics) dataplane.IngressMetrics

+ func CreateSessionMetrics(m *Metrics) dataplane.SessionMetrics

+ func ExperimentalExportMainRT() bool

+ type ConfigPublisherAdvertiser struct

+ ConfigPublisher *control.ConfigPublisher

+ func (a *ConfigPublisherAdvertiser) AdvertiseList(from, to addr.IA) []*net.IPNet

+ type DataplaneSessionFactory struct

+ Metrics dataplane.SessionMetrics

+ PacketConnFactory PacketConnFactory

+ PathStatsPublisher dataplane.PathStatsPublisher

+ func (dpf DataplaneSessionFactory) New(id uint8, policyID int, remoteIA addr.IA, remoteAddr net.Addr) control.DataplaneSession

+ type Gateway struct

+ ConfigReloadTrigger chan struct{}

+ ControlClientIP net.IP

+ ControlServerAddr *net.UDPAddr

+ Daemon sciond.Connector

+ DataAddr *net.UDPAddr

+ DataClientIP net.IP

+ DataServerAddr *net.UDPAddr

+ Dispatcher reliable.Dispatcher

+ HTTPEndpoints service.StatusPages

+ HTTPServeMux *http.ServeMux

+ ID string

+ InternalDevice io.ReadWriteCloser

+ Logger log.Logger

+ Metrics *Metrics

+ PathMonitorIP net.IP

+ ProbeClientIP net.IP

+ ProbeServerAddr *net.UDPAddr

+ RouteDevice netlink.Link

+ RouteSource net.IP

+ RoutingPolicyFile string

+ ServiceDiscoveryClientIP net.IP

+ TrafficPolicyFile string

+ func (g *Gateway) Run() error

+ type MetricMeta struct

+ Help string

+ Labels []string

+ Name string

+ func (mm *MetricMeta) NewCounterVec() *prometheus.CounterVec

+ func (mm *MetricMeta) NewGaugeVec() *prometheus.GaugeVec

+ type Metrics struct

+ FrameBytesReceivedTotal *prometheus.CounterVec

+ FrameBytesSentTotal *prometheus.CounterVec

+ FramesDiscardedTotal *prometheus.CounterVec

+ FramesReceivedTotal *prometheus.CounterVec

+ FramesSentTotal *prometheus.CounterVec

+ IPPktBytesLocalReceivedTotal *prometheus.CounterVec

+ IPPktBytesLocalSentTotal *prometheus.CounterVec

+ IPPktBytesReceivedTotal *prometheus.CounterVec

+ IPPktBytesSentTotal *prometheus.CounterVec

+ IPPktsDiscardedTotal *prometheus.CounterVec

+ IPPktsLocalReceivedTotal *prometheus.CounterVec

+ IPPktsLocalSentTotal *prometheus.CounterVec

+ IPPktsReceivedTotal *prometheus.CounterVec

+ IPPktsSentTotal *prometheus.CounterVec

+ PathsMonitored *prometheus.GaugeVec

+ PrefixesAccepted *prometheus.GaugeVec

+ PrefixesAdvertised *prometheus.GaugeVec

+ PrefixesRejected *prometheus.GaugeVec

+ ReceiveExternalErrorsTotal *prometheus.CounterVec

+ ReceiveLocalErrorsTotal *prometheus.CounterVec

+ Remotes *prometheus.GaugeVec

+ SendExternalErrorsTotal *prometheus.CounterVec

+ SendLocalErrorsTotal *prometheus.CounterVec

+ SessionPathsAvailable *prometheus.GaugeVec

+ func NewMetrics() *Metrics

+ type PacketConnFactory struct

+ Addr *net.UDPAddr

+ Network *snet.SCIONNetwork

+ func (pcf PacketConnFactory) New() (net.PacketConn, error)

+ type PathMonitor struct

+ func (pm *PathMonitor) Register(remote addr.IA, policies *policies.Policies, policyID int) control.PathMonitorRegistration

+ type RoutingPolicyPublisherAdapter struct

+ func (cp RoutingPolicyPublisherAdapter) PublishRoutingPolicy(rp *routing.Policy)

+ type RoutingTableFactory struct

+ Device netlink.Link

+ Source net.IP

+ func (rtf RoutingTableFactory) New(routingChains []*control.RoutingChain) (control.RoutingTable, error)

+ type WatcherFactory struct

+ Aggregator control.PrefixConsumer

+ Dialer libgrpc.Dialer

+ PathMonitor control.PathMonitor

+ Policies *policies.Policies

+ func (wf *WatcherFactory) New(remote addr.IA, metrics control.GatewayWatcherMetrics) control.Runner