grpcserver

package
v1.24.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 25, 2026 License: MIT Imports: 52 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenerateExtensionToken 

func GenerateExtensionToken(extension *extensions.Extension, serverInfo *ServerInfo) (string, error)

GenerateExtensionToken generates a JWT token for the extension.

func NewAccountService 

func NewAccountService(subscriptionsManager *account.SubscriptionsManager) azdext.AccountServiceServer

func NewAiModelService 

func NewAiModelService(
	modelService *ai.AiModelService,
) azdext.AiModelServiceServer

NewAiModelService creates a new AI model gRPC service.

func NewComposeService 

func NewComposeService(
	lazyAzdContext *lazy.Lazy[*azdcontext.AzdContext],
	lazyEnv *lazy.Lazy[*environment.Environment],
	lazyEnvManger *lazy.Lazy[environment.Manager],
) azdext.ComposeServiceServer

func NewContainerService 

func NewContainerService(
	console input.Console,
	lazyContainerHelper *lazy.Lazy[*project.ContainerHelper],
	lazyServiceManager *lazy.Lazy[project.ServiceManager],
	lazyProjectConf *lazy.Lazy[*project.ProjectConfig],
	lazyEnvironment *lazy.Lazy[*environment.Environment],
) azdext.ContainerServiceServer

func NewCopilotService 

func NewCopilotService(agentFactory agent.AgentFactory) azdext.CopilotServiceServer

NewCopilotService creates a new CopilotService gRPC server.

func NewDeploymentService 

func NewDeploymentService(
	lazyAzdContext *lazy.Lazy[*azdcontext.AzdContext],
	lazyEnvManager *lazy.Lazy[environment.Manager],
	lazyProjectConfig *lazy.Lazy[*project.ProjectConfig],
	lazyBicepProvider *lazy.Lazy[*bicep.BicepProvider],
	azureDeploymentService azapi.DeploymentService,
) azdext.DeploymentServiceServer

func NewEnvironmentService 

func NewEnvironmentService(
	lazyAzdContext *lazy.Lazy[*azdcontext.AzdContext],
	lazyEnvManager *lazy.Lazy[environment.Manager],
) azdext.EnvironmentServiceServer

func NewEventService 

func NewEventService(
	extensionManager *extensions.Manager,
	lazyEnvManager *lazy.Lazy[environment.Manager],
	lazyProject *lazy.Lazy[*project.ProjectConfig],
	lazyEnv *lazy.Lazy[*environment.Environment],
	console input.Console,
) azdext.EventServiceServer

func NewExtensionService 

func NewExtensionService(extensionManager *extensions.Manager) azdext.ExtensionServiceServer

NewExtensionService creates a new ExtensionService instance.

func NewExternalProvisioningProviderFactory added in v1.24.2 

func NewExternalProvisioningProviderFactory(
	providerName string,
	extension *extensions.Extension,
	broker *grpcbroker.MessageBroker[azdext.ProvisioningMessage],
) func() provisioning.Provider

NewExternalProvisioningProviderFactory returns a DI-compatible factory function.

func NewFrameworkService 

func NewFrameworkService(
	container *ioc.NestedContainer,
	extensionManager *extensions.Manager,
) azdext.FrameworkServiceServer

NewFrameworkService creates a new FrameworkService instance.

func NewProjectService 

func NewProjectService(
	lazyAzdContext *lazy.Lazy[*azdcontext.AzdContext],
	lazyEnvManager *lazy.Lazy[environment.Manager],
	lazyResourceManager *lazy.Lazy[project.ResourceManager],
	lazyEnv *lazy.Lazy[*environment.Environment],
	lazyProjectConfig *lazy.Lazy[*project.ProjectConfig],
	importManager *project.ImportManager,
	ghCli *github.Cli,
) azdext.ProjectServiceServer

