envoy

package
v0.0.0-...-d11cad2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 62 Imported by: 0

Documentation

Index

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

func InArray 

func InArray(a []string, v string) (ret bool, i int)

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 Authz 

type Authz struct {
	Timeout          string
	FailureModeAllow bool
}

type AuthzFilter 

type AuthzFilter struct{}

type Callback 

type Callback struct {
	// contains filtered or unexported fields
}

func (*Callback) OnDeltaStreamClosed 

func (c *Callback) OnDeltaStreamClosed(id int64, n *core.Node)

func (*Callback) OnDeltaStreamOpen 

func (c *Callback) OnDeltaStreamOpen(ctx context.Context, id int64, typ string) error

func (*Callback) OnFetchRequest 

func (c *Callback) OnFetchRequest(ctx context.Context, req *discovery.DiscoveryRequest) error

func (*Callback) OnFetchResponse 

func (c *Callback) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)

func (*Callback) OnStreamClosed 

func (c *Callback) OnStreamClosed(id int64, n *core.Node)

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 (c *Callback) OnStreamOpen(ctx context.Context, id int64, typ string) error

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 ChallengeParams struct {
	Name     string `json:"name"`
	Domain   string `json:"domain"`
	URI      string `json:"uri"`
	Token    string `json:"token"`
	Body     string `json:"body"`
	AuthzURI string `json:"authzURI"`
}

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 ClusterParams struct {
	Name           string
	TargetHostname string
	Port           int64
	HTTP2          bool
	HealthCheck    HealthCheck
	ConnectTimeout int64
}

type Compression 

type Compression struct{}

type CompressionParams 

type CompressionParams struct {
	Type                string
	ContentLength       uint32
	ContentType         []string
	DisableOnEtagHeader bool
	Listener            ListenerParamsListener
}

type Conditions 

type Conditions struct {
	Hostname string
	Prefix   string
	Path     string
	Regex    string
	Methods  []string
}

type CreateCertParams 

type CreateCertParams struct {
	Name            string
	Domains         []string
	DomainsToVerify []string
}

type DefaultsParams 

type DefaultsParams struct {
	Name           string
	ConnectTimeout int64
}

type DirectResponse 

type DirectResponse struct {
	Status uint32
	Body   string
}

type DirectResponseAction 

type DirectResponseAction struct {
	Status uint32
	Body   string
}

type HTTPHealthCheck 

type HTTPHealthCheck struct {
	Path string
}

type HealthCheck 

type HealthCheck struct {
	HTTPHealthCheck    HTTPHealthCheck
	Timeout            string
	Interval           string
	HealthyThreshold   uint32
	UnhealthyThreshold uint32
	UnhealthyInterval  string
}

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 

func (l *Listener) HasMTLSDefault(listenerName, attr string) bool

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 ListenerParamsListener struct {
	MTLS             string
	Port             int64
	StripAnyHostPort bool
	DisableOnDefault bool
}

type LuaFilter 

type LuaFilter struct{}

type LuaFilterParams 

type LuaFilterParams struct {
	Name       string
	InlineCode string
	Listener   ListenerParamsListener
}

type MTLS 

type MTLS struct {
	// contains filtered or unexported fields
}

type MTLSParams 

type MTLSParams struct {
	Name                   string
	PrivateKey             string
	Certificate            string
	Port                   int64
	AllowedSubjectAltNames []string
	AllowedIPRanges        []string
	CACertificate          string
	EnableProxyProtocol    bool
}

type NewNode 

type NewNode struct {
	// contains filtered or unexported fields
}

type ObjectDependency 

type ObjectDependency struct {
	Type string
	Name string
}

type RateLimit 

type RateLimit struct {
	// contains filtered or unexported fields
}

type RateLimitDescriptor 

type RateLimitDescriptor struct {
	DestinationCluster bool
	SourceCluster      bool
	RemoteAddress      bool
	RequestHeader      string
	MTLSSubject        bool
}

type RateLimitParams 

type RateLimitParams struct {
	Name        string
	Descriptors []RateLimitDescriptor
	Listener    ListenerParamsListener
}

type RegexRewrite 

type RegexRewrite struct {
	Regex        string
	Substitution string
}

type RenewalQueue 

type RenewalQueue struct {
	// contains filtered or unexported fields
}

func NewRenewalQueue 

func NewRenewalQueue(s storage.Storage, acmeContact string, workQueue *WorkQueue) (*RenewalQueue, error)

func (*RenewalQueue) CheckRenewals 

func (r *RenewalQueue) CheckRenewals() error

func (*RenewalQueue) StartQueue 

func (r *RenewalQueue) StartQueue()

type TLSParams 

type TLSParams struct {
	Name       string
	CertBundle string
	PrivateKey string
	Domain     string
}

type Tracing 

type Tracing struct{}

type TracingParams 

type TracingParams struct {
	Enabled          bool
	ClientSampling   float64
	RandomSampling   float64
	OverallSampling  float64
	Listener         ListenerParamsListener
	CollectorCluster string
	ProviderName     string
}

type WorkQueue 

type WorkQueue struct {
	// contains filtered or unexported fields
}

func NewWorkQueue 

func NewWorkQueue(s storage.Storage, acmeContact string) (*WorkQueue, error)

func (*WorkQueue) GetVersion 

func (w *WorkQueue) GetVersion() int64

func (*WorkQueue) InitCache 

func (w *WorkQueue) InitCache() cache.SnapshotCache

func (*WorkQueue) InitCallback 

func (w *WorkQueue) InitCallback() *Callback

func (*WorkQueue) Submit 

func (w *WorkQueue) Submit(items []WorkQueueItem) (string, error)

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 NewXDS 

func NewXDS(s storage.Storage, acmeContact, port string) *XDS

func (*XDS) CreateCertsForRules 

func (x *XDS) CreateCertsForRules() error

func (*XDS) ImportObject 

func (x *XDS) ImportObject(object pkgApi.Object) ([]WorkQueueItem, error)

func (*XDS) ImportObjects 

func (x *XDS) ImportObjects() error

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 (x *XDS) RemoveRule(rule pkgApi.Rule, ruleStillPresent bool) ([]WorkQueueItem, error)

func (*XDS) StartRenewalQueue 

func (x *XDS) StartRenewalQueue() error

func (*XDS) WaitForFirstEnvoy 

func (x *XDS) WaitForFirstEnvoy()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.