Documentation
¶
Index ¶
- Constants
- func AsConfigMapData(config string) map[string]string
- func AsInt(value interface{}) (int, bool)
- func AsUint64(value interface{}) (uint64, bool)
- func GetRouterConfigForHeadlessProxy(definition types.ServiceInterface, siteId string, version string, ...) (string, error)
- func GetSiteNameForGateway(gateway *Router) string
- func MarshalRouterConfig(config RouterConfig) (string, error)
- func RouterConfigEquals(actual, desired string) bool
- type AddedSslProfiles
- type Address
- type Agent
- func (a *Agent) BatchQuery(queries []Query) ([][]Record, error)
- func (a *Agent) Close() error
- func (a *Agent) Create(typename string, name string, attributes map[string]interface{}) error
- func (a *Agent) CreateSslProfile(profile SslProfile) error
- func (a *Agent) Delete(typename string, name string) error
- func (a *Agent) GetAllRouters() ([]Router, error)
- func (a *Agent) GetBridges(routers []Router) ([]BridgeConfig, error)
- func (a *Agent) GetConnections() ([]Connection, error)
- func (a *Agent) GetConnectionsFor(agent string) ([]Connection, error)
- func (a *Agent) GetConnectorByName(name string) (*Connector, error)
- func (a *Agent) GetHttpRequestInfo(routers []Router) ([][]HttpRequestInfo, error)
- func (a *Agent) GetInteriorNodes() ([]RouterNode, error)
- func (a *Agent) GetLocalBridgeConfig() (*BridgeConfig, error)
- func (a *Agent) GetLocalConnectorStatus() (map[string]ConnectorStatus, error)
- func (a *Agent) GetLocalConnectors() (map[string]Connector, error)
- func (a *Agent) GetLocalGateways() ([]Router, error)
- func (a *Agent) GetLocalHttpConnectors(filter HttpEndpointFilter) ([]HttpEndpoint, error)
- func (a *Agent) GetLocalHttpListeners(filter HttpEndpointFilter) ([]HttpEndpoint, error)
- func (a *Agent) GetLocalHttpRequestInfo() ([]HttpRequestInfo, error)
- func (a *Agent) GetLocalRouter() (*Router, error)
- func (a *Agent) GetLocalTcpConnections() ([]TcpConnection, error)
- func (a *Agent) GetLocalTcpConnectors(filter TcpEndpointFilter) ([]TcpEndpoint, error)
- func (a *Agent) GetLocalTcpListeners(filter TcpEndpointFilter) ([]TcpEndpoint, error)
- func (a *Agent) GetSslProfileByName(name string) (*SslProfile, error)
- func (a *Agent) GetTcpConnections(routers []Router) ([][]TcpConnection, error)
- func (a *Agent) Query(typename string, attributes []string) ([]Record, error)
- func (a *Agent) QueryByAgentAddress(typename string, attributes []string, agent string) ([]Record, error)
- func (a *Agent) QueryRouterNode(typename string, attributes []string, node *RouterNode) ([]Record, error)
- func (a *Agent) Request(request *Request) (*Response, error)
- func (a *Agent) UpdateConnectorConfig(changes *ConnectorDifference) error
- func (a *Agent) UpdateLocalBridgeConfig(changes *BridgeConfigDifference) error
- type AgentPool
- type AmqpConnection
- type AmqpReceiver
- type AmqpSender
- type BridgeConfig
- func (bc *BridgeConfig) AddHttpConnector(e HttpEndpoint)
- func (bc *BridgeConfig) AddHttpListener(e HttpEndpoint)
- func (bc *BridgeConfig) AddTcpConnector(e TcpEndpoint)
- func (bc *BridgeConfig) AddTcpListener(e TcpEndpoint)
- func (a *BridgeConfig) Difference(b *BridgeConfig) *BridgeConfigDifference
- func (bc *BridgeConfig) RemoveHttpConnector(name string) (bool, HttpEndpoint)
- func (bc *BridgeConfig) RemoveHttpListener(name string) (bool, HttpEndpoint)
- func (bc *BridgeConfig) RemoveTcpConnector(name string) (bool, TcpEndpoint)
- func (bc *BridgeConfig) RemoveTcpListener(name string) (bool, TcpEndpoint)
- func (b *BridgeConfig) UpdateConfigMap(configmap *corev1.ConfigMap) (bool, error)
- type BridgeConfigDifference
- type Connection
- type ConnectionFactory
- type Connector
- type ConnectorDifference
- type ConnectorStatus
- type DeletedSslProfiles
- type Distribution
- type HttpEndpoint
- type HttpEndpointDifference
- type HttpEndpointFilter
- type HttpEndpointMap
- type HttpRequestInfo
- type Listener
- type LogConfig
- type Mode
- type Query
- type Record
- type Request
- type RequestResponse
- type RequestServer
- type Response
- type Role
- type Router
- type RouterConfig
- func (r *RouterConfig) AddAddress(a Address)
- func (r *RouterConfig) AddConnector(c Connector)
- func (r *RouterConfig) AddHttpConnector(e HttpEndpoint)
- func (r *RouterConfig) AddHttpListener(e HttpEndpoint)
- func (r *RouterConfig) AddListener(l Listener)
- func (r *RouterConfig) AddSimpleSslProfile(s SslProfile)
- func (r *RouterConfig) AddSimpleSslProfileWithPath(path string, s SslProfile)
- func (r *RouterConfig) AddSslProfile(s SslProfile)
- func (r *RouterConfig) AddSslProfileWithPath(path string, s SslProfile)
- func (r *RouterConfig) AddTcpConnector(e TcpEndpoint)
- func (r *RouterConfig) AddTcpListener(e TcpEndpoint)
- func (r *RouterConfig) AsConfigMapData() (map[string]string, error)
- func (r *RouterConfig) GetSiteMetadata() SiteMetadata
- func (r *RouterConfig) IsEdge() bool
- func (r *RouterConfig) RemoveConnector(name string) (bool, Connector)
- func (r *RouterConfig) RemoveHttpConnector(name string) (bool, HttpEndpoint)
- func (r *RouterConfig) RemoveHttpListener(name string) (bool, HttpEndpoint)
- func (r *RouterConfig) RemoveSslProfile(name string) bool
- func (r *RouterConfig) RemoveTcpConnector(name string) (bool, TcpEndpoint)
- func (r *RouterConfig) RemoveTcpListener(name string) (bool, TcpEndpoint)
- func (r *RouterConfig) SetLogLevel(module string, level string) bool
- func (r *RouterConfig) SetLogLevels(levels map[string]string) bool
- func (r *RouterConfig) SetSiteMetadata(site *SiteMetadata)
- func (r *RouterConfig) UpdateBridgeConfig(desired BridgeConfig) bool
- func (r *RouterConfig) UpdateConfigMap(configmap *corev1.ConfigMap) (bool, error)
- func (r *RouterConfig) WriteToConfigMap(configmap *corev1.ConfigMap) error
- type RouterMetadata
- type RouterNode
- type SiteMetadata
- type SslProfile
- type TcpConnection
- type TcpEndpoint
- type TcpEndpointDifference
- type TcpEndpointFilter
- type TcpEndpointMap
Constants ¶
View Source
const ( DirectionIn string = "in" DirectionOut string = "out" )
View Source
const ( HttpVersion1 string = "HTTP1" HttpVersion2 = "HTTP2" )
View Source
const ( DistributionBalanced Distribution = "balanced" DistributionMulticast = "multicast" DistributionClosest = "closest" )
View Source
const (
VersionProperty string = "version"
)
Variables ¶
This section is empty.
Functions ¶
func AsConfigMapData ¶
func GetSiteNameForGateway ¶
func MarshalRouterConfig ¶
func MarshalRouterConfig(config RouterConfig) (string, error)
func RouterConfigEquals ¶
Types ¶
type AddedSslProfiles ¶
type AddedSslProfiles []string
type Agent ¶
type Agent struct {
// contains filtered or unexported fields
}
func (*Agent) CreateSslProfile ¶
func (a *Agent) CreateSslProfile(profile SslProfile) error
func (*Agent) GetAllRouters ¶
func (*Agent) GetBridges ¶
func (a *Agent) GetBridges(routers []Router) ([]BridgeConfig, error)
func (*Agent) GetConnections ¶
func (a *Agent) GetConnections() ([]Connection, error)
func (*Agent) GetConnectionsFor ¶
func (a *Agent) GetConnectionsFor(agent string) ([]Connection, error)
func (*Agent) GetConnectorByName ¶
func (*Agent) GetHttpRequestInfo ¶
func (a *Agent) GetHttpRequestInfo(routers []Router) ([][]HttpRequestInfo, error)
func (*Agent) GetInteriorNodes ¶
func (a *Agent) GetInteriorNodes() ([]RouterNode, error)
func (*Agent) GetLocalBridgeConfig ¶
func (a *Agent) GetLocalBridgeConfig() (*BridgeConfig, error)
func (*Agent) GetLocalConnectorStatus ¶
func (a *Agent) GetLocalConnectorStatus() (map[string]ConnectorStatus, error)
func (*Agent) GetLocalConnectors ¶
func (*Agent) GetLocalGateways ¶
func (*Agent) GetLocalHttpConnectors ¶
func (a *Agent) GetLocalHttpConnectors(filter HttpEndpointFilter) ([]HttpEndpoint, error)
func (*Agent) GetLocalHttpListeners ¶
func (a *Agent) GetLocalHttpListeners(filter HttpEndpointFilter) ([]HttpEndpoint, error)
func (*Agent) GetLocalHttpRequestInfo ¶
func (a *Agent) GetLocalHttpRequestInfo() ([]HttpRequestInfo, error)
func (*Agent) GetLocalRouter ¶
func (*Agent) GetLocalTcpConnections ¶
func (a *Agent) GetLocalTcpConnections() ([]TcpConnection, error)
func (*Agent) GetLocalTcpConnectors ¶
func (a *Agent) GetLocalTcpConnectors(filter TcpEndpointFilter) ([]TcpEndpoint, error)
func (*Agent) GetLocalTcpListeners ¶
func (a *Agent) GetLocalTcpListeners(filter TcpEndpointFilter) ([]TcpEndpoint, error)
func (*Agent) GetSslProfileByName ¶
func (a *Agent) GetSslProfileByName(name string) (*SslProfile, error)
func (*Agent) GetTcpConnections ¶
func (a *Agent) GetTcpConnections(routers []Router) ([][]TcpConnection, error)
func (*Agent) QueryByAgentAddress ¶
func (*Agent) QueryRouterNode ¶
func (*Agent) UpdateConnectorConfig ¶
func (a *Agent) UpdateConnectorConfig(changes *ConnectorDifference) error
func (*Agent) UpdateLocalBridgeConfig ¶
func (a *Agent) UpdateLocalBridgeConfig(changes *BridgeConfigDifference) error
type AmqpConnection ¶
type AmqpConnection struct {
// contains filtered or unexported fields
}
func (*AmqpConnection) Close ¶
func (c *AmqpConnection) Close()
type AmqpReceiver ¶
type AmqpReceiver struct {
// contains filtered or unexported fields
}
func (*AmqpReceiver) Close ¶
func (s *AmqpReceiver) Close() error
type AmqpSender ¶
type AmqpSender struct {
// contains filtered or unexported fields
}
func (*AmqpSender) Close ¶
func (s *AmqpSender) Close() error
type BridgeConfig ¶
type BridgeConfig struct {
TcpListeners TcpEndpointMap
TcpConnectors TcpEndpointMap
HttpListeners HttpEndpointMap
HttpConnectors HttpEndpointMap
}
func GetBridgeConfigFromConfigMap ¶
func GetBridgeConfigFromConfigMap(configmap *corev1.ConfigMap) (*BridgeConfig, error)
func NewBridgeConfig ¶
func NewBridgeConfig() BridgeConfig
func NewBridgeConfigCopy ¶
func NewBridgeConfigCopy(src BridgeConfig) BridgeConfig
func (*BridgeConfig) AddHttpConnector ¶
func (bc *BridgeConfig) AddHttpConnector(e HttpEndpoint)
func (*BridgeConfig) AddHttpListener ¶
func (bc *BridgeConfig) AddHttpListener(e HttpEndpoint)
func (*BridgeConfig) AddTcpConnector ¶
func (bc *BridgeConfig) AddTcpConnector(e TcpEndpoint)
func (*BridgeConfig) AddTcpListener ¶
func (bc *BridgeConfig) AddTcpListener(e TcpEndpoint)
func (*BridgeConfig) Difference ¶
func (a *BridgeConfig) Difference(b *BridgeConfig) *BridgeConfigDifference
func (*BridgeConfig) RemoveHttpConnector ¶
func (bc *BridgeConfig) RemoveHttpConnector(name string) (bool, HttpEndpoint)
func (*BridgeConfig) RemoveHttpListener ¶
func (bc *BridgeConfig) RemoveHttpListener(name string) (bool, HttpEndpoint)
func (*BridgeConfig) RemoveTcpConnector ¶
func (bc *BridgeConfig) RemoveTcpConnector(name string) (bool, TcpEndpoint)
func (*BridgeConfig) RemoveTcpListener ¶
func (bc *BridgeConfig) RemoveTcpListener(name string) (bool, TcpEndpoint)
func (*BridgeConfig) UpdateConfigMap ¶
func (b *BridgeConfig) UpdateConfigMap(configmap *corev1.ConfigMap) (bool, error)
type BridgeConfigDifference ¶
type BridgeConfigDifference struct {
TcpListeners TcpEndpointDifference
TcpConnectors TcpEndpointDifference
HttpListeners HttpEndpointDifference
HttpConnectors HttpEndpointDifference
AddedSslProfiles []string
DeletedSSlProfiles []string
}
func (*BridgeConfigDifference) Empty ¶
func (a *BridgeConfigDifference) Empty() bool
func (*BridgeConfigDifference) Print ¶
func (a *BridgeConfigDifference) Print()
type Connection ¶
type ConnectionFactory ¶
type ConnectionFactory struct {
// contains filtered or unexported fields
}
func NewConnectionFactory ¶
func NewConnectionFactory(url string, config *tls.Config) *ConnectionFactory
func (*ConnectionFactory) Connect ¶
func (f *ConnectionFactory) Connect() (messaging.Connection, error)
func (*ConnectionFactory) Url ¶
func (f *ConnectionFactory) Url() string
type Connector ¶
type Connector struct {
Name string `json:"name,omitempty"`
Role Role `json:"role,omitempty"`
Host string `json:"host"`
Port string `json:"port"`
RouteContainer bool `json:"routeContainer,omitempty"`
Cost int32 `json:"cost,omitempty"`
VerifyHostname bool `json:"verifyHostname,omitempty"`
SslProfile string `json:"sslProfile,omitempty"`
LinkCapacity int32 `json:"linkCapacity,omitempty"`
MaxFrameSize int `json:"maxFrameSize,omitempty"`
MaxSessionFrames int `json:"maxSessionFrames,omitempty"`
}
func (*Connector) SetMaxFrameSize ¶
func (*Connector) SetMaxSessionFrames ¶
type ConnectorDifference ¶
type ConnectorDifference struct {
Deleted []Connector
Added []Connector
AddedSslProfiles map[string]SslProfile
}
func ConnectorsDifference ¶
func ConnectorsDifference(actual map[string]Connector, desired *RouterConfig, ignorePrefix *string) *ConnectorDifference
func (*ConnectorDifference) Empty ¶
func (a *ConnectorDifference) Empty() bool
type ConnectorStatus ¶
type DeletedSslProfiles ¶
type DeletedSslProfiles []string
type Distribution ¶
type Distribution string
type HttpEndpoint ¶
type HttpEndpoint struct {
Name string `json:"name,omitempty"`
Host string `json:"host,omitempty"`
Port string `json:"port,omitempty"`
Address string `json:"address,omitempty"`
SiteId string `json:"siteId,omitempty"`
ProtocolVersion string `json:"protocolVersion,omitempty"`
Aggregation string `json:"aggregation,omitempty"`
EventChannel bool `json:"eventChannel,omitempty"`
HostOverride string `json:"hostOverride,omitempty"`
SslProfile string `json:"sslProfile,omitempty"`
VerifyHostname *bool `json:"verifyHostname,omitempty"`
}
func GetHttpConnectors ¶
func GetHttpConnectors(bridges []BridgeConfig) []HttpEndpoint
func GetHttpListeners ¶
func GetHttpListeners(bridges []BridgeConfig) []HttpEndpoint
func (HttpEndpoint) Equivalent ¶
func (a HttpEndpoint) Equivalent(b HttpEndpoint) bool
type HttpEndpointDifference ¶
type HttpEndpointDifference struct {
Deleted []HttpEndpoint
Added []HttpEndpoint
}
func (*HttpEndpointDifference) Empty ¶
func (a *HttpEndpointDifference) Empty() bool
type HttpEndpointFilter ¶
type HttpEndpointFilter func(*HttpEndpoint) bool
type HttpEndpointMap ¶
type HttpEndpointMap map[string]HttpEndpoint
func (HttpEndpointMap) Difference ¶
func (a HttpEndpointMap) Difference(b HttpEndpointMap) HttpEndpointDifference
type HttpRequestInfo ¶
type HttpRequestInfo struct {
Name string `json:"name"`
Host string `json:"host"`
Address string `json:"address"`
Site string `json:"site"`
Direction string `json:"direction"`
Requests int `json:"requests"`
BytesIn int `json:"bytesIn"`
BytesOut int `json:"bytesOut"`
MaxLatency int `json:"maxLatency"`
Details map[string]int `json:"details"`
}
type Listener ¶
type Listener struct {
Name string `json:"name,omitempty" yaml:"name,omitempty"`
Role Role `json:"role,omitempty" yaml:"role,omitempty"`
Host string `json:"host,omitempty" yaml:"host,omitempty"`
Port int32 `json:"port" yaml:"port,omitempty"`
RouteContainer bool `json:"routeContainer,omitempty" yaml:"route-container,omitempty"`
Http bool `json:"http,omitempty" yaml:"http,omitempty"`
Cost int32 `json:"cost,omitempty" yaml:"cost,omitempty"`
SslProfile string `json:"sslProfile,omitempty" yaml:"ssl-profile,omitempty"`
SaslMechanisms string `json:"saslMechanisms,omitempty" yaml:"sasl-mechanisms,omitempty"`
AuthenticatePeer bool `json:"authenticatePeer,omitempty" yaml:"authenticate-peer,omitempty"`
LinkCapacity int32 `json:"linkCapacity,omitempty" yaml:"link-capacity,omitempty"`
HttpRootDir string `json:"httpRootDir,omitempty" yaml:"http-rootdir,omitempty"`
Websockets bool `json:"websockets,omitempty" yaml:"web-sockets,omitempty"`
Healthz bool `json:"healthz,omitempty" yaml:"healthz,omitempty"`
Metrics bool `json:"metrics,omitempty" yaml:"metrics,omitempty"`
MaxFrameSize int `json:"maxFrameSize,omitempty" yaml:"max-frame-size,omitempty"`
MaxSessionFrames int `json:"maxSessionFrames,omitempty" yaml:"max-session-frames,omitempty"`
}
func (*Listener) SetMaxFrameSize ¶
func (*Listener) SetMaxSessionFrames ¶
type RequestResponse ¶
type RequestServer ¶
type RequestServer struct {
// contains filtered or unexported fields
}
func NewRequestServer ¶
func NewRequestServer(address string, handler RequestResponse, pool *AgentPool) *RequestServer
type Router ¶
type Router struct {
Id string
Address string
Edge bool
Site SiteMetadata
Version string
ConnectedTo []string
}
func GetRoutersForSite ¶
type RouterConfig ¶
type RouterConfig struct {
Metadata RouterMetadata
SslProfiles map[string]SslProfile
Listeners map[string]Listener
Connectors map[string]Connector
Addresses map[string]Address
LogConfig map[string]LogConfig
Bridges BridgeConfig
}
func GetRouterConfigFromConfigMap ¶
func GetRouterConfigFromConfigMap(configmap *corev1.ConfigMap) (*RouterConfig, error)
func InitialConfig ¶
func UnmarshalRouterConfig ¶
func UnmarshalRouterConfig(config string) (RouterConfig, error)
func (*RouterConfig) AddAddress ¶
func (r *RouterConfig) AddAddress(a Address)
func (*RouterConfig) AddConnector ¶
func (r *RouterConfig) AddConnector(c Connector)
func (*RouterConfig) AddHttpConnector ¶
func (r *RouterConfig) AddHttpConnector(e HttpEndpoint)
func (*RouterConfig) AddHttpListener ¶
func (r *RouterConfig) AddHttpListener(e HttpEndpoint)
func (*RouterConfig) AddListener ¶
func (r *RouterConfig) AddListener(l Listener)
func (*RouterConfig) AddSimpleSslProfile ¶
func (r *RouterConfig) AddSimpleSslProfile(s SslProfile)
func (*RouterConfig) AddSimpleSslProfileWithPath ¶
func (r *RouterConfig) AddSimpleSslProfileWithPath(path string, s SslProfile)
func (*RouterConfig) AddSslProfile ¶
func (r *RouterConfig) AddSslProfile(s SslProfile)
func (*RouterConfig) AddSslProfileWithPath ¶
func (r *RouterConfig) AddSslProfileWithPath(path string, s SslProfile)
func (*RouterConfig) AddTcpConnector ¶
func (r *RouterConfig) AddTcpConnector(e TcpEndpoint)
func (*RouterConfig) AddTcpListener ¶
func (r *RouterConfig) AddTcpListener(e TcpEndpoint)
func (*RouterConfig) AsConfigMapData ¶
func (r *RouterConfig) AsConfigMapData() (map[string]string, error)
func (*RouterConfig) GetSiteMetadata ¶
func (r *RouterConfig) GetSiteMetadata() SiteMetadata
func (*RouterConfig) IsEdge ¶
func (r *RouterConfig) IsEdge() bool
func (*RouterConfig) RemoveConnector ¶
func (r *RouterConfig) RemoveConnector(name string) (bool, Connector)
func (*RouterConfig) RemoveHttpConnector ¶
func (r *RouterConfig) RemoveHttpConnector(name string) (bool, HttpEndpoint)
func (*RouterConfig) RemoveHttpListener ¶
func (r *RouterConfig) RemoveHttpListener(name string) (bool, HttpEndpoint)
func (*RouterConfig) RemoveSslProfile ¶
func (r *RouterConfig) RemoveSslProfile(name string) bool
func (*RouterConfig) RemoveTcpConnector ¶
func (r *RouterConfig) RemoveTcpConnector(name string) (bool, TcpEndpoint)
func (*RouterConfig) RemoveTcpListener ¶
func (r *RouterConfig) RemoveTcpListener(name string) (bool, TcpEndpoint)
func (*RouterConfig) SetLogLevel ¶
func (r *RouterConfig) SetLogLevel(module string, level string) bool
func (*RouterConfig) SetLogLevels ¶
func (r *RouterConfig) SetLogLevels(levels map[string]string) bool
func (*RouterConfig) SetSiteMetadata ¶
func (r *RouterConfig) SetSiteMetadata(site *SiteMetadata)
func (*RouterConfig) UpdateBridgeConfig ¶
func (r *RouterConfig) UpdateBridgeConfig(desired BridgeConfig) bool
func (*RouterConfig) UpdateConfigMap ¶
func (r *RouterConfig) UpdateConfigMap(configmap *corev1.ConfigMap) (bool, error)
func (*RouterConfig) WriteToConfigMap ¶
func (r *RouterConfig) WriteToConfigMap(configmap *corev1.ConfigMap) error
type RouterMetadata ¶
type RouterNode ¶
type SiteMetadata ¶
type SslProfile ¶
type TcpConnection ¶
type TcpConnection struct {
Name string `json:"name"`
Host string `json:"host"`
Address string `json:"address"`
Direction string `json:"direction"`
BytesIn int `json:"bytesIn"`
BytesOut int `json:"bytesOut"`
Uptime uint64 `json:"uptimeSeconds"`
LastIn uint64 `json:"lastInSeconds"`
LastOut uint64 `json:"lastOutSeconds"`
}
type TcpEndpoint ¶
type TcpEndpoint struct {
Name string `json:"name,omitempty"`
Host string `json:"host,omitempty"`
Port string `json:"port,omitempty"`
Address string `json:"address,omitempty"`
SiteId string `json:"siteId,omitempty"`
SslProfile string `json:"sslProfile,omitempty"`
VerifyHostname *bool `json:"verifyHostname,omitempty"`
}
func GetTcpConnectors ¶
func GetTcpConnectors(bridges []BridgeConfig) []TcpEndpoint
func (TcpEndpoint) Equivalent ¶
func (a TcpEndpoint) Equivalent(b TcpEndpoint) bool
type TcpEndpointDifference ¶
type TcpEndpointDifference struct {
Deleted []string
Added []TcpEndpoint
}
func (*TcpEndpointDifference) Empty ¶
func (a *TcpEndpointDifference) Empty() bool
type TcpEndpointFilter ¶
type TcpEndpointFilter func(*TcpEndpoint) bool
type TcpEndpointMap ¶
type TcpEndpointMap map[string]TcpEndpoint
func (TcpEndpointMap) Difference ¶
func (a TcpEndpointMap) Difference(b TcpEndpointMap) TcpEndpointDifference
Click to show internal directories.
Click to hide internal directories.