service

Documentation

Index

• Constants
• Variables
• type DownloadService
  • func NewDownloadService(m Mirror, logger log.Logger) *DownloadService
  • func (d *DownloadService) Download(ctx context.Context, req *connect.Request[registryv1alpha1.DownloadRequest]) (*connect.Response[registryv1alpha1.DownloadResponse], error)
  • func (d *DownloadService) DownloadManifestAndBlobs(ctx context.Context, ...) (*connect.Response[registryv1alpha1.DownloadManifestAndBlobsResponse], error)
• type Mirror
  • func NewMirror(cfg *conf.Mirror, objectStorage *data.ObjectStorage, logger log.Logger) (Mirror, error)
• type ObjectStorage
• type RepositoryCommitService
  • func NewRepositoryCommitService(m Mirror) *RepositoryCommitService
  • func (r *RepositoryCommitService) GetRepositoryCommitByReference(ctx context.Context, ...) (*connect.Response[registryv1alpha1.GetRepositoryCommitByReferenceResponse], ...)
• type RepositoryService
  • func NewRepositoryService(m Mirror) *RepositoryService
  • func (r *RepositoryService) DeleteRepository(ctx context.Context, ...) (*connect.Response[registryv1alpha1.DeleteRepositoryResponse], error)
  • func (r *RepositoryService) GetRepositoriesByFullName(ctx context.Context, ...) (*connect.Response[registryv1alpha1.GetRepositoriesByFullNameResponse], error)
  • func (r *RepositoryService) GetRepositoryByFullName(ctx context.Context, ...) (*connect.Response[registryv1alpha1.GetRepositoryByFullNameResponse], error)
  • func (r *RepositoryService) ListRepositories(ctx context.Context, ...) (*connect.Response[registryv1alpha1.ListRepositoriesResponse], error)
  • func (r *RepositoryService) ListUserRepositories(ctx context.Context, ...) (*connect.Response[registryv1alpha1.ListUserRepositoriesResponse], error)
• type ResolveService
  • func NewResolveService(m Mirror) *ResolveService
  • func (r *ResolveService) GetModulePins(ctx context.Context, ...) (*connect.Response[registryv1alpha1.GetModulePinsResponse], error)

Constants

const (
	APISubdomainPrefix = "api."
)

Variables

var ProviderSet = wire.NewSet(
	NewMirror, NewResolveService, NewRepositoryService, NewRepositoryCommitService, NewDownloadService,
)

ProviderSet is service providers.

Types

type DownloadService

type DownloadService struct {
	Mirror

	registryv1alpha1connect.UnimplementedDownloadServiceHandler
	// contains filtered or unexported fields
}

func NewDownloadService

func NewDownloadService(m Mirror, logger log.Logger) *DownloadService

func (*DownloadService) Download

func (d *DownloadService) Download(ctx context.Context, req *connect.Request[registryv1alpha1.DownloadRequest]) (*connect.Response[registryv1alpha1.DownloadResponse], error)

func (*DownloadService) DownloadManifestAndBlobs

func (d *DownloadService) DownloadManifestAndBlobs(ctx context.Context, req *connect.Request[registryv1alpha1.DownloadManifestAndBlobsRequest]) (*connect.Response[registryv1alpha1.DownloadManifestAndBlobsResponse], error)

type Mirror

type Mirror interface {
	GetClient() (*http.Client, string)
	Remote() string
	ServerName() string
	ServeHTTP(http.ResponseWriter, *http.Request)
	ObjectStorage() ObjectStorage
}

func NewMirror

func NewMirror(cfg *conf.Mirror, objectStorage *data.ObjectStorage, logger log.Logger) (Mirror, error)

type ObjectStorage

type ObjectStorage interface {
	HasModuleSnapshot(ctx context.Context, ref bufmoduleref.ModuleReference) (bool, error)
	CreateModuleSnapshot(context.Context, bufmoduleref.ModuleReference, *registryv1alpha1.DownloadResponse) error
	FetchModuleSnapshot(context.Context, bufmoduleref.ModuleReference) (*registryv1alpha1.DownloadResponse, error)
}

type RepositoryCommitService

type RepositoryCommitService struct {
	Mirror

	registryv1alpha1connect.UnimplementedRepositoryCommitServiceHandler
	// contains filtered or unexported fields
}

func NewRepositoryCommitService

func NewRepositoryCommitService(m Mirror) *RepositoryCommitService

func (*RepositoryCommitService) GetRepositoryCommitByReference

func (r *RepositoryCommitService) GetRepositoryCommitByReference(ctx context.Context, req *connect.Request[registryv1alpha1.GetRepositoryCommitByReferenceRequest]) (*connect.Response[registryv1alpha1.GetRepositoryCommitByReferenceResponse], error)

type RepositoryService

type RepositoryService struct {
	Mirror

	registryv1alpha1connect.UnimplementedRepositoryServiceHandler
	// contains filtered or unexported fields
}

func NewRepositoryService

func NewRepositoryService(m Mirror) *RepositoryService

func (*RepositoryService) DeleteRepository

func (r *RepositoryService) DeleteRepository(ctx context.Context, req *connect.Request[registryv1alpha1.DeleteRepositoryRequest]) (*connect.Response[registryv1alpha1.DeleteRepositoryResponse], error)

func (*RepositoryService) GetRepositoriesByFullName

func (r *RepositoryService) GetRepositoriesByFullName(ctx context.Context, req *connect.Request[registryv1alpha1.GetRepositoriesByFullNameRequest]) (*connect.Response[registryv1alpha1.GetRepositoriesByFullNameResponse], error)

func (*RepositoryService) GetRepositoryByFullName

func (r *RepositoryService) GetRepositoryByFullName(ctx context.Context, req *connect.Request[registryv1alpha1.GetRepositoryByFullNameRequest]) (*connect.Response[registryv1alpha1.GetRepositoryByFullNameResponse], error)

func (*RepositoryService) ListRepositories

func (r *RepositoryService) ListRepositories(ctx context.Context, req *connect.Request[registryv1alpha1.ListRepositoriesRequest]) (*connect.Response[registryv1alpha1.ListRepositoriesResponse], error)

func (*RepositoryService) ListUserRepositories

func (r *RepositoryService) ListUserRepositories(ctx context.Context, req *connect.Request[registryv1alpha1.ListUserRepositoriesRequest]) (*connect.Response[registryv1alpha1.ListUserRepositoriesResponse], error)

type ResolveService

type ResolveService struct {
	Mirror

	registryv1alpha1connect.UnimplementedResolveServiceHandler
	// contains filtered or unexported fields
}

func NewResolveService

func NewResolveService(m Mirror) *ResolveService

func (*ResolveService) GetModulePins

func (r *ResolveService) GetModulePins(ctx context.Context, req *connect.Request[registryv1alpha1.GetModulePinsRequest]) (*connect.Response[registryv1alpha1.GetModulePinsResponse], error)