icas

package
v0.0.0-...-a9d0937 Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2024 License: Apache-2.0 Imports: 9 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 (*BatchUpdateReferencesRequest) ProtoMessage

func (*BatchUpdateReferencesRequest) ProtoMessage()

func (*BatchUpdateReferencesRequest) ProtoReflect

func (*BatchUpdateReferencesRequest) Reset

func (x *BatchUpdateReferencesRequest) Reset()

func (*BatchUpdateReferencesRequest) 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 (*BatchUpdateReferencesRequest_Request) GetReference

func (*BatchUpdateReferencesRequest_Request) ProtoMessage

func (*BatchUpdateReferencesRequest_Request) ProtoMessage()

func (*BatchUpdateReferencesRequest_Request) ProtoReflect

func (*BatchUpdateReferencesRequest_Request) Reset

func (*BatchUpdateReferencesRequest_Request) 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.

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 assignable 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 (m *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 (*Reference_ContentAddressableStorage) GetInstanceName

func (x *Reference_ContentAddressableStorage) GetInstanceName() string

func (*Reference_ContentAddressableStorage) ProtoMessage

func (*Reference_ContentAddressableStorage) ProtoMessage()

func (*Reference_ContentAddressableStorage) ProtoReflect

func (*Reference_ContentAddressableStorage) Reset

func (*Reference_ContentAddressableStorage) 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.

func (UnimplementedIndirectContentAddressableStorageServer) BatchUpdateReferences

func (UnimplementedIndirectContentAddressableStorageServer) FindMissingReferences

func (UnimplementedIndirectContentAddressableStorageServer) GetReference

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL