Documentation
¶
Index ¶
Constants ¶
const DownloadPath = "/download/{digest}"
i.e /download/sha256:1234567890abcdef
Variables ¶
var ProviderSet = wire.NewSet(NewByteStreamService, NewResourceService, NewDownloadService)
ProviderSet is service providers.
Functions ¶
This section is empty.
Types ¶
type ByteStreamService ¶
type ByteStreamService struct {
*bytestream.UnimplementedByteStreamServer
// contains filtered or unexported fields
}
Implements the bytestream interface https://github.com/googleapis/googleapis/blob/master/google/bytestream/bytestream.proto#L49 specifically both the write and the read methods
func NewByteStreamService ¶
func NewByteStreamService(bp backend.Provider, opts ...NewOpt) *ByteStreamService
func (*ByteStreamService) Read ¶
func (s *ByteStreamService) Read(req *bytestream.ReadRequest, stream bytestream.ByteStream_ReadServer) error
Server-side streaming RPC for reading blobs, implements the bytestream interface NOTE: Due to the fact that we are using the OCI backend, we can not stream the content directly from the backend but instead we need to download the whole artifact and then stream it to the client
func (*ByteStreamService) Write ¶
func (s *ByteStreamService) Write(stream bytestream.ByteStream_WriteServer) error
Client-side streaming RPC for writing blobs. Iterate on the stream of file chunks, aggregate them in a buffer, send them to the backend and return a response with the commitedSize
type DownloadService ¶ added in v0.16.0
type DownloadService struct {
// contains filtered or unexported fields
}
func NewDownloadService ¶ added in v0.16.0
func NewDownloadService(bp backend.Provider, opts ...NewOpt) *DownloadService
func (*DownloadService) ServeHTTP ¶ added in v0.16.0
func (s *DownloadService) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ResourceService ¶
type ResourceService struct {
v1.UnimplementedResourceServiceServer
// contains filtered or unexported fields
}
func NewResourceService ¶
func NewResourceService(bp backend.Provider, opts ...NewOpt) *ResourceService
func (*ResourceService) Describe ¶
func (s *ResourceService) Describe(ctx context.Context, req *v1.ResourceServiceDescribeRequest) (*v1.ResourceServiceDescribeResponse, error)
Return the metadata if an artifact referenced by its content digest
type StatusService ¶
type StatusService struct {
pb.UnimplementedStatusServiceServer
// contains filtered or unexported fields
}
func NewStatusService ¶
func NewStatusService(version string) *StatusService
func (*StatusService) Infoz ¶
func (s *StatusService) Infoz(_ context.Context, _ *pb.InfozRequest) (*pb.InfozResponse, error)
func (*StatusService) Statusz ¶
func (s *StatusService) Statusz(_ context.Context, _ *pb.StatuszRequest) (*pb.StatuszResponse, error)
Source Files