The highest tagged major version is
Documentation
¶
Index ¶
- type AppProxy
- func (p *AppProxy) Enforce(ctx context.Context, puID string, puInfo *policy.PUInfo) error
- func (p *AppProxy) GetFilterQueue() *fqconfig.FilterQueue
- func (p *AppProxy) Ping(ctx context.Context, contextID string, sctx *serviceregistry.ServiceContext, ...) error
- func (p *AppProxy) Run(ctx context.Context) error
- func (p *AppProxy) ServiceData(contextID string, ip net.IP, port int, serviceAddresses map[string][]string) (*serviceregistry.ServiceContext, *serviceregistry.DependentServiceData, error)
- func (p *AppProxy) Unenforce(ctx context.Context, puID string) error
- func (p *AppProxy) UpdateSecrets(secret secrets.Secrets) error
- type ServerInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppProxy ¶
AppProxy maintains state for proxies connections from listen to backend.
func NewAppProxy ¶
func NewAppProxy( tp tokenaccessor.TokenAccessor, c collector.EventCollector, puFromID cache.DataStore, s secrets.Secrets, t tcommon.ServiceTokenIssuer, datapathKeyPair ephemeralkeys.KeyAccessor, agentVersion semver.Version, ) (*AppProxy, error)
NewAppProxy creates a new instance of the application proxy.
func (*AppProxy) Enforce ¶
Enforce implements enforcer.Enforcer interface. It will create the necessary proxies for the particular PU. Enforce can be called multiple times, once for every policy update.
func (*AppProxy) GetFilterQueue ¶
func (p *AppProxy) GetFilterQueue() *fqconfig.FilterQueue
GetFilterQueue is a stub for TCP proxy
func (*AppProxy) Ping ¶
func (p *AppProxy) Ping(ctx context.Context, contextID string, sctx *serviceregistry.ServiceContext, sdata *serviceregistry.DependentServiceData, pingConfig *policy.PingConfig) error
Ping runs ping to the given config based on the service type. Returns error on invalid types.
func (*AppProxy) Run ¶
Run starts all the network side proxies. Application side proxies will have to start during enforce in order to support multiple Linux processes.
func (*AppProxy) ServiceData ¶
func (p *AppProxy) ServiceData( contextID string, ip net.IP, port int, serviceAddresses map[string][]string) (*serviceregistry.ServiceContext, *serviceregistry.DependentServiceData, error)
ServiceData returns the servicectx and dependentservice for the given ip:port.
type ServerInterface ¶
type ServerInterface interface {
UpdateSecrets(cert *tls.Certificate, ca *x509.CertPool, secrets secrets.Secrets, certPEM, keyPEM string)
ShutDown() error
}
ServerInterface describes the methods required by an application processor.
Source Files
Directories