sds

Documentation

Overview

Package sds implements secret discovery service in NodeAgent.

Index

• type Context
  • func (c *Context) Close()
  • func (c *Context) Initialize(_ *core.Node) error
  • func (c *Context) Process(req *discovery.DiscoveryRequest) error
  • func (c *Context) Push(ev any) error
  • func (c *Context) Watcher() xds.Watcher
  • func (c *Context) XdsConnection() *xds.Connection
• type Server
  • func NewServer(options *security.Options, workloadSecretCache security.SecretManager, ...) *Server
  • func (s *Server) OnSecretUpdate(resourceName string)
  • func (s *Server) Stop()
• type Watch
  • func (w *Watch) DeleteWatchedResource(string)
  • func (w *Watch) GetID() string
  • func (w *Watch) GetWatchedResource(string) *xds.WatchedResource
  • func (w *Watch) NewWatchedResource(typeURL string, names []string)
  • func (w *Watch) UpdateWatchedResource(_ string, f func(*xds.WatchedResource) *xds.WatchedResource)

Types

type Context

type Context struct {
	BaseConnection xds.Connection
	// contains filtered or unexported fields
}

func (*Context) Close

func (c *Context) Close()

func (*Context) Initialize

func (c *Context) Initialize(_ *core.Node) error

func (*Context) Process

func (c *Context) Process(req *discovery.DiscoveryRequest) error

func (*Context) Push

func (c *Context) Push(ev any) error

func (*Context) Watcher

func (c *Context) Watcher() xds.Watcher

func (*Context) XdsConnection

func (c *Context) XdsConnection() *xds.Connection

type Server

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

Server is the gPRC server that exposes SDS through UDS.

func NewServer

func NewServer(options *security.Options, workloadSecretCache security.SecretManager, pkpConf *mesh.PrivateKeyProvider) *Server

NewServer creates and starts the Grpc server for SDS.

func (*Server) OnSecretUpdate

func (s *Server) OnSecretUpdate(resourceName string)

func (*Server) Stop

func (s *Server) Stop()

Stop closes the gRPC server and debug server.

type Watch

type Watch struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Watch) DeleteWatchedResource

func (w *Watch) DeleteWatchedResource(string)

func (*Watch) GetID

func (w *Watch) GetID() string

func (*Watch) GetWatchedResource

func (w *Watch) GetWatchedResource(string) *xds.WatchedResource

func (*Watch) NewWatchedResource

func (w *Watch) NewWatchedResource(typeURL string, names []string)

func (*Watch) UpdateWatchedResource

func (w *Watch) UpdateWatchedResource(_ string, f func(*xds.WatchedResource) *xds.WatchedResource)