registry

package
v0.6.10 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2023 License: Apache-2.0 Imports: 26 Imported by: 2

README

server

This directory contains most of the handwritten code that implements the registry-server.

Documentation

Index

Constants

View Source 
const TopicName = "registry-events"

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Database  string
	DBConfig  string
	LogLevel  string
	LogFormat string
	Notify    bool
	ProjectID string
}

Config configures the registry server.

type RegistryServer 

type RegistryServer struct {
	rpc.UnimplementedRegistryServer
	rpc.UnimplementedAdminServer
	// contains filtered or unexported fields
}

RegistryServer implements a Registry server.

func New 

func New(config Config) (*RegistryServer, error)

func (*RegistryServer) Close added in v0.5.4 

func (s *RegistryServer) Close()

func (*RegistryServer) CreateApi 

func (s *RegistryServer) CreateApi(ctx context.Context, req *rpc.CreateApiRequest) (*rpc.Api, error)

CreateApi handles the corresponding API request.

func (*RegistryServer) CreateApiDeployment added in v0.3.9 

func (s *RegistryServer) CreateApiDeployment(ctx context.Context, req *rpc.CreateApiDeploymentRequest) (*rpc.ApiDeployment, error)

CreateApiDeployment handles the corresponding API request.

func (*RegistryServer) CreateApiSpec 

func (s *RegistryServer) CreateApiSpec(ctx context.Context, req *rpc.CreateApiSpecRequest) (*rpc.ApiSpec, error)

CreateApiSpec handles the corresponding API request.

func (*RegistryServer) CreateApiVersion 

func (s *RegistryServer) CreateApiVersion(ctx context.Context, req *rpc.CreateApiVersionRequest) (*rpc.ApiVersion, error)

CreateApiVersion handles the corresponding API request.

func (*RegistryServer) CreateArtifact 

func (s *RegistryServer) CreateArtifact(ctx context.Context, req *rpc.CreateArtifactRequest) (*rpc.Artifact, error)

CreateArtifact handles the corresponding API request.

func (*RegistryServer) CreateProject 

func (s *RegistryServer) CreateProject(ctx context.Context, req *rpc.CreateProjectRequest) (*rpc.Project, error)

CreateProject handles the corresponding API request.

func (*RegistryServer) DeleteApi 

func (s *RegistryServer) DeleteApi(ctx context.Context, req *rpc.DeleteApiRequest) (*emptypb.Empty, error)

DeleteApi handles the corresponding API request.

func (*RegistryServer) DeleteApiDeployment added in v0.3.9 

func (s *RegistryServer) DeleteApiDeployment(ctx context.Context, req *rpc.DeleteApiDeploymentRequest) (*emptypb.Empty, error)

DeleteApiDeployment handles the corresponding API request.

func (*RegistryServer) DeleteApiDeploymentRevision added in v0.3.9 

func (s *RegistryServer) DeleteApiDeploymentRevision(ctx context.Context, req *rpc.DeleteApiDeploymentRevisionRequest) (*rpc.ApiDeployment, error)

DeleteApiDeploymentRevision handles the corresponding API request.

func (*RegistryServer) DeleteApiSpec 

func (s *RegistryServer) DeleteApiSpec(ctx context.Context, req *rpc.DeleteApiSpecRequest) (*emptypb.Empty, error)

DeleteApiSpec handles the corresponding API request.

func (*RegistryServer) DeleteApiSpecRevision 

func (s *RegistryServer) DeleteApiSpecRevision(ctx context.Context, req *rpc.DeleteApiSpecRevisionRequest) (*rpc.ApiSpec, error)

DeleteApiSpecRevision handles the corresponding API request.

func (*RegistryServer) DeleteApiVersion 

func (s *RegistryServer) DeleteApiVersion(ctx context.Context, req *rpc.DeleteApiVersionRequest) (*emptypb.Empty, error)

DeleteApiVersion handles the corresponding API request.

func (*RegistryServer) DeleteArtifact 

func (s *RegistryServer) DeleteArtifact(ctx context.Context, req *rpc.DeleteArtifactRequest) (*emptypb.Empty, error)