NewProjectService creates a new project service instance with lazy-loaded dependencies. The service provides gRPC methods for managing Azure Developer CLI projects, including project configuration, service management, and extension configuration through AdditionalProperties.

Parameters:

  • lazyAzdContext: Lazy-loaded Azure Developer CLI context for project directory operations
  • lazyEnvManager: Lazy-loaded environment manager for handling Azure environments
  • lazyResourceManager: Lazy-loaded resource manager for resolving target resources
  • lazyEnv: Lazy-loaded environment for accessing environment variables and subscription info
  • lazyProjectConfig: Lazy-loaded project configuration for accessing project settings

Returns an implementation of azdext.ProjectServiceServer.

func NewPromptService 

func NewPromptService(
	prompter prompt.PromptService,
	resourceService *azapi.ResourceService,
	aiModelService *ai.AiModelService,
	globalOptions *internal.GlobalCommandOptions,
) azdext.PromptServiceServer

func NewProvisioningService added in v1.24.2 

func NewProvisioningService(
	container *ioc.NestedContainer,
	extensionManager *extensions.Manager,
) azdext.ProvisioningServiceServer

NewProvisioningService creates a new ProvisioningService instance.

func NewServiceTargetService 

func NewServiceTargetService(
	container *ioc.NestedContainer,
	extensionManager *extensions.Manager,
	lazyEnv *lazy.Lazy[*environment.Environment],
) azdext.ServiceTargetServiceServer

NewServiceTargetService creates a new ServiceTargetService instance.

func NewUserConfigService 

func NewUserConfigService(userConfigManager config.UserConfigManager) (azdext.UserConfigServiceServer, error)

NewConfigService creates a new instance of configService.

func NewWorkflowService 

func NewWorkflowService(runner *workflow.Runner) azdext.WorkflowServiceServer

NewWorkflowService creates a new instance of the workflow service.

func ParseExtensionToken 

func ParseExtensionToken(tokenValue string, serverInfo *ServerInfo) (*extensions.ExtensionClaims, error)

ParseExtensionToken parses and validates the extension token.

Types

type ExtensionService 

type ExtensionService struct {
	azdext.UnimplementedExtensionServiceServer
	// contains filtered or unexported fields
}

ExtensionService implements azdext.ExtensionServiceServer.

func (*ExtensionService) Ready 

func (s *ExtensionService) Ready(ctx context.Context, req *azdext.ReadyRequest) (*azdext.ReadyResponse, error)

Ready signals that the extension is done registering all capabilities. The extension will remain alive as long as its streams are active and context is not cancelled.

func (*ExtensionService) ReportError 

func (s *ExtensionService) ReportError(
	ctx context.Context, req *azdext.ReportErrorRequest,
) (*azdext.ReportErrorResponse, error)

ReportError receives a structured error from the extension and stores it so the host can retrieve it after the extension process exits.

type ExternalProvisioningProvider added in v1.24.2 

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

ExternalProvisioningProvider implements provisioning.Provider by delegating to an extension.

func (*ExternalProvisioningProvider) Deploy added in v1.24.2 

func (p *ExternalProvisioningProvider) Deploy(
	ctx context.Context,
) (*provisioning.DeployResult, error)

Deploy performs the provisioning deployment.

func (*ExternalProvisioningProvider) Destroy added in v1.24.2 

func (p *ExternalProvisioningProvider) Destroy(
	ctx context.Context,
	options provisioning.DestroyOptions,
) (*provisioning.DestroyResult, error)

Destroy destroys the provisioned infrastructure.

func (*ExternalProvisioningProvider) EnsureEnv added in v1.24.2 

func (p *ExternalProvisioningProvider) EnsureEnv(ctx context.Context) error

EnsureEnv ensures the environment is configured properly.

func (*ExternalProvisioningProvider) Initialize added in v1.24.2 

func (p *ExternalProvisioningProvider) Initialize(
	ctx context.Context,
	projectPath string,
	options provisioning.Options,
) error

