servers

package
v0.8.1 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: MPL-2.0 Imports: 36 Imported by: 0

Documentation

Overview

Package servers implements the gRPC servers.

Package servers implements the gRPC servers.

Package servers implements the gRPC servers.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentServer 

type AgentServer struct {
	pb.UnimplementedAgentsServer
	// contains filtered or unexported fields
}

AgentServer embeds the UnimplementedAgentsServer.

func NewAgentServer 

func NewAgentServer(
	agentService agent.Service,
	urnResolver *urn.Resolver,
) *AgentServer

NewAgentServer returns an instance of AgentServer.

func (*AgentServer) AssignServiceAccountToAgent 

func (s *AgentServer) AssignServiceAccountToAgent(ctx context.Context, req *pb.AssignServiceAccountToAgentRequest) (*emptypb.Empty, error)

AssignServiceAccountToAgent assigns a service account to an agent.

func (*AgentServer) CreateAgent 

func (s *AgentServer) CreateAgent(ctx context.Context, req *pb.CreateAgentRequest) (*pb.Agent, error)

CreateAgent creates an Agent.

func (*AgentServer) CreateAgentSession 

func (s *AgentServer) CreateAgentSession(ctx context.Context, req *pb.CreateAgentSessionRequest) (*pb.AgentSession, error)

CreateAgentSession creates an AgentSession.

func (*AgentServer) CreateAgentSessionError 

func (s *AgentServer) CreateAgentSessionError(ctx context.Context, req *pb.CreateAgentSessionErrorRequest) (*emptypb.Empty, error)

CreateAgentSessionError creates an agent session error.

func (*AgentServer) DeleteAgent 

func (s *AgentServer) DeleteAgent(ctx context.Context, req *pb.DeleteAgentRequest) (*emptypb.Empty, error)

DeleteAgent deletes an Agent.

func (*AgentServer) GetAgentByID 

func (s *AgentServer) GetAgentByID(ctx context.Context, req *pb.GetAgentByIDRequest) (*pb.Agent, error)

GetAgentByID returns an Agent by an ID.

func (*AgentServer) GetAgents 

func (s *AgentServer) GetAgents(ctx context.Context, req *pb.GetAgentsRequest) (*pb.GetAgentsResponse, error)

GetAgents returns a paginated list of Agents.

func (*AgentServer) SendAgentSessionHeartbeat 

func (s *AgentServer) SendAgentSessionHeartbeat(ctx context.Context, req *pb.AgentSessionHeartbeatRequest) (*emptypb.Empty, error)

SendAgentSessionHeartbeat sends an agent session heartbeat.

func (*AgentServer) UnassignServiceAccountFromAgent 

func (s *AgentServer) UnassignServiceAccountFromAgent(ctx context.Context, req *pb.UnassignServiceAccountFromAgentRequest) (*emptypb.Empty, error)

UnassignServiceAccountFromAgent unassigns a service account from an agent.

func (*AgentServer) UpdateAgent 

func (s *AgentServer) UpdateAgent(ctx context.Context, req *pb.UpdateAgentRequest) (*pb.Agent, error)

UpdateAgent updates an Agent.

type AuthSettingsServer 

type AuthSettingsServer struct {
	pb.UnimplementedAuthSettingsServer
	// contains filtered or unexported fields
}

AuthSettingsServer embeds the UnimplementedAuthSettingsServer.

func NewAuthSettingsServer 

func NewAuthSettingsServer(oauthProviders []config.IdpConfig) *AuthSettingsServer

NewAuthSettingsServer returns an instance of AuthSettingsServer.

func (*AuthSettingsServer) GetAuthSettings 

func (s *AuthSettingsServer) GetAuthSettings(_ context.Context, _ *emptypb.Empty) (*pb.GetAuthSettingsResponse, error)

GetAuthSettings returns the IDP auth settings.

type EnvironmentServer 

type EnvironmentServer struct {
	pb.UnimplementedEnvironmentsServer
	// contains filtered or unexported fields
}

EnvironmentServer embeds the UnimplementedEnvironmentsServer.

func NewEnvironmentServer 

func NewEnvironmentServer(
	environmentService environment.Service,
	urnResolver *urn.Resolver,
) *EnvironmentServer

NewEnvironmentServer returns an instance of EnvironmentServer.

func (*EnvironmentServer) CreateEnvironment 

func (s *EnvironmentServer) CreateEnvironment(ctx context.Context, req *pb.CreateEnvironmentRequest) (*pb.Environment, error)

CreateEnvironment creates an Environment.

func (*EnvironmentServer) DeleteEnvironment 

func (s *EnvironmentServer) DeleteEnvironment(ctx context.Context, req *pb.DeleteEnvironmentRequest) (*emptypb.Empty, error)

