Documentation
¶
Index ¶
- func AthenzGrpcServerName() string
- func ClientAuthType() string
- func NewCredentials() credentials.TransportCredentials
- func StartGrpcServer(opts *options.Options, certUpdates chan bool) error
- func StartUdsListener(udsPath string) (net.Listener, error)
- type ClientInfo
- type Listener
- type ServerHandler
- func (handler *ServerHandler) DeltaSecrets(envoySecret.SecretDiscoveryService_DeltaSecretsServer) error
- func (handler *ServerHandler) FetchSecrets(ctx context.Context, req *envoyDiscovery.DiscoveryRequest) (*envoyDiscovery.DiscoveryResponse, error)
- func (handler *ServerHandler) NotifySubscribers()
- func (handler *ServerHandler) StreamSecrets(stream envoySecret.SecretDiscoveryService_StreamSecretsServer) error
- type Subscriber
- func (subscriber *Subscriber) Close()
- func (subscriber *Subscriber) GetCertUpdates() chan bool
- func (subscriber *Subscriber) GetId() string
- func (subscriber *Subscriber) GetVersionInfo() string
- func (subscriber *Subscriber) IncrementVersion()
- func (subscriber *Subscriber) Notify()
- func (subscriber *Subscriber) SetResponseNonce(nonce string)
- func (subscriber *Subscriber) ValidateResponseNonce(responseNonce string) bool
- func (subscriber *Subscriber) ValidateVersionInfo(versionInfo string) bool
- type UdsConn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AthenzGrpcServerName ¶
func AthenzGrpcServerName() string
func ClientAuthType ¶
func ClientAuthType() string
func NewCredentials ¶
func NewCredentials() credentials.TransportCredentials
func StartUdsListener ¶
StartUdsListener Start a Unix-Domain-Socket listener. We're going to create a simple wrapper struct for the Listener object since we want to intercept Accept calls and extract the caller's user and process ids. The client info object will then be passed to grpc as credentials.AuthInfo which can be accessed later from the stream context
Types ¶
type ClientInfo ¶
func ClientInfoFromContext ¶
func ClientInfoFromContext(ctx context.Context) ClientInfo
func (ClientInfo) AuthType ¶
func (ClientInfo) AuthType() string
type ServerHandler ¶
type ServerHandler struct {
Mutex sync.RWMutex
Options *options.Options
Subscribers map[string]*Subscriber
}
func NewServerHandler ¶
func NewServerHandler(opts *options.Options) *ServerHandler
func (*ServerHandler) DeltaSecrets ¶
func (handler *ServerHandler) DeltaSecrets(envoySecret.SecretDiscoveryService_DeltaSecretsServer) error
func (*ServerHandler) FetchSecrets ¶
func (handler *ServerHandler) FetchSecrets(ctx context.Context, req *envoyDiscovery.DiscoveryRequest) (*envoyDiscovery.DiscoveryResponse, error)
func (*ServerHandler) NotifySubscribers ¶
func (handler *ServerHandler) NotifySubscribers()
func (*ServerHandler) StreamSecrets ¶
func (handler *ServerHandler) StreamSecrets(stream envoySecret.SecretDiscoveryService_StreamSecretsServer) error
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func NewSubscriber ¶
func NewSubscriber() *Subscriber
func (*Subscriber) Close ¶
func (subscriber *Subscriber) Close()
func (*Subscriber) GetCertUpdates ¶
func (subscriber *Subscriber) GetCertUpdates() chan bool
func (*Subscriber) GetId ¶
func (subscriber *Subscriber) GetId() string
func (*Subscriber) GetVersionInfo ¶
func (subscriber *Subscriber) GetVersionInfo() string
func (*Subscriber) IncrementVersion ¶
func (subscriber *Subscriber) IncrementVersion()
func (*Subscriber) Notify ¶
func (subscriber *Subscriber) Notify()
func (*Subscriber) SetResponseNonce ¶
func (subscriber *Subscriber) SetResponseNonce(nonce string)
func (*Subscriber) ValidateResponseNonce ¶
func (subscriber *Subscriber) ValidateResponseNonce(responseNonce string) bool
func (*Subscriber) ValidateVersionInfo ¶
func (subscriber *Subscriber) ValidateVersionInfo(versionInfo string) bool
type UdsConn ¶
type UdsConn struct {
net.Conn
ClientInfo ClientInfo
}
Source Files
Click to show internal directories.
Click to hide internal directories.