controller

package
v0.0.0-...-4c964c4 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 2025 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HeadDockerUUID = "Docker-Upload-UUID"
)

Variables

View Source 
var WireSet = wire.NewSet(
	ProvideArtifactController,
)

Functions

This section is empty.

Types

type ArtifactAuthRequest 

type ArtifactAuthRequest interface {
	Session() *auth.Session
	Space() *types.Space
}

type AssetMeta 

type AssetMeta struct {
	Id          int64
	BlobId      int64
	Size        int64
	Path        string
	ContentType string
	ETag        string
	LastModify  int64

	Ref string
}

func (*AssetMeta) Write 

func (r *AssetMeta) Write(w http.ResponseWriter)

type BaseReq 

type BaseReq struct {
	// contains filtered or unexported fields
}

func (*BaseReq) Session 

func (b *BaseReq) Session() *auth.Session

func (*BaseReq) Space 

func (b *BaseReq) Space() *types.Space

type ContainerManifestRequest 

type ContainerManifestRequest struct {
	*ContainerReq

	IsTag  bool
	Tag    string
	Digest digest.Digest
}

type ContainerReq 

type ContainerReq struct {
	// contains filtered or unexported fields
}

func (*ContainerReq) FullName 

func (cr *ContainerReq) FullName() string

func (*ContainerReq) Session 

func (cr *ContainerReq) Session() *auth.Session

func (*ContainerReq) Space 

func (cr *ContainerReq) Space() *types.Space

type ContainerUploadRequest 

type ContainerUploadRequest struct {
	*ContainerReq
	// contains filtered or unexported fields
}

type Controller 

type Controller struct {
	// contains filtered or unexported fields
}

func NewController 

func NewController(
	tx dbtx.Transactor, urlProvider url.Provider, authorizer authz.Authorizer,
	artStore store.ArtifactStore,
	spaceStore store.SpaceStore,
	fileStore storage.ContentStorage,
	settings *settings.Service,
	gcSvc *artifactgc.Service,
) *Controller

func ProvideArtifactController 

func ProvideArtifactController(tx dbtx.Transactor,
	urlProvider url.Provider, authorizer authz.Authorizer,
	artStore store.ArtifactStore, spaceStore store.SpaceStore, fileStore storage.ContentStorage,
	settings *settings.Service, gcSvc *artifactgc.Service,
) *Controller

func (*Controller) AppendBlobContent 

func (c *Controller) AppendBlobContent(ctx context.Context, r *http.Request, uploadRequest *ContainerUploadRequest) (HttpResponseWriter, error)

func (*Controller) CancelBlobUpload 

func (c *Controller) CancelBlobUpload(ctx context.Context, uploadRequest *ContainerUploadRequest) (HttpResponseWriter, error)

func (*Controller) DeleteContainerBlob 

func (c *Controller) DeleteContainerBlob(ctx context.Context, ctnReq *ContainerReq, digest string) (HttpResponseWriter, error)

func (*Controller) DeleteContainerManifest 

func (c *Controller) DeleteContainerManifest(ctx context.Context, manifestReq *ContainerManifestRequest,
) (HttpResponseWriter, error)

func (*Controller) DeleteContainerTag 

func (c *Controller) DeleteContainerTag(ctx context.Context, req *ContainerManifestRequest) (HttpResponseWriter, error)

func (*Controller) FinishBlobUpload 

func (c *Controller) FinishBlobUpload(ctx context.Context, r *http.Request, uploadRequest *ContainerUploadRequest) (HttpResponseWriter, error)

func (*Controller) GarbageCollectContainer 

func (c *Controller) GarbageCollectContainer(ctx context.Context) (*types.JobUIDResponse, error)

func (*Controller) GarbageCollectSoftRemove 

func (c *Controller) GarbageCollectSoftRemove(ctx context.Context) (*types.JobUIDResponse, error)

func (*Controller) GetAssetContent 

func (c *Controller) GetAssetContent(ctx context.Context, path string, format types.ArtifactFormat, viewId *int64) ([]byte, *AssetMeta, error)

func (*Controller) GetAssetInfo 

func (c *Controller) GetAssetInfo(ctx context.Context, path string, format types.ArtifactFormat, viewId *int64) (*AssetMeta, error)

func (*Controller) GetAssetReader 

func (c *Controller) GetAssetReader(ctx context.Context, path string, format types.ArtifactFormat, viewId *int64) (io.ReadCloser, *AssetMeta, error)

func (*Controller) GetBlobUploadStatus 

func (c *Controller) GetBlobUploadStatus(ctx context.Context, uploadRequest *ContainerUploadRequest) (HttpResponseWriter, error)

func (*Controller) GetContainerBlob 

func (c *Controller) GetContainerBlob(ctx context.Context, ctnReq *ContainerReq, digest string) (HttpResponseWriter, error)

func (*Controller) GetContainerManifest 

func (c *Controller) GetContainerManifest(ctx context.Context, req *http.Request, manifestReq *ContainerManifestRequest) (HttpResponseWriter, error)

func (*Controller) GetContainerTag 

func (c *Controller) GetContainerTag(ctx context.Context, req *http.Request, manifestReq *ContainerManifestRequest) (HttpResponseWriter, error)

func (*Controller) GetMetaInfo 

func (c *Controller) GetMetaInfo(ctx context.Context, path string, format types.ArtifactFormat, viewId int64) (*AssetMeta, error)

func (*Controller) GetMetaReader 

func (c *Controller) GetMetaReader(ctx context.Context, path string, format types.ArtifactFormat, viewId int64) (io.ReadCloser, *AssetMeta, error)

func (*Controller) GetVersionAssetInfo 

