registry

package
v0.3.7 Latest Latest
Warning

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

Go to latest
Published: Oct 28, 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
	rpc.UnimplementedAdminServer
	// 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) (*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) 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

ListApiSpecRevisions handles the corresponding API request.

func (*RegistryServer) ListApiSpecs

ListApiSpecs handles the corresponding API request.

func (*RegistryServer) ListApiVersions

ListApiVersions handles the corresponding API request.

func (*RegistryServer) ListApis

ListApis handles the corresponding API request.

func (*RegistryServer) ListArtifacts

ListArtifacts handles the corresponding API request.

func (*RegistryServer) ListProjects

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.

Directories

Path Synopsis
internal

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL