Documentation
¶
Index ¶
- type NodeAgentClient
- type Retriever
- type Server
- func (s *Server) CloseAllWlds()
- func (s *Server) Serve(path string)
- func (s *Server) Stop()
- func (s *Server) WaitDone()
- func (s *Server) WorkloadAdded(ctx context.Context, request *pb.WorkloadInfo) (*pb.NodeAgentMgmtResponse, error)
- func (s *Server) WorkloadDeleted(ctx context.Context, request *pb.WorkloadInfo) (*pb.NodeAgentMgmtResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NodeAgentClient ¶
type NodeAgentClient struct {
// contains filtered or unexported fields
}
NodeAgentClient specify a UDS client connection
func ClientUds ¶
func ClientUds(path string) *NodeAgentClient
ClientUds create a new client with path
func NewClient ¶
func NewClient(path string) *NodeAgentClient
NewClient is used by the flexvolume driver to interface with the nodeagent grpc server
func (*NodeAgentClient) WorkloadAdded ¶
func (c *NodeAgentClient) WorkloadAdded(ninputs *pb.WorkloadInfo) (*pb.NodeAgentMgmtResponse, error)
WorkloadAdded add the workload.
func (*NodeAgentClient) WorkloadDeleted ¶
func (c *NodeAgentClient) WorkloadDeleted(ninputs *pb.WorkloadInfo) (*pb.NodeAgentMgmtResponse, error)
WorkloadDeleted delete the workload.
type Retriever ¶
type Retriever interface {
Retrieve(opt *pkiutil.CertOptions) (newCert, certChain, privateKey []byte, err error)
}
Retriever is the interface responsible for retrieving key/cert from upstream CA.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server specifies the node agent server. TODO(incfly): adds sync.Mutex to protects the fields, such as `handlerMap`.
func (*Server) Serve ¶
Serve opens the UDS channel and starts to serve NodeAgentService on that uds channel.
func (*Server) WaitDone ¶
func (s *Server) WaitDone()
WaitDone waits for a response back from Workloadhandler
func (*Server) WorkloadAdded ¶
func (s *Server) WorkloadAdded(ctx context.Context, request *pb.WorkloadInfo) (*pb.NodeAgentMgmtResponse, error)
WorkloadAdded defines the server side action when a workload is added.
func (*Server) WorkloadDeleted ¶
func (s *Server) WorkloadDeleted(ctx context.Context, request *pb.WorkloadInfo) (*pb.NodeAgentMgmtResponse, error)
WorkloadDeleted defines the server side action when a workload is deleted.
Source Files