proto

type ContainerProfileChunk struct {
	// metadata is set on the first chunk only.
	Metadata *ContainerProfileChunkMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// blob_chunk is a slice of the marshaled ContainerProfile payload.
	BlobChunk            []byte   `protobuf:"bytes,2,opt,name=blob_chunk,json=blobChunk,proto3" json:"blob_chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ContainerProfileChunkMetadata struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ErrorCode int32

type GetContainerProfileStreamChunk struct {
	// metadata is set on the first chunk only.
	Metadata *GetContainerProfileStreamChunkMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// blob_chunk is a slice of the marshaled ContainerProfile payload.
	BlobChunk            []byte   `protobuf:"bytes,2,opt,name=blob_chunk,json=blobChunk,proto3" json:"blob_chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type GetContainerProfileStreamChunkMetadata struct {
	Success      bool      `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string    `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ErrorCode    ErrorCode `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=storageserver.v1.ErrorCode" json:"error_code,omitempty"`
	// exists indicates whether a ContainerProfile row was found.
	Exists               bool     `protobuf:"varint,4,opt,name=exists,proto3" json:"exists,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type GetContainerProfileStreamRequest struct {
	// Namespace of the workload.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Name of the container profile to fetch.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Region of the resource (non-k8s scope identifier).
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// CloudAccountIdentifier of the resource (non-k8s scope identifier).
	CloudAccountIdentifier string   `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

type GetProfileRequest struct {
	// Kind specifies the type of profile: "applicationProfile", "networkNeighborhood", or "containerProfile"
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// Namespace of the workload (k8s scope identifier)
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Name of the workload
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Region of the resource (non-k8s scope identifier, e.g. "us-east-1")
	Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
	// CloudAccountIdentifier of the resource (non-k8s scope identifier, e.g. AWS account ID "123456789012", GCP project ID)
	CloudAccountIdentifier string   `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

type GetProfileResponse struct {
	// Success indicates if the profile was successfully retrieved
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if the operation failed
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Error code for programmatic error handling
	ErrorCode ErrorCode `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=storageserver.v1.ErrorCode" json:"error_code,omitempty"`
	// ApplicationProfile is populated when kind is "applicationProfile"
	ApplicationProfile *v1beta1.ApplicationProfile `protobuf:"bytes,4,opt,name=application_profile,json=applicationProfile,proto3" json:"application_profile,omitempty"`
	// NetworkNeighborhood is populated when kind is "networkNeighborhood"
	NetworkNeighborhood *v1beta1.NetworkNeighborhood `protobuf:"bytes,5,opt,name=network_neighborhood,json=networkNeighborhood,proto3" json:"network_neighborhood,omitempty"`
	// ContainerProfile is populated when kind is "containerProfile"
	ContainerProfile     *v1beta1.ContainerProfile `protobuf:"bytes,6,opt,name=container_profile,json=containerProfile,proto3" json:"container_profile,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

type GetSBOMChunk struct {
	// metadata is set on the first chunk only.
	Metadata *GetSBOMChunkMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// blob_chunk is a slice of the marshaled SBOMSyft payload.
	BlobChunk            []byte   `protobuf:"bytes,2,opt,name=blob_chunk,json=blobChunk,proto3" json:"blob_chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type GetSBOMChunkMetadata struct {
	Success              bool          `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage         string        `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ErrorCode            ErrorCode     `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=storageserver.v1.ErrorCode" json:"error_code,omitempty"`
	Exists               bool          `protobuf:"varint,4,opt,name=exists,proto3" json:"exists,omitempty"`
	SbomMetadata         *SBOMMetadata `protobuf:"bytes,5,opt,name=sbom_metadata,json=sbomMetadata,proto3" json:"sbom_metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

type GetSBOMRequest struct {
	// image_digest is the SHA-256 digest of the requested image (without the
	// "sha256:" prefix).
	ImageDigest string `protobuf:"bytes,1,opt,name=image_digest,json=imageDigest,proto3" json:"image_digest,omitempty"`
	// syft_version is the syft version that produced the requested SBOM. The
	// (image_digest, syft_version) pair is the lookup key. Leave empty to
	// request "latest available version" semantics; the server returns the
	// most recently created SBOM for the image.
	SyftVersion string `protobuf:"bytes,2,opt,name=syft_version,json=syftVersion,proto3" json:"syft_version,omitempty"`
	// metadata_only skips the blob and returns only SBOMMetadata. Used by
	// agents to decide whether to regenerate.
	MetadataOnly         bool     `protobuf:"varint,3,opt,name=metadata_only,json=metadataOnly,proto3" json:"metadata_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ListApplicationProfilesRequest struct {
	// Namespace to list profiles from
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Limit number of items to return (0 means server default)
	Limit int64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// Continue token for pagination
	Cont string `protobuf:"bytes,5,opt,name=cont,proto3" json:"cont,omitempty"`
	// Region of the resource (non-k8s scope identifier, e.g. "us-east-1")
	Region string `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	// CloudAccountIdentifier of the resource (non-k8s scope identifier, e.g. AWS account ID "123456789012", GCP project ID)
	CloudAccountIdentifier string   `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

type ListApplicationProfilesResponse struct {
	// Success indicates if the list was successfully retrieved
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if the operation failed
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Error code for programmatic error handling
	ErrorCode ErrorCode `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=storageserver.v1.ErrorCode" json:"error_code,omitempty"`
	// ApplicationProfiles list (Spec will be nil for each item)
	ApplicationProfiles []*v1beta1.ApplicationProfile `protobuf:"bytes,4,rep,name=application_profiles,json=applicationProfiles,proto3" json:"application_profiles,omitempty"`
	// Continue token for next page (empty if no more results)
	Cont                 string   `protobuf:"bytes,5,opt,name=cont,proto3" json:"cont,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ListNetworkNeighborhoodsRequest struct {
	// Namespace to list neighborhoods from
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Limit number of items to return (0 means server default)
	Limit int64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// Continue token for pagination
	Cont string `protobuf:"bytes,5,opt,name=cont,proto3" json:"cont,omitempty"`
	// Region of the resource (non-k8s scope identifier, e.g. "us-east-1")
	Region string `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	// CloudAccountIdentifier of the resource (non-k8s scope identifier, e.g. AWS account ID "123456789012", GCP project ID)
	CloudAccountIdentifier string   `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

type ListNetworkNeighborhoodsResponse struct {
	// Success indicates if the list was successfully retrieved
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if the operation failed
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Error code for programmatic error handling
	ErrorCode ErrorCode `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=storageserver.v1.ErrorCode" json:"error_code,omitempty"`
	// NetworkNeighborhoods list (Spec will be nil for each item)
	NetworkNeighborhoods []*v1beta1.NetworkNeighborhood `protobuf:"bytes,4,rep,name=network_neighborhoods,json=networkNeighborhoods,proto3" json:"network_neighborhoods,omitempty"`
	// Continue token for next page (empty if no more results)
	Cont                 string   `protobuf:"bytes,5,opt,name=cont,proto3" json:"cont,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type PutSBOMChunk struct {
	// metadata is set on the first chunk only.
	Metadata *PutSBOMChunkMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// blob_chunk is a slice of the marshaled SBOMSyft payload.
	BlobChunk            []byte   `protobuf:"bytes,2,opt,name=blob_chunk,json=blobChunk,proto3" json:"blob_chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type PutSBOMChunkMetadata struct {
	ImageDigest          string     `protobuf:"bytes,1,opt,name=image_digest,json=imageDigest,proto3" json:"image_digest,omitempty"`
	SyftVersion          string     `protobuf:"bytes,2,opt,name=syft_version,json=syftVersion,proto3" json:"syft_version,omitempty"`
	Source               SBOMSource `protobuf:"varint,3,opt,name=source,proto3,enum=storageserver.v1.SBOMSource" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

type PutSBOMResponse struct {
	Success              bool      `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage         string    `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ErrorCode            ErrorCode `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=storageserver.v1.ErrorCode" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

type SBOMMetadata struct {
	// image_digest of the scanned image (without the "sha256:" prefix).
	ImageDigest string `protobuf:"bytes,1,opt,name=image_digest,json=imageDigest,proto3" json:"image_digest,omitempty"`
	// syft_version that produced the SBOM blob.
	SyftVersion string `protobuf:"bytes,2,opt,name=syft_version,json=syftVersion,proto3" json:"syft_version,omitempty"`
	// source identifies how this SBOM was produced.
	Source SBOMSource `protobuf:"varint,3,opt,name=source,proto3,enum=storageserver.v1.SBOMSource" json:"source,omitempty"`
	// blob_size_bytes is the size of the SBOM blob in S3.
	BlobSizeBytes int64 `protobuf:"varint,4,opt,name=blob_size_bytes,json=blobSizeBytes,proto3" json:"blob_size_bytes,omitempty"`
	// created_at is the RFC3339 timestamp when the row was first inserted.
	CreatedAt string `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// last_referenced_at is the RFC3339 timestamp when the orchestrator most
	// recently resolved an inventory entry to this SBOM. Drives eviction.
	LastReferencedAt string `protobuf:"bytes,6,opt,name=last_referenced_at,json=lastReferencedAt,proto3" json:"last_referenced_at,omitempty"`
	// annotations carries the SBOMSyft's Kubernetes annotations so a
	// metadata_only=true fetch is sufficient for agents that branch on them
	// (e.g. status, tool-version, node-name, scanner-memory-limit) without
	// downloading and unmarshaling the full SBOM blob.
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type SBOMSource int32

type SendContainerProfileRequest struct {
	// ContainerProfile is the time-series container profile from node agent
	ContainerProfile     *v1beta1.ContainerProfile `protobuf:"bytes,1,opt,name=container_profile,json=containerProfile,proto3" json:"container_profile,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

type SendContainerProfileResponse struct {
	// Success indicates if the profile was successfully sent to Pulsar
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if the operation failed
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Error code for programmatic error handling
	ErrorCode            ErrorCode `protobuf:"varint,3,opt,name=error_code,json=errorCode,proto3,enum=storageserver.v1.ErrorCode" json:"error_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

type StorageServiceClient interface {
	// Deprecated: Do not use.
	// SendContainerProfile receives a container profile (time-series snapshot) from node agent
	// and sends it to Pulsar for processing by the ingester.
	//
	// Deprecated: use SendContainerProfileStream. The unary form is silently
	// capped by gRPC's default 4 MiB message limit; container profiles with
	// many or large entries (or with MaxContainerProfileSize raised) can
	// exceed this and fail on the wire. The streaming variant has no such
	// bound.
	SendContainerProfile(ctx context.Context, in *SendContainerProfileRequest, opts ...grpc.CallOption) (*SendContainerProfileResponse, error)
	// GetProfile retrieves an aggregated profile (ApplicationProfile, NetworkNeighborhood,
	// or ContainerProfile) by fetching them from S3.
	//
	// Note: for ContainerProfile specifically, prefer GetContainerProfileStream,
	// which is not subject to the default 4 MiB unary gRPC message limit.
	GetProfile(ctx context.Context, in *GetProfileRequest, opts ...grpc.CallOption) (*GetProfileResponse, error)
	// ListApplicationProfiles lists all ApplicationProfiles in a namespace (returns metadata only, nil Spec)
	ListApplicationProfiles(ctx context.Context, in *ListApplicationProfilesRequest, opts ...grpc.CallOption) (*ListApplicationProfilesResponse, error)
	// ListNetworkNeighborhoods lists all NetworkNeighborhoods in a namespace (returns metadata only, nil Spec)
	ListNetworkNeighborhoods(ctx context.Context, in *ListNetworkNeighborhoodsRequest, opts ...grpc.CallOption) (*ListNetworkNeighborhoodsResponse, error)
	// SendContainerProfileStream is the streaming replacement for
	// SendContainerProfile. Client-streaming so the caller need not know the
	// payload size in advance — required because container profiles with
	// many or large entries can exceed the default 4 MiB unary gRPC limit.
	//
	// The first chunk MUST set metadata (which carries identifying labels
	// and may be empty otherwise) and MAY include blob_chunk for small
	// payloads. Subsequent chunks set only blob_chunk. Concatenated
	// blob_chunk values form the marshaled ContainerProfile proto payload.
	SendContainerProfileStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ContainerProfileChunk, SendContainerProfileResponse], error)
	// GetContainerProfileStream is the streaming replacement for
	// GetProfile(kind=ContainerProfile). Server-streaming so the caller need
	// not know the response size in advance.
	//
	// The first chunk in the response carries metadata + status. When the
	// profile does not exist or success is false, the server closes the
	// stream after the metadata chunk. Otherwise subsequent chunks carry
	// the marshaled ContainerProfile bytes.
	GetContainerProfileStream(ctx context.Context, in *GetContainerProfileStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetContainerProfileStreamChunk], error)
	// PutSBOMStream uploads an SBOM produced for an image. Client-streaming
	// so the caller need not know the payload size in advance and can stream
	// bytes from any io.Reader. Idempotent on (customer_guid, image_digest,
	// syft_version) — duplicate calls upsert the metadata row and overwrite
	// the S3 blob; end-state is consistent.
	//
	// The first chunk MUST set metadata (image_digest, syft_version, source)
	// and MAY include blob_chunk for small payloads. Subsequent chunks set
	// only blob_chunk. Concatenated blob_chunk values form the marshaled
	// SBOMSyft proto payload.
	PutSBOMStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[PutSBOMChunk, PutSBOMResponse], error)
	// GetSBOMStream probes for or fetches an SBOM by (customer_guid,
	// image_digest, syft_version). Server-streaming so the caller need not
	// know the response size in advance.
	//
	// The first chunk in the response carries metadata + status. When the
	// request sets metadata_only=true OR the row does not exist OR success
	// is false, the server closes the stream after the metadata chunk.
	// Otherwise subsequent chunks carry the marshaled SBOMSyft bytes.
	GetSBOMStream(ctx context.Context, in *GetSBOMRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetSBOMChunk], error)
}

type StorageServiceServer interface {
	// Deprecated: Do not use.
	// SendContainerProfile receives a container profile (time-series snapshot) from node agent
	// and sends it to Pulsar for processing by the ingester.
	//
	// Deprecated: use SendContainerProfileStream. The unary form is silently
	// capped by gRPC's default 4 MiB message limit; container profiles with
	// many or large entries (or with MaxContainerProfileSize raised) can
	// exceed this and fail on the wire. The streaming variant has no such
	// bound.
	SendContainerProfile(context.Context, *SendContainerProfileRequest) (*SendContainerProfileResponse, error)
	// GetProfile retrieves an aggregated profile (ApplicationProfile, NetworkNeighborhood,
	// or ContainerProfile) by fetching them from S3.
	//
	// Note: for ContainerProfile specifically, prefer GetContainerProfileStream,
	// which is not subject to the default 4 MiB unary gRPC message limit.
	GetProfile(context.Context, *GetProfileRequest) (*GetProfileResponse, error)
	// ListApplicationProfiles lists all ApplicationProfiles in a namespace (returns metadata only, nil Spec)
	ListApplicationProfiles(context.Context, *ListApplicationProfilesRequest) (*ListApplicationProfilesResponse, error)
	// ListNetworkNeighborhoods lists all NetworkNeighborhoods in a namespace (returns metadata only, nil Spec)
	ListNetworkNeighborhoods(context.Context, *ListNetworkNeighborhoodsRequest) (*ListNetworkNeighborhoodsResponse, error)
	// SendContainerProfileStream is the streaming replacement for
	// SendContainerProfile. Client-streaming so the caller need not know the
	// payload size in advance — required because container profiles with
	// many or large entries can exceed the default 4 MiB unary gRPC limit.
	//
	// The first chunk MUST set metadata (which carries identifying labels
	// and may be empty otherwise) and MAY include blob_chunk for small
	// payloads. Subsequent chunks set only blob_chunk. Concatenated
	// blob_chunk values form the marshaled ContainerProfile proto payload.
	SendContainerProfileStream(grpc.ClientStreamingServer[ContainerProfileChunk, SendContainerProfileResponse]) error
	// GetContainerProfileStream is the streaming replacement for
	// GetProfile(kind=ContainerProfile). Server-streaming so the caller need
	// not know the response size in advance.
	//
	// The first chunk in the response carries metadata + status. When the
	// profile does not exist or success is false, the server closes the
	// stream after the metadata chunk. Otherwise subsequent chunks carry
	// the marshaled ContainerProfile bytes.
	GetContainerProfileStream(*GetContainerProfileStreamRequest, grpc.ServerStreamingServer[GetContainerProfileStreamChunk]) error
	// PutSBOMStream uploads an SBOM produced for an image. Client-streaming
	// so the caller need not know the payload size in advance and can stream
	// bytes from any io.Reader. Idempotent on (customer_guid, image_digest,
	// syft_version) — duplicate calls upsert the metadata row and overwrite
	// the S3 blob; end-state is consistent.
	//
	// The first chunk MUST set metadata (image_digest, syft_version, source)
	// and MAY include blob_chunk for small payloads. Subsequent chunks set
	// only blob_chunk. Concatenated blob_chunk values form the marshaled
	// SBOMSyft proto payload.
	PutSBOMStream(grpc.ClientStreamingServer[PutSBOMChunk, PutSBOMResponse]) error
	// GetSBOMStream probes for or fetches an SBOM by (customer_guid,
	// image_digest, syft_version). Server-streaming so the caller need not
	// know the response size in advance.
	//
	// The first chunk in the response carries metadata + status. When the
	// request sets metadata_only=true OR the row does not exist OR success
	// is false, the server closes the stream after the metadata chunk.
	// Otherwise subsequent chunks carry the marshaled SBOMSyft bytes.
	GetSBOMStream(*GetSBOMRequest, grpc.ServerStreamingServer[GetSBOMChunk]) error
	// contains filtered or unexported methods
}

type StorageService_GetContainerProfileStreamClient = grpc.ServerStreamingClient[GetContainerProfileStreamChunk]

type StorageService_GetContainerProfileStreamServer = grpc.ServerStreamingServer[GetContainerProfileStreamChunk]

type StorageService_GetSBOMStreamClient = grpc.ServerStreamingClient[GetSBOMChunk]

type StorageService_GetSBOMStreamServer = grpc.ServerStreamingServer[GetSBOMChunk]

type StorageService_PutSBOMStreamClient = grpc.ClientStreamingClient[PutSBOMChunk, PutSBOMResponse]

type StorageService_PutSBOMStreamServer = grpc.ClientStreamingServer[PutSBOMChunk, PutSBOMResponse]

type StorageService_SendContainerProfileStreamClient = grpc.ClientStreamingClient[ContainerProfileChunk, SendContainerProfileResponse]

type StorageService_SendContainerProfileStreamServer = grpc.ClientStreamingServer[ContainerProfileChunk, SendContainerProfileResponse]

type UnimplementedStorageServiceServer struct{}

type UnsafeStorageServiceServer interface {
	// contains filtered or unexported methods
}