Documentation
¶
Index ¶
- func AckDeltaResponse(resourceType resource_v3.Type, nonce string) proto.Message
- func AckSotWResponse(resourceType resource_v3.Type, version, nonce string, resourceNames []string) proto.Message
- func GetDownstreamTlsContext(ts *envoy_config_core_v3.TransportSocket) *auth.DownstreamTlsContext
- func GetTcpProxy(filter *envoy_config_listener_v3.Filter) *envoy_extensions_filters_network_tcp_proxy_v3.TcpProxy
- func GetUnifiedMetadata(md *envoy_config_core_v3.Metadata) (map[string]interface{}, error)
- func NackDeltaResponse(resourceType resource_v3.Type, nonce string, err error) proto.Message
- func NackSotWResponse(resourceType resource_v3.Type, version, nonce string, resourceNames []string, ...) *discovery_v3.DiscoveryRequest
- func SortedStringSliceEqual(a, b []string) bool
- func StringSliceSubtract(a, b []string) []string
- type KeyValueCollection
- func (c *KeyValueCollection[K, S]) Get(key K) (S, bool)
- func (c *KeyValueCollection[K, S]) Items() map[K]S
- func (c *KeyValueCollection[K, S]) Keep(items map[K]struct{})
- func (c *KeyValueCollection[K, S]) Lock()
- func (c *KeyValueCollection[K, S]) RLock()
- func (c *KeyValueCollection[K, S]) RUnlock()
- func (c *KeyValueCollection[K, S]) Set(key K, stats S)
- func (c *KeyValueCollection[K, S]) Unlock()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AckDeltaResponse ¶
func AckDeltaResponse(resourceType resource_v3.Type, nonce string) proto.Message
AckDeltaResponse creates a 'DeltaDiscoveryRequest' to tell the management server that the config change for the given resource type was accepted
func AckSotWResponse ¶
func AckSotWResponse(resourceType resource_v3.Type, version, nonce string, resourceNames []string) proto.Message
AckSotWResponse creates a 'DiscoveryRequest' to tell the management server that the config change for the given resource type was accepted
func GetDownstreamTlsContext ¶
func GetDownstreamTlsContext(ts *envoy_config_core_v3.TransportSocket) *auth.DownstreamTlsContext
func GetTcpProxy ¶
func GetTcpProxy(filter *envoy_config_listener_v3.Filter) *envoy_extensions_filters_network_tcp_proxy_v3.TcpProxy
func GetUnifiedMetadata ¶
func GetUnifiedMetadata(md *envoy_config_core_v3.Metadata) (map[string]interface{}, error)
func NackDeltaResponse ¶
NackDeltaResponse creates a 'DeltaDiscoveryRequest' to tell the management server that the config change for the given resource type was rejected due to the given error
func NackSotWResponse ¶
func NackSotWResponse(resourceType resource_v3.Type, version, nonce string, resourceNames []string, err error) *discovery_v3.DiscoveryRequest
NackSotWResponse creates a 'DiscoveryRequest' to tell the management server that the config change for the given resource type was rejected due to the given error
func SortedStringSliceEqual ¶
SortedStringSliceEqual returns true if the provided sorted strings are equal
func StringSliceSubtract ¶
StringSliceSubtract returns the Get of a-b
Types ¶
type KeyValueCollection ¶
type KeyValueCollection[K comparable, V comparable] struct { // contains filtered or unexported fields }
KeyValueCollection thread-safe collection of <K, V> items
func NewKeyValueCollection ¶
func NewKeyValueCollection[K comparable, V comparable]() *KeyValueCollection[K, V]
func (*KeyValueCollection[K, S]) Get ¶
func (c *KeyValueCollection[K, S]) Get(key K) (S, bool)
func (*KeyValueCollection[K, S]) Items ¶
func (c *KeyValueCollection[K, S]) Items() map[K]S
func (*KeyValueCollection[K, S]) Keep ¶
func (c *KeyValueCollection[K, S]) Keep(items map[K]struct{})
func (*KeyValueCollection[K, S]) Lock ¶
func (c *KeyValueCollection[K, S]) Lock()
func (*KeyValueCollection[K, S]) RLock ¶
func (c *KeyValueCollection[K, S]) RLock()
func (*KeyValueCollection[K, S]) RUnlock ¶
func (c *KeyValueCollection[K, S]) RUnlock()
func (*KeyValueCollection[K, S]) Set ¶
func (c *KeyValueCollection[K, S]) Set(key K, stats S)
func (*KeyValueCollection[K, S]) Unlock ¶
func (c *KeyValueCollection[K, S]) Unlock()
Source Files