func (c *Controller) GetVersionAssetInfo(ctx context.Context, viewId, pkgId int64, version, path string) (*VersionAssetMeta, error)

func (*Controller) GetVersionAssetReader 

func (c *Controller) GetVersionAssetReader(ctx context.Context, viewId, pkgId int64, version, path string) (io.ReadCloser, *VersionAssetMeta, error)

func (*Controller) HeadBlob 

func (c *Controller) HeadBlob(ctx context.Context, ctnReq *ContainerReq, digest string) (HttpResponseWriter, error)

func (*Controller) HeadContainerManifest 

func (c *Controller) HeadContainerManifest(ctx context.Context, req *http.Request, manifestReq *ContainerManifestRequest) (HttpResponseWriter, error)

func (*Controller) HeadContainerTag 

func (c *Controller) HeadContainerTag(ctx context.Context, req *http.Request, manifestReq *ContainerManifestRequest) (HttpResponseWriter, error)

func (*Controller) ListAssets 

func (c *Controller) ListAssets(ctx context.Context, req *BaseReq,
	packageName, group, version string, format types.ArtifactFormat,
) ([]*types.ArtifactAssetsRes, error)

func (*Controller) ListContainerImages 

func (c *Controller) ListContainerImages(ctx context.Context, req *BaseReq, packageName, version string) (*container.TagMetadata, error)

func (*Controller) ListNodeInfo 

func (c *Controller) ListNodeInfo(ctx context.Context, in *ListNodeInfoRequest) ([]*types.ArtifactNodeInfo, error)

func (*Controller) ListTags 

func (c *Controller) ListTags(ctx context.Context, req *ContainerReq) (*tagList, error)

func (*Controller) ListTree 

func (c *Controller) ListTree(ctx context.Context, req *BaseReq, filter *types.ArtifactTreeFilter) ([]*types.ArtifactTreeRes, error)

func (*Controller) ListVersions 

func (c *Controller) ListVersions(ctx context.Context, req *BaseReq, format types.ArtifactFormat,
	filter *types.ArtifactVersionFilter,
) ([]*types.ArtifactVersionsRes, error)

func (*Controller) LoadBaseRequest 

func (c *Controller) LoadBaseRequest(ctx context.Context, r *http.Request) (*BaseReq, error)

func (*Controller) LoadContainerManifestRequest 

func (c *Controller) LoadContainerManifestRequest(ctx context.Context, r *http.Request) (*ContainerManifestRequest, error)

func (*Controller) LoadContainerRequest 

func (c *Controller) LoadContainerRequest(ctx context.Context, r *http.Request) (*ContainerReq, error)

func (*Controller) LoadContainerResumeUploadRequest 

func (c *Controller) LoadContainerResumeUploadRequest(ctx context.Context, r *http.Request, requireState bool) (*ContainerUploadRequest, error)

func (*Controller) ParseSpaceView 

func (c *Controller) ParseSpaceView(ctx context.Context, spaceRef string) (*adapter.ViewDescriptor, error)

func (*Controller) PutContainerTag 

func (c *Controller) PutContainerTag(ctx context.Context, req *http.Request, manifestReq *ContainerManifestRequest) (HttpResponseWriter, error)

func (*Controller) PutManifest 

func (c *Controller) PutManifest(ctx context.Context, req *http.Request, manifestReq *ContainerManifestRequest,
) (HttpResponseWriter, error)

func (*Controller) RefreshTree 

func (c *Controller) RefreshTree(ctx context.Context) error

func (*Controller) SaveContainerBlob 

func (c *Controller) SaveContainerBlob(
	ctx context.Context, ctnReq *ContainerReq,
	req *http.Request, reference digest.Digest,
) (HttpResponseWriter, error)

func (*Controller) SoftRemove 

func (c *Controller) SoftRemove(ctx context.Context, req *BaseReq, in *ListNodeInfoRequest) (*types.ArtifactNodeRemoveReport, error)

func (*Controller) StartBlobUpload 

func (c *Controller) StartBlobUpload(
	ctx context.Context, ctnReq *ContainerReq,
) (HttpResponseWriter, error)

func (*Controller) StatisticCapacity 

func (c *Controller) StatisticCapacity(ctx context.Context) (*types.ArtifactStatisticResponse, error)

func (*Controller) StatisticContainerCapacity 

func (c *Controller) StatisticContainerCapacity(ctx context.Context) (*types.ArtifactStatisticResponse, error)

func (*Controller) UploadHelm 

func (c *Controller) UploadHelm(ctx context.Context, r *http.Request, helmReq *BaseReq) (HttpResponseWriter, error)

func (*Controller) UploadRaw 

func (c *Controller) UploadRaw(ctx context.Context, r *http.Request, helmReq *BaseReq) (HttpResponseWriter, error)

type HttpResponseWriter 

type HttpResponseWriter interface {
	Write(w http.ResponseWriter)
}

func NewResponseWriter 

func NewResponseWriter(fn func(w http.ResponseWriter)) HttpResponseWriter

type IndexUpdater 

type IndexUpdater struct {
	// contains filtered or unexported fields
}

func (*IndexUpdater) Run 

func (u *IndexUpdater) Run(ctx context.Context, store store.ArtifactStore, req *BaseReq) error

type ListNodeInfoRequest 

type ListNodeInfoRequest struct {
	NodeIds []string `json:"node_ids"`
}

type RequestView 

type RequestView struct {
	Space     *types.Space
	View      *types.ArtifactView
	StorageId int64
}

type VersionAssetMeta 

type VersionAssetMeta struct {
	*AssetMeta
	VersionId int64
}

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.