DeleteEnvironment deletes an Environment.

func (*EnvironmentServer) GetEnvironmentByID 

func (s *EnvironmentServer) GetEnvironmentByID(ctx context.Context,
	req *pb.GetEnvironmentByIDRequest) (*pb.Environment, error)

GetEnvironmentByID returns an Environment by an ID.

func (*EnvironmentServer) GetEnvironments 

func (s *EnvironmentServer) GetEnvironments(ctx context.Context, req *pb.GetEnvironmentsRequest) (*pb.GetEnvironmentsResponse, error)

GetEnvironments returns a paginated list of Environments.

func (*EnvironmentServer) UpdateEnvironment 

func (s *EnvironmentServer) UpdateEnvironment(ctx context.Context, req *pb.UpdateEnvironmentRequest) (*pb.Environment, error)

UpdateEnvironment updates an Environment.

type JobServer 

type JobServer struct {
	pb.UnimplementedJobsServer
	// contains filtered or unexported fields
}

JobServer embeds the UnimplementedJobsServer.

func NewJobServer 

func NewJobServer(
	jobService job.Service,
	urnResolver *urn.Resolver,
) *JobServer

NewJobServer returns an instance of JobServer.

func (*JobServer) CancelJob 

func (s *JobServer) CancelJob(ctx context.Context, req *pb.CancelJobRequest) (*emptypb.Empty, error)

CancelJob cancels a Job.

func (*JobServer) ClaimJob 

func (s *JobServer) ClaimJob(ctx context.Context, req *pb.ClaimJobRequest) (*pb.ClaimJobResponse, error)

ClaimJob claims a new Job.

func (*JobServer) GetJob 

func (s *JobServer) GetJob(ctx context.Context, input *pb.GetJobInput) (*pb.Job, error)

GetJob gets one Job.

func (*JobServer) GetLogsStreaming 

func (s *JobServer) GetLogsStreaming(req *pb.GetLogsStreamingRequest, server pb.Jobs_GetLogsStreamingServer) error

GetLogsStreaming returns a stream of logs for a particular job

func (*JobServer) SetJobStatus 

func (s *JobServer) SetJobStatus(ctx context.Context, input *pb.SetJobStatusInput) (*pb.Job, error)

SetJobStatus sets the status of a Job.

func (*JobServer) SubscribeToJobCancellationEvent 

func (s *JobServer) SubscribeToJobCancellationEvent(req *pb.JobCancellationEventRequest, stream pb.Jobs_SubscribeToJobCancellationEventServer) error

SubscribeToJobCancellationEvent subscribes to job cancellation events.

func (*JobServer) WriteLogs 

func (s *JobServer) WriteLogs(ctx context.Context, req *pb.WriteLogsRequest) (*emptypb.Empty, error)

WriteLogs writes logs to the log stream for a particular job

type LifecycleTemplateServer 

type LifecycleTemplateServer struct {
	pb.UnimplementedLifecycleTemplatesServer
	// contains filtered or unexported fields
}

LifecycleTemplateServer embeds the UnimplementedLifecycleTemplatesServer.

func NewLifecycleTemplateServer 

func NewLifecycleTemplateServer(logger logger.Logger,
	lifecycleTemplateService lifecycletemplate.Service,
	urnResolver *urn.Resolver,
	maxUploadSize int64,
) *LifecycleTemplateServer

NewLifecycleTemplateServer returns an instance of LifecycleTemplateServer.

func (*LifecycleTemplateServer) CreateLifecycleTemplate 

func (s *LifecycleTemplateServer) CreateLifecycleTemplate(ctx context.Context,
	req *pb.CreateLifecycleTemplateRequest) (*pb.LifecycleTemplate, error)

CreateLifecycleTemplate creates a new LifecycleTemplate.

func (*LifecycleTemplateServer) GetLifecycleTemplateByID 

func (s *LifecycleTemplateServer) GetLifecycleTemplateByID(ctx context.Context,
	req *pb.GetLifecycleTemplateByIdRequest,
) (*pb.LifecycleTemplate, error)

GetLifecycleTemplateByID returns a LifecycleTemplate by an ID.

func (*LifecycleTemplateServer) GetLifecycleTemplateData 

func (s *LifecycleTemplateServer) GetLifecycleTemplateData(req *pb.GetLifecycleTemplateDataRequest, server pb.LifecycleTemplates_GetLifecycleTemplateDataServer) error

GetLifecycleTemplateData returns a stream of LifecycleTemplate data.

func (*LifecycleTemplateServer) GetLifecycleTemplates 

