Documentation
¶
Index ¶
- Constants
- func InArray(a []string, v string) (ret bool, i int)
- type AccessLogServer
- type AccessLogServerParams
- type Action
- type ActionProxy
- type Auth
- type Authz
- type AuthzFilter
- type Callback
- func (c *Callback) OnDeltaStreamClosed(id int64, n *core.Node)
- func (c *Callback) OnDeltaStreamOpen(ctx context.Context, id int64, typ string) error
- func (c *Callback) OnFetchRequest(ctx context.Context, req *discovery.DiscoveryRequest) error
- func (c *Callback) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
- func (c *Callback) OnStreamClosed(id int64, n *core.Node)
- func (c *Callback) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
- func (c *Callback) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, ...)
- func (c *Callback) OnStreamOpen(ctx context.Context, id int64, typ string) error
- func (c *Callback) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error
- func (c *Callback) OnStreamResponse(context.Context, int64, *discovery.DiscoveryRequest, ...)
- type Cert
- type ChallengeParams
- type Cluster
- type ClusterParams
- type Compression
- type CompressionParams
- type Conditions
- type CreateCertParams
- type DefaultsParams
- type DirectResponse
- type DirectResponseAction
- type HTTPHealthCheck
- type HealthCheck
- type JwtProvider
- type Listener
- type ListenerParams
- type ListenerParamsListener
- type LuaFilter
- type LuaFilterParams
- type MTLS
- type MTLSParams
- type NewNode
- type ObjectDependency
- type RateLimit
- type RateLimitDescriptor
- type RateLimitParams
- type RegexRewrite
- type RenewalQueue
- type TLSParams
- type Tracing
- type TracingParams
- type WorkQueue
- type WorkQueueCache
- type WorkQueueItem
- type WorkQueueSubmissionState
- type XDS
- func (x *XDS) CreateCertsForRules() error
- func (x *XDS) ImportObject(object pkgApi.Object) ([]WorkQueueItem, error)
- func (x *XDS) ImportObjects() error
- func (x *XDS) ImportRule(rule pkgApi.Rule) ([]WorkQueueItem, error)
- func (x *XDS) ReceiveNotification(notifications []*notification.NotificationRequest_NotificationItem) error
- func (x *XDS) RemoveRule(rule pkgApi.Rule, ruleStillPresent bool) ([]WorkQueueItem, error)
- func (x *XDS) StartRenewalQueue() error
- func (x *XDS) WaitForFirstEnvoy()
Constants ¶
View Source
const Envoy_HTTP_Filter = "envoy.filters.network.http_connection_manager"
View Source
const Error_NoFilterChainFound = "NoFilterChainFound"
View Source
const Error_NoFilterFound = "NoFilterFound"
View Source
const PRESET_CONNECT_TIMEOUT_SECONDS = 2
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AccessLogServer ¶
type AccessLogServer struct{}
type AccessLogServerParams ¶
type AccessLogServerParams struct {
Name string
AdditionalRequestHeadersToLog []string
AdditionalResponseHeadersToLog []string
Listener ListenerParamsListener
}
type Action ¶
type Action struct {
RuleName string
Type string
Proxy ActionProxy
DirectResponse DirectResponseAction
}
type ActionProxy ¶
type ActionProxy struct {
TargetHostname string
Port int64
HealthCheck HealthCheck
EnableWebsockets bool
PrefixRewrite string
RegexRewrite RegexRewrite
ConnectTimeout int64
}
type Auth ¶
type Auth struct {
JwtProvider string
Issuer string
Forward bool
RemoteJwks string
Listener ListenerParamsListener
}
type AuthzFilter ¶
type AuthzFilter struct{}
type Callback ¶
type Callback struct {
// contains filtered or unexported fields
}
func (*Callback) OnDeltaStreamClosed ¶
func (*Callback) OnDeltaStreamOpen ¶
func (*Callback) OnFetchRequest ¶
func (*Callback) OnFetchResponse ¶
func (c *Callback) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
func (*Callback) OnStreamDeltaRequest ¶
func (c *Callback) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
func (*Callback) OnStreamDeltaResponse ¶
func (c *Callback) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, res *discovery.DeltaDiscoveryResponse)
func (*Callback) OnStreamOpen ¶
func (*Callback) OnStreamRequest ¶
func (c *Callback) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error
func (*Callback) OnStreamResponse ¶
func (c *Callback) OnStreamResponse(context.Context, int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
type Cert ¶
type Cert struct {
// contains filtered or unexported fields
}
func (*Cert) CreateCert ¶
func (c *Cert) CreateCert(params CreateCertParams) (string, string, error)
type ChallengeParams ¶
type Cluster ¶
type Cluster struct {
DefaultsParams DefaultsParams
}
func (*Cluster) GetClusterNames ¶
func (c *Cluster) GetClusterNames(clusters []cacheTypes.Resource) []string
func (*Cluster) PrintCluster ¶
func (c *Cluster) PrintCluster(cache *WorkQueueCache, name string) (string, error)
type ClusterParams ¶
type Compression ¶
type Compression struct{}
type CompressionParams ¶
type CompressionParams struct {
Type string
ContentLength uint32
ContentType []string
DisableOnEtagHeader bool
Listener ListenerParamsListener
}
type Conditions ¶
type CreateCertParams ¶
type DefaultsParams ¶
type DirectResponse ¶
type DirectResponseAction ¶
type HTTPHealthCheck ¶
type HTTPHealthCheck struct {
Path string
}
type HealthCheck ¶
type JwtProvider ¶
type JwtProvider struct{}
func (*JwtProvider) DeleteJwtRule ¶
func (j *JwtProvider) DeleteJwtRule(cache *WorkQueueCache, params ListenerParams, paramsTLS TLSParams) error
func (*JwtProvider) UpdateJwtRule ¶
func (j *JwtProvider) UpdateJwtRule(cache *WorkQueueCache, params ListenerParams, paramsTLS TLSParams) error
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
func (*Listener) DeleteRoute ¶
func (l *Listener) DeleteRoute(cache *WorkQueueCache, params ListenerParams, paramsTLS TLSParams) error
func (*Listener) GetListenerNames ¶
func (l *Listener) GetListenerNames(listeners []cacheTypes.Resource) []string
func (*Listener) HasMTLSDefault ¶
type ListenerParams ¶
type ListenerParams struct {
Name string
Protocol string
TargetHostname string
EnableWebSockets bool
PrefixRewrite string
RegexRewrite RegexRewrite
Conditions Conditions
Auth Auth
Authz Authz
DirectResponse DirectResponse
Listener ListenerParamsListener
}
type ListenerParamsListener ¶
type LuaFilterParams ¶
type LuaFilterParams struct {
Name string
InlineCode string
Listener ListenerParamsListener
}
type MTLSParams ¶
type ObjectDependency ¶
type RateLimitDescriptor ¶
type RateLimitParams ¶
type RateLimitParams struct {
Name string
Descriptors []RateLimitDescriptor
Listener ListenerParamsListener
}
type RegexRewrite ¶
type RenewalQueue ¶
type RenewalQueue struct {
// contains filtered or unexported fields
}
func NewRenewalQueue ¶
func (*RenewalQueue) CheckRenewals ¶
func (r *RenewalQueue) CheckRenewals() error
func (*RenewalQueue) StartQueue ¶
func (r *RenewalQueue) StartQueue()
type TracingParams ¶
type WorkQueue ¶
type WorkQueue struct {
// contains filtered or unexported fields
}
func (*WorkQueue) GetVersion ¶
func (*WorkQueue) InitCache ¶
func (w *WorkQueue) InitCache() cache.SnapshotCache
func (*WorkQueue) InitCallback ¶
func (*WorkQueue) WaitForFirstEnvoy ¶
func (w *WorkQueue) WaitForFirstEnvoy()
type WorkQueueCache ¶
type WorkQueueCache struct {
// contains filtered or unexported fields
}
type WorkQueueItem ¶
type WorkQueueItem struct {
Action string
DependsOn string
DependsOnItemIDs []string
TLSParams TLSParams
ClusterParams ClusterParams
ListenerParams ListenerParams
ChallengeParams ChallengeParams
CreateCertParams CreateCertParams
TracingParams TracingParams
CompressionParams CompressionParams
AccessLogServerParams AccessLogServerParams
RateLimitParams RateLimitParams
MTLSParams MTLSParams
LuaFilterParams LuaFilterParams
DefaultsParams DefaultsParams
// contains filtered or unexported fields
}
type WorkQueueSubmissionState ¶
type WorkQueueSubmissionState struct {
// contains filtered or unexported fields
}
type XDS ¶
type XDS struct {
// contains filtered or unexported fields
}
func (*XDS) CreateCertsForRules ¶
func (*XDS) ImportObject ¶
func (x *XDS) ImportObject(object pkgApi.Object) ([]WorkQueueItem, error)
func (*XDS) ImportObjects ¶
func (*XDS) ImportRule ¶
func (x *XDS) ImportRule(rule pkgApi.Rule) ([]WorkQueueItem, error)
func (*XDS) ReceiveNotification ¶
func (x *XDS) ReceiveNotification(notifications []*notification.NotificationRequest_NotificationItem) error
ReceiveNotification receives notification items and will process them
func (*XDS) RemoveRule ¶
func (*XDS) StartRenewalQueue ¶
func (*XDS) WaitForFirstEnvoy ¶
func (x *XDS) WaitForFirstEnvoy()
Click to show internal directories.
Click to hide internal directories.