DeleteArtifact handles the corresponding API request.

func (*RegistryServer) DeleteProject 

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

DeleteProject handles the corresponding API request.

func (*RegistryServer) GetApi 

func (s *RegistryServer) GetApi(ctx context.Context, req *rpc.GetApiRequest) (*rpc.Api, error)

GetApi handles the corresponding API request.

func (*RegistryServer) GetApiDeployment added in v0.3.9 

func (s *RegistryServer) GetApiDeployment(ctx context.Context, req *rpc.GetApiDeploymentRequest) (*rpc.ApiDeployment, error)

GetApiDeployment handles the corresponding API request.

func (*RegistryServer) GetApiSpec 

func (s *RegistryServer) GetApiSpec(ctx context.Context, req *rpc.GetApiSpecRequest) (*rpc.ApiSpec, error)

GetApiSpec handles the corresponding API request.

func (*RegistryServer) GetApiSpecContents 

func (s *RegistryServer) GetApiSpecContents(ctx context.Context, req *rpc.GetApiSpecContentsRequest) (*httpbody.HttpBody, error)

GetApiSpecContents handles the corresponding API request.

func (*RegistryServer) GetApiVersion 

func (s *RegistryServer) GetApiVersion(ctx context.Context, req *rpc.GetApiVersionRequest) (*rpc.ApiVersion, error)

GetApiVersion handles the corresponding API request.

func (*RegistryServer) GetArtifact 

func (s *RegistryServer) GetArtifact(ctx context.Context, req *rpc.GetArtifactRequest) (*rpc.Artifact, error)

GetArtifact handles the corresponding API request.

func (*RegistryServer) GetArtifactContents 

func (s *RegistryServer) GetArtifactContents(ctx context.Context, req *rpc.GetArtifactContentsRequest) (*httpbody.HttpBody, error)

GetArtifactContents handles the corresponding API request.

func (*RegistryServer) GetProject 

func (s *RegistryServer) GetProject(ctx context.Context, req *rpc.GetProjectRequest) (*rpc.Project, error)

GetProject handles the corresponding API request.

func (*RegistryServer) GetStatus 

func (s *RegistryServer) GetStatus(ctx context.Context, req *emptypb.Empty) (*rpc.Status, error)

GetStatus handles the corresponding API request.

func (*RegistryServer) GetStorage added in v0.4.2 

func (s *RegistryServer) GetStorage(ctx context.Context, req *emptypb.Empty) (*rpc.Storage, error)

GetStorage handles the corresponding API request.

func (*RegistryServer) ListApiDeploymentRevisions added in v0.3.9 

func (s *RegistryServer) ListApiDeploymentRevisions(ctx context.Context, req *rpc.ListApiDeploymentRevisionsRequest) (*rpc.ListApiDeploymentRevisionsResponse, error)

ListApiDeploymentRevisions handles the corresponding API request.

func (*RegistryServer) ListApiDeployments added in v0.3.9 

func (s *RegistryServer) ListApiDeployments(ctx context.Context, req *rpc.ListApiDeploymentsRequest) (*rpc.ListApiDeploymentsResponse, error)

ListApiDeployments handles the corresponding API request.

func (*RegistryServer) ListApiSpecRevisions 

func (s *RegistryServer) ListApiSpecRevisions(ctx context.Context, req *rpc.ListApiSpecRevisionsRequest) (*rpc.ListApiSpecRevisionsResponse, error)

ListApiSpecRevisions handles the corresponding API request.

func (*RegistryServer) ListApiSpecs 

func (s *RegistryServer) ListApiSpecs(ctx context.Context, req *rpc.ListApiSpecsRequest) (*rpc.ListApiSpecsResponse, error)

ListApiSpecs handles the corresponding API request.

func (*RegistryServer) ListApiVersions 

func (s *RegistryServer) ListApiVersions(ctx context.Context, req *rpc.ListApiVersionsRequest) (*rpc.ListApiVersionsResponse, error)

ListApiVersions handles the corresponding API request.

func (*RegistryServer) ListApis 