func (s *LifecycleTemplateServer) GetLifecycleTemplates(ctx context.Context,
	req *pb.GetLifecycleTemplatesRequest) (*pb.GetLifecycleTemplatesResponse, error)

GetLifecycleTemplates returns a paginated list of LifecycleTemplates.

func (*LifecycleTemplateServer) UploadLifecycleTemplate 

func (s *LifecycleTemplateServer) UploadLifecycleTemplate(stream pb.LifecycleTemplates_UploadLifecycleTemplateServer) error

UploadLifecycleTemplate uploads to a LifecycleTemplate.

type OrganizationServer 

type OrganizationServer struct {
	pb.UnimplementedOrganizationsServer
	// contains filtered or unexported fields
}

OrganizationServer embeds the UnimplementedOrganizationsServer.

func NewOrganizationServer 

func NewOrganizationServer(
	organizationService organization.Service,
	urnResolver *urn.Resolver,
) *OrganizationServer

NewOrganizationServer returns an instance of OrganizationServer.

func (*OrganizationServer) CreateOrganization 

func (s *OrganizationServer) CreateOrganization(ctx context.Context, req *pb.CreateOrganizationRequest) (*pb.Organization, error)

CreateOrganization creates a new Organization.

func (*OrganizationServer) DeleteOrganization 

func (s *OrganizationServer) DeleteOrganization(ctx context.Context, req *pb.DeleteOrganizationRequest) (*emptypb.Empty, error)

DeleteOrganization deletes an Organization.

func (*OrganizationServer) GetOrganizationByID 

func (s *OrganizationServer) GetOrganizationByID(ctx context.Context, req *pb.GetOrganizationByIdRequest) (*pb.Organization, error)

GetOrganizationByID returns an Organization by an ID.

func (*OrganizationServer) GetOrganizations 

func (s *OrganizationServer) GetOrganizations(ctx context.Context, req *pb.GetOrganizationsRequest) (*pb.GetOrganizationsResponse, error)

GetOrganizations returns a paginated list of Organizations.

func (*OrganizationServer) UpdateOrganization 

func (s *OrganizationServer) UpdateOrganization(ctx context.Context, req *pb.UpdateOrganizationRequest) (*pb.Organization, error)

UpdateOrganization returns the updated Organization.

type PipelineServer 

type PipelineServer struct {
	pb.UnimplementedPipelinesServer
	// contains filtered or unexported fields
}

PipelineServer embeds the UnimplementedPipelinesServer.

func NewPipelineServer 

func NewPipelineServer(
	pipelineService pipeline.Service,
	urnResolver *urn.Resolver,
) *PipelineServer

NewPipelineServer returns an instance of PipelineServer.

func (*PipelineServer) CancelPipeline 

func (s *PipelineServer) CancelPipeline(ctx context.Context, req *pb.CancelPipelineRequest) (*emptypb.Empty, error)

CancelPipeline deletes an Pipeline.

func (*PipelineServer) CreatePipeline 

func (s *PipelineServer) CreatePipeline(ctx context.Context, req *pb.CreatePipelineRequest) (*pb.Pipeline, error)

CreatePipeline creates a new Pipeline.

func (*PipelineServer) CreatePipelineJWT 

func (s *PipelineServer) CreatePipelineJWT(ctx context.Context, req *pb.CreatePipelineJWTRequest) (*pb.CreatePipelineJWTResponse, error)

CreatePipelineJWT creates a new pipeline JWT

func (*PipelineServer) GetPipelineActionOutputs 

func (s *PipelineServer) GetPipelineActionOutputs(ctx context.Context, req *pb.GetPipelineActionOutputsRequest) (*pb.GetPipelineActionOutputsResponse, error)

GetPipelineActionOutputs returns the outputs for a list of actions

func (*PipelineServer) GetPipelineByID 

func (s *PipelineServer) GetPipelineByID(ctx context.Context, req *pb.GetPipelineByIdRequest) (*pb.Pipeline, error)

GetPipelineByID returns an Pipeline by an ID.

func (*PipelineServer) GetPipelineEventsStreaming 

func (s *PipelineServer) GetPipelineEventsStreaming(req *pb.GetPipelineEventsStreamingRequest, server pb.Pipelines_GetPipelineEventsStreamingServer) error

GetPipelineEventsStreaming returns a stream of pipeline events.

func (*PipelineServer) GetPipelineVariables 

func (s *PipelineServer) GetPipelineVariables(ctx context.Context, req *pb.GetPipelineVariablesRequest) (*pb.GetPipelineVariablesResponse, error)

GetPipelineVariables returns a list of variables for a pipeline.

func (*PipelineServer) GetPipelines 

func (s *PipelineServer) GetPipelines(ctx context.Context, req *pb.GetPipelinesRequest) (*pb.GetPipelinesResponse, error)

