Documentation
¶
Index ¶
- type AgentGrpcServer
- func (s *AgentGrpcServer) Close()
- func (s *AgentGrpcServer) CloseSession(session *console.ConsoleSession) error
- func (s *AgentGrpcServer) StartSession(session *console.ConsoleSession) error
- func (s *AgentGrpcServer) Stream(stream pb.RouterService_StreamServer) error
- func (s *AgentGrpcServer) TPMChallenge(stream pb.Enrollment_TPMChallengeServer) error
- type AgentServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentGrpcServer ¶
type AgentGrpcServer struct {
pb.UnimplementedRouterServiceServer
pb.UnimplementedEnrollmentServer
// contains filtered or unexported fields
}
func NewAgentGrpcServer ¶
func NewAgentGrpcServer( log logrus.FieldLogger, cfg *config.Config, svc service.Service, ) *AgentGrpcServer
New returns a new instance of a flightctl server.
func (*AgentGrpcServer) Close ¶ added in v0.10.0
func (s *AgentGrpcServer) Close()
func (*AgentGrpcServer) CloseSession ¶ added in v0.4.0
func (s *AgentGrpcServer) CloseSession(session *console.ConsoleSession) error
This function is called by the console session manager to signal that the session has been closed from the other side
func (*AgentGrpcServer) StartSession ¶ added in v0.4.0
func (s *AgentGrpcServer) StartSession(session *console.ConsoleSession) error
This function is called by the console session manager to signal that it is ready to accept connections from the agent. This is a way to provide the gRPC service with the session UUID and the channels
func (*AgentGrpcServer) Stream ¶
func (s *AgentGrpcServer) Stream(stream pb.RouterService_StreamServer) error
func (*AgentGrpcServer) TPMChallenge ¶ added in v0.10.0
func (s *AgentGrpcServer) TPMChallenge(stream pb.Enrollment_TPMChallengeServer) error
TPMChallenge implements the TPM challenge-response protocol for device enrollment
type AgentServer ¶
type AgentServer struct {
// contains filtered or unexported fields
}
func New ¶
func New( ctx context.Context, log logrus.FieldLogger, cfg *config.Config, st store.Store, ca *crypto.CAClient, listener net.Listener, queuesProvider queues.Provider, tlsConfig *tls.Config, ) (*AgentServer, error)
New returns a new instance of a flightctl server.
func (*AgentServer) GetGRPCServer ¶ added in v0.4.0
func (s *AgentServer) GetGRPCServer() *AgentGrpcServer
func (*AgentServer) Stop ¶ added in v0.10.0
func (s *AgentServer) Stop()
Stop cleans up all resources
Source Files
Click to show internal directories.
Click to hide internal directories.