registry

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2021 License: Apache-2.0 Imports: 23 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
	// contains filtered or unexported fields
}

RegistryServer implements a Registry server.

func New 

func New(config Config) *RegistryServer

func (*RegistryServer) CreateApi 

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

CreateApi 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) 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) (*emptypb.Empty, 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) 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) 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) LoggingInterceptor 

func (s *RegistryServer) LoggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

func (*RegistryServer) ReplaceArtifact 

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

ReplaceArtifact 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) 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) 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
storage
storage/filtering
storage/gorm
storage/models
test/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.