GetPipelines returns a paginated list of Pipelines.

func (*PipelineServer) RetryNestedPipeline 

func (s *PipelineServer) RetryNestedPipeline(ctx context.Context, req *pb.RetryNestedPipelineRequest) (*emptypb.Empty, error)

RetryNestedPipeline retries a pipeline.

func (*PipelineServer) RetryPipelineTask 

func (s *PipelineServer) RetryPipelineTask(ctx context.Context, req *pb.RetryPipelineTaskRequest) (*emptypb.Empty, error)

RetryPipelineTask retries a pipeline task.

func (*PipelineServer) RunPipeline 

func (s *PipelineServer) RunPipeline(ctx context.Context, req *pb.RunPipelineRequest) (*emptypb.Empty, error)

RunPipeline starts a pipeline.

func (*PipelineServer) RunPipelineTask 

func (s *PipelineServer) RunPipelineTask(ctx context.Context, req *pb.RunPipelineTaskRequest) (*emptypb.Empty, error)

RunPipelineTask starts a pipeline task.

func (*PipelineServer) SetPipelineActionOutputs 

func (s *PipelineServer) SetPipelineActionOutputs(ctx context.Context, req *pb.SetPipelineActionOutputsRequest) (*emptypb.Empty, error)

SetPipelineActionOutputs sets the outputs for a pipeline action.

func (*PipelineServer) SetPipelineActionStatus 

func (s *PipelineServer) SetPipelineActionStatus(ctx context.Context, req *pb.SetPipelineActionStatusRequest) (*pb.Pipeline, error)

SetPipelineActionStatus sets the status for a pipeline action.

type PipelineTemplateServer 

type PipelineTemplateServer struct {
	pb.UnimplementedPipelineTemplatesServer
	// contains filtered or unexported fields
}

PipelineTemplateServer embeds the UnimplementedPipelineTemplatesServer.

func NewPipelineTemplateServer 

func NewPipelineTemplateServer(
	logger logger.Logger,
	pipelineTemplateService pipelinetemplate.Service,
	urnResolver *urn.Resolver,
	maxUploadSize int64,
) *PipelineTemplateServer

NewPipelineTemplateServer returns an instance of PipelineTemplateServer.

func (*PipelineTemplateServer) CreatePipelineTemplate 

func (s *PipelineTemplateServer) CreatePipelineTemplate(ctx context.Context, req *pb.CreatePipelineTemplateRequest) (*pb.PipelineTemplate, error)

CreatePipelineTemplate creates a new PipelineTemplate.

func (*PipelineTemplateServer) DeletePipelineTemplate 

func (s *PipelineTemplateServer) DeletePipelineTemplate(ctx context.Context,
	req *pb.DeletePipelineTemplateRequest) (*emptypb.Empty, error)

DeletePipelineTemplate deletes a PipelineTemplate.

func (*PipelineTemplateServer) GetPipelineTemplateByID 

func (s *PipelineTemplateServer) GetPipelineTemplateByID(ctx context.Context,
	req *pb.GetPipelineTemplateByIdRequest,
) (*pb.PipelineTemplate, error)

GetPipelineTemplateByID returns a PipelineTemplate by an ID.

func (*PipelineTemplateServer) GetPipelineTemplateData 

func (s *PipelineTemplateServer) GetPipelineTemplateData(req *pb.GetPipelineTemplateDataRequest, server pb.PipelineTemplates_GetPipelineTemplateDataServer) error

GetPipelineTemplateData returns a stream of PipelineTemplate data.

func (*PipelineTemplateServer) GetPipelineTemplates 

func (s *PipelineTemplateServer) GetPipelineTemplates(ctx context.Context, req *pb.GetPipelineTemplatesRequest) (*pb.GetPipelineTemplatesResponse, error)

GetPipelineTemplates returns a paginated list of PipelineTemplates.

func (*PipelineTemplateServer) UploadPipelineTemplate 

func (s *PipelineTemplateServer) UploadPipelineTemplate(stream pb.PipelineTemplates_UploadPipelineTemplateServer) error

UploadPipelineTemplate uploads to a PipelineTemplate.

type PluginRegistryServer 

type PluginRegistryServer struct {
	pb.UnimplementedPluginRegistryServer
	// contains filtered or unexported fields
}

PluginRegistryServer embeds the UnimplementedPluginRegistryServer.

func NewPluginRegistryServer 

func NewPluginRegistryServer(
	pluginRegistryService pluginregistry.Service,
	urnResolver *urn.Resolver,
	maxPluginBinaryUploadSize int64,
) *PluginRegistryServer

NewPluginRegistryServer returns an instance of PluginRegistryServer.

func (*PluginRegistryServer) CreatePlugin 