func (s *RegistryServer) ListApis(ctx context.Context, req *rpc.ListApisRequest) (*rpc.ListApisResponse, error)

ListApis handles the corresponding API request.

func (*RegistryServer) ListArtifacts 

func (s *RegistryServer) ListArtifacts(ctx context.Context, req *rpc.ListArtifactsRequest) (*rpc.ListArtifactsResponse, error)

ListArtifacts handles the corresponding API request.

func (*RegistryServer) ListProjects 

func (s *RegistryServer) ListProjects(ctx context.Context, req *rpc.ListProjectsRequest) (*rpc.ListProjectsResponse, error)

ListProjects handles the corresponding API request.

func (*RegistryServer) MigrateDatabase added in v0.3.11 

func (s *RegistryServer) MigrateDatabase(ctx context.Context, req *rpc.MigrateDatabaseRequest) (*longrunning.Operation, error)

MigrateDatabase handles the corresponding API request.

func (*RegistryServer) ReplaceArtifact 

func (s *RegistryServer) ReplaceArtifact(ctx context.Context, req *rpc.ReplaceArtifactRequest) (*rpc.Artifact, error)

ReplaceArtifact handles the corresponding API request.

func (*RegistryServer) RollbackApiDeployment added in v0.3.9 

func (s *RegistryServer) RollbackApiDeployment(ctx context.Context, req *rpc.RollbackApiDeploymentRequest) (*rpc.ApiDeployment, error)

RollbackApiDeployment handles the corresponding API request.

func (*RegistryServer) RollbackApiSpec 

func (s *RegistryServer) RollbackApiSpec(ctx context.Context, req *rpc.RollbackApiSpecRequest) (*rpc.ApiSpec, error)

RollbackApiSpec handles the corresponding API request.

func (*RegistryServer) ServeGRPC added in v0.5.4 

func (rs *RegistryServer) ServeGRPC(addr *net.TCPAddr, opt ...grpc.ServerOption) (net.Listener, *grpc.Server, error)

GRPCListen starts a net.Listener and grpc.Server for this RegistryServer. Caller is responsible for stopping server.

func (*RegistryServer) TagApiDeploymentRevision added in v0.3.9 

func (s *RegistryServer) TagApiDeploymentRevision(ctx context.Context, req *rpc.TagApiDeploymentRevisionRequest) (*rpc.ApiDeployment, error)

TagApiDeploymentRevision handles the corresponding API request.

func (*RegistryServer) TagApiSpecRevision 

func (s *RegistryServer) TagApiSpecRevision(ctx context.Context, req *rpc.TagApiSpecRevisionRequest) (*rpc.ApiSpec, error)

TagApiSpecRevision handles the corresponding API request.

func (*RegistryServer) UpdateApi 

func (s *RegistryServer) UpdateApi(ctx context.Context, req *rpc.UpdateApiRequest) (*rpc.Api, error)

UpdateApi handles the corresponding API request.

func (*RegistryServer) UpdateApiDeployment added in v0.3.9 

func (s *RegistryServer) UpdateApiDeployment(ctx context.Context, req *rpc.UpdateApiDeploymentRequest) (*rpc.ApiDeployment, error)

UpdateApiDeployment handles the corresponding API request.

func (*RegistryServer) UpdateApiSpec 

func (s *RegistryServer) UpdateApiSpec(ctx context.Context, req *rpc.UpdateApiSpecRequest) (*rpc.ApiSpec, error)

UpdateApiSpec handles the corresponding API request.

func (*RegistryServer) UpdateApiVersion 

func (s *RegistryServer) UpdateApiVersion(ctx context.Context, req *rpc.UpdateApiVersionRequest) (*rpc.ApiVersion, error)

UpdateApiVersion handles the corresponding API request.

func (*RegistryServer) UpdateProject 

func (s *RegistryServer) UpdateProject(ctx context.Context, req *rpc.UpdateProjectRequest) (*rpc.Project, error)

UpdateProject handles the corresponding API request.

Source Files

View all Source files

Directories

Path Synopsis
internal
buildinfo
storage
storage/filtering
storage/models
test
remote
seeder

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.