Initialize initializes the provider with project path and options. Note: projectPath validation (path traversal, absolute path checks) is not performed here — this matches the existing pattern in service targets and framework services. Path validation should be addressed holistically across all extension provider types.

func (*ExternalProvisioningProvider) Name added in v1.24.2 

func (p *ExternalProvisioningProvider) Name() string

Name returns the provisioning provider name.

func (*ExternalProvisioningProvider) Parameters added in v1.24.2 

func (p *ExternalProvisioningProvider) Parameters(
	ctx context.Context,
) ([]provisioning.Parameter, error)

Parameters returns the provisioning parameters.

func (*ExternalProvisioningProvider) PlannedOutputs added in v1.24.2 

func (p *ExternalProvisioningProvider) PlannedOutputs(
	ctx context.Context,
) ([]provisioning.PlannedOutput, error)

PlannedOutputs returns planned outputs from the extension provider.

func (*ExternalProvisioningProvider) Preview added in v1.24.2 

func (p *ExternalProvisioningProvider) Preview(
	ctx context.Context,
) (*provisioning.DeployPreviewResult, error)

Preview returns a preview of what a deployment would change.

func (*ExternalProvisioningProvider) State added in v1.24.2 

func (p *ExternalProvisioningProvider) State(
	ctx context.Context,
	options *provisioning.StateOptions,
) (*provisioning.StateResult, error)

State returns the current state of provisioned infrastructure.

type FrameworkService 

type FrameworkService struct {
	azdext.UnimplementedFrameworkServiceServer
	// contains filtered or unexported fields
}

FrameworkService implements azdext.FrameworkServiceServer.

func (*FrameworkService) Stream 

func (s *FrameworkService) Stream(stream azdext.FrameworkService_StreamServer) error

Stream handles the bi-directional streaming for framework service operations.

type ProvisioningService added in v1.24.2 

type ProvisioningService struct {
	azdext.UnimplementedProvisioningServiceServer
	// contains filtered or unexported fields
}

ProvisioningService implements azdext.ProvisioningServiceServer.

func (*ProvisioningService) Stream added in v1.24.2 

func (s *ProvisioningService) Stream(
	stream azdext.ProvisioningService_StreamServer,
) error

Stream handles the bi-directional streaming for provisioning operations.

type Server 

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

func NewServer 

func NewServer(
	projectService azdext.ProjectServiceServer,
	environmentService azdext.EnvironmentServiceServer,
	promptService azdext.PromptServiceServer,
	userConfigService azdext.UserConfigServiceServer,
	deploymentService azdext.DeploymentServiceServer,
	eventService azdext.EventServiceServer,
	composeService azdext.ComposeServiceServer,
	workflowService azdext.WorkflowServiceServer,
	extensionService azdext.ExtensionServiceServer,
	serviceTargetService azdext.ServiceTargetServiceServer,
	frameworkService azdext.FrameworkServiceServer,
	containerService azdext.ContainerServiceServer,
	accountService azdext.AccountServiceServer,
	aiModelService azdext.AiModelServiceServer,
	copilotService azdext.CopilotServiceServer,
	provisioningService azdext.ProvisioningServiceServer,
) *Server

func (*Server) Start 

func (s *Server) Start() (*ServerInfo, error)

func (*Server) Stop 

func (s *Server) Stop() error

type ServerInfo 

type ServerInfo struct {
	Address    string
	Port       int
	SigningKey []byte
}

type ServiceTargetService 

type ServiceTargetService struct {
	azdext.UnimplementedServiceTargetServiceServer
	// contains filtered or unexported fields
}

ServiceTargetService implements azdext.ServiceTargetServiceServer.

func (*ServiceTargetService) Stream 

func (s *ServiceTargetService) Stream(stream azdext.ServiceTargetService_StreamServer) error

Stream handles the bi-directional streaming for service target operations.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.