func (s *PluginRegistryServer) CreatePlugin(ctx context.Context, req *pb.CreatePluginRequest) (*pb.Plugin, error)

CreatePlugin creates a new plugin.

func (*PluginRegistryServer) CreatePluginPlatform 

func (s *PluginRegistryServer) CreatePluginPlatform(ctx context.Context, req *pb.CreatePluginPlatformRequest) (*pb.PluginPlatform, error)

CreatePluginPlatform creates a new plugin platform.

func (*PluginRegistryServer) CreatePluginVersion 

func (s *PluginRegistryServer) CreatePluginVersion(ctx context.Context, req *pb.CreatePluginVersionRequest) (*pb.PluginVersion, error)

CreatePluginVersion creates a new plugin version.

func (*PluginRegistryServer) DeletePlugin 

func (s *PluginRegistryServer) DeletePlugin(ctx context.Context, req *pb.DeletePluginRequest) (*emptypb.Empty, error)

DeletePlugin deletes a plugin.

func (*PluginRegistryServer) DeletePluginPlatform 

func (s *PluginRegistryServer) DeletePluginPlatform(ctx context.Context, req *pb.DeletePluginPlatformRequest) (*emptypb.Empty, error)

DeletePluginPlatform deletes a plugin platform by its ID.

func (*PluginRegistryServer) DeletePluginVersion 

func (s *PluginRegistryServer) DeletePluginVersion(ctx context.Context, req *pb.DeletePluginVersionRequest) (*emptypb.Empty, error)

DeletePluginVersion deletes a plugin version by its ID.

func (*PluginRegistryServer) GetPluginByID 

func (s *PluginRegistryServer) GetPluginByID(ctx context.Context, req *pb.GetPluginByIdRequest) (*pb.Plugin, error)

GetPluginByID returns a plugin by its ID.

func (*PluginRegistryServer) GetPluginPlatformByID 

func (s *PluginRegistryServer) GetPluginPlatformByID(ctx context.Context, req *pb.GetPluginPlatformByIdRequest) (*pb.PluginPlatform, error)

GetPluginPlatformByID returns a plugin platform by its ID.

func (*PluginRegistryServer) GetPluginPlatforms 

func (s *PluginRegistryServer) GetPluginPlatforms(ctx context.Context, req *pb.GetPluginPlatformsRequest) (*pb.GetPluginPlatformsResponse, error)

GetPluginPlatforms returns a paginated list of plugin platforms.

func (*PluginRegistryServer) GetPluginVersionByID 

func (s *PluginRegistryServer) GetPluginVersionByID(ctx context.Context, req *pb.GetPluginVersionByIdRequest) (*pb.PluginVersion, error)

GetPluginVersionByID returns a plugin version by its ID.

func (*PluginRegistryServer) GetPluginVersions 

func (s *PluginRegistryServer) GetPluginVersions(ctx context.Context, req *pb.GetPluginVersionsRequest) (*pb.GetPluginVersionsResponse, error)

GetPluginVersions returns a paginated list of plugin versions.

func (*PluginRegistryServer) GetPlugins 

func (s *PluginRegistryServer) GetPlugins(ctx context.Context, req *pb.GetPluginsRequest) (*pb.GetPluginsResponse, error)

GetPlugins returns a paginated list of plugins.

func (*PluginRegistryServer) UpdatePlugin 

func (s *PluginRegistryServer) UpdatePlugin(ctx context.Context, req *pb.UpdatePluginRequest) (*pb.Plugin, error)

UpdatePlugin updates a plugin.

func (*PluginRegistryServer) UploadPluginPlatformBinary 

func (s *PluginRegistryServer) UploadPluginPlatformBinary(stream pb.PluginRegistry_UploadPluginPlatformBinaryServer) error

UploadPluginPlatformBinary uploads a plugin platform binary.

func (*PluginRegistryServer) UploadPluginVersionDocFile 

func (s *PluginRegistryServer) UploadPluginVersionDocFile(stream pb.PluginRegistry_UploadPluginVersionDocFileServer) error

UploadPluginVersionDocFile uploads a documentation file for a plugin version.

func (*PluginRegistryServer) UploadPluginVersionReadme 

func (s *PluginRegistryServer) UploadPluginVersionReadme(stream pb.PluginRegistry_UploadPluginVersionReadmeServer) error

UploadPluginVersionReadme uploads a readme for a plugin version.

func (*PluginRegistryServer) UploadPluginVersionSchema 

func (s *PluginRegistryServer) UploadPluginVersionSchema(stream pb.PluginRegistry_UploadPluginVersionSchemaServer) error

UploadPluginVersionSchema uploads a schema for a plugin version.

