icas

package
v0.0.0-...-f24d5ce Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2025 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	IndirectContentAddressableStorage_FindMissingReferences_FullMethodName = "/buildbarn.icas.IndirectContentAddressableStorage/FindMissingReferences"
	IndirectContentAddressableStorage_BatchUpdateReferences_FullMethodName = "/buildbarn.icas.IndirectContentAddressableStorage/BatchUpdateReferences"
	IndirectContentAddressableStorage_GetReference_FullMethodName          = "/buildbarn.icas.IndirectContentAddressableStorage/GetReference"
)

Variables

View Source 
var File_pkg_proto_icas_icas_proto protoreflect.FileDescriptor
View Source 
var IndirectContentAddressableStorage_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "buildbarn.icas.IndirectContentAddressableStorage",
	HandlerType: (*IndirectContentAddressableStorageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FindMissingReferences",
			Handler:    _IndirectContentAddressableStorage_FindMissingReferences_Handler,
		},
		{
			MethodName: "BatchUpdateReferences",
			Handler:    _IndirectContentAddressableStorage_BatchUpdateReferences_Handler,
		},
		{
			MethodName: "GetReference",
			Handler:    _IndirectContentAddressableStorage_GetReference_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/proto/icas/icas.proto",
}

IndirectContentAddressableStorage_ServiceDesc is the grpc.ServiceDesc for IndirectContentAddressableStorage service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterIndirectContentAddressableStorageServer 

func RegisterIndirectContentAddressableStorageServer(s grpc.ServiceRegistrar, srv IndirectContentAddressableStorageServer)

Types

type BatchUpdateReferencesRequest 

type BatchUpdateReferencesRequest struct {
	InstanceName   string                                  `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	Requests       []*BatchUpdateReferencesRequest_Request `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	DigestFunction v2.DigestFunction_Value                 `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BatchUpdateReferencesRequest) Descriptor deprecated 

func (*BatchUpdateReferencesRequest) Descriptor() ([]byte, []int)

Deprecated: Use BatchUpdateReferencesRequest.ProtoReflect.Descriptor instead.

func (*BatchUpdateReferencesRequest) GetDigestFunction 

func (x *BatchUpdateReferencesRequest) GetDigestFunction() v2.DigestFunction_Value

func (*BatchUpdateReferencesRequest) GetInstanceName 

func (x *BatchUpdateReferencesRequest) GetInstanceName() string

func (*BatchUpdateReferencesRequest) GetRequests 

func (x *BatchUpdateReferencesRequest) GetRequests() []*BatchUpdateReferencesRequest_Request

func (*BatchUpdateReferencesRequest) ProtoMessage 

func (*BatchUpdateReferencesRequest) ProtoMessage()

func (*BatchUpdateReferencesRequest) ProtoReflect 

func (x *BatchUpdateReferencesRequest) ProtoReflect() protoreflect.Message

func (*BatchUpdateReferencesRequest) Reset 

func (x *BatchUpdateReferencesRequest) Reset()

func (*BatchUpdateReferencesRequest) String 

func (x *BatchUpdateReferencesRequest) String() string

type BatchUpdateReferencesRequest_Request 

type BatchUpdateReferencesRequest_Request struct {
	Digest    *v2.Digest `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	Reference *Reference `protobuf:"bytes,2,opt,name=reference,proto3" json:"reference,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchUpdateReferencesRequest_Request) Descriptor deprecated 

func (*BatchUpdateReferencesRequest_Request) Descriptor() ([]byte, []int)

Deprecated: Use BatchUpdateReferencesRequest_Request.ProtoReflect.Descriptor instead.

func (*BatchUpdateReferencesRequest_Request) GetDigest 

func (x *BatchUpdateReferencesRequest_Request) GetDigest() *v2.Digest

func (*BatchUpdateReferencesRequest_Request) GetReference 

func (x *BatchUpdateReferencesRequest_Request) GetReference() *Reference

func (*BatchUpdateReferencesRequest_Request) ProtoMessage 

func (*BatchUpdateReferencesRequest_Request) ProtoMessage()

func (*BatchUpdateReferencesRequest_Request) ProtoReflect 

func (x *BatchUpdateReferencesRequest_Request) ProtoReflect() protoreflect.Message

func (*BatchUpdateReferencesRequest_Request) Reset 

func (x *BatchUpdateReferencesRequest_Request) Reset()

func (*BatchUpdateReferencesRequest_Request) String 

func (x *BatchUpdateReferencesRequest_Request) String() string

type GetReferenceRequest 

type GetReferenceRequest struct {
	InstanceName   string                  `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	Digest         *v2.Digest              `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	DigestFunction v2.DigestFunction_Value `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetReferenceRequest) Descriptor deprecated 

