Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentGrpcServer ¶
type AgentGrpcServer struct {
pb.UnimplementedRouterServiceServer
// contains filtered or unexported fields
}
func NewAgentGrpcServer ¶
func NewAgentGrpcServer( log logrus.FieldLogger, cfg *config.Config, ) *AgentGrpcServer
New returns a new instance of a flightctl server.
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) PrepareGRPCService ¶ added in v0.4.0
func (s *AgentGrpcServer) PrepareGRPCService() *grpc.Server
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
type AgentServer ¶
type AgentServer struct {
// contains filtered or unexported fields
}
func New ¶
func New( log logrus.FieldLogger, cfg *config.Config, store store.Store, ca *crypto.CAClient, listener net.Listener, queuesProvider queues.Provider, tlsConfig *tls.Config, metrics *instrumentation.ApiMetrics, ) *AgentServer
New returns a new instance of a flightctl server.
func (*AgentServer) GetGRPCServer ¶ added in v0.4.0
func (s *AgentServer) GetGRPCServer() *AgentGrpcServer
Source Files
Click to show internal directories.
Click to hide internal directories.