func (*PluginRegistryServer) UploadPluginVersionShaSums 

func (s *PluginRegistryServer) UploadPluginVersionShaSums(stream pb.PluginRegistry_UploadPluginVersionShaSumsServer) error

UploadPluginVersionShaSums uploads SHA sums for a plugin version.

type ProjectServer 

type ProjectServer struct {
	pb.UnimplementedProjectsServer
	// contains filtered or unexported fields
}

ProjectServer embeds the UnimplementedProjectsServer.

func NewProjectServer 

func NewProjectServer(
	projectService project.Service,
	urnResolver *urn.Resolver,
) *ProjectServer

NewProjectServer returns an instance of ProjectServer.

func (*ProjectServer) CreateProject 

func (s *ProjectServer) CreateProject(ctx context.Context, req *pb.CreateProjectRequest) (*pb.Project, error)

CreateProject creates a new Project.

func (*ProjectServer) DeleteProject 

func (s *ProjectServer) DeleteProject(ctx context.Context, req *pb.DeleteProjectRequest) (*emptypb.Empty, error)

DeleteProject deletes an Project.

func (*ProjectServer) GetProjectByID 

func (s *ProjectServer) GetProjectByID(ctx context.Context, req *pb.GetProjectByIdRequest) (*pb.Project, error)

GetProjectByID returns an Project by an ID.

func (*ProjectServer) GetProjects 

func (s *ProjectServer) GetProjects(ctx context.Context, req *pb.GetProjectsRequest) (*pb.GetProjectsResponse, error)

GetProjects returns a paginated list of Projects.

func (*ProjectServer) UpdateProject 

func (s *ProjectServer) UpdateProject(ctx context.Context, req *pb.UpdateProjectRequest) (*pb.Project, error)

UpdateProject returns the updated Project.

type ReleaseLifecycleServer 

type ReleaseLifecycleServer struct {
	pb.UnimplementedReleaseLifecyclesServer
	// contains filtered or unexported fields
}

ReleaseLifecycleServer embeds the UnimplementedReleaseLifecyclesServer.

func NewReleaseLifecycleServer 

func NewReleaseLifecycleServer(releaseLifecycleService releaselifecycle.Service, urnResolver *urn.Resolver,
) *ReleaseLifecycleServer

NewReleaseLifecycleServer returns an instance of ReleaseLifecycleServer.

func (*ReleaseLifecycleServer) CreateReleaseLifecycle 

func (s *ReleaseLifecycleServer) CreateReleaseLifecycle(ctx context.Context,
	req *pb.CreateReleaseLifecycleRequest) (*pb.ReleaseLifecycle, error)

CreateReleaseLifecycle creates a new ReleaseLifecycle.

func (*ReleaseLifecycleServer) DeleteReleaseLifecycle 

func (s *ReleaseLifecycleServer) DeleteReleaseLifecycle(ctx context.Context,
	req *pb.DeleteReleaseLifecycleRequest) (*emptypb.Empty, error)

DeleteReleaseLifecycle deletes an existing ReleaseLifecycle.

func (*ReleaseLifecycleServer) GetReleaseLifecycleByID 

func (s *ReleaseLifecycleServer) GetReleaseLifecycleByID(ctx context.Context,
	req *pb.GetReleaseLifecycleByIdRequest,
) (*pb.ReleaseLifecycle, error)

GetReleaseLifecycleByID returns a ReleaseLifecycle by an ID.

func (*ReleaseLifecycleServer) GetReleaseLifecycles 

func (s *ReleaseLifecycleServer) GetReleaseLifecycles(ctx context.Context,
	req *pb.GetReleaseLifecyclesRequest) (*pb.GetReleaseLifecyclesResponse, error)

GetReleaseLifecycles returns a paginated list of ReleaseLifecycles.

func (*ReleaseLifecycleServer) UpdateReleaseLifecycle 

func (s *ReleaseLifecycleServer) UpdateReleaseLifecycle(ctx context.Context,
	req *pb.UpdateReleaseLifecycleRequest) (*pb.ReleaseLifecycle, error)

UpdateReleaseLifecycle updates an existing ReleaseLifecycle.

type ReleaseServer 

type ReleaseServer struct {
	pb.UnimplementedReleasesServer
	// contains filtered or unexported fields
}

ReleaseServer embeds the UnimplementedReleasesServer.

func NewReleaseServer 

func NewReleaseServer(releaseService release.Service, urnResolver *urn.Resolver) *ReleaseServer

NewReleaseServer returns an instance of ReleaseServer.

func (*ReleaseServer) AddParticipantToRelease 

func (s *ReleaseServer) AddParticipantToRelease(ctx context.Context, req *pb.AddParticipantToReleaseRequest) (*pb.Release, error)