func (*GetReferenceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetReferenceRequest.ProtoReflect.Descriptor instead.

func (*GetReferenceRequest) GetDigest 

func (x *GetReferenceRequest) GetDigest() *v2.Digest

func (*GetReferenceRequest) GetDigestFunction 

func (x *GetReferenceRequest) GetDigestFunction() v2.DigestFunction_Value

func (*GetReferenceRequest) GetInstanceName 

func (x *GetReferenceRequest) GetInstanceName() string

func (*GetReferenceRequest) ProtoMessage 

func (*GetReferenceRequest) ProtoMessage()

func (*GetReferenceRequest) ProtoReflect 

func (x *GetReferenceRequest) ProtoReflect() protoreflect.Message

func (*GetReferenceRequest) Reset 

func (x *GetReferenceRequest) Reset()

func (*GetReferenceRequest) String 

func (x *GetReferenceRequest) String() string

type IndirectContentAddressableStorageClient 

type IndirectContentAddressableStorageClient interface {
	FindMissingReferences(ctx context.Context, in *v2.FindMissingBlobsRequest, opts ...grpc.CallOption) (*v2.FindMissingBlobsResponse, error)
	BatchUpdateReferences(ctx context.Context, in *BatchUpdateReferencesRequest, opts ...grpc.CallOption) (*v2.BatchUpdateBlobsResponse, error)
	GetReference(ctx context.Context, in *GetReferenceRequest, opts ...grpc.CallOption) (*Reference, error)
}

IndirectContentAddressableStorageClient is the client API for IndirectContentAddressableStorage service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIndirectContentAddressableStorageClient 

func NewIndirectContentAddressableStorageClient(cc grpc.ClientConnInterface) IndirectContentAddressableStorageClient

type IndirectContentAddressableStorageServer 

type IndirectContentAddressableStorageServer interface {
	FindMissingReferences(context.Context, *v2.FindMissingBlobsRequest) (*v2.FindMissingBlobsResponse, error)
	BatchUpdateReferences(context.Context, *BatchUpdateReferencesRequest) (*v2.BatchUpdateBlobsResponse, error)
	GetReference(context.Context, *GetReferenceRequest) (*Reference, error)
}

IndirectContentAddressableStorageServer is the server API for IndirectContentAddressableStorage service. All implementations should embed UnimplementedIndirectContentAddressableStorageServer for forward compatibility.

type Reference 

type Reference struct {

	// Types that are valid to be assigned to Medium:
	//
	//	*Reference_HttpUrl
	//	*Reference_S3_
	//	*Reference_Gcs
	//	*Reference_ContentAddressableStorage_
	Medium       isReference_Medium  `protobuf_oneof:"medium"`
	OffsetBytes  int64               `protobuf:"varint,3,opt,name=offset_bytes,json=offsetBytes,proto3" json:"offset_bytes,omitempty"`
	SizeBytes    int64               `protobuf:"varint,4,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Decompressor v2.Compressor_Value `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Reference) Descriptor deprecated 

func (*Reference) Descriptor() ([]byte, []int)

Deprecated: Use Reference.ProtoReflect.Descriptor instead.

func (*Reference) GetContentAddressableStorage 

func (x *Reference) GetContentAddressableStorage() *Reference_ContentAddressableStorage

func (*Reference) GetDecompressor 

func (x *Reference) GetDecompressor() v2.Compressor_Value

func (*Reference) GetGcs 

func (x *Reference) GetGcs() *Reference_GCS

func (*Reference) GetHttpUrl 

func (x *Reference) GetHttpUrl() string

func (*Reference) GetMedium 

func (x *Reference) GetMedium() isReference_Medium

func (*Reference) GetOffsetBytes 

func (x *Reference) GetOffsetBytes() int64

func (*Reference) GetS3 

func (x *Reference) GetS3() *Reference_S3

func (*Reference) GetSizeBytes 

func (x *Reference) GetSizeBytes() int64

func (*Reference) ProtoMessage 

func (*Reference) ProtoMessage()

func (*Reference) ProtoReflect 

func (x *Reference) ProtoReflect() protoreflect.Message

func (*Reference) Reset 

func (x *Reference) Reset()

func (*Reference) String 

func (x *Reference) String() string

type Reference_ContentAddressableStorage 

type Reference_ContentAddressableStorage struct {
	InstanceName   string                  `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	DigestFunction v2.DigestFunction_Value `` /* 162-byte string literal not displayed */
	BlobDigest     *v2.Digest              `protobuf:"bytes,3,opt,name=blob_digest,json=blobDigest,proto3" json:"blob_digest,omitempty"`
	// contains filtered or unexported fields
}

func (*Reference_ContentAddressableStorage) Descriptor deprecated 

func (*Reference_ContentAddressableStorage) Descriptor() ([]byte, []int)

Deprecated: Use Reference_ContentAddressableStorage.ProtoReflect.Descriptor instead.

func (*Reference_ContentAddressableStorage) GetBlobDigest 

func (x *Reference_ContentAddressableStorage) GetBlobDigest() *v2.Digest

func (*Reference_ContentAddressableStorage) GetDigestFunction 

func (x *Reference_ContentAddressableStorage) GetDigestFunction() v2.DigestFunction_Value

func (*Reference_ContentAddressableStorage) GetInstanceName 

func (x *Reference_ContentAddressableStorage) GetInstanceName() string

func (*Reference_ContentAddressableStorage) ProtoMessage 

func (*Reference_ContentAddressableStorage) ProtoMessage()

func (*Reference_ContentAddressableStorage) ProtoReflect 

func (x *Reference_ContentAddressableStorage) ProtoReflect() protoreflect.Message

func (*Reference_ContentAddressableStorage) Reset 

func (x *Reference_ContentAddressableStorage) Reset()

func (*Reference_ContentAddressableStorage) String 

func (x *Reference_ContentAddressableStorage) String() string

type Reference_ContentAddressableStorage_ 

type Reference_ContentAddressableStorage_ struct {
	ContentAddressableStorage *Reference_ContentAddressableStorage `protobuf:"bytes,8,opt,name=content_addressable_storage,json=contentAddressableStorage,proto3,oneof"`
}

type Reference_GCS 

type Reference_GCS struct {
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Object string `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*Reference_GCS) Descriptor deprecated 

func (*Reference_GCS) Descriptor() ([]byte, []int)

Deprecated: Use Reference_GCS.ProtoReflect.Descriptor instead.

func (*Reference_GCS) GetBucket 

func (x *Reference_GCS) GetBucket() string

func (*Reference_GCS) GetObject 

func (x *Reference_GCS) GetObject() string

func (*Reference_GCS) ProtoMessage 

func (*Reference_GCS) ProtoMessage()

func (*Reference_GCS) ProtoReflect 

func (x *Reference_GCS) ProtoReflect() protoreflect.Message

func (*Reference_GCS) Reset 

func (x *Reference_GCS) Reset()

func (*Reference_GCS) String 

func (x *Reference_GCS) String() string

type Reference_Gcs 

type Reference_Gcs struct {
	Gcs *Reference_GCS `protobuf:"bytes,7,opt,name=gcs,proto3,oneof"`
}

type Reference_HttpUrl 

type Reference_HttpUrl struct {
	HttpUrl string `protobuf:"bytes,1,opt,name=http_url,json=httpUrl,proto3,oneof"`
}

type Reference_S3 

type Reference_S3 struct {
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key    string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*Reference_S3) Descriptor deprecated 

func (*Reference_S3) Descriptor() ([]byte, []int)

Deprecated: Use Reference_S3.ProtoReflect.Descriptor instead.

func (*Reference_S3) GetBucket 

func (x *Reference_S3) GetBucket() string

func (*Reference_S3) GetKey 

func (x *Reference_S3) GetKey() string

func (*Reference_S3) ProtoMessage 

func (*Reference_S3) ProtoMessage()

func (*Reference_S3) ProtoReflect 

func (x *Reference_S3) ProtoReflect() protoreflect.Message

func (*Reference_S3) Reset 

func (x *Reference_S3) Reset()

func (*Reference_S3) String 

func (x *Reference_S3) String() string

type Reference_S3_ 

type Reference_S3_ struct {
	S3 *Reference_S3 `protobuf:"bytes,2,opt,name=s3,proto3,oneof"`
}

type UnimplementedIndirectContentAddressableStorageServer 

type UnimplementedIndirectContentAddressableStorageServer struct{}

UnimplementedIndirectContentAddressableStorageServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedIndirectContentAddressableStorageServer) BatchUpdateReferences 

func (UnimplementedIndirectContentAddressableStorageServer) BatchUpdateReferences(context.Context, *BatchUpdateReferencesRequest) (*v2.BatchUpdateBlobsResponse, error)

func (UnimplementedIndirectContentAddressableStorageServer) FindMissingReferences 

func (UnimplementedIndirectContentAddressableStorageServer) FindMissingReferences(context.Context, *v2.FindMissingBlobsRequest) (*v2.FindMissingBlobsResponse, error)

func (UnimplementedIndirectContentAddressableStorageServer) GetReference 

func (UnimplementedIndirectContentAddressableStorageServer) GetReference(context.Context, *GetReferenceRequest) (*Reference, error)

type UnsafeIndirectContentAddressableStorageServer 

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

UnsafeIndirectContentAddressableStorageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IndirectContentAddressableStorageServer will result in compilation errors.

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.