Documentation ¶
Index ¶
- Constants
- type Agent
- func (a *Agent) AddCloudProvider(ctx context.Context, request *captenpluginspb.AddCloudProviderRequest) (*captenpluginspb.AddCloudProviderResponse, error)
- func (a *Agent) AddContainerRegistry(ctx context.Context, request *captenpluginspb.AddContainerRegistryRequest) (*captenpluginspb.AddContainerRegistryResponse, error)
- func (a *Agent) AddCrossplanProvider(ctx context.Context, request *captenpluginspb.AddCrossplanProviderRequest) (*captenpluginspb.AddCrossplanProviderResponse, error)
- func (a *Agent) AddGitProject(ctx context.Context, request *captenpluginspb.AddGitProjectRequest) (*captenpluginspb.AddGitProjectResponse, error)
- func (a *Agent) AuthInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
- func (a *Agent) ConfigureAppSSO(ctx context.Context, req *agentpb.ConfigureAppSSORequest) (*agentpb.ConfigureAppSSOResponse, error)
- func (a *Agent) ConfigureVaultSecret(ctx context.Context, request *agentpb.ConfigureVaultSecretRequest) (*agentpb.ConfigureVaultSecretResponse, error)
- func (a *Agent) CreateVaultRole(ctx context.Context, request *agentpb.CreateVaultRoleRequest) (*agentpb.CreateVaultRoleResponse, error)
- func (a *Agent) DeleteCloudProvider(ctx context.Context, request *captenpluginspb.DeleteCloudProviderRequest) (*captenpluginspb.DeleteCloudProviderResponse, error)
- func (a *Agent) DeleteContainerRegistry(ctx context.Context, request *captenpluginspb.DeleteContainerRegistryRequest) (*captenpluginspb.DeleteContainerRegistryResponse, error)
- func (a *Agent) DeleteCrossplanProvider(ctx context.Context, request *captenpluginspb.DeleteCrossplanProviderRequest) (*captenpluginspb.DeleteCrossplanProviderResponse, error)
- func (a *Agent) DeleteGitProject(ctx context.Context, request *captenpluginspb.DeleteGitProjectRequest) (*captenpluginspb.DeleteGitProjectResponse, error)
- func (a *Agent) DeleteVaultRole(ctx context.Context, request *agentpb.DeleteVaultRoleRequest) (*agentpb.DeleteVaultRoleResponse, error)
- func (a *Agent) DeployClusterPlugin(ctx context.Context, request *clusterpluginspb.DeployClusterPluginRequest) (*clusterpluginspb.DeployClusterPluginResponse, error)
- func (a *Agent) DeployDefaultApps(ctx context.Context, request *agentpb.DeployDefaultAppsRequest) (*agentpb.DeployDefaultAppsResponse, error)
- func (a *Agent) GetArgoCDProjects(ctx context.Context, request *captenpluginspb.GetArgoCDProjectsRequest) (*captenpluginspb.GetArgoCDProjectsResponse, error)
- func (a *Agent) GetCaptenPlugins(ctx context.Context, request *captenpluginspb.GetCaptenPluginsRequest) (*captenpluginspb.GetCaptenPluginsResponse, error)
- func (a *Agent) GetCloudProviders(ctx context.Context, request *captenpluginspb.GetCloudProvidersRequest) (*captenpluginspb.GetCloudProvidersResponse, error)
- func (a *Agent) GetCloudProvidersWithFilter(ctx context.Context, ...) (*captenpluginspb.GetCloudProvidersWithFilterResponse, error)
- func (a *Agent) GetClusterAppConfig(ctx context.Context, request *agentpb.GetClusterAppConfigRequest) (*agentpb.GetClusterAppConfigResponse, error)
- func (a *Agent) GetClusterAppLaunches(ctx context.Context, request *agentpb.GetClusterAppLaunchesRequest) (*agentpb.GetClusterAppLaunchesResponse, error)
- func (a *Agent) GetClusterAppValues(ctx context.Context, request *agentpb.GetClusterAppValuesRequest) (*agentpb.GetClusterAppValuesResponse, error)
- func (a *Agent) GetClusterApps(ctx context.Context, request *agentpb.GetClusterAppsRequest) (*agentpb.GetClusterAppsResponse, error)
- func (a *Agent) GetClusterDefaultApps(ctx context.Context, request *agentpb.GetDefaultAppsStatusRequest) (*agentpb.GetDefaultAppsStatusResponse, error)
- func (a *Agent) GetClusterGlobalValues(ctx context.Context, _ *agentpb.GetClusterGlobalValuesRequest) (*agentpb.GetClusterGlobalValuesResponse, error)
- func (a *Agent) GetClusterPlugins(ctx context.Context, request *clusterpluginspb.GetClusterPluginsRequest) (*clusterpluginspb.GetClusterPluginsResponse, error)
- func (a *Agent) GetContainerRegistry(ctx context.Context, request *captenpluginspb.GetContainerRegistryRequest) (*captenpluginspb.GetContainerRegistryResponse, error)
- func (a *Agent) GetContainerRegistryById(ctx context.Context, request *captensdkpb.GetContainerRegistryByIdRequest) (*captensdkpb.GetContainerRegistryByIdResponse, error)
- func (a *Agent) GetCrossplanProviders(ctx context.Context, _ *captenpluginspb.GetCrossplanProvidersRequest) (*captenpluginspb.GetCrossplanProvidersResponse, error)
- func (a *Agent) GetCrossplaneProject(ctx context.Context, request *captenpluginspb.GetCrossplaneProjectsRequest) (*captenpluginspb.GetCrossplaneProjectsResponse, error)
- func (a *Agent) GetCrossplaneProviders() (providers []model.CrossplaneProvider, err error)
- func (a *Agent) GetGitProjectById(ctx context.Context, request *captensdkpb.GetGitProjectByIdRequest) (*captensdkpb.GetGitProjectByIdResponse, error)
- func (a *Agent) GetGitProjects(ctx context.Context, request *captenpluginspb.GetGitProjectsRequest) (*captenpluginspb.GetGitProjectsResponse, error)
- func (a *Agent) GetGitProjectsForLabels(ctx context.Context, request *captenpluginspb.GetGitProjectsForLabelsRequest) (*captenpluginspb.GetGitProjectsForLabelsResponse, error)
- func (a *Agent) GetManagedClusterKubeconfig(ctx context.Context, ...) (*captenpluginspb.GetManagedClusterKubeconfigResponse, error)
- func (a *Agent) GetManagedClusters(ctx context.Context, request *captenpluginspb.GetManagedClustersRequest) (*captenpluginspb.GetManagedClustersResponse, error)
- func (a *Agent) GetTektonProject(ctx context.Context, request *captenpluginspb.GetTektonProjectRequest) (*captenpluginspb.GetTektonProjectResponse, error)
- func (a *Agent) Ping(ctx context.Context, request *agentpb.PingRequest) (*agentpb.PingResponse, error)
- func (a *Agent) RegisterArgoCDProject(ctx context.Context, request *captenpluginspb.RegisterArgoCDProjectRequest) (*captenpluginspb.RegisterArgoCDProjectResponse, error)
- func (a *Agent) RegisterCrossplaneProject(ctx context.Context, request *captenpluginspb.RegisterCrossplaneProjectRequest) (*captenpluginspb.RegisterCrossplaneProjectResponse, error)
- func (a *Agent) RegisterTektonProject(ctx context.Context, request *captenpluginspb.RegisterTektonProjectRequest) (*captenpluginspb.RegisterTektonProjectResponse, error)
- func (a *Agent) SetupDatabase(ctx context.Context, req *captensdkpb.DBSetupRequest) (*captensdkpb.DBSetupResponse, error)
- func (a *Agent) StoreCredential(ctx context.Context, request *agentpb.StoreCredentialRequest) (*agentpb.StoreCredentialResponse, error)
- func (a *Agent) StoreManagedClusterCredential(ctx context.Context, id string, kubeconfig string, endpoint string) error
- func (a *Agent) SyncApp(ctx context.Context, request *agentpb.SyncAppRequest) (*agentpb.SyncAppResponse, error)
- func (a *Agent) UnDeployClusterPlugin(ctx context.Context, request *clusterpluginspb.UnDeployClusterPluginRequest) (*clusterpluginspb.UnDeployClusterPluginResponse, error)
- func (a *Agent) UnRegisterCrossplaneProject(ctx context.Context, ...) (*captenpluginspb.UnRegisterCrossplaneProjectResponse, error)
- func (a *Agent) UnRegisterTektonProject(ctx context.Context, request *captenpluginspb.UnRegisterTektonProjectRequest) (*captenpluginspb.UnRegisterTektonProjectResponse, error)
- func (a *Agent) UpdateCloudProvider(ctx context.Context, request *captenpluginspb.UpdateCloudProviderRequest) (*captenpluginspb.UpdateCloudProviderResponse, error)
- func (a *Agent) UpdateContainerRegistry(ctx context.Context, request *captenpluginspb.UpdateContainerRegistryRequest) (*captenpluginspb.UpdateContainerRegistryResponse, error)
- func (a *Agent) UpdateCrossplanProvider(ctx context.Context, request *captenpluginspb.UpdateCrossplanProviderRequest) (*captenpluginspb.UpdateCrossplanProviderResponse, error)
- func (a *Agent) UpdateGitProject(ctx context.Context, request *captenpluginspb.UpdateGitProjectRequest) (*captenpluginspb.UpdateGitProjectResponse, error)
- func (a *Agent) UpdateVaultRole(ctx context.Context, request *agentpb.UpdateVaultRoleRequest) (*agentpb.UpdateVaultRoleResponse, error)
- type DockerConfig
- type DockerConfigEntry
- type DockerConfigJSON
Constants ¶
View Source
const ManagedClusterEntityName = "managedcluster"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Agent ¶
type Agent struct { agentpb.UnimplementedAgentServer captenpluginspb.UnimplementedCaptenPluginsServer captensdkpb.UnimplementedCaptenSdkServer clusterpluginspb.UnimplementedClusterPluginsServer // contains filtered or unexported fields }
func NewAgent ¶
func NewAgent(log logging.Logger, cfg *config.SericeConfig, as *captenstore.Store, pas *pluginconfigtore.Store) (*Agent, error)
func (*Agent) AddCloudProvider ¶
func (a *Agent) AddCloudProvider(ctx context.Context, request *captenpluginspb.AddCloudProviderRequest) ( *captenpluginspb.AddCloudProviderResponse, error)
func (*Agent) AddContainerRegistry ¶
func (a *Agent) AddContainerRegistry(ctx context.Context, request *captenpluginspb.AddContainerRegistryRequest) ( *captenpluginspb.AddContainerRegistryResponse, error)
func (*Agent) AddCrossplanProvider ¶
func (a *Agent) AddCrossplanProvider(ctx context.Context, request *captenpluginspb.AddCrossplanProviderRequest) ( *captenpluginspb.AddCrossplanProviderResponse, error)
func (*Agent) AddGitProject ¶
func (a *Agent) AddGitProject(ctx context.Context, request *captenpluginspb.AddGitProjectRequest) ( *captenpluginspb.AddGitProjectResponse, error)
func (*Agent) AuthInterceptor ¶
func (a *Agent) AuthInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)
func (*Agent) ConfigureAppSSO ¶
func (a *Agent) ConfigureAppSSO(ctx context.Context, req *agentpb.ConfigureAppSSORequest) (*agentpb.ConfigureAppSSOResponse, error)
func (*Agent) ConfigureVaultSecret ¶
func (a *Agent) ConfigureVaultSecret(ctx context.Context, request *agentpb.ConfigureVaultSecretRequest) (*agentpb.ConfigureVaultSecretResponse, error)
func (*Agent) CreateVaultRole ¶
func (a *Agent) CreateVaultRole(ctx context.Context, request *agentpb.CreateVaultRoleRequest) (*agentpb.CreateVaultRoleResponse, error)
func (*Agent) DeleteCloudProvider ¶
func (a *Agent) DeleteCloudProvider(ctx context.Context, request *captenpluginspb.DeleteCloudProviderRequest) ( *captenpluginspb.DeleteCloudProviderResponse, error)
func (*Agent) DeleteContainerRegistry ¶
func (a *Agent) DeleteContainerRegistry(ctx context.Context, request *captenpluginspb.DeleteContainerRegistryRequest) ( *captenpluginspb.DeleteContainerRegistryResponse, error)
func (*Agent) DeleteCrossplanProvider ¶
func (a *Agent) DeleteCrossplanProvider(ctx context.Context, request *captenpluginspb.DeleteCrossplanProviderRequest) ( *captenpluginspb.DeleteCrossplanProviderResponse, error)
func (*Agent) DeleteGitProject ¶
func (a *Agent) DeleteGitProject(ctx context.Context, request *captenpluginspb.DeleteGitProjectRequest) ( *captenpluginspb.DeleteGitProjectResponse, error)
func (*Agent) DeleteVaultRole ¶
func (a *Agent) DeleteVaultRole(ctx context.Context, request *agentpb.DeleteVaultRoleRequest) (*agentpb.DeleteVaultRoleResponse, error)
func (*Agent) DeployClusterPlugin ¶
func (a *Agent) DeployClusterPlugin(ctx context.Context, request *clusterpluginspb.DeployClusterPluginRequest) ( *clusterpluginspb.DeployClusterPluginResponse, error)
func (*Agent) DeployDefaultApps ¶
func (a *Agent) DeployDefaultApps(ctx context.Context, request *agentpb.DeployDefaultAppsRequest) ( *agentpb.DeployDefaultAppsResponse, error)
func (*Agent) GetArgoCDProjects ¶
func (a *Agent) GetArgoCDProjects(ctx context.Context, request *captenpluginspb.GetArgoCDProjectsRequest) ( *captenpluginspb.GetArgoCDProjectsResponse, error)
func (*Agent) GetCaptenPlugins ¶
func (a *Agent) GetCaptenPlugins(ctx context.Context, request *captenpluginspb.GetCaptenPluginsRequest) ( *captenpluginspb.GetCaptenPluginsResponse, error)
func (*Agent) GetCloudProviders ¶
func (a *Agent) GetCloudProviders(ctx context.Context, request *captenpluginspb.GetCloudProvidersRequest) ( *captenpluginspb.GetCloudProvidersResponse, error)
func (*Agent) GetCloudProvidersWithFilter ¶
func (a *Agent) GetCloudProvidersWithFilter(ctx context.Context, request *captenpluginspb.GetCloudProvidersWithFilterRequest) ( *captenpluginspb.GetCloudProvidersWithFilterResponse, error)
func (*Agent) GetClusterAppConfig ¶
func (a *Agent) GetClusterAppConfig(ctx context.Context, request *agentpb.GetClusterAppConfigRequest) ( *agentpb.GetClusterAppConfigResponse, error)
func (*Agent) GetClusterAppLaunches ¶
func (a *Agent) GetClusterAppLaunches(ctx context.Context, request *agentpb.GetClusterAppLaunchesRequest) ( *agentpb.GetClusterAppLaunchesResponse, error)
func (*Agent) GetClusterAppValues ¶
func (a *Agent) GetClusterAppValues(ctx context.Context, request *agentpb.GetClusterAppValuesRequest) ( *agentpb.GetClusterAppValuesResponse, error)
func (*Agent) GetClusterApps ¶
func (a *Agent) GetClusterApps(ctx context.Context, request *agentpb.GetClusterAppsRequest) ( *agentpb.GetClusterAppsResponse, error)
func (*Agent) GetClusterDefaultApps ¶
func (a *Agent) GetClusterDefaultApps(ctx context.Context, request *agentpb.GetDefaultAppsStatusRequest) ( *agentpb.GetDefaultAppsStatusResponse, error)
func (*Agent) GetClusterGlobalValues ¶
func (a *Agent) GetClusterGlobalValues(ctx context.Context, _ *agentpb.GetClusterGlobalValuesRequest) (*agentpb.GetClusterGlobalValuesResponse, error)
func (*Agent) GetClusterPlugins ¶
func (a *Agent) GetClusterPlugins(ctx context.Context, request *clusterpluginspb.GetClusterPluginsRequest) ( *clusterpluginspb.GetClusterPluginsResponse, error)
func (*Agent) GetContainerRegistry ¶
func (a *Agent) GetContainerRegistry(ctx context.Context, request *captenpluginspb.GetContainerRegistryRequest) ( *captenpluginspb.GetContainerRegistryResponse, error)
func (*Agent) GetContainerRegistryById ¶
func (a *Agent) GetContainerRegistryById(ctx context.Context, request *captensdkpb.GetContainerRegistryByIdRequest) ( *captensdkpb.GetContainerRegistryByIdResponse, error)
func (*Agent) GetCrossplanProviders ¶
func (a *Agent) GetCrossplanProviders(ctx context.Context, _ *captenpluginspb.GetCrossplanProvidersRequest) ( *captenpluginspb.GetCrossplanProvidersResponse, error)
func (*Agent) GetCrossplaneProject ¶
func (a *Agent) GetCrossplaneProject(ctx context.Context, request *captenpluginspb.GetCrossplaneProjectsRequest) ( *captenpluginspb.GetCrossplaneProjectsResponse, error)
func (*Agent) GetCrossplaneProviders ¶
func (a *Agent) GetCrossplaneProviders() (providers []model.CrossplaneProvider, err error)
func (*Agent) GetGitProjectById ¶
func (a *Agent) GetGitProjectById(ctx context.Context, request *captensdkpb.GetGitProjectByIdRequest) ( *captensdkpb.GetGitProjectByIdResponse, error)
func (*Agent) GetGitProjects ¶
func (a *Agent) GetGitProjects(ctx context.Context, request *captenpluginspb.GetGitProjectsRequest) ( *captenpluginspb.GetGitProjectsResponse, error)
func (*Agent) GetGitProjectsForLabels ¶
func (a *Agent) GetGitProjectsForLabels(ctx context.Context, request *captenpluginspb.GetGitProjectsForLabelsRequest) ( *captenpluginspb.GetGitProjectsForLabelsResponse, error)
func (*Agent) GetManagedClusterKubeconfig ¶
func (a *Agent) GetManagedClusterKubeconfig(ctx context.Context, request *captenpluginspb.GetManagedClusterKubeconfigRequest) ( *captenpluginspb.GetManagedClusterKubeconfigResponse, error)
func (*Agent) GetManagedClusters ¶
func (a *Agent) GetManagedClusters(ctx context.Context, request *captenpluginspb.GetManagedClustersRequest) ( *captenpluginspb.GetManagedClustersResponse, error)
func (*Agent) GetTektonProject ¶
func (a *Agent) GetTektonProject(ctx context.Context, request *captenpluginspb.GetTektonProjectRequest) ( *captenpluginspb.GetTektonProjectResponse, error)
func (*Agent) Ping ¶
func (a *Agent) Ping(ctx context.Context, request *agentpb.PingRequest) (*agentpb.PingResponse, error)
func (*Agent) RegisterArgoCDProject ¶
func (a *Agent) RegisterArgoCDProject(ctx context.Context, request *captenpluginspb.RegisterArgoCDProjectRequest) ( *captenpluginspb.RegisterArgoCDProjectResponse, error)
func (*Agent) RegisterCrossplaneProject ¶
func (a *Agent) RegisterCrossplaneProject(ctx context.Context, request *captenpluginspb.RegisterCrossplaneProjectRequest) ( *captenpluginspb.RegisterCrossplaneProjectResponse, error)
func (*Agent) RegisterTektonProject ¶
func (a *Agent) RegisterTektonProject(ctx context.Context, request *captenpluginspb.RegisterTektonProjectRequest) ( *captenpluginspb.RegisterTektonProjectResponse, error)
func (*Agent) SetupDatabase ¶
func (a *Agent) SetupDatabase(ctx context.Context, req *captensdkpb.DBSetupRequest) (*captensdkpb.DBSetupResponse, error)
func (*Agent) StoreCredential ¶
func (a *Agent) StoreCredential(ctx context.Context, request *agentpb.StoreCredentialRequest) (*agentpb.StoreCredentialResponse, error)
func (*Agent) StoreManagedClusterCredential ¶
func (a *Agent) StoreManagedClusterCredential(ctx context.Context, id string, kubeconfig string, endpoint string) error
store managed cluster kubeconfig and endpoint in vault
func (*Agent) SyncApp ¶
func (a *Agent) SyncApp(ctx context.Context, request *agentpb.SyncAppRequest) ( *agentpb.SyncAppResponse, error)
func (*Agent) UnDeployClusterPlugin ¶
func (a *Agent) UnDeployClusterPlugin(ctx context.Context, request *clusterpluginspb.UnDeployClusterPluginRequest) ( *clusterpluginspb.UnDeployClusterPluginResponse, error)
func (*Agent) UnRegisterCrossplaneProject ¶
func (a *Agent) UnRegisterCrossplaneProject(ctx context.Context, request *captenpluginspb.UnRegisterCrossplaneProjectRequest) ( *captenpluginspb.UnRegisterCrossplaneProjectResponse, error)
func (*Agent) UnRegisterTektonProject ¶
func (a *Agent) UnRegisterTektonProject(ctx context.Context, request *captenpluginspb.UnRegisterTektonProjectRequest) ( *captenpluginspb.UnRegisterTektonProjectResponse, error)
func (*Agent) UpdateCloudProvider ¶
func (a *Agent) UpdateCloudProvider(ctx context.Context, request *captenpluginspb.UpdateCloudProviderRequest) ( *captenpluginspb.UpdateCloudProviderResponse, error)
func (*Agent) UpdateContainerRegistry ¶
func (a *Agent) UpdateContainerRegistry(ctx context.Context, request *captenpluginspb.UpdateContainerRegistryRequest) ( *captenpluginspb.UpdateContainerRegistryResponse, error)
func (*Agent) UpdateCrossplanProvider ¶
func (a *Agent) UpdateCrossplanProvider(ctx context.Context, request *captenpluginspb.UpdateCrossplanProviderRequest) ( *captenpluginspb.UpdateCrossplanProviderResponse, error)
func (*Agent) UpdateGitProject ¶
func (a *Agent) UpdateGitProject(ctx context.Context, request *captenpluginspb.UpdateGitProjectRequest) ( *captenpluginspb.UpdateGitProjectResponse, error)
func (*Agent) UpdateVaultRole ¶
func (a *Agent) UpdateVaultRole(ctx context.Context, request *agentpb.UpdateVaultRoleRequest) (*agentpb.UpdateVaultRoleResponse, error)
type DockerConfig ¶
type DockerConfig map[string]DockerConfigEntry
type DockerConfigEntry ¶
type DockerConfigJSON ¶
type DockerConfigJSON struct { Auths DockerConfig `json:"auths" datapolicy:"token"` // +optional HttpHeaders map[string]string `json:"HttpHeaders,omitempty" datapolicy:"token"` }
Source Files ¶
- agent.go
- agent_auth.go
- agent_cluster_apps.go
- app_config_sso.go
- app_values_util.go
- capten_plugin_apis.go
- capten_sdk_apis.go
- capten_sdk_db_apis.go
- cluster_plugin_apis.go
- container_registry.go
- plugin_argocd_apis.go
- plugin_cloud_provider_apis.go
- plugin_crossplane_project_apis.go
- plugin_crossplane_provider_apis.go
- plugin_git_apis.go
- plugin_managed_clusters_apis.go
- plugin_tekton_apis.go
- store_cred_apis.go
Click to show internal directories.
Click to hide internal directories.