AddParticipantToRelease adds a participant to a Release.

func (*ReleaseServer) CreateRelease 

func (s *ReleaseServer) CreateRelease(ctx context.Context, req *pb.CreateReleaseRequest) (*pb.Release, error)

CreateRelease creates a Release.

func (*ReleaseServer) DeleteRelease 

func (s *ReleaseServer) DeleteRelease(ctx context.Context, req *pb.DeleteReleaseRequest) (*emptypb.Empty, error)

DeleteRelease deletes a Release.

func (*ReleaseServer) GetReleaseByID 

func (s *ReleaseServer) GetReleaseByID(ctx context.Context, req *pb.GetReleaseByIdRequest) (*pb.Release, error)

GetReleaseByID returns a Release by an ID.

func (*ReleaseServer) GetReleases 

func (s *ReleaseServer) GetReleases(ctx context.Context, req *pb.GetReleasesRequest) (*pb.GetReleasesResponse, error)

GetReleases returns a paginated list of Releases.

func (*ReleaseServer) RemoveParticipantFromRelease 

func (s *ReleaseServer) RemoveParticipantFromRelease(ctx context.Context, req *pb.RemoveParticipantFromReleaseRequest) (*pb.Release, error)

RemoveParticipantFromRelease removes a participant from a Release.

func (*ReleaseServer) UpdateRelease 

func (s *ReleaseServer) UpdateRelease(ctx context.Context, req *pb.UpdateReleaseRequest) (*pb.Release, error)

UpdateRelease updates a Release.

func (*ReleaseServer) UpdateReleaseDeploymentPipeline 

func (s *ReleaseServer) UpdateReleaseDeploymentPipeline(ctx context.Context, req *pb.UpdateReleaseDeploymentPipelineRequest) (*pb.Pipeline, error)

UpdateReleaseDeploymentPipeline updates a release deployment pipeline.

type ResourceLimitServer 

type ResourceLimitServer struct {
	pb.UnimplementedResourceLimitsServer
	// contains filtered or unexported fields
}

ResourceLimitServer embeds the UnimplementedResourceLimitsServer.

func NewResourceLimitServer 

func NewResourceLimitServer(resourceLimitService resourcelimit.Service) *ResourceLimitServer

NewResourceLimitServer returns an instance of ResourceLimitServer.

func (*ResourceLimitServer) GetResourceLimits 

func (s *ResourceLimitServer) GetResourceLimits(ctx context.Context, _ *emptypb.Empty) (*pb.GetResourceLimitsResponse, error)

GetResourceLimits returns a list of ResourceLimits.

func (*ResourceLimitServer) UpdateResourceLimit 

func (s *ResourceLimitServer) UpdateResourceLimit(ctx context.Context, req *pb.UpdateResourceLimitRequest) (*pb.ResourceLimit, error)

UpdateResourceLimit returns the updated ResourceLimit.

type ServiceAccountServer 

type ServiceAccountServer struct {
	pb.UnimplementedServiceAccountsServer
	// contains filtered or unexported fields
}

ServiceAccountServer embeds the UnimplementedServiceAccountsServer.

func NewServiceAccountServer 

func NewServiceAccountServer(
	serviceAccountService serviceaccount.Service,
	urnResolver *urn.Resolver,
) *ServiceAccountServer

NewServiceAccountServer returns an instance of ServiceAccountServer.

func (*ServiceAccountServer) CreateServiceAccount 

func (s *ServiceAccountServer) CreateServiceAccount(ctx context.Context, req *pb.CreateServiceAccountRequest) (*pb.ServiceAccount, error)

CreateServiceAccount creates a new service account.

func (*ServiceAccountServer) CreateToken 

func (s *ServiceAccountServer) CreateToken(ctx context.Context, req *pb.CreateTokenRequest) (*pb.CreateTokenResponse, error)

CreateToken creates a new token for a service account using an existing token.

func (*ServiceAccountServer) DeleteServiceAccount 

func (s *ServiceAccountServer) DeleteServiceAccount(ctx context.Context, req *pb.DeleteServiceAccountRequest) (*emptypb.Empty, error)

DeleteServiceAccount deletes an existing service account.

func (*ServiceAccountServer) GetServiceAccountByID 

func (s *ServiceAccountServer) GetServiceAccountByID(ctx context.Context, req *pb.GetServiceAccountByIDRequest) (*pb.ServiceAccount, error)

GetServiceAccountByID returns a service account by its ID.

func (*ServiceAccountServer) GetServiceAccounts 

func (s *ServiceAccountServer) GetServiceAccounts(ctx context.Context, req *pb.GetServiceAccountsRequest) (*pb.GetServiceAccountsResponse, error)

