Documentation
¶
Overview ¶
Package helper implements the helper for the remoteagent component
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type UnimplementedRemoteAgentServer ¶
type UnimplementedRemoteAgentServer struct {
// contains filtered or unexported fields
}
UnimplementedRemoteAgentServer is a wrapper around a gRPC server that implements the RemoteAgentServer protocol. It takes care of the registration logic with the Core Agent.
func NewUnimplementedRemoteAgentServer ¶
func NewUnimplementedRemoteAgentServer(ipcComp ipc.Component, log log.Component, config config.Component, lc compdef.Lifecycle, agentIpcAddress string, agentFlavor string, displayName string) (*UnimplementedRemoteAgentServer, error)
NewUnimplementedRemoteAgentServer creates a new unimplemented remote agent server
func (*UnimplementedRemoteAgentServer) GetGRPCServer ¶
func (s *UnimplementedRemoteAgentServer) GetGRPCServer() *grpc.Server
GetGRPCServer returns the gRPC server
func (*UnimplementedRemoteAgentServer) Start ¶
func (s *UnimplementedRemoteAgentServer) Start()
Start begins serving gRPC and starts the RAR registration loop. Impls must call this after registering services on GetGRPCServer().
func (*UnimplementedRemoteAgentServer) WaitSessionID ¶
func (s *UnimplementedRemoteAgentServer) WaitSessionID(ctx context.Context) (string, error)
WaitSessionID blocks until the remote agent is registered and a session ID is available, or ctx is done. It returns the session ID or an error if the context is cancelled before registration completes.
Source Files