server

package

v0.61.1 Latest Latest Go to latest Published: Mar 29, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Details

This section is empty.

View Source

var ScanSuperSet = wire.NewSet(
	local.SuperSet,
	wire.Bind(new(scan.Backend), new(local.Service)),
	NewScanServer,
)

ScanSuperSet binds the dependencies for the server implementation.

This section is empty.

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

CacheServer implements the cache

func NewCacheServer(c cache.Cache) *CacheServer

NewCacheServer is the factory method for cacheServer

func (s *CacheServer) DeleteBlobs(_ context.Context, in *rpcCache.DeleteBlobsRequest) (*emptypb.Empty, error)

DeleteBlobs removes blobs by IDs

func (s *CacheServer) MissingBlobs(_ context.Context, in *rpcCache.MissingBlobsRequest) (*rpcCache.MissingBlobsResponse, error)

MissingBlobs returns missing blobs from cache

func (s *CacheServer) PutArtifact(_ context.Context, in *rpcCache.PutArtifactRequest) (*emptypb.Empty, error)

PutArtifact puts the artifacts in cache

func (s *CacheServer) PutBlob(_ context.Context, in *rpcCache.PutBlobRequest) (*emptypb.Empty, error)

PutBlob puts the blobs in cache

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

ScanServer implements the scanner service. It uses local.Service as its backend to perform various types of security scanning.

func NewScanServer(s scan.Backend) *ScanServer

NewScanServer creates a new ScanServer instance with the specified backend implementation.

func (s *ScanServer) Scan(ctx context.Context, in *rpcScanner.ScanRequest) (*rpcScanner.ScanResponse, error)

Scan scans and return response

func (s *ScanServer) ToOptions(in *rpcScanner.ScanOptions) types.ScanOptions

type Server struct {

	// For OCI registries
	types.RegistryOptions
	// contains filtered or unexported fields
}

Server represents Tunnel server

func NewServer(appVersion, addr, cacheDir, token, tokenHeader, pathPrefix string, dbRepositories []name.Reference, opt types.RegistryOptions) Server

NewServer returns an instance of Server

func (s Server) ListenAndServe(ctx context.Context, serverCache cache.Cache, skipDBUpdate bool) error

ListenAndServe starts Tunnel server

func (s Server) NewServeMux(ctx context.Context, serverCache cache.Cache, dbUpdateWg, requestWg *sync.WaitGroup) *http.ServeMux