GetServiceAccounts returns a list of service accounts.

func (*ServiceAccountServer) UpdateServiceAccount 

func (s *ServiceAccountServer) UpdateServiceAccount(ctx context.Context, req *pb.UpdateServiceAccountRequest) (*pb.ServiceAccount, error)

UpdateServiceAccount updates an existing service account.

type TeamServer 

type TeamServer struct {
	pb.UnimplementedTeamsServer
	// contains filtered or unexported fields
}

TeamServer embeds the UnimplementedTeamsServer.

func NewTeamServer 

func NewTeamServer(
	teamService team.Service,
	urnResolver *urn.Resolver,
) *TeamServer

NewTeamServer returns an instance of TeamServer.

func (*TeamServer) GetTeamByID 

func (s *TeamServer) GetTeamByID(ctx context.Context, req *pb.GetTeamByIdRequest) (*pb.Team, error)

GetTeamByID returns a team by ID.

func (*TeamServer) GetTeams 

func (s *TeamServer) GetTeams(ctx context.Context, req *pb.GetTeamsRequest) (*pb.GetTeamsResponse, error)

GetTeams returns a paginated list of teams.

type VCSProviderServer 

type VCSProviderServer struct {
	pb.UnimplementedVCSProvidersServer
	// contains filtered or unexported fields
}

VCSProviderServer embeds the UnimplementedVCSProvidersServer.

func NewVCSProviderServer 

func NewVCSProviderServer(
	logger logger.Logger,
	vcsService vcs.Service,
	urnResolver *urn.Resolver,
) *VCSProviderServer

NewVCSProviderServer returns an instance of VCSProviderServer.

func (*VCSProviderServer) CreateVCSProvider 

func (s *VCSProviderServer) CreateVCSProvider(ctx context.Context, req *pb.CreateVCSProviderRequest) (*pb.CreateVCSProviderResponse, error)

CreateVCSProvider creates a new VCSProvider.

func (*VCSProviderServer) CreateVCSTokenForPipeline added in v0.8.0 

func (s *VCSProviderServer) CreateVCSTokenForPipeline(ctx context.Context, req *pb.CreateVCSTokenForPipelineRequest) (*pb.CreateVCSTokenForPipelineResponse, error)

CreateVCSTokenForPipeline creates a new VCS token for a pipeline.

func (*VCSProviderServer) DeleteVCSProvider 

func (s *VCSProviderServer) DeleteVCSProvider(ctx context.Context, req *pb.DeleteVCSProviderRequest) (*emptypb.Empty, error)

DeleteVCSProvider deletes a VCSProvider.

func (*VCSProviderServer) GetRepositoryArchive 

func (s *VCSProviderServer) GetRepositoryArchive(req *pb.GetRepositoryArchiveRequest, server pb.VCSProviders_GetRepositoryArchiveServer) error

GetRepositoryArchive returns the archive for a given repository.

func (*VCSProviderServer) GetVCSProviderByID 

func (s *VCSProviderServer) GetVCSProviderByID(ctx context.Context, req *pb.GetVCSProviderByIDRequest) (*pb.VCSProvider, error)

GetVCSProviderByID returns a VCSProvider by its ID.

func (*VCSProviderServer) GetVCSProviders 

func (s *VCSProviderServer) GetVCSProviders(ctx context.Context, req *pb.GetVCSProvidersRequest) (*pb.GetVCSProvidersResponse, error)

GetVCSProviders returns a paginated list of VCSProviders.

func (*VCSProviderServer) ResetVCSProviderOAuthToken 

func (s *VCSProviderServer) ResetVCSProviderOAuthToken(ctx context.Context, req *pb.ResetVCSProviderOAuthTokenRequest) (*pb.ResetVCSProviderOAuthTokenResponse, error)

ResetVCSProviderOAuthToken resets the OAuth token used to authenticate with the remote VCS system.

func (*VCSProviderServer) UpdateVCSProvider 

func (s *VCSProviderServer) UpdateVCSProvider(ctx context.Context, req *pb.UpdateVCSProviderRequest) (*pb.VCSProvider, error)

UpdateVCSProvider updates a existing VCSProvider.

type VersionServer added in v0.3.0 

type VersionServer struct {
	pb.UnimplementedVersionServer
	// contains filtered or unexported fields
}

VersionServer implements functionality related to API version.

func NewVersionServer added in v0.3.0 

func NewVersionServer(version string) *VersionServer

NewVersionServer returns an instance of VersionServer.

func (*VersionServer) GetVersion added in v0.3.0 

func (s *VersionServer) GetVersion(_ context.Context, _ *emptypb.Empty) (*pb.GetVersionResponse, error)

GetVersion returns the API version.

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.