api

package
Version: v0.0.0-...-da87561 Latest Latest
Warning

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

Go to latest
Published: Dec 8, 2022 License: Apache-2.0 Imports: 16 Imported by: 18

Documentation

Overview

Package api contains CIPD backend API definitions.

Package api is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source
var (
	HashAlgo_name = map[int32]string{
		0: "HASH_ALGO_UNSPECIFIED",
		1: "SHA1",
		2: "SHA256",
	}
	HashAlgo_value = map[string]int32{
		"HASH_ALGO_UNSPECIFIED": 0,
		"SHA1":                  1,
		"SHA256":                2,
	}
)

Enum value maps for HashAlgo.

View Source
var (
	UploadStatus_name = map[int32]string{
		0: "UPLOAD_STATUS_UNSPECIFIED",
		1: "UPLOADING",
		2: "VERIFYING",
		3: "PUBLISHED",
		4: "ERRORED",
		5: "CANCELED",
	}
	UploadStatus_value = map[string]int32{
		"UPLOAD_STATUS_UNSPECIFIED": 0,
		"UPLOADING":                 1,
		"VERIFYING":                 2,
		"PUBLISHED":                 3,
		"ERRORED":                   4,
		"CANCELED":                  5,
	}
)

Enum value maps for UploadStatus.

View Source
var (
	EventKind_name = map[int32]string{
		0:   "EVENT_KIND_UNSPECIFIED",
		100: "PREFIX_ACL_CHANGED",
		200: "PACKAGE_CREATED",
		201: "PACKAGE_DELETED",
		202: "PACKAGE_HIDDEN",
		203: "PACKAGE_UNHIDDEN",
		300: "INSTANCE_CREATED",
		301: "INSTANCE_DELETED",
		302: "INSTANCE_REF_SET",
		303: "INSTANCE_REF_UNSET",
		304: "INSTANCE_TAG_ATTACHED",
		305: "INSTANCE_TAG_DETACHED",
		306: "INSTANCE_METADATA_ATTACHED",
		307: "INSTANCE_METADATA_DETACHED",
	}
	EventKind_value = map[string]int32{
		"EVENT_KIND_UNSPECIFIED":     0,
		"PREFIX_ACL_CHANGED":         100,
		"PACKAGE_CREATED":            200,
		"PACKAGE_DELETED":            201,
		"PACKAGE_HIDDEN":             202,
		"PACKAGE_UNHIDDEN":           203,
		"INSTANCE_CREATED":           300,
		"INSTANCE_DELETED":           301,
		"INSTANCE_REF_SET":           302,
		"INSTANCE_REF_UNSET":         303,
		"INSTANCE_TAG_ATTACHED":      304,
		"INSTANCE_TAG_DETACHED":      305,
		"INSTANCE_METADATA_ATTACHED": 306,
		"INSTANCE_METADATA_DETACHED": 307,
	}
)

Enum value maps for EventKind.

View Source
var (
	Role_name = map[int32]string{
		0: "ROLE_UNSPECIFIED",
		1: "READER",
		2: "WRITER",
		3: "OWNER",
	}
	Role_value = map[string]int32{
		"ROLE_UNSPECIFIED": 0,
		"READER":           1,
		"WRITER":           2,
		"OWNER":            3,
	}
)

Enum value maps for Role.

View Source
var (
	RegistrationStatus_name = map[int32]string{
		0: "REGISTRATION_STATUS_UNSPECIFIED",
		1: "REGISTERED",
		2: "ALREADY_REGISTERED",
		3: "NOT_UPLOADED",
	}
	RegistrationStatus_value = map[string]int32{
		"REGISTRATION_STATUS_UNSPECIFIED": 0,
		"REGISTERED":                      1,
		"ALREADY_REGISTERED":              2,
		"NOT_UPLOADED":                    3,
	}
)

Enum value maps for RegistrationStatus.

View Source
var (
	Processor_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "SUCCEEDED",
		3: "FAILED",
	}
	Processor_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"SUCCEEDED":         2,
		"FAILED":            3,
	}
)

Enum value maps for Processor_State.

View Source
var File_go_chromium_org_luci_cipd_api_cipd_v1_access_log_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cipd_api_cipd_v1_cas_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cipd_api_cipd_v1_events_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cipd_api_cipd_v1_exported_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cipd_api_cipd_v1_repo_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_cipd_api_cipd_v1_verification_log_proto protoreflect.FileDescriptor
View Source
var Repository_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cipd.Repository",
	HandlerType: (*RepositoryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPrefixMetadata",
			Handler:    _Repository_GetPrefixMetadata_Handler,
		},
		{
			MethodName: "GetInheritedPrefixMetadata",
			Handler:    _Repository_GetInheritedPrefixMetadata_Handler,
		},
		{
			MethodName: "UpdatePrefixMetadata",
			Handler:    _Repository_UpdatePrefixMetadata_Handler,
		},
		{
			MethodName: "GetRolesInPrefix",
			Handler:    _Repository_GetRolesInPrefix_Handler,
		},
		{
			MethodName: "ListPrefix",
			Handler:    _Repository_ListPrefix_Handler,
		},
		{
			MethodName: "HidePackage",
			Handler:    _Repository_HidePackage_Handler,
		},
		{
			MethodName: "UnhidePackage",
			Handler:    _Repository_UnhidePackage_Handler,
		},
		{
			MethodName: "DeletePackage",
			Handler:    _Repository_DeletePackage_Handler,
		},
		{
			MethodName: "RegisterInstance",
			Handler:    _Repository_RegisterInstance_Handler,
		},
		{
			MethodName: "ListInstances",
			Handler:    _Repository_ListInstances_Handler,
		},
		{
			MethodName: "SearchInstances",
			Handler:    _Repository_SearchInstances_Handler,
		},
		{
			MethodName: "CreateRef",
			Handler:    _Repository_CreateRef_Handler,
		},
		{
			MethodName: "DeleteRef",
			Handler:    _Repository_DeleteRef_Handler,
		},
		{
			MethodName: "ListRefs",
			Handler:    _Repository_ListRefs_Handler,
		},
		{
			MethodName: "AttachTags",
			Handler:    _Repository_AttachTags_Handler,
		},
		{
			MethodName: "DetachTags",
			Handler:    _Repository_DetachTags_Handler,
		},
		{
			MethodName: "AttachMetadata",
			Handler:    _Repository_AttachMetadata_Handler,
		},
		{
			MethodName: "DetachMetadata",
			Handler:    _Repository_DetachMetadata_Handler,
		},
		{
			MethodName: "ListMetadata",
			Handler:    _Repository_ListMetadata_Handler,
		},
		{
			MethodName: "ResolveVersion",
			Handler:    _Repository_ResolveVersion_Handler,
		},
		{
			MethodName: "GetInstanceURL",
			Handler:    _Repository_GetInstanceURL_Handler,
		},
		{
			MethodName: "DescribeInstance",
			Handler:    _Repository_DescribeInstance_Handler,
		},
		{
			MethodName: "DescribeClient",
			Handler:    _Repository_DescribeClient_Handler,
		},
		{
			MethodName: "DescribeBootstrapBundle",
			Handler:    _Repository_DescribeBootstrapBundle_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go.chromium.org/luci/cipd/api/cipd/v1/repo.proto",
}

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

View Source
var Storage_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cipd.Storage",
	HandlerType: (*StorageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetObjectURL",
			Handler:    _Storage_GetObjectURL_Handler,
		},
		{
			MethodName: "BeginUpload",
			Handler:    _Storage_BeginUpload_Handler,
		},
		{
			MethodName: "FinishUpload",
			Handler:    _Storage_FinishUpload_Handler,
		},
		{
			MethodName: "CancelUpload",
			Handler:    _Storage_CancelUpload_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go.chromium.org/luci/cipd/api/cipd/v1/cas.proto",
}

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

Functions

func FileDescriptorSet

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterRepositoryServer

func RegisterRepositoryServer(s grpc.ServiceRegistrar, srv RepositoryServer)

func RegisterStorageServer

func RegisterStorageServer(s grpc.ServiceRegistrar, srv StorageServer)

Types

type AccessLogEntry

type AccessLogEntry struct {
	Method           string   `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`                                                 // the RPC method, e.g. "/cipd.Repository/ListPrefix"
	Timestamp        int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                                          // microseconds since epoch
	Package          string   `protobuf:"bytes,3,opt,name=package,proto3" json:"package,omitempty"`                                               // CIPD package or package prefix (if known)
	Instance         string   `protobuf:"bytes,4,opt,name=instance,proto3" json:"instance,omitempty"`                                             // CIPD instance ID (if known)
	Version          string   `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`                                               // CIPD package version (if known)
	Tags             []string `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`                                                     // the requested tags (if known)
	Metadata         []string `protobuf:"bytes,7,rep,name=metadata,proto3" json:"metadata,omitempty"`                                             // the requested metadata keys (if known)
	Flags            []string `protobuf:"bytes,8,rep,name=flags,proto3" json:"flags,omitempty"`                                                   // encoding of boolean flags in the request
	CallIdentity     string   `protobuf:"bytes,9,opt,name=call_identity,json=callIdentity,proto3" json:"call_identity,omitempty"`                 // identity used to authorize the call
	PeerIdentity     string   `protobuf:"bytes,10,opt,name=peer_identity,json=peerIdentity,proto3" json:"peer_identity,omitempty"`                // identity of a service that made the RPC
	PeerIp           string   `protobuf:"bytes,11,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"`                                  // IP address of the caller
	UserAgent        string   `protobuf:"bytes,12,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"`                         // value of "User-Agent" header
	ServiceVersion   string   `protobuf:"bytes,13,opt,name=service_version,json=serviceVersion,proto3" json:"service_version,omitempty"`          // GAE app and version that handled the request
	ProcessId        string   `protobuf:"bytes,14,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`                         // identifier of the concrete backend process
	RequestId        string   `protobuf:"bytes,15,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`                         // Cloud Trace ID of the request
	AuthDbRev        int64    `protobuf:"varint,16,opt,name=auth_db_rev,json=authDbRev,proto3" json:"auth_db_rev,omitempty"`                      // AuthDB revision used to authorize the call
	ResponseCode     string   `protobuf:"bytes,17,opt,name=response_code,json=responseCode,proto3" json:"response_code,omitempty"`                // canonical gRPC response code (e.g. "OK")
	ResponseErr      string   `protobuf:"bytes,18,opt,name=response_err,json=responseErr,proto3" json:"response_err,omitempty"`                   // the response error message if any
	ResponseTimeUsec int64    `protobuf:"varint,19,opt,name=response_time_usec,json=responseTimeUsec,proto3" json:"response_time_usec,omitempty"` // time spent handling the request in microseconds
	// contains filtered or unexported fields
}

AccessLogEntry defines a schema for `access` BigQuery table with access logs.

This is a best effort log populated using in-memory buffers. Some entries may be dropped if a process crashes before it flushes the buffer.

Field types must be compatible with BigQuery Storage Write API, see https://cloud.google.com/bigquery/docs/write-api#data_type_conversions

func (*AccessLogEntry) Descriptor deprecated

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

Deprecated: Use AccessLogEntry.ProtoReflect.Descriptor instead.

func (*AccessLogEntry) GetAuthDbRev

func (x *AccessLogEntry) GetAuthDbRev() int64

func (*AccessLogEntry) GetCallIdentity

func (x *AccessLogEntry) GetCallIdentity() string

func (*AccessLogEntry) GetFlags

func (x *AccessLogEntry) GetFlags() []string

func (*AccessLogEntry) GetInstance

func (x *AccessLogEntry) GetInstance() string

func (*AccessLogEntry) GetMetadata

func (x *AccessLogEntry) GetMetadata() []string

func (*AccessLogEntry) GetMethod

func (x *AccessLogEntry) GetMethod() string

func (*AccessLogEntry) GetPackage

func (x *AccessLogEntry) GetPackage() string

func (*AccessLogEntry) GetPeerIdentity

func (x *AccessLogEntry) GetPeerIdentity() string

func (*AccessLogEntry) GetPeerIp

func (x *AccessLogEntry) GetPeerIp() string

func (*AccessLogEntry) GetProcessId

func (x *AccessLogEntry) GetProcessId() string

func (*AccessLogEntry) GetRequestId

func (x *AccessLogEntry) GetRequestId() string

func (*AccessLogEntry) GetResponseCode

func (x *AccessLogEntry) GetResponseCode() string

func (*AccessLogEntry) GetResponseErr

func (x *AccessLogEntry) GetResponseErr() string

func (*AccessLogEntry) GetResponseTimeUsec

func (x *AccessLogEntry) GetResponseTimeUsec() int64

func (*AccessLogEntry) GetServiceVersion

func (x *AccessLogEntry) GetServiceVersion() string

func (*AccessLogEntry) GetTags

func (x *AccessLogEntry) GetTags() []string

func (*AccessLogEntry) GetTimestamp

func (x *AccessLogEntry) GetTimestamp() int64

func (*AccessLogEntry) GetUserAgent

func (x *AccessLogEntry) GetUserAgent() string

func (*AccessLogEntry) GetVersion

func (x *AccessLogEntry) GetVersion() string

func (*AccessLogEntry) ProtoMessage

func (*AccessLogEntry) ProtoMessage()

func (*AccessLogEntry) ProtoReflect

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

func (*AccessLogEntry) Reset

func (x *AccessLogEntry) Reset()

func (*AccessLogEntry) String

func (x *AccessLogEntry) String() string

type AttachMetadataRequest

type AttachMetadataRequest struct {

	// The package that holds the instance we attach metadata to.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The instance we attach metadata to.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// One or more metadata entries to attach.
	Metadata []*InstanceMetadata `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachMetadataRequest) Descriptor deprecated

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

Deprecated: Use AttachMetadataRequest.ProtoReflect.Descriptor instead.

func (*AttachMetadataRequest) GetInstance

func (x *AttachMetadataRequest) GetInstance() *ObjectRef

func (*AttachMetadataRequest) GetMetadata

func (x *AttachMetadataRequest) GetMetadata() []*InstanceMetadata

func (*AttachMetadataRequest) GetPackage

func (x *AttachMetadataRequest) GetPackage() string

func (*AttachMetadataRequest) ProtoMessage

func (*AttachMetadataRequest) ProtoMessage()

func (*AttachMetadataRequest) ProtoReflect

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

func (*AttachMetadataRequest) Reset

func (x *AttachMetadataRequest) Reset()

func (*AttachMetadataRequest) String

func (x *AttachMetadataRequest) String() string

type AttachTagsRequest

type AttachTagsRequest struct {

	// The package that holds the instance we attach tags to.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The instance we attach tags to.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// One or more tags to attach (order doesn't matter).
	Tags []*Tag `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachTagsRequest) Descriptor deprecated

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

Deprecated: Use AttachTagsRequest.ProtoReflect.Descriptor instead.

func (*AttachTagsRequest) GetInstance

func (x *AttachTagsRequest) GetInstance() *ObjectRef

func (*AttachTagsRequest) GetPackage

func (x *AttachTagsRequest) GetPackage() string

func (*AttachTagsRequest) GetTags

func (x *AttachTagsRequest) GetTags() []*Tag

func (*AttachTagsRequest) ProtoMessage

func (*AttachTagsRequest) ProtoMessage()

func (*AttachTagsRequest) ProtoReflect

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

func (*AttachTagsRequest) Reset

func (x *AttachTagsRequest) Reset()

func (*AttachTagsRequest) String

func (x *AttachTagsRequest) String() string

type BeginUploadRequest

type BeginUploadRequest struct {

	// A reference to the object the client wants to put in the storage, if known.
	//
	// If such object already exists, RPC will finish with ALREADY_EXISTS status
	// right away.
	//
	// If this field is missing (in case the client doesn't know the hash yet),
	// the client MUST supply hash_algo field, to let the backend know what
	// hashing algorithm it should use for calculating object's hash.
	//
	// The calculated hash will be returned back to the client as part of
	// UploadOperation ('object' field) by FinishUpload call.
	Object *ObjectRef `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// An algorithm to use to derive object's name during uploads when the final
	// hash of the object is not yet known.
	//
	// Optional if 'object' is present.
	//
	// If both 'object' and 'hash_algo' are present, 'object.hash_algo' MUST match
	// 'hash_algo'.
	HashAlgo HashAlgo `protobuf:"varint,2,opt,name=hash_algo,json=hashAlgo,proto3,enum=cipd.HashAlgo" json:"hash_algo,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginUploadRequest) Descriptor deprecated

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

Deprecated: Use BeginUploadRequest.ProtoReflect.Descriptor instead.

func (*BeginUploadRequest) GetHashAlgo

func (x *BeginUploadRequest) GetHashAlgo() HashAlgo

func (*BeginUploadRequest) GetObject

func (x *BeginUploadRequest) GetObject() *ObjectRef

func (*BeginUploadRequest) ProtoMessage

func (*BeginUploadRequest) ProtoMessage()

func (*BeginUploadRequest) ProtoReflect

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

func (*BeginUploadRequest) Reset

func (x *BeginUploadRequest) Reset()

func (*BeginUploadRequest) String

func (x *BeginUploadRequest) String() string

type CancelUploadRequest

type CancelUploadRequest struct {

	// An identifier of an upload operation returned by BeginUpload RPC.
	UploadOperationId string `protobuf:"bytes,1,opt,name=upload_operation_id,json=uploadOperationId,proto3" json:"upload_operation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelUploadRequest) Descriptor deprecated

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

Deprecated: Use CancelUploadRequest.ProtoReflect.Descriptor instead.

func (*CancelUploadRequest) GetUploadOperationId

func (x *CancelUploadRequest) GetUploadOperationId() string

func (*CancelUploadRequest) ProtoMessage

func (*CancelUploadRequest) ProtoMessage()

func (*CancelUploadRequest) ProtoReflect

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

func (*CancelUploadRequest) Reset

func (x *CancelUploadRequest) Reset()

func (*CancelUploadRequest) String

func (x *CancelUploadRequest) String() string

type DeleteRefRequest

type DeleteRefRequest struct {

	// Name of the ref, e.g. "latest".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of the package where the ref is defined.
	Package string `protobuf:"bytes,2,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRefRequest) Descriptor deprecated

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

Deprecated: Use DeleteRefRequest.ProtoReflect.Descriptor instead.

func (*DeleteRefRequest) GetName

func (x *DeleteRefRequest) GetName() string

func (*DeleteRefRequest) GetPackage

func (x *DeleteRefRequest) GetPackage() string

func (*DeleteRefRequest) ProtoMessage

func (*DeleteRefRequest) ProtoMessage()

func (*DeleteRefRequest) ProtoReflect

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

func (*DeleteRefRequest) Reset

func (x *DeleteRefRequest) Reset()

func (*DeleteRefRequest) String

func (x *DeleteRefRequest) String() string

type DescribeBootstrapBundleRequest

type DescribeBootstrapBundleRequest struct {

	// The package prefix that contains the bootstrap packages being described.
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// If given, specifies exactly what packages to examine.
	//
	// Examined package names will be formed as "<prefix>/<variant>".
	//
	// Based on existing package naming conventions, `variants` usually would be
	// an enumeration of platforms (e.g. ["linux-amd64", "mac-amd64", ...]).
	//
	// If empty, the CIPD backend will describe all packages directly under the
	// prefix (if any). If there are no packages under the prefix, the request
	// fails with NOT_FOUND.
	Variants []string `protobuf:"bytes,2,rep,name=variants,proto3" json:"variants,omitempty"`
	// The package version to describe, see ResolveVersion for details.
	//
	// Applies to all packages matching `prefix` + `variants`.
	//
	// If *all* packages lack this version, the request fails with NOT_FOUND.
	//
	// If only some packages lack this version, their corresponding BootstrapFile
	// entries in DescribeBootstrapBundleRequest will have google.rpc.Status set
	// to NOT_FOUND.
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeBootstrapBundleRequest) Descriptor deprecated

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

Deprecated: Use DescribeBootstrapBundleRequest.ProtoReflect.Descriptor instead.

func (*DescribeBootstrapBundleRequest) GetPrefix

func (x *DescribeBootstrapBundleRequest) GetPrefix() string

func (*DescribeBootstrapBundleRequest) GetVariants

func (x *DescribeBootstrapBundleRequest) GetVariants() []string

func (*DescribeBootstrapBundleRequest) GetVersion

func (x *DescribeBootstrapBundleRequest) GetVersion() string

func (*DescribeBootstrapBundleRequest) ProtoMessage

func (*DescribeBootstrapBundleRequest) ProtoMessage()

func (*DescribeBootstrapBundleRequest) ProtoReflect

func (*DescribeBootstrapBundleRequest) Reset

func (x *DescribeBootstrapBundleRequest) Reset()

func (*DescribeBootstrapBundleRequest) String

type DescribeBootstrapBundleResponse

type DescribeBootstrapBundleResponse struct {
	Files []*DescribeBootstrapBundleResponse_BootstrapFile `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeBootstrapBundleResponse) Descriptor deprecated

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

Deprecated: Use DescribeBootstrapBundleResponse.ProtoReflect.Descriptor instead.

func (*DescribeBootstrapBundleResponse) GetFiles

func (*DescribeBootstrapBundleResponse) ProtoMessage

func (*DescribeBootstrapBundleResponse) ProtoMessage()

func (*DescribeBootstrapBundleResponse) ProtoReflect

func (*DescribeBootstrapBundleResponse) Reset

func (*DescribeBootstrapBundleResponse) String

type DescribeBootstrapBundleResponse_BootstrapFile

type DescribeBootstrapBundleResponse_BootstrapFile struct {
	Package  string         `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`   // the package the file was extracted from
	Status   *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`     // not OK on errors related to this package
	Instance *ObjectRef     `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"` // the resolved package instance
	File     *ObjectRef     `protobuf:"bytes,4,opt,name=file,proto3" json:"file,omitempty"`         // the extracted file in the CAS
	Name     string         `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`         // the name of the extracted file
	Size     int64          `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`        // its size in bytes
	// contains filtered or unexported fields
}

func (*DescribeBootstrapBundleResponse_BootstrapFile) Descriptor deprecated

Deprecated: Use DescribeBootstrapBundleResponse_BootstrapFile.ProtoReflect.Descriptor instead.

func (*DescribeBootstrapBundleResponse_BootstrapFile) GetFile

func (*DescribeBootstrapBundleResponse_BootstrapFile) GetInstance

func (*DescribeBootstrapBundleResponse_BootstrapFile) GetName

func (*DescribeBootstrapBundleResponse_BootstrapFile) GetPackage

func (*DescribeBootstrapBundleResponse_BootstrapFile) GetSize

func (*DescribeBootstrapBundleResponse_BootstrapFile) GetStatus

func (*DescribeBootstrapBundleResponse_BootstrapFile) ProtoMessage

func (*DescribeBootstrapBundleResponse_BootstrapFile) ProtoReflect

func (*DescribeBootstrapBundleResponse_BootstrapFile) Reset

func (*DescribeBootstrapBundleResponse_BootstrapFile) String

type DescribeClientRequest

type DescribeClientRequest struct {

	// The CIPD client package we want to get info about.
	//
	// For example 'infra/tools/cipd/linux-amd64'.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The client instance we want to get the info about.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeClientRequest) Descriptor deprecated

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

Deprecated: Use DescribeClientRequest.ProtoReflect.Descriptor instead.

func (*DescribeClientRequest) GetInstance

func (x *DescribeClientRequest) GetInstance() *ObjectRef

func (*DescribeClientRequest) GetPackage

func (x *DescribeClientRequest) GetPackage() string

func (*DescribeClientRequest) ProtoMessage

func (*DescribeClientRequest) ProtoMessage()

func (*DescribeClientRequest) ProtoReflect

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

func (*DescribeClientRequest) Reset

func (x *DescribeClientRequest) Reset()

func (*DescribeClientRequest) String

func (x *DescribeClientRequest) String() string

type DescribeClientResponse

type DescribeClientResponse struct {

	// The instance with all output fields filled in.
	Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// Reference to the extracted client binary in the storage.
	//
	// The hash algo here always matches the algo used when uploading the client
	// package file.
	//
	// Clients should expect to find an algo here that they do not support (if
	// the server was updated to support a better algo). They should pick the best
	// algo they support from client_ref_aliases list and use it for validation.
	//
	// Thus this field is mostly FYI.
	ClientRef *ObjectRef `protobuf:"bytes,2,opt,name=client_ref,json=clientRef,proto3" json:"client_ref,omitempty"`
	// Signed URL pointing to the extracted client binary in the storage.
	ClientBinary *ObjectURL `protobuf:"bytes,3,opt,name=client_binary,json=clientBinary,proto3" json:"client_binary,omitempty"`
	// Size of the client binary in bytes.
	ClientSize int64 `protobuf:"varint,4,opt,name=client_size,json=clientSize,proto3" json:"client_size,omitempty"`
	// SHA1 digest of the client binary (as hex string).
	//
	// Used only by old clients and present here for backward compatibility
	// reasons.
	//
	// Newer clients must verify one of client_ref_aliases instead.
	LegacySha1 string `protobuf:"bytes,5,opt,name=legacy_sha1,json=legacySha1,proto3" json:"legacy_sha1,omitempty"`
	// Contains hashes of the client binary calculated using ALL algos supported
	// by the server at the time the client package was uploaded.
	//
	// The callers that want to verify the client binary hash should pick the best
	// algo they understand.
	//
	// The list at least includes 'client_ref' itself and SHA1 hash (matching
	// legacy_sha1). The order is undefined.
	ClientRefAliases []*ObjectRef `protobuf:"bytes,6,rep,name=client_ref_aliases,json=clientRefAliases,proto3" json:"client_ref_aliases,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeClientResponse) Descriptor deprecated

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

Deprecated: Use DescribeClientResponse.ProtoReflect.Descriptor instead.

func (*DescribeClientResponse) GetClientBinary

func (x *DescribeClientResponse) GetClientBinary() *ObjectURL

func (*DescribeClientResponse) GetClientRef

func (x *DescribeClientResponse) GetClientRef() *ObjectRef

func (*DescribeClientResponse) GetClientRefAliases

func (x *DescribeClientResponse) GetClientRefAliases() []*ObjectRef

func (*DescribeClientResponse) GetClientSize

func (x *DescribeClientResponse) GetClientSize() int64

func (*DescribeClientResponse) GetInstance

func (x *DescribeClientResponse) GetInstance() *Instance

func (*DescribeClientResponse) GetLegacySha1

func (x *DescribeClientResponse) GetLegacySha1() string

func (*DescribeClientResponse) ProtoMessage

func (*DescribeClientResponse) ProtoMessage()

func (*DescribeClientResponse) ProtoReflect

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

func (*DescribeClientResponse) Reset

func (x *DescribeClientResponse) Reset()

func (*DescribeClientResponse) String

func (x *DescribeClientResponse) String() string

type DescribeInstanceRequest

type DescribeInstanceRequest struct {

	// The package that holds the instance we want to get the info for.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The instance we want to get the info for.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// Whether the response should include "refs" field.
	DescribeRefs bool `protobuf:"varint,3,opt,name=describe_refs,json=describeRefs,proto3" json:"describe_refs,omitempty"`
	// Whether the response should include "tags" field.
	DescribeTags bool `protobuf:"varint,4,opt,name=describe_tags,json=describeTags,proto3" json:"describe_tags,omitempty"`
	// Whether the response should include "processors" field.
	DescribeProcessors bool `protobuf:"varint,5,opt,name=describe_processors,json=describeProcessors,proto3" json:"describe_processors,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeInstanceRequest) Descriptor deprecated

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

Deprecated: Use DescribeInstanceRequest.ProtoReflect.Descriptor instead.

func (*DescribeInstanceRequest) GetDescribeProcessors

func (x *DescribeInstanceRequest) GetDescribeProcessors() bool

func (*DescribeInstanceRequest) GetDescribeRefs

func (x *DescribeInstanceRequest) GetDescribeRefs() bool

func (*DescribeInstanceRequest) GetDescribeTags

func (x *DescribeInstanceRequest) GetDescribeTags() bool

func (*DescribeInstanceRequest) GetInstance

func (x *DescribeInstanceRequest) GetInstance() *ObjectRef

func (*DescribeInstanceRequest) GetPackage

func (x *DescribeInstanceRequest) GetPackage() string

func (*DescribeInstanceRequest) ProtoMessage

func (*DescribeInstanceRequest) ProtoMessage()

func (*DescribeInstanceRequest) ProtoReflect

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

func (*DescribeInstanceRequest) Reset

func (x *DescribeInstanceRequest) Reset()

func (*DescribeInstanceRequest) String

func (x *DescribeInstanceRequest) String() string

type DescribeInstanceResponse

type DescribeInstanceResponse struct {

	// The instance with all output fields filled in.
	Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// Refs pointing to the instance, sorted by modification time, most recent
	// first.
	//
	// Present only if the request has describe_refs == true.
	Refs []*Ref `protobuf:"bytes,2,rep,name=refs,proto3" json:"refs,omitempty"`
	// Tags attached to the instance, sorted by the tag key first, and then
	// by the timestamp (most recent first).
	//
	// Present only if the request has describe_tags == true.
	Tags []*Tag `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// State of the processors that handled the instance (if any), sorted by their
	// ID.
	//
	// Present only if the request has describe_processors == true.
	Processors []*Processor `protobuf:"bytes,4,rep,name=processors,proto3" json:"processors,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeInstanceResponse) Descriptor deprecated

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

Deprecated: Use DescribeInstanceResponse.ProtoReflect.Descriptor instead.

func (*DescribeInstanceResponse) GetInstance

func (x *DescribeInstanceResponse) GetInstance() *Instance

func (*DescribeInstanceResponse) GetProcessors

func (x *DescribeInstanceResponse) GetProcessors() []*Processor

func (*DescribeInstanceResponse) GetRefs

func (x *DescribeInstanceResponse) GetRefs() []*Ref

func (*DescribeInstanceResponse) GetTags

func (x *DescribeInstanceResponse) GetTags() []*Tag

func (*DescribeInstanceResponse) ProtoMessage

func (*DescribeInstanceResponse) ProtoMessage()

func (*DescribeInstanceResponse) ProtoReflect

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

func (*DescribeInstanceResponse) Reset

func (x *DescribeInstanceResponse) Reset()

func (*DescribeInstanceResponse) String

func (x *DescribeInstanceResponse) String() string

type DetachMetadataRequest

type DetachMetadataRequest struct {

	// The package that holds the instance we detach metadata from.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The instance we detach metadata from.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// Entries to detach: only 'fingerprint' or 'key'+'value' are used.
	Metadata []*InstanceMetadata `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*DetachMetadataRequest) Descriptor deprecated

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

Deprecated: Use DetachMetadataRequest.ProtoReflect.Descriptor instead.

func (*DetachMetadataRequest) GetInstance

func (x *DetachMetadataRequest) GetInstance() *ObjectRef

func (*DetachMetadataRequest) GetMetadata

func (x *DetachMetadataRequest) GetMetadata() []*InstanceMetadata

func (*DetachMetadataRequest) GetPackage

func (x *DetachMetadataRequest) GetPackage() string

func (*DetachMetadataRequest) ProtoMessage

func (*DetachMetadataRequest) ProtoMessage()

func (*DetachMetadataRequest) ProtoReflect

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

func (*DetachMetadataRequest) Reset

func (x *DetachMetadataRequest) Reset()

func (*DetachMetadataRequest) String

func (x *DetachMetadataRequest) String() string

type DetachTagsRequest

type DetachTagsRequest struct {

	// The package that holds the instance we detach tags from.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The instance we detach tags from.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// One or more tags to detach (order doesn't matter).
	Tags []*Tag `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*DetachTagsRequest) Descriptor deprecated

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

Deprecated: Use DetachTagsRequest.ProtoReflect.Descriptor instead.

func (*DetachTagsRequest) GetInstance

func (x *DetachTagsRequest) GetInstance() *ObjectRef

func (*DetachTagsRequest) GetPackage

func (x *DetachTagsRequest) GetPackage() string

func (*DetachTagsRequest) GetTags

func (x *DetachTagsRequest) GetTags() []*Tag

func (*DetachTagsRequest) ProtoMessage

func (*DetachTagsRequest) ProtoMessage()

func (*DetachTagsRequest) ProtoReflect

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

func (*DetachTagsRequest) Reset

func (x *DetachTagsRequest) Reset()

func (*DetachTagsRequest) String

func (x *DetachTagsRequest) String() string

type Event

type Event struct {
	Kind EventKind `protobuf:"varint,1,opt,name=kind,proto3,enum=cipd.EventKind" json:"kind,omitempty"`
	Who  string    `protobuf:"bytes,2,opt,name=who,proto3" json:"who,omitempty"` // an identity string, e.g. "user:<email>"
	// Real time is used only for up to millisecond precisions. Nanoseconds are
	// abused to order events emitted by a single transaction.
	When          *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=when,proto3" json:"when,omitempty"`
	Package       string                 `protobuf:"bytes,4,opt,name=package,proto3" json:"package,omitempty"`   // a package name or a prefix (for PREFIX_* events)
	Instance      string                 `protobuf:"bytes,5,opt,name=instance,proto3" json:"instance,omitempty"` // an instance ID for INSTANCE_*
	Ref           string                 `protobuf:"bytes,6,opt,name=ref,proto3" json:"ref,omitempty"`           // a ref name for INSTANCE_REF_*
	Tag           string                 `protobuf:"bytes,7,opt,name=tag,proto3" json:"tag,omitempty"`           // a tag (in 'k:v' form) for INSTANCE_TAG_*
	GrantedRole   []*PrefixMetadata_ACL  `protobuf:"bytes,8,rep,name=granted_role,json=grantedRole,proto3" json:"granted_role,omitempty"`
	RevokedRole   []*PrefixMetadata_ACL  `protobuf:"bytes,9,rep,name=revoked_role,json=revokedRole,proto3" json:"revoked_role,omitempty"`
	MdKey         string                 `protobuf:"bytes,10,opt,name=md_key,json=mdKey,proto3" json:"md_key,omitempty"`                           // a metadata key
	MdValue       string                 `protobuf:"bytes,11,opt,name=md_value,json=mdValue,proto3" json:"md_value,omitempty"`                     // a metadata value, populated only for exported content types
	MdContentType string                 `protobuf:"bytes,12,opt,name=md_content_type,json=mdContentType,proto3" json:"md_content_type,omitempty"` // a metadata content type
	MdFingerprint string                 `protobuf:"bytes,13,opt,name=md_fingerprint,json=mdFingerprint,proto3" json:"md_fingerprint,omitempty"`   // a metadata fingerprint
	// contains filtered or unexported fields
}

Event in a global structured event log.

It exists in both BigQuery (for adhoc queries) and in Datastore (for showing in web UI, e.g. for "recent tags" feature).

Datastore entities contains serialized Event as is, plus a copy of some of its fields for indexing.

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetGrantedRole

func (x *Event) GetGrantedRole() []*PrefixMetadata_ACL

func (*Event) GetInstance

func (x *Event) GetInstance() string

func (*Event) GetKind

func (x *Event) GetKind() EventKind

func (*Event) GetMdContentType

func (x *Event) GetMdContentType() string

func (*Event) GetMdFingerprint

func (x *Event) GetMdFingerprint() string

func (*Event) GetMdKey

func (x *Event) GetMdKey() string

func (*Event) GetMdValue

func (x *Event) GetMdValue() string

func (*Event) GetPackage

func (x *Event) GetPackage() string

func (*Event) GetRef

func (x *Event) GetRef() string

func (*Event) GetRevokedRole

func (x *Event) GetRevokedRole() []*PrefixMetadata_ACL

func (*Event) GetTag

func (x *Event) GetTag() string

func (*Event) GetWhen

func (x *Event) GetWhen() *timestamppb.Timestamp

func (*Event) GetWho

func (x *Event) GetWho() string

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type EventKind

type EventKind int32
const (
	EventKind_EVENT_KIND_UNSPECIFIED EventKind = 0
	// Prefix events: relate to some CIPD prefix.
	EventKind_PREFIX_ACL_CHANGED EventKind = 100
	// Package events: relate to a package (as a whole).
	EventKind_PACKAGE_CREATED  EventKind = 200
	EventKind_PACKAGE_DELETED  EventKind = 201
	EventKind_PACKAGE_HIDDEN   EventKind = 202
	EventKind_PACKAGE_UNHIDDEN EventKind = 203
	// Instance events: relate to a particular package instance.
	EventKind_INSTANCE_CREATED           EventKind = 300
	EventKind_INSTANCE_DELETED           EventKind = 301
	EventKind_INSTANCE_REF_SET           EventKind = 302
	EventKind_INSTANCE_REF_UNSET         EventKind = 303
	EventKind_INSTANCE_TAG_ATTACHED      EventKind = 304
	EventKind_INSTANCE_TAG_DETACHED      EventKind = 305
	EventKind_INSTANCE_METADATA_ATTACHED EventKind = 306
	EventKind_INSTANCE_METADATA_DETACHED EventKind = 307
)

func (EventKind) Descriptor

func (EventKind) Descriptor() protoreflect.EnumDescriptor

func (EventKind) Enum

func (x EventKind) Enum() *EventKind

func (EventKind) EnumDescriptor deprecated

func (EventKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventKind.Descriptor instead.

func (EventKind) Number

func (x EventKind) Number() protoreflect.EnumNumber

func (EventKind) String

func (x EventKind) String() string

func (EventKind) Type

type ExportedTag

type ExportedTag struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                   // (pkg, inst, id) is full tag key
	Instance   string                 `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`                       // an instance ID, e.g. "AdPcH..."
	Package    string                 `protobuf:"bytes,3,opt,name=package,proto3" json:"package,omitempty"`                         // a package name, e.g. "a/b/c"
	Key        string                 `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`                                 // key portion of the tag
	Value      string                 `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`                             // value portion of the tag
	AttachedBy string                 `protobuf:"bytes,6,opt,name=attached_by,json=attachedBy,proto3" json:"attached_by,omitempty"` // who added it, "user:<email>"
	AttachedTs *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=attached_ts,json=attachedTs,proto3" json:"attached_ts,omitempty"` // when it was added
	// contains filtered or unexported fields
}

ExportedTag defines a schema for 'exported_tags_<jobid>' BigQuery tables.

It is populated by EXPORT_TAGS_TO_BQ mapper job and can be used for various adhoc analysis of tags.

func (*ExportedTag) Descriptor deprecated

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

Deprecated: Use ExportedTag.ProtoReflect.Descriptor instead.

func (*ExportedTag) GetAttachedBy

func (x *ExportedTag) GetAttachedBy() string

func (*ExportedTag) GetAttachedTs

func (x *ExportedTag) GetAttachedTs() *timestamppb.Timestamp

func (*ExportedTag) GetId

func (x *ExportedTag) GetId() string

func (*ExportedTag) GetInstance

func (x *ExportedTag) GetInstance() string

func (*ExportedTag) GetKey

func (x *ExportedTag) GetKey() string

func (*ExportedTag) GetPackage

func (x *ExportedTag) GetPackage() string

func (*ExportedTag) GetValue

func (x *ExportedTag) GetValue() string

func (*ExportedTag) ProtoMessage

func (*ExportedTag) ProtoMessage()

func (*ExportedTag) ProtoReflect

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

func (*ExportedTag) Reset

func (x *ExportedTag) Reset()

func (*ExportedTag) String

func (x *ExportedTag) String() string

type FinishUploadRequest

type FinishUploadRequest struct {

	// An identifier of an upload operation returned by BeginUpload RPC.
	UploadOperationId string `protobuf:"bytes,1,opt,name=upload_operation_id,json=uploadOperationId,proto3" json:"upload_operation_id,omitempty"`
	// If set, instructs Storage to skip the hash verification and just assume the
	// uploaded object has the given hash.
	//
	// This is used internally by the service as an optimization for cases when
	// it trusts the uploaded data (for example, when it upload it itself).
	//
	// External callers are denied usage of this field. Attempt to use it results
	// in PERMISSION_DENIED.
	ForceHash *ObjectRef `protobuf:"bytes,2,opt,name=force_hash,json=forceHash,proto3" json:"force_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishUploadRequest) Descriptor deprecated

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

Deprecated: Use FinishUploadRequest.ProtoReflect.Descriptor instead.

func (*FinishUploadRequest) GetForceHash

func (x *FinishUploadRequest) GetForceHash() *ObjectRef

func (*FinishUploadRequest) GetUploadOperationId

func (x *FinishUploadRequest) GetUploadOperationId() string

func (*FinishUploadRequest) ProtoMessage

func (*FinishUploadRequest) ProtoMessage()

func (*FinishUploadRequest) ProtoReflect

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

func (*FinishUploadRequest) Reset

func (x *FinishUploadRequest) Reset()

func (*FinishUploadRequest) String

func (x *FinishUploadRequest) String() string

type GetInstanceURLRequest

type GetInstanceURLRequest struct {

	// The package that holds the instance we want to get URL of.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The instance we want to get URL of.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInstanceURLRequest) Descriptor deprecated

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

Deprecated: Use GetInstanceURLRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceURLRequest) GetInstance

func (x *GetInstanceURLRequest) GetInstance() *ObjectRef

func (*GetInstanceURLRequest) GetPackage

func (x *GetInstanceURLRequest) GetPackage() string

func (*GetInstanceURLRequest) ProtoMessage

func (*GetInstanceURLRequest) ProtoMessage()

func (*GetInstanceURLRequest) ProtoReflect

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

func (*GetInstanceURLRequest) Reset

func (x *GetInstanceURLRequest) Reset()

func (*GetInstanceURLRequest) String

func (x *GetInstanceURLRequest) String() string

type GetObjectURLRequest

type GetObjectURLRequest struct {

	// A reference to the object the client wants to fetch.
	Object *ObjectRef `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// If present, the returned URL will be served with Content-Disposition header
	// that includes the given filename. It makes browsers save the file under the
	// given name.
	DownloadFilename string `protobuf:"bytes,2,opt,name=download_filename,json=downloadFilename,proto3" json:"download_filename,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectURLRequest) Descriptor deprecated

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

Deprecated: Use GetObjectURLRequest.ProtoReflect.Descriptor instead.

func (*GetObjectURLRequest) GetDownloadFilename

func (x *GetObjectURLRequest) GetDownloadFilename() string

func (*GetObjectURLRequest) GetObject

func (x *GetObjectURLRequest) GetObject() *ObjectRef

func (*GetObjectURLRequest) ProtoMessage

func (*GetObjectURLRequest) ProtoMessage()

func (*GetObjectURLRequest) ProtoReflect

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

func (*GetObjectURLRequest) Reset

func (x *GetObjectURLRequest) Reset()

func (*GetObjectURLRequest) String

func (x *GetObjectURLRequest) String() string

type HashAlgo

type HashAlgo int32

Supported hashing algorithms used by the content-addressable storage.

Literal names are important, since they are used to construct Google Storage paths internally.

const (
	HashAlgo_HASH_ALGO_UNSPECIFIED HashAlgo = 0
	HashAlgo_SHA1                  HashAlgo = 1
	HashAlgo_SHA256                HashAlgo = 2
)

func (HashAlgo) Descriptor

func (HashAlgo) Descriptor() protoreflect.EnumDescriptor

func (HashAlgo) Enum

func (x HashAlgo) Enum() *HashAlgo

func (HashAlgo) EnumDescriptor deprecated

func (HashAlgo) EnumDescriptor() ([]byte, []int)

Deprecated: Use HashAlgo.Descriptor instead.

func (HashAlgo) Number

func (x HashAlgo) Number() protoreflect.EnumNumber

func (HashAlgo) String

func (x HashAlgo) String() string

func (HashAlgo) Type

type InheritedPrefixMetadata

type InheritedPrefixMetadata struct {

	// Per-prefix metadata that applies to a prefix, ordered by prefix length.
	//
	// For example, when requesting metadata for prefix "a/b/c/d" the reply may
	// contain entries for "a", "a/b", "a/b/c/d" (in that order, with "a/b/c"
	// skipped in this example as not having any metadata attached).
	PerPrefixMetadata []*PrefixMetadata `protobuf:"bytes,1,rep,name=per_prefix_metadata,json=perPrefixMetadata,proto3" json:"per_prefix_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*InheritedPrefixMetadata) Descriptor deprecated

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

Deprecated: Use InheritedPrefixMetadata.ProtoReflect.Descriptor instead.

func (*InheritedPrefixMetadata) GetPerPrefixMetadata

func (x *InheritedPrefixMetadata) GetPerPrefixMetadata() []*PrefixMetadata

func (*InheritedPrefixMetadata) ProtoMessage

func (*InheritedPrefixMetadata) ProtoMessage()

func (*InheritedPrefixMetadata) ProtoReflect

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

func (*InheritedPrefixMetadata) Reset

func (x *InheritedPrefixMetadata) Reset()

func (*InheritedPrefixMetadata) String

func (x *InheritedPrefixMetadata) String() string

type Instance

type Instance struct {

	// A name of the package, e.g. "a/b/c/d".
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// A reference to the instance file in the storage.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// User who registered the instance (output only).
	RegisteredBy string `protobuf:"bytes,3,opt,name=registered_by,json=registeredBy,proto3" json:"registered_by,omitempty"`
	// When the instance was registered (output only).
	RegisteredTs *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=registered_ts,json=registeredTs,proto3" json:"registered_ts,omitempty"`
	// contains filtered or unexported fields
}

Instance is a pointer to an instance of some package.

func (*Instance) Descriptor deprecated

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetInstance

func (x *Instance) GetInstance() *ObjectRef

func (*Instance) GetPackage

func (x *Instance) GetPackage() string

func (*Instance) GetRegisteredBy

func (x *Instance) GetRegisteredBy() string

func (*Instance) GetRegisteredTs

func (x *Instance) GetRegisteredTs() *timestamppb.Timestamp

func (*Instance) ProtoMessage

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect

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

func (*Instance) Reset

func (x *Instance) Reset()

func (*Instance) String

func (x *Instance) String() string

type InstanceMetadata

type InstanceMetadata struct {

	// Key is a lowercase string matching [a-z0-9_\-]{1,400}.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value is an arbitrary byte blob smaller than 512 Kb.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Optional MIME content type of the metadata value, primarily for UI.
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// Fingerprint identifies this metadata entry.
	//
	// It is the first 16 bytes of SHA256("<key>:<value>") in lowercase hex
	// encoding (i.e. it is 32 lowercase hex characters).
	//
	// Populated by the server in all responses. Ignored in AttachMetadataRequest,
	// optionally used in DetachMetadataRequest.
	Fingerprint string `protobuf:"bytes,4,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// User that attached this metadata (output only).
	AttachedBy string `protobuf:"bytes,5,opt,name=attached_by,json=attachedBy,proto3" json:"attached_by,omitempty"`
	// When the metadata was attached (output only).
	AttachedTs *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=attached_ts,json=attachedTs,proto3" json:"attached_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceMetadata) Descriptor deprecated

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

Deprecated: Use InstanceMetadata.ProtoReflect.Descriptor instead.

func (*InstanceMetadata) GetAttachedBy

func (x *InstanceMetadata) GetAttachedBy() string

func (*InstanceMetadata) GetAttachedTs

func (x *InstanceMetadata) GetAttachedTs() *timestamppb.Timestamp

func (*InstanceMetadata) GetContentType

func (x *InstanceMetadata) GetContentType() string

func (*InstanceMetadata) GetFingerprint

func (x *InstanceMetadata) GetFingerprint() string

func (*InstanceMetadata) GetKey

func (x *InstanceMetadata) GetKey() string

func (*InstanceMetadata) GetValue

func (x *InstanceMetadata) GetValue() []byte

func (*InstanceMetadata) ProtoMessage

func (*InstanceMetadata) ProtoMessage()

func (*InstanceMetadata) ProtoReflect

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

func (*InstanceMetadata) Reset

func (x *InstanceMetadata) Reset()

func (*InstanceMetadata) String

func (x *InstanceMetadata) String() string

type ListInstancesRequest

type ListInstancesRequest struct {

	// Name of a package to list instances of.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// Number of instances to return on one page, default is 100.
	PageSize int32 `protobuf:"varint,20,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Value of 'next_page_token' from the previous response.
	//
	// Can be used to resume fetching.
	PageToken string `protobuf:"bytes,21,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInstancesRequest) Descriptor deprecated

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

Deprecated: Use ListInstancesRequest.ProtoReflect.Descriptor instead.

func (*ListInstancesRequest) GetPackage

func (x *ListInstancesRequest) GetPackage() string

func (*ListInstancesRequest) GetPageSize

func (x *ListInstancesRequest) GetPageSize() int32

func (*ListInstancesRequest) GetPageToken

func (x *ListInstancesRequest) GetPageToken() string

func (*ListInstancesRequest) ProtoMessage

func (*ListInstancesRequest) ProtoMessage()

func (*ListInstancesRequest) ProtoReflect

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

func (*ListInstancesRequest) Reset

func (x *ListInstancesRequest) Reset()

func (*ListInstancesRequest) String

func (x *ListInstancesRequest) String() string

type ListInstancesResponse

type ListInstancesResponse struct {

	// Package instances, sorted by registration time, most recent first.
	Instances []*Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// Value to pass as 'page_token' in ListInstancesRequest to resume fetching or
	// empty string if there's no more results.
	NextPageToken string `protobuf:"bytes,20,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInstancesResponse) Descriptor deprecated

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

Deprecated: Use ListInstancesResponse.ProtoReflect.Descriptor instead.

func (*ListInstancesResponse) GetInstances

func (x *ListInstancesResponse) GetInstances() []*Instance

func (*ListInstancesResponse) GetNextPageToken

func (x *ListInstancesResponse) GetNextPageToken() string

func (*ListInstancesResponse) ProtoMessage

func (*ListInstancesResponse) ProtoMessage()

func (*ListInstancesResponse) ProtoReflect

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

func (*ListInstancesResponse) Reset

func (x *ListInstancesResponse) Reset()

func (*ListInstancesResponse) String

func (x *ListInstancesResponse) String() string

type ListMetadataRequest

type ListMetadataRequest struct {

	// The package that holds the instance we list metadata of.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The instance to list metadata of.
	Instance *ObjectRef `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// Metadata keys to limit the listing to or empty to list all metadata.
	Keys []string `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"`
	// Number of results to return on one page. Ignored for now.
	PageSize int32 `protobuf:"varint,20,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Value of 'next_page_token' from the previous response.
	PageToken string `protobuf:"bytes,21,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMetadataRequest) Descriptor deprecated

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

Deprecated: Use ListMetadataRequest.ProtoReflect.Descriptor instead.

func (*ListMetadataRequest) GetInstance

func (x *ListMetadataRequest) GetInstance() *ObjectRef

func (*ListMetadataRequest) GetKeys

func (x *ListMetadataRequest) GetKeys() []string

func (*ListMetadataRequest) GetPackage

func (x *ListMetadataRequest) GetPackage() string

func (*ListMetadataRequest) GetPageSize

func (x *ListMetadataRequest) GetPageSize() int32

func (*ListMetadataRequest) GetPageToken

func (x *ListMetadataRequest) GetPageToken() string

func (*ListMetadataRequest) ProtoMessage

func (*ListMetadataRequest) ProtoMessage()

func (*ListMetadataRequest) ProtoReflect

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

func (*ListMetadataRequest) Reset

func (x *ListMetadataRequest) Reset()

func (*ListMetadataRequest) String

func (x *ListMetadataRequest) String() string

type ListMetadataResponse

type ListMetadataResponse struct {

	// Discovered metadata ordered by 'attached_ts' (the most recent first).
	Metadata []*InstanceMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// Value to pass as 'page_token' in ListMetadataRequest to resume fetching or
	// an empty string if there's no more results.
	NextPageToken string `protobuf:"bytes,20,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMetadataResponse) Descriptor deprecated

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

Deprecated: Use ListMetadataResponse.ProtoReflect.Descriptor instead.

func (*ListMetadataResponse) GetMetadata

func (x *ListMetadataResponse) GetMetadata() []*InstanceMetadata

func (*ListMetadataResponse) GetNextPageToken

func (x *ListMetadataResponse) GetNextPageToken() string

func (*ListMetadataResponse) ProtoMessage

func (*ListMetadataResponse) ProtoMessage()

func (*ListMetadataResponse) ProtoReflect

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

func (*ListMetadataResponse) Reset

func (x *ListMetadataResponse) Reset()

func (*ListMetadataResponse) String

func (x *ListMetadataResponse) String() string

type ListPrefixRequest

type ListPrefixRequest struct {

	// A prefix within the repository to list, e.g. "a/b/c". Empty prefix is also
	// accepted: it means "root of the repository".
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// If false, list only direct descendants of the prefix, otherwise all.
	Recursive bool `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// If true, include hidden packages in the result.
	IncludeHidden bool `protobuf:"varint,3,opt,name=include_hidden,json=includeHidden,proto3" json:"include_hidden,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPrefixRequest) Descriptor deprecated

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

Deprecated: Use ListPrefixRequest.ProtoReflect.Descriptor instead.

func (*ListPrefixRequest) GetIncludeHidden

func (x *ListPrefixRequest) GetIncludeHidden() bool

func (*ListPrefixRequest) GetPrefix

func (x *ListPrefixRequest) GetPrefix() string

func (*ListPrefixRequest) GetRecursive

func (x *ListPrefixRequest) GetRecursive() bool

func (*ListPrefixRequest) ProtoMessage

func (*ListPrefixRequest) ProtoMessage()

func (*ListPrefixRequest) ProtoReflect

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

func (*ListPrefixRequest) Reset

func (x *ListPrefixRequest) Reset()

func (*ListPrefixRequest) String

func (x *ListPrefixRequest) String() string

type ListPrefixResponse

type ListPrefixResponse struct {

	// Lexicographically sorted list of full packages names.
	Packages []string `protobuf:"bytes,1,rep,name=packages,proto3" json:"packages,omitempty"`
	// Lexicographically sorted list of child prefixes (without trailing '/').
	Prefixes []string `protobuf:"bytes,2,rep,name=prefixes,proto3" json:"prefixes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPrefixResponse) Descriptor deprecated

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

Deprecated: Use ListPrefixResponse.ProtoReflect.Descriptor instead.

func (*ListPrefixResponse) GetPackages

func (x *ListPrefixResponse) GetPackages() []string

func (*ListPrefixResponse) GetPrefixes

func (x *ListPrefixResponse) GetPrefixes() []string

func (*ListPrefixResponse) ProtoMessage

func (*ListPrefixResponse) ProtoMessage()

func (*ListPrefixResponse) ProtoReflect

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

func (*ListPrefixResponse) Reset

func (x *ListPrefixResponse) Reset()

func (*ListPrefixResponse) String

func (x *ListPrefixResponse) String() string

type ListRefsRequest

type ListRefsRequest struct {

	// Name of a package to list refs of.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRefsRequest) Descriptor deprecated

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

Deprecated: Use ListRefsRequest.ProtoReflect.Descriptor instead.

func (*ListRefsRequest) GetPackage

func (x *ListRefsRequest) GetPackage() string

func (*ListRefsRequest) ProtoMessage

func (*ListRefsRequest) ProtoMessage()

func (*ListRefsRequest) ProtoReflect

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

func (*ListRefsRequest) Reset

func (x *ListRefsRequest) Reset()

func (*ListRefsRequest) String

func (x *ListRefsRequest) String() string

type ListRefsResponse

type ListRefsResponse struct {

	// Package refs, sorted by modification time, most recently touched first.
	Refs []*Ref `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRefsResponse) Descriptor deprecated

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

Deprecated: Use ListRefsResponse.ProtoReflect.Descriptor instead.

func (*ListRefsResponse) GetRefs

func (x *ListRefsResponse) GetRefs() []*Ref

func (*ListRefsResponse) ProtoMessage

func (*ListRefsResponse) ProtoMessage()

func (*ListRefsResponse) ProtoReflect

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

func (*ListRefsResponse) Reset

func (x *ListRefsResponse) Reset()

func (*ListRefsResponse) String

func (x *ListRefsResponse) String() string

type MockRepositoryClient

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

MockRepositoryClient is a mock of RepositoryClient interface.

func NewMockRepositoryClient

func NewMockRepositoryClient(ctrl *gomock.Controller) *MockRepositoryClient

NewMockRepositoryClient creates a new mock instance.

func (*MockRepositoryClient) AttachMetadata

func (m *MockRepositoryClient) AttachMetadata(ctx context.Context, in *AttachMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

AttachMetadata mocks base method.

func (*MockRepositoryClient) AttachTags

AttachTags mocks base method.

func (*MockRepositoryClient) CreateRef

func (m *MockRepositoryClient) CreateRef(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*emptypb.Empty, error)

CreateRef mocks base method.

func (*MockRepositoryClient) DeletePackage

func (m *MockRepositoryClient) DeletePackage(ctx context.Context, in *PackageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeletePackage mocks base method.

func (*MockRepositoryClient) DeleteRef

DeleteRef mocks base method.

func (*MockRepositoryClient) DescribeBootstrapBundle

DescribeBootstrapBundle mocks base method.

func (*MockRepositoryClient) DescribeClient

DescribeClient mocks base method.

func (*MockRepositoryClient) DescribeInstance

DescribeInstance mocks base method.

func (*MockRepositoryClient) DetachMetadata

func (m *MockRepositoryClient) DetachMetadata(ctx context.Context, in *DetachMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DetachMetadata mocks base method.

func (*MockRepositoryClient) DetachTags

DetachTags mocks base method.

func (*MockRepositoryClient) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRepositoryClient) GetInheritedPrefixMetadata

func (m *MockRepositoryClient) GetInheritedPrefixMetadata(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*InheritedPrefixMetadata, error)

GetInheritedPrefixMetadata mocks base method.

func (*MockRepositoryClient) GetInstanceURL

func (m *MockRepositoryClient) GetInstanceURL(ctx context.Context, in *GetInstanceURLRequest, opts ...grpc.CallOption) (*ObjectURL, error)

GetInstanceURL mocks base method.

func (*MockRepositoryClient) GetPrefixMetadata

func (m *MockRepositoryClient) GetPrefixMetadata(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*PrefixMetadata, error)

GetPrefixMetadata mocks base method.

func (*MockRepositoryClient) GetRolesInPrefix

func (m *MockRepositoryClient) GetRolesInPrefix(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*RolesInPrefixResponse, error)

GetRolesInPrefix mocks base method.

func (*MockRepositoryClient) HidePackage

func (m *MockRepositoryClient) HidePackage(ctx context.Context, in *PackageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

HidePackage mocks base method.

func (*MockRepositoryClient) ListInstances

ListInstances mocks base method.

func (*MockRepositoryClient) ListMetadata

ListMetadata mocks base method.

func (*MockRepositoryClient) ListPrefix

ListPrefix mocks base method.

func (*MockRepositoryClient) ListRefs

ListRefs mocks base method.

func (*MockRepositoryClient) RegisterInstance

func (m *MockRepositoryClient) RegisterInstance(ctx context.Context, in *Instance, opts ...grpc.CallOption) (*RegisterInstanceResponse, error)

RegisterInstance mocks base method.

func (*MockRepositoryClient) ResolveVersion

func (m *MockRepositoryClient) ResolveVersion(ctx context.Context, in *ResolveVersionRequest, opts ...grpc.CallOption) (*Instance, error)

ResolveVersion mocks base method.

func (*MockRepositoryClient) SearchInstances

SearchInstances mocks base method.

func (*MockRepositoryClient) UnhidePackage

func (m *MockRepositoryClient) UnhidePackage(ctx context.Context, in *PackageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

UnhidePackage mocks base method.

func (*MockRepositoryClient) UpdatePrefixMetadata

func (m *MockRepositoryClient) UpdatePrefixMetadata(ctx context.Context, in *PrefixMetadata, opts ...grpc.CallOption) (*PrefixMetadata, error)

UpdatePrefixMetadata mocks base method.

type MockRepositoryClientMockRecorder

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

MockRepositoryClientMockRecorder is the mock recorder for MockRepositoryClient.

func (*MockRepositoryClientMockRecorder) AttachMetadata

func (mr *MockRepositoryClientMockRecorder) AttachMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call

AttachMetadata indicates an expected call of AttachMetadata.

func (*MockRepositoryClientMockRecorder) AttachTags

func (mr *MockRepositoryClientMockRecorder) AttachTags(ctx, in interface{}, opts ...interface{}) *gomock.Call

AttachTags indicates an expected call of AttachTags.

func (*MockRepositoryClientMockRecorder) CreateRef

func (mr *MockRepositoryClientMockRecorder) CreateRef(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateRef indicates an expected call of CreateRef.

func (*MockRepositoryClientMockRecorder) DeletePackage

func (mr *MockRepositoryClientMockRecorder) DeletePackage(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeletePackage indicates an expected call of DeletePackage.

func (*MockRepositoryClientMockRecorder) DeleteRef

func (mr *MockRepositoryClientMockRecorder) DeleteRef(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteRef indicates an expected call of DeleteRef.

func (*MockRepositoryClientMockRecorder) DescribeBootstrapBundle

func (mr *MockRepositoryClientMockRecorder) DescribeBootstrapBundle(ctx, in interface{}, opts ...interface{}) *gomock.Call

DescribeBootstrapBundle indicates an expected call of DescribeBootstrapBundle.

func (*MockRepositoryClientMockRecorder) DescribeClient

func (mr *MockRepositoryClientMockRecorder) DescribeClient(ctx, in interface{}, opts ...interface{}) *gomock.Call

DescribeClient indicates an expected call of DescribeClient.

func (*MockRepositoryClientMockRecorder) DescribeInstance

func (mr *MockRepositoryClientMockRecorder) DescribeInstance(ctx, in interface{}, opts ...interface{}) *gomock.Call

DescribeInstance indicates an expected call of DescribeInstance.

func (*MockRepositoryClientMockRecorder) DetachMetadata

func (mr *MockRepositoryClientMockRecorder) DetachMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call

DetachMetadata indicates an expected call of DetachMetadata.

func (*MockRepositoryClientMockRecorder) DetachTags

func (mr *MockRepositoryClientMockRecorder) DetachTags(ctx, in interface{}, opts ...interface{}) *gomock.Call

DetachTags indicates an expected call of DetachTags.

func (*MockRepositoryClientMockRecorder) GetInheritedPrefixMetadata

func (mr *MockRepositoryClientMockRecorder) GetInheritedPrefixMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetInheritedPrefixMetadata indicates an expected call of GetInheritedPrefixMetadata.

func (*MockRepositoryClientMockRecorder) GetInstanceURL

func (mr *MockRepositoryClientMockRecorder) GetInstanceURL(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetInstanceURL indicates an expected call of GetInstanceURL.

func (*MockRepositoryClientMockRecorder) GetPrefixMetadata

func (mr *MockRepositoryClientMockRecorder) GetPrefixMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetPrefixMetadata indicates an expected call of GetPrefixMetadata.

func (*MockRepositoryClientMockRecorder) GetRolesInPrefix

func (mr *MockRepositoryClientMockRecorder) GetRolesInPrefix(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetRolesInPrefix indicates an expected call of GetRolesInPrefix.

func (*MockRepositoryClientMockRecorder) HidePackage

func (mr *MockRepositoryClientMockRecorder) HidePackage(ctx, in interface{}, opts ...interface{}) *gomock.Call

HidePackage indicates an expected call of HidePackage.

func (*MockRepositoryClientMockRecorder) ListInstances

func (mr *MockRepositoryClientMockRecorder) ListInstances(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListInstances indicates an expected call of ListInstances.

func (*MockRepositoryClientMockRecorder) ListMetadata

func (mr *MockRepositoryClientMockRecorder) ListMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListMetadata indicates an expected call of ListMetadata.

func (*MockRepositoryClientMockRecorder) ListPrefix

func (mr *MockRepositoryClientMockRecorder) ListPrefix(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListPrefix indicates an expected call of ListPrefix.

func (*MockRepositoryClientMockRecorder) ListRefs

func (mr *MockRepositoryClientMockRecorder) ListRefs(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListRefs indicates an expected call of ListRefs.

func (*MockRepositoryClientMockRecorder) RegisterInstance

func (mr *MockRepositoryClientMockRecorder) RegisterInstance(ctx, in interface{}, opts ...interface{}) *gomock.Call

RegisterInstance indicates an expected call of RegisterInstance.

func (*MockRepositoryClientMockRecorder) ResolveVersion

func (mr *MockRepositoryClientMockRecorder) ResolveVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResolveVersion indicates an expected call of ResolveVersion.

func (*MockRepositoryClientMockRecorder) SearchInstances

func (mr *MockRepositoryClientMockRecorder) SearchInstances(ctx, in interface{}, opts ...interface{}) *gomock.Call

SearchInstances indicates an expected call of SearchInstances.

func (*MockRepositoryClientMockRecorder) UnhidePackage

func (mr *MockRepositoryClientMockRecorder) UnhidePackage(ctx, in interface{}, opts ...interface{}) *gomock.Call

UnhidePackage indicates an expected call of UnhidePackage.

func (*MockRepositoryClientMockRecorder) UpdatePrefixMetadata

func (mr *MockRepositoryClientMockRecorder) UpdatePrefixMetadata(ctx, in interface{}, opts ...interface{}) *gomock.Call

UpdatePrefixMetadata indicates an expected call of UpdatePrefixMetadata.

type MockRepositoryServer

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

MockRepositoryServer is a mock of RepositoryServer interface.

func NewMockRepositoryServer

func NewMockRepositoryServer(ctrl *gomock.Controller) *MockRepositoryServer

NewMockRepositoryServer creates a new mock instance.

func (*MockRepositoryServer) AttachMetadata

func (m *MockRepositoryServer) AttachMetadata(arg0 context.Context, arg1 *AttachMetadataRequest) (*emptypb.Empty, error)

AttachMetadata mocks base method.

func (*MockRepositoryServer) AttachTags

func (m *MockRepositoryServer) AttachTags(arg0 context.Context, arg1 *AttachTagsRequest) (*emptypb.Empty, error)

AttachTags mocks base method.

func (*MockRepositoryServer) CreateRef

func (m *MockRepositoryServer) CreateRef(arg0 context.Context, arg1 *Ref) (*emptypb.Empty, error)

CreateRef mocks base method.

func (*MockRepositoryServer) DeletePackage

func (m *MockRepositoryServer) DeletePackage(arg0 context.Context, arg1 *PackageRequest) (*emptypb.Empty, error)

DeletePackage mocks base method.

func (*MockRepositoryServer) DeleteRef

func (m *MockRepositoryServer) DeleteRef(arg0 context.Context, arg1 *DeleteRefRequest) (*emptypb.Empty, error)

DeleteRef mocks base method.

func (*MockRepositoryServer) DescribeBootstrapBundle

DescribeBootstrapBundle mocks base method.

func (*MockRepositoryServer) DescribeClient

DescribeClient mocks base method.

func (*MockRepositoryServer) DescribeInstance

DescribeInstance mocks base method.

func (*MockRepositoryServer) DetachMetadata

func (m *MockRepositoryServer) DetachMetadata(arg0 context.Context, arg1 *DetachMetadataRequest) (*emptypb.Empty, error)

DetachMetadata mocks base method.

func (*MockRepositoryServer) DetachTags

func (m *MockRepositoryServer) DetachTags(arg0 context.Context, arg1 *DetachTagsRequest) (*emptypb.Empty, error)

DetachTags mocks base method.

func (*MockRepositoryServer) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRepositoryServer) GetInheritedPrefixMetadata

func (m *MockRepositoryServer) GetInheritedPrefixMetadata(arg0 context.Context, arg1 *PrefixRequest) (*InheritedPrefixMetadata, error)

GetInheritedPrefixMetadata mocks base method.

func (*MockRepositoryServer) GetInstanceURL

func (m *MockRepositoryServer) GetInstanceURL(arg0 context.Context, arg1 *GetInstanceURLRequest) (*ObjectURL, error)

GetInstanceURL mocks base method.

func (*MockRepositoryServer) GetPrefixMetadata

func (m *MockRepositoryServer) GetPrefixMetadata(arg0 context.Context, arg1 *PrefixRequest) (*PrefixMetadata, error)

GetPrefixMetadata mocks base method.

func (*MockRepositoryServer) GetRolesInPrefix

func (m *MockRepositoryServer) GetRolesInPrefix(arg0 context.Context, arg1 *PrefixRequest) (*RolesInPrefixResponse, error)

GetRolesInPrefix mocks base method.

func (*MockRepositoryServer) HidePackage

func (m *MockRepositoryServer) HidePackage(arg0 context.Context, arg1 *PackageRequest) (*emptypb.Empty, error)

HidePackage mocks base method.

func (*MockRepositoryServer) ListInstances

ListInstances mocks base method.

func (*MockRepositoryServer) ListMetadata

ListMetadata mocks base method.

func (*MockRepositoryServer) ListPrefix

ListPrefix mocks base method.

func (*MockRepositoryServer) ListRefs

ListRefs mocks base method.

func (*MockRepositoryServer) RegisterInstance

func (m *MockRepositoryServer) RegisterInstance(arg0 context.Context, arg1 *Instance) (*RegisterInstanceResponse, error)

RegisterInstance mocks base method.

func (*MockRepositoryServer) ResolveVersion

func (m *MockRepositoryServer) ResolveVersion(arg0 context.Context, arg1 *ResolveVersionRequest) (*Instance, error)

ResolveVersion mocks base method.

func (*MockRepositoryServer) SearchInstances

SearchInstances mocks base method.

func (*MockRepositoryServer) UnhidePackage

func (m *MockRepositoryServer) UnhidePackage(arg0 context.Context, arg1 *PackageRequest) (*emptypb.Empty, error)

UnhidePackage mocks base method.

func (*MockRepositoryServer) UpdatePrefixMetadata

func (m *MockRepositoryServer) UpdatePrefixMetadata(arg0 context.Context, arg1 *PrefixMetadata) (*PrefixMetadata, error)

UpdatePrefixMetadata mocks base method.

type MockRepositoryServerMockRecorder

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

MockRepositoryServerMockRecorder is the mock recorder for MockRepositoryServer.

func (*MockRepositoryServerMockRecorder) AttachMetadata

func (mr *MockRepositoryServerMockRecorder) AttachMetadata(arg0, arg1 interface{}) *gomock.Call

AttachMetadata indicates an expected call of AttachMetadata.

func (*MockRepositoryServerMockRecorder) AttachTags

func (mr *MockRepositoryServerMockRecorder) AttachTags(arg0, arg1 interface{}) *gomock.Call

AttachTags indicates an expected call of AttachTags.

func (*MockRepositoryServerMockRecorder) CreateRef

func (mr *MockRepositoryServerMockRecorder) CreateRef(arg0, arg1 interface{}) *gomock.Call

CreateRef indicates an expected call of CreateRef.

func (*MockRepositoryServerMockRecorder) DeletePackage

func (mr *MockRepositoryServerMockRecorder) DeletePackage(arg0, arg1 interface{}) *gomock.Call

DeletePackage indicates an expected call of DeletePackage.

func (*MockRepositoryServerMockRecorder) DeleteRef

func (mr *MockRepositoryServerMockRecorder) DeleteRef(arg0, arg1 interface{}) *gomock.Call

DeleteRef indicates an expected call of DeleteRef.

func (*MockRepositoryServerMockRecorder) DescribeBootstrapBundle

func (mr *MockRepositoryServerMockRecorder) DescribeBootstrapBundle(arg0, arg1 interface{}) *gomock.Call

DescribeBootstrapBundle indicates an expected call of DescribeBootstrapBundle.

func (*MockRepositoryServerMockRecorder) DescribeClient

func (mr *MockRepositoryServerMockRecorder) DescribeClient(arg0, arg1 interface{}) *gomock.Call

DescribeClient indicates an expected call of DescribeClient.

func (*MockRepositoryServerMockRecorder) DescribeInstance

func (mr *MockRepositoryServerMockRecorder) DescribeInstance(arg0, arg1 interface{}) *gomock.Call

DescribeInstance indicates an expected call of DescribeInstance.

func (*MockRepositoryServerMockRecorder) DetachMetadata

func (mr *MockRepositoryServerMockRecorder) DetachMetadata(arg0, arg1 interface{}) *gomock.Call

DetachMetadata indicates an expected call of DetachMetadata.

func (*MockRepositoryServerMockRecorder) DetachTags

func (mr *MockRepositoryServerMockRecorder) DetachTags(arg0, arg1 interface{}) *gomock.Call

DetachTags indicates an expected call of DetachTags.

func (*MockRepositoryServerMockRecorder) GetInheritedPrefixMetadata

func (mr *MockRepositoryServerMockRecorder) GetInheritedPrefixMetadata(arg0, arg1 interface{}) *gomock.Call

GetInheritedPrefixMetadata indicates an expected call of GetInheritedPrefixMetadata.

func (*MockRepositoryServerMockRecorder) GetInstanceURL

func (mr *MockRepositoryServerMockRecorder) GetInstanceURL(arg0, arg1 interface{}) *gomock.Call

GetInstanceURL indicates an expected call of GetInstanceURL.

func (*MockRepositoryServerMockRecorder) GetPrefixMetadata

func (mr *MockRepositoryServerMockRecorder) GetPrefixMetadata(arg0, arg1 interface{}) *gomock.Call

GetPrefixMetadata indicates an expected call of GetPrefixMetadata.

func (*MockRepositoryServerMockRecorder) GetRolesInPrefix

func (mr *MockRepositoryServerMockRecorder) GetRolesInPrefix(arg0, arg1 interface{}) *gomock.Call

GetRolesInPrefix indicates an expected call of GetRolesInPrefix.

func (*MockRepositoryServerMockRecorder) HidePackage

func (mr *MockRepositoryServerMockRecorder) HidePackage(arg0, arg1 interface{}) *gomock.Call

HidePackage indicates an expected call of HidePackage.

func (*MockRepositoryServerMockRecorder) ListInstances

func (mr *MockRepositoryServerMockRecorder) ListInstances(arg0, arg1 interface{}) *gomock.Call

ListInstances indicates an expected call of ListInstances.

func (*MockRepositoryServerMockRecorder) ListMetadata

func (mr *MockRepositoryServerMockRecorder) ListMetadata(arg0, arg1 interface{}) *gomock.Call

ListMetadata indicates an expected call of ListMetadata.

func (*MockRepositoryServerMockRecorder) ListPrefix

func (mr *MockRepositoryServerMockRecorder) ListPrefix(arg0, arg1 interface{}) *gomock.Call

ListPrefix indicates an expected call of ListPrefix.

func (*MockRepositoryServerMockRecorder) ListRefs

func (mr *MockRepositoryServerMockRecorder) ListRefs(arg0, arg1 interface{}) *gomock.Call

ListRefs indicates an expected call of ListRefs.

func (*MockRepositoryServerMockRecorder) RegisterInstance

func (mr *MockRepositoryServerMockRecorder) RegisterInstance(arg0, arg1 interface{}) *gomock.Call

RegisterInstance indicates an expected call of RegisterInstance.

func (*MockRepositoryServerMockRecorder) ResolveVersion

func (mr *MockRepositoryServerMockRecorder) ResolveVersion(arg0, arg1 interface{}) *gomock.Call

ResolveVersion indicates an expected call of ResolveVersion.

func (*MockRepositoryServerMockRecorder) SearchInstances

func (mr *MockRepositoryServerMockRecorder) SearchInstances(arg0, arg1 interface{}) *gomock.Call

SearchInstances indicates an expected call of SearchInstances.

func (*MockRepositoryServerMockRecorder) UnhidePackage

func (mr *MockRepositoryServerMockRecorder) UnhidePackage(arg0, arg1 interface{}) *gomock.Call

UnhidePackage indicates an expected call of UnhidePackage.

func (*MockRepositoryServerMockRecorder) UpdatePrefixMetadata

func (mr *MockRepositoryServerMockRecorder) UpdatePrefixMetadata(arg0, arg1 interface{}) *gomock.Call

UpdatePrefixMetadata indicates an expected call of UpdatePrefixMetadata.

type MockUnsafeRepositoryServer

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

MockUnsafeRepositoryServer is a mock of UnsafeRepositoryServer interface.

func NewMockUnsafeRepositoryServer

func NewMockUnsafeRepositoryServer(ctrl *gomock.Controller) *MockUnsafeRepositoryServer

NewMockUnsafeRepositoryServer creates a new mock instance.

func (*MockUnsafeRepositoryServer) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeRepositoryServerMockRecorder

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

MockUnsafeRepositoryServerMockRecorder is the mock recorder for MockUnsafeRepositoryServer.

type ObjectRef

type ObjectRef struct {
	HashAlgo  HashAlgo `protobuf:"varint,1,opt,name=hash_algo,json=hashAlgo,proto3,enum=cipd.HashAlgo" json:"hash_algo,omitempty"` // an algorithm applied to the body to get the name
	HexDigest string   `protobuf:"bytes,2,opt,name=hex_digest,json=hexDigest,proto3" json:"hex_digest,omitempty"`                  // the name as lowercase hex string, e.g 'abcdef...'
	// contains filtered or unexported fields
}

A reference to an object in the content-addressable storage.

func (*ObjectRef) Descriptor deprecated

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

Deprecated: Use ObjectRef.ProtoReflect.Descriptor instead.

func (*ObjectRef) GetHashAlgo

func (x *ObjectRef) GetHashAlgo() HashAlgo

func (*ObjectRef) GetHexDigest

func (x *ObjectRef) GetHexDigest() string

func (*ObjectRef) ProtoMessage

func (*ObjectRef) ProtoMessage()

func (*ObjectRef) ProtoReflect

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

func (*ObjectRef) Reset

func (x *ObjectRef) Reset()

func (*ObjectRef) String

func (x *ObjectRef) String() string

type ObjectURL

type ObjectURL struct {

	// A signed HTTPS URL to the object's body.
	//
	// Fetching it doesn't require authentication. Expires after some unspecified
	// short amount of time. It is expected that callers will use it immediately.
	//
	// The URL isn't guaranteed to have any particular internal structure. Do not
	// attempt to parse it.
	SignedUrl string `protobuf:"bytes,1,opt,name=signed_url,json=signedUrl,proto3" json:"signed_url,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectURL) Descriptor deprecated

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

Deprecated: Use ObjectURL.ProtoReflect.Descriptor instead.

func (*ObjectURL) GetSignedUrl

func (x *ObjectURL) GetSignedUrl() string

func (*ObjectURL) ProtoMessage

func (*ObjectURL) ProtoMessage()

func (*ObjectURL) ProtoReflect

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

func (*ObjectURL) Reset

func (x *ObjectURL) Reset()

func (*ObjectURL) String

func (x *ObjectURL) String() string

type PackageRequest

type PackageRequest struct {
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// contains filtered or unexported fields
}

PackageRequest names a package and nothing else.

func (*PackageRequest) Descriptor deprecated

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

Deprecated: Use PackageRequest.ProtoReflect.Descriptor instead.

func (*PackageRequest) GetPackage

func (x *PackageRequest) GetPackage() string

func (*PackageRequest) ProtoMessage

func (*PackageRequest) ProtoMessage()

func (*PackageRequest) ProtoReflect

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

func (*PackageRequest) Reset

func (x *PackageRequest) Reset()

func (*PackageRequest) String

func (x *PackageRequest) String() string

type PrefixMetadata

type PrefixMetadata struct {

	// Prefix this metadata is defined at, e.g. "a/b/c".
	//
	// Note: there's no metadata at the root, so prefix must never be "".
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// An opaque string that identifies a particular version of this metadata.
	//
	// Used by UpdatePrefixMetadata to prevent an accidental overwrite of changes.
	Fingerprint string `protobuf:"bytes,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// When the metadata was modified the last time.
	//
	// Managed by the server, ignored when passed to UpdatePrefixMetadata.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Identity string of whoever modified the metadata the last time.
	//
	// Managed by the server, ignored when passed to UpdatePrefixMetadata.
	UpdateUser string `protobuf:"bytes,4,opt,name=update_user,json=updateUser,proto3" json:"update_user,omitempty"`
	// ACLs that apply to this prefix and all subprefixes, as a mapping from
	// a role to a list of users and groups that have it.
	Acls []*PrefixMetadata_ACL `protobuf:"bytes,5,rep,name=acls,proto3" json:"acls,omitempty"`
	// contains filtered or unexported fields
}

PrefixMetadata is metadata defined at some concrete package prefix.

It applies to this prefix and all subprefixes, recursively.

func (*PrefixMetadata) Descriptor deprecated

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

Deprecated: Use PrefixMetadata.ProtoReflect.Descriptor instead.

func (*PrefixMetadata) GetAcls

func (x *PrefixMetadata) GetAcls() []*PrefixMetadata_ACL

func (*PrefixMetadata) GetFingerprint

func (x *PrefixMetadata) GetFingerprint() string

func (*PrefixMetadata) GetPrefix

func (x *PrefixMetadata) GetPrefix() string

func (*PrefixMetadata) GetUpdateTime

func (x *PrefixMetadata) GetUpdateTime() *timestamppb.Timestamp

func (*PrefixMetadata) GetUpdateUser

func (x *PrefixMetadata) GetUpdateUser() string

func (*PrefixMetadata) ProtoMessage

func (*PrefixMetadata) ProtoMessage()

func (*PrefixMetadata) ProtoReflect

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

func (*PrefixMetadata) Reset

func (x *PrefixMetadata) Reset()

func (*PrefixMetadata) String

func (x *PrefixMetadata) String() string

type PrefixMetadata_ACL

type PrefixMetadata_ACL struct {

	// Role that this ACL describes.
	Role Role `protobuf:"varint,1,opt,name=role,proto3,enum=cipd.Role" json:"role,omitempty"`
	// Users and groups that have the specified role.
	//
	// Each entry has a form "<kind>:<value>", e.g "group:..." or "user:...".
	Principals []string `protobuf:"bytes,2,rep,name=principals,proto3" json:"principals,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefixMetadata_ACL) Descriptor deprecated

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

Deprecated: Use PrefixMetadata_ACL.ProtoReflect.Descriptor instead.

func (*PrefixMetadata_ACL) GetPrincipals

func (x *PrefixMetadata_ACL) GetPrincipals() []string

func (*PrefixMetadata_ACL) GetRole

func (x *PrefixMetadata_ACL) GetRole() Role

func (*PrefixMetadata_ACL) ProtoMessage

func (*PrefixMetadata_ACL) ProtoMessage()

func (*PrefixMetadata_ACL) ProtoReflect

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

func (*PrefixMetadata_ACL) Reset

func (x *PrefixMetadata_ACL) Reset()

func (*PrefixMetadata_ACL) String

func (x *PrefixMetadata_ACL) String() string

type PrefixRequest

type PrefixRequest struct {

	// A prefix within the repository, e.g. "a/b/c".
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefixRequest) Descriptor deprecated

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

Deprecated: Use PrefixRequest.ProtoReflect.Descriptor instead.

func (*PrefixRequest) GetPrefix

func (x *PrefixRequest) GetPrefix() string

func (*PrefixRequest) ProtoMessage

func (*PrefixRequest) ProtoMessage()

func (*PrefixRequest) ProtoReflect

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

func (*PrefixRequest) Reset

func (x *PrefixRequest) Reset()

func (*PrefixRequest) String

func (x *PrefixRequest) String() string

type Processor

type Processor struct {

	// Internal identifier of the processor, e.g. "cipd_client_binary:v1"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The state of this processor, see the enum.
	State Processor_State `protobuf:"varint,2,opt,name=state,proto3,enum=cipd.Processor_State" json:"state,omitempty"`
	// When the processor finished running (successfully or not).
	FinishedTs *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=finished_ts,json=finishedTs,proto3" json:"finished_ts,omitempty"`
	// For SUCCEEDED state, result of the processing.
	Result *structpb.Struct `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	// For FAILED state, the error message.
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Processor describes a state of some post-registration processing step performed on an instance.

func (*Processor) Descriptor deprecated

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

Deprecated: Use Processor.ProtoReflect.Descriptor instead.

func (*Processor) GetError

func (x *Processor) GetError() string

func (*Processor) GetFinishedTs

func (x *Processor) GetFinishedTs() *timestamppb.Timestamp

func (*Processor) GetId

func (x *Processor) GetId() string

func (*Processor) GetResult

func (x *Processor) GetResult() *structpb.Struct

func (*Processor) GetState

func (x *Processor) GetState() Processor_State

func (*Processor) ProtoMessage

func (*Processor) ProtoMessage()

func (*Processor) ProtoReflect

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

func (*Processor) Reset

func (x *Processor) Reset()

func (*Processor) String

func (x *Processor) String() string

type Processor_State

type Processor_State int32
const (
	Processor_STATE_UNSPECIFIED Processor_State = 0
	Processor_PENDING           Processor_State = 1
	Processor_SUCCEEDED         Processor_State = 2
	Processor_FAILED            Processor_State = 3
)

func (Processor_State) Descriptor

func (Processor_State) Enum

func (x Processor_State) Enum() *Processor_State

func (Processor_State) EnumDescriptor deprecated

func (Processor_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Processor_State.Descriptor instead.

func (Processor_State) Number

func (Processor_State) String

func (x Processor_State) String() string

func (Processor_State) Type

type Ref

type Ref struct {

	// Name of the ref, e.g. "latest".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of the package where the ref is defined.
	Package string `protobuf:"bytes,2,opt,name=package,proto3" json:"package,omitempty"`
	// A package instance the ref is pointing to.
	Instance *ObjectRef `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	// User who modified this ref the last time (output only).
	ModifiedBy string `protobuf:"bytes,4,opt,name=modified_by,json=modifiedBy,proto3" json:"modified_by,omitempty"`
	// When the ref was modified the last time (output only).
	ModifiedTs *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=modified_ts,json=modifiedTs,proto3" json:"modified_ts,omitempty"`
	// contains filtered or unexported fields
}

Ref is a mutable named pointer to some package instance that can be used as a version identifier.

func (*Ref) Descriptor deprecated

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

Deprecated: Use Ref.ProtoReflect.Descriptor instead.

func (*Ref) GetInstance

func (x *Ref) GetInstance() *ObjectRef

func (*Ref) GetModifiedBy

func (x *Ref) GetModifiedBy() string

func (*Ref) GetModifiedTs

func (x *Ref) GetModifiedTs() *timestamppb.Timestamp

func (*Ref) GetName

func (x *Ref) GetName() string

func (*Ref) GetPackage

func (x *Ref) GetPackage() string

func (*Ref) ProtoMessage

func (*Ref) ProtoMessage()

func (*Ref) ProtoReflect

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

func (*Ref) Reset

func (x *Ref) Reset()

func (*Ref) String

func (x *Ref) String() string

type RegisterInstanceResponse

type RegisterInstanceResponse struct {

	// Outcome of the operation, see the enum for possibilities.
	//
	// Defines what other fields are present.
	Status RegistrationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=cipd.RegistrationStatus" json:"status,omitempty"`
	// For statuses REGISTERED and ALREADY_REGISTERED contains details about the
	// instance. Not set for NOT_UPLOADED status.
	Instance *Instance `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// For status NOT_UPLOADED contains a new upload operation that can be used
	// together with Storage service to upload the instance file. Not set for
	// other statuses.
	UploadOp *UploadOperation `protobuf:"bytes,3,opt,name=upload_op,json=uploadOp,proto3" json:"upload_op,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterInstanceResponse) Descriptor deprecated

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

Deprecated: Use RegisterInstanceResponse.ProtoReflect.Descriptor instead.

func (*RegisterInstanceResponse) GetInstance

func (x *RegisterInstanceResponse) GetInstance() *Instance

func (*RegisterInstanceResponse) GetStatus

func (*RegisterInstanceResponse) GetUploadOp

func (x *RegisterInstanceResponse) GetUploadOp() *UploadOperation

func (*RegisterInstanceResponse) ProtoMessage

func (*RegisterInstanceResponse) ProtoMessage()

func (*RegisterInstanceResponse) ProtoReflect

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

func (*RegisterInstanceResponse) Reset

func (x *RegisterInstanceResponse) Reset()

func (*RegisterInstanceResponse) String

func (x *RegisterInstanceResponse) String() string

type RegistrationStatus

type RegistrationStatus int32

RegistrationStatus is part of RegisterInstance RPC response.

const (
	RegistrationStatus_REGISTRATION_STATUS_UNSPECIFIED RegistrationStatus = 0
	RegistrationStatus_REGISTERED                      RegistrationStatus = 1 // the instance was successfully registered just now
	RegistrationStatus_ALREADY_REGISTERED              RegistrationStatus = 2 // the instance already exists, this is OK
	RegistrationStatus_NOT_UPLOADED                    RegistrationStatus = 3 // the instance should be uploaded to Storage first
)

func (RegistrationStatus) Descriptor

func (RegistrationStatus) Enum

func (RegistrationStatus) EnumDescriptor deprecated

func (RegistrationStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use RegistrationStatus.Descriptor instead.

func (RegistrationStatus) Number

func (RegistrationStatus) String

func (x RegistrationStatus) String() string

func (RegistrationStatus) Type

type RepositoryClient

type RepositoryClient interface {
	// Returns metadata associated with the given prefix.
	//
	// Requires the caller to have OWNER role for the requested prefix or any of
	// parent prefixes, or be in a special global "cipd-prefixes-viewers" group,
	// otherwise the call fails with PERMISSION_DENIED error.
	//
	// If the caller has OWNER permission in any of parent prefixes, but the
	// requested prefix has no metadata associated with it, the call fails with
	// NOT_FOUND error.
	GetPrefixMetadata(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*PrefixMetadata, error)
	// Returns metadata associated with the given prefix and all parent prefixes.
	//
	// Requires the caller to have OWNER role for the requested prefix or any of
	// parent prefixes, or be in a special global "cipd-prefixes-viewers" group,
	// otherwise the call fails with PERMISSION_DENIED error.
	//
	// Note that if the caller has permission to see the metadata for the
	// requested prefix, they will also see metadata for all parent prefixes,
	// since it is needed to assemble the final metadata for the prefix (it
	// includes inherited properties from all parent prefixes).
	GetInheritedPrefixMetadata(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*InheritedPrefixMetadata, error)
	// Updates or creates metadata associated with the given prefix.
	//
	// Requires the caller to have OWNER role for the requested prefix or any of
	// parent prefixes, otherwise the call fails with PERMISSION_DENIED error.
	//
	// This method checks 'fingerprint' field of the PrefixMetadata object. If the
	// metadata for the given prefix already exists, and the fingerprint in the
	// request doesn't match the current fingerprint, the request fails with
	// FAILED_PRECONDITION error.
	//
	// If the metadata doesn't exist yet, its fingerprint is assumed to be empty
	// string. So pass empty fingerprint when creating initial metadata objects.
	//
	// If the caller passes empty fingerprint, but the metadata already exists,
	// the request fails with ALREADY_EXISTS error.
	//
	// Note that there's no way to delete metadata once it was created. Passing
	// empty PrefixMetadata object is the best that can be done.
	//
	// On success returns PrefixMetadata object with the updated fingerprint.
	UpdatePrefixMetadata(ctx context.Context, in *PrefixMetadata, opts ...grpc.CallOption) (*PrefixMetadata, error)
	// Returns a set of roles the caller has in the given prefix.
	//
	// Unlike GetPrefixMetadata call that requires special permissions (since it
	// returns a lot of detailed information), GetRolesInPrefix can be called by
	// anyone.
	//
	// It understands and expands roles inheritance, e.g. if the caller is an
	// OWNER, the result will also contain WRITER and READER (as they are implied
	// by being an OWNER).
	//
	// Returns empty set of roles if the caller has no permissions to access the
	// prefix at all or such prefix doesn't exist.
	GetRolesInPrefix(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*RolesInPrefixResponse, error)
	// Lists packages and subprefixes registered under the prefix.
	//
	// Lists either only direct descendants or recursively all descendants. The
	// result is sorted lexicographically.
	//
	// For example, for packages ["a", "a/b", "a/c/d", "a/c/e/f"], listing of "a"
	// will be:
	//   * {packages: ["a/b"], prefixes: ["a/c"]} if listing non-recursively.
	//   * {packages: ["a/b", "a/c/d", "a/c/e/f"], prefixes: ["a/c", "a/c/e"]} if
	//     listing recursively.
	//
	// Returns only packages and prefixes visible to the caller. This applies even
	// when listing a prefix the caller has no direct read access to. For example,
	// recursively listing the root prefix will return all packages the caller has
	// read access to (no matter when in the hierarchy they are located), even if
	// the caller has no READER permission in the root. It works as if the caller
	// can freely browse the repository that contains only the packages they can
	// see and nothing else.
	ListPrefix(ctx context.Context, in *ListPrefixRequest, opts ...grpc.CallOption) (*ListPrefixResponse, error)
	// HidePackage marks the package as hidden.
	//
	// This removes it from the ListPrefix results, but doesn't otherwise affect
	// its usage (e.g. it is still fetchable).
	//
	// Requires OWNER role for the package prefix. Returns PERMISSION_DENIED
	// otherwise.
	HidePackage(ctx context.Context, in *PackageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// UnhidePackage marks the package as visible again.
	//
	// It's reverse of HidePackage.
	//
	// Requires OWNER role for the package prefix. Returns PERMISSION_DENIED
	// otherwise.
	UnhidePackage(ctx context.Context, in *PackageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeletePackage removes the package (along with all its instances, tags, refs
	// etc) from the repository.
	//
	// There's no undo. Once the package is deleted, it is gone forever.
	//
	// This operation has a potential to break various pinned historical CIPD
	// ensure files and thus should not be used casually, only in extreme cases.
	// Consider just hiding the package instead of deleting it.
	//
	// For the reasons above, the operation requires admin access: only owners of
	// the repository root can delete packages.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a root owner.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package doesn't exist.
	DeletePackage(ctx context.Context, in *PackageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Registers a package instance in the repository (if it was uploaded to the
	// storage already and wasn't registered yet) or initiates a new upload
	// operation.
	//
	// Callers are expected to execute the following protocol:
	//   1. Attempt to register a package instance by calling RegisterInstance.
	//   2. On NOT_UPLOADED status, upload the package data and finalize the
	//      upload operation using Storage RPC service and upload_op from the
	//      response.
	//   3. Once the upload operation is finalized, call RegisterInstance again,
	//      it should succeed with status REGISTERED now.
	//
	// If such instance is already registered by someone else, returns
	// ALREADY_REGISTERED status. This is not an error.
	//
	// Callers must have roles WRITER or OWNER for the package prefix. Returns
	// PERMISSION_DENIED otherwise.
	RegisterInstance(ctx context.Context, in *Instance, opts ...grpc.CallOption) (*RegisterInstanceResponse, error)
	// Lists instances of a package, most recent first.
	//
	// Callers must have roles READER (or above) for the package prefix. Returns
	// PERMISSION_DENIED otherwise.
	//
	// If the package doesn't exist, returns NOT_FOUND.
	ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
	// Returns package instances that have all given tags attached.
	//
	// Queries only instances of some particular package (i.e. this is not a
	// global query).
	//
	// Callers must have roles READER (or above) for the package prefix. Returns
	// PERMISSION_DENIED otherwise.
	//
	// If the package doesn't exist, returns NOT_FOUND.
	SearchInstances(ctx context.Context, in *SearchInstancesRequest, opts ...grpc.CallOption) (*SearchInstancesResponse, error)
	// Creates a new ref or moves an existing one.
	//
	// A ref is a mutable named pointer to some existing package instance that
	// can be used as a version identifier. For example, "latest" or "stable".
	//
	// Refs are namespaced to some particular package. E.g. "latest" ref in
	// packages "A" and "B" are completely different entities not related to each
	// other.
	//
	// Pointing a ref to an instance generally makes the instance "discoverable".
	// For that reason the ref can be set only to instances that successfully
	// passed all post-registration processing.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance the ref points to doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	CreateRef(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Removes a ref.
	//
	// Not a failure if there's no such ref.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package doesn't exist.
	DeleteRef(ctx context.Context, in *DeleteRefRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Lists refs defined in a package, most recently modified first.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package doesn't exist.
	ListRefs(ctx context.Context, in *ListRefsRequest, opts ...grpc.CallOption) (*ListRefsResponse, error)
	// Attaches one or more tags to an instance.
	//
	// Silently skips already attached tags.
	//
	// Tags are "key:value" pairs associated with a concrete package instance.
	// They can be used for querying registered instances and for version
	// resolution: if a tag is attached to one and only one instance of a package,
	// the tag uniquely identifies this instance and such tag can be used as an
	// alias of the instance ID.
	//
	// Tags generally should be assumed globally namespaced (e.g. it makes sense
	// to query for all registered instances with a given tag, across all
	// packages), and they don't have to be unique: same tag may be attached to
	// multiple instances (of the same or different packages).
	//
	// Additionally, tags (unlike refs) are intended to be mostly static, since
	// they usually relate to some properties of package instances, which are
	// static entities. This is particularity important for tags used for version
	// resolution.
	//
	// Attaching a tag to an instance generally makes the instance "discoverable".
	// For that reason tags can be attached only to instances that successfully
	// passed all post-registration processing.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	AttachTags(ctx context.Context, in *AttachTagsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Detaches one or more tags if they were attached.
	//
	// This call should not be used routinely, since tags are assumed to be
	// static (and thus not detachable).
	//
	// It is occasionally useful for fixing screw ups though. For that reason,
	// DetachTags is allowed only by OWNERS of a prefix (not WRITERS, like
	// AttachTags).
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not an OWNER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	DetachTags(ctx context.Context, in *DetachTagsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Attaches one or more metadata entries to an instance.
	//
	// An instance metadata entry is a key-value pair, where the key is a
	// lowercase string and the value is an arbitrary blob up to 512 Kb in size.
	//
	// A single key can have multiple different values associated with it.
	// Completely identical key-value pairs are deduplicated: attaching already
	// attached metadata is a noop. Thus all metadata of an instance is a
	// multimap, where a key maps to a set of unique values.
	//
	// A metadata entry is identified by its fingerprint: a hash of concatenated
	// key and value (see InstanceMetadata message for details). It can be used,
	// for example, to point to an entry to detach in DetachMetadata.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	AttachMetadata(ctx context.Context, in *AttachMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Detaches one or more metadata entries if they were attached.
	//
	// Entries are identified by their fingerprints. They can either be calculated
	// from a key-value pair by the client (see InstanceMetadata message for
	// details), by the server (if InstanceMetadata messages inside
	// DetachMetadataRequest have 'key' and 'value' populated, but not
	// 'fingerprint') or taken from some existing InstanceMetadata message (e.g.
	// from inside a ListMetadataResponse).
	//
	// Detaching metadata that doesn't exist is a noop.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not an OWNER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	DetachMetadata(ctx context.Context, in *DetachMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Lists metadata entries attached to an instance.
	//
	// Either returns all metadata or only entries with requested keys. The list
	// is sorted by the registration time of metadata entries (the most recent
	// first).
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	ListMetadata(ctx context.Context, in *ListMetadataRequest, opts ...grpc.CallOption) (*ListMetadataResponse, error)
	// Takes a version string and resolves it into a concrete package instance.
	//
	// A version string can be any of:
	//   * A string-encoded instance ID, e.g. "abcdef....".
	//   * A ref name, e.g. "latest".
	//   * A tag, e.g. "version:1.10.3".
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if there's no such package or version.
	//   FAILED_PRECONDITION if the tag resolves to multiple instances.
	ResolveVersion(ctx context.Context, in *ResolveVersionRequest, opts ...grpc.CallOption) (*Instance, error)
	// Produces a signed URL that can be used to fetch the package instance file.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if there's no such instance.
	GetInstanceURL(ctx context.Context, in *GetInstanceURLRequest, opts ...grpc.CallOption) (*ObjectURL, error)
	// Returns information about a package instance.
	//
	// Depending on fields set in the request, returns details such as when the
	// instance was registered and by whom, refs pointing to it, tags attached to
	// it, state of all processors that handled it (if any).
	//
	// May also be used as a simple instance presence check, if all describe_*
	// fields in the request are false. If the request succeeds, then the
	// instance exists.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the instance doesn't exist.
	DescribeInstance(ctx context.Context, in *DescribeInstanceRequest, opts ...grpc.CallOption) (*DescribeInstanceResponse, error)
	// Returns information about a CIPD client package.
	//
	// Used by the client self-update procedure.
	//
	// Returns:
	//   NOT_FOUND if the package or the instance doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	DescribeClient(ctx context.Context, in *DescribeClientRequest, opts ...grpc.CallOption) (*DescribeClientResponse, error)
	// Returns information about binaries extracted from bootstrap packages under
	// some prefix.
	//
	// This is a niche functionality used by some LUCI systems.
	//
	// Unlike other RPC methods here, it operates with a bunch of packages at
	// once. Errors that relate to a particular package instance (instead of the
	// request as a whole) are returned as google.rpc.Status inside the
	// corresponding BootstrapFile entry in DescribeBootstrapBundleResponse.
	// Possible statuses communicated that way:
	//   NOT_FOUND if the requested version of the package doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed or it is not
	//       a bootstrap package at all.
	//   ABORTED if the instance has failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	//
	// NOTE: The CIPD package server implements a REST endpoint which can be used
	// to retrieve the contents of bootstrap packages:
	//
	//   GET /bootstrap/<package>/+/<version>
	//
	// which will serve a 302 redirect to a signed url for the `file` contents.
	//
	// Returns:
	//   OK if the request was accepted and (perhaps partially) processed.
	//   NOT_FOUND if none of the requested instances exist.
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	DescribeBootstrapBundle(ctx context.Context, in *DescribeBootstrapBundleRequest, opts ...grpc.CallOption) (*DescribeBootstrapBundleResponse, error)
}

RepositoryClient is the client API for Repository 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 NewRepositoryClient

func NewRepositoryClient(cc grpc.ClientConnInterface) RepositoryClient

type RepositoryServer

type RepositoryServer interface {
	// Returns metadata associated with the given prefix.
	//
	// Requires the caller to have OWNER role for the requested prefix or any of
	// parent prefixes, or be in a special global "cipd-prefixes-viewers" group,
	// otherwise the call fails with PERMISSION_DENIED error.
	//
	// If the caller has OWNER permission in any of parent prefixes, but the
	// requested prefix has no metadata associated with it, the call fails with
	// NOT_FOUND error.
	GetPrefixMetadata(context.Context, *PrefixRequest) (*PrefixMetadata, error)
	// Returns metadata associated with the given prefix and all parent prefixes.
	//
	// Requires the caller to have OWNER role for the requested prefix or any of
	// parent prefixes, or be in a special global "cipd-prefixes-viewers" group,
	// otherwise the call fails with PERMISSION_DENIED error.
	//
	// Note that if the caller has permission to see the metadata for the
	// requested prefix, they will also see metadata for all parent prefixes,
	// since it is needed to assemble the final metadata for the prefix (it
	// includes inherited properties from all parent prefixes).
	GetInheritedPrefixMetadata(context.Context, *PrefixRequest) (*InheritedPrefixMetadata, error)
	// Updates or creates metadata associated with the given prefix.
	//
	// Requires the caller to have OWNER role for the requested prefix or any of
	// parent prefixes, otherwise the call fails with PERMISSION_DENIED error.
	//
	// This method checks 'fingerprint' field of the PrefixMetadata object. If the
	// metadata for the given prefix already exists, and the fingerprint in the
	// request doesn't match the current fingerprint, the request fails with
	// FAILED_PRECONDITION error.
	//
	// If the metadata doesn't exist yet, its fingerprint is assumed to be empty
	// string. So pass empty fingerprint when creating initial metadata objects.
	//
	// If the caller passes empty fingerprint, but the metadata already exists,
	// the request fails with ALREADY_EXISTS error.
	//
	// Note that there's no way to delete metadata once it was created. Passing
	// empty PrefixMetadata object is the best that can be done.
	//
	// On success returns PrefixMetadata object with the updated fingerprint.
	UpdatePrefixMetadata(context.Context, *PrefixMetadata) (*PrefixMetadata, error)
	// Returns a set of roles the caller has in the given prefix.
	//
	// Unlike GetPrefixMetadata call that requires special permissions (since it
	// returns a lot of detailed information), GetRolesInPrefix can be called by
	// anyone.
	//
	// It understands and expands roles inheritance, e.g. if the caller is an
	// OWNER, the result will also contain WRITER and READER (as they are implied
	// by being an OWNER).
	//
	// Returns empty set of roles if the caller has no permissions to access the
	// prefix at all or such prefix doesn't exist.
	GetRolesInPrefix(context.Context, *PrefixRequest) (*RolesInPrefixResponse, error)
	// Lists packages and subprefixes registered under the prefix.
	//
	// Lists either only direct descendants or recursively all descendants. The
	// result is sorted lexicographically.
	//
	// For example, for packages ["a", "a/b", "a/c/d", "a/c/e/f"], listing of "a"
	// will be:
	//   * {packages: ["a/b"], prefixes: ["a/c"]} if listing non-recursively.
	//   * {packages: ["a/b", "a/c/d", "a/c/e/f"], prefixes: ["a/c", "a/c/e"]} if
	//     listing recursively.
	//
	// Returns only packages and prefixes visible to the caller. This applies even
	// when listing a prefix the caller has no direct read access to. For example,
	// recursively listing the root prefix will return all packages the caller has
	// read access to (no matter when in the hierarchy they are located), even if
	// the caller has no READER permission in the root. It works as if the caller
	// can freely browse the repository that contains only the packages they can
	// see and nothing else.
	ListPrefix(context.Context, *ListPrefixRequest) (*ListPrefixResponse, error)
	// HidePackage marks the package as hidden.
	//
	// This removes it from the ListPrefix results, but doesn't otherwise affect
	// its usage (e.g. it is still fetchable).
	//
	// Requires OWNER role for the package prefix. Returns PERMISSION_DENIED
	// otherwise.
	HidePackage(context.Context, *PackageRequest) (*emptypb.Empty, error)
	// UnhidePackage marks the package as visible again.
	//
	// It's reverse of HidePackage.
	//
	// Requires OWNER role for the package prefix. Returns PERMISSION_DENIED
	// otherwise.
	UnhidePackage(context.Context, *PackageRequest) (*emptypb.Empty, error)
	// DeletePackage removes the package (along with all its instances, tags, refs
	// etc) from the repository.
	//
	// There's no undo. Once the package is deleted, it is gone forever.
	//
	// This operation has a potential to break various pinned historical CIPD
	// ensure files and thus should not be used casually, only in extreme cases.
	// Consider just hiding the package instead of deleting it.
	//
	// For the reasons above, the operation requires admin access: only owners of
	// the repository root can delete packages.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a root owner.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package doesn't exist.
	DeletePackage(context.Context, *PackageRequest) (*emptypb.Empty, error)
	// Registers a package instance in the repository (if it was uploaded to the
	// storage already and wasn't registered yet) or initiates a new upload
	// operation.
	//
	// Callers are expected to execute the following protocol:
	//   1. Attempt to register a package instance by calling RegisterInstance.
	//   2. On NOT_UPLOADED status, upload the package data and finalize the
	//      upload operation using Storage RPC service and upload_op from the
	//      response.
	//   3. Once the upload operation is finalized, call RegisterInstance again,
	//      it should succeed with status REGISTERED now.
	//
	// If such instance is already registered by someone else, returns
	// ALREADY_REGISTERED status. This is not an error.
	//
	// Callers must have roles WRITER or OWNER for the package prefix. Returns
	// PERMISSION_DENIED otherwise.
	RegisterInstance(context.Context, *Instance) (*RegisterInstanceResponse, error)
	// Lists instances of a package, most recent first.
	//
	// Callers must have roles READER (or above) for the package prefix. Returns
	// PERMISSION_DENIED otherwise.
	//
	// If the package doesn't exist, returns NOT_FOUND.
	ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
	// Returns package instances that have all given tags attached.
	//
	// Queries only instances of some particular package (i.e. this is not a
	// global query).
	//
	// Callers must have roles READER (or above) for the package prefix. Returns
	// PERMISSION_DENIED otherwise.
	//
	// If the package doesn't exist, returns NOT_FOUND.
	SearchInstances(context.Context, *SearchInstancesRequest) (*SearchInstancesResponse, error)
	// Creates a new ref or moves an existing one.
	//
	// A ref is a mutable named pointer to some existing package instance that
	// can be used as a version identifier. For example, "latest" or "stable".
	//
	// Refs are namespaced to some particular package. E.g. "latest" ref in
	// packages "A" and "B" are completely different entities not related to each
	// other.
	//
	// Pointing a ref to an instance generally makes the instance "discoverable".
	// For that reason the ref can be set only to instances that successfully
	// passed all post-registration processing.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance the ref points to doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	CreateRef(context.Context, *Ref) (*emptypb.Empty, error)
	// Removes a ref.
	//
	// Not a failure if there's no such ref.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package doesn't exist.
	DeleteRef(context.Context, *DeleteRefRequest) (*emptypb.Empty, error)
	// Lists refs defined in a package, most recently modified first.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package doesn't exist.
	ListRefs(context.Context, *ListRefsRequest) (*ListRefsResponse, error)
	// Attaches one or more tags to an instance.
	//
	// Silently skips already attached tags.
	//
	// Tags are "key:value" pairs associated with a concrete package instance.
	// They can be used for querying registered instances and for version
	// resolution: if a tag is attached to one and only one instance of a package,
	// the tag uniquely identifies this instance and such tag can be used as an
	// alias of the instance ID.
	//
	// Tags generally should be assumed globally namespaced (e.g. it makes sense
	// to query for all registered instances with a given tag, across all
	// packages), and they don't have to be unique: same tag may be attached to
	// multiple instances (of the same or different packages).
	//
	// Additionally, tags (unlike refs) are intended to be mostly static, since
	// they usually relate to some properties of package instances, which are
	// static entities. This is particularity important for tags used for version
	// resolution.
	//
	// Attaching a tag to an instance generally makes the instance "discoverable".
	// For that reason tags can be attached only to instances that successfully
	// passed all post-registration processing.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	AttachTags(context.Context, *AttachTagsRequest) (*emptypb.Empty, error)
	// Detaches one or more tags if they were attached.
	//
	// This call should not be used routinely, since tags are assumed to be
	// static (and thus not detachable).
	//
	// It is occasionally useful for fixing screw ups though. For that reason,
	// DetachTags is allowed only by OWNERS of a prefix (not WRITERS, like
	// AttachTags).
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not an OWNER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	DetachTags(context.Context, *DetachTagsRequest) (*emptypb.Empty, error)
	// Attaches one or more metadata entries to an instance.
	//
	// An instance metadata entry is a key-value pair, where the key is a
	// lowercase string and the value is an arbitrary blob up to 512 Kb in size.
	//
	// A single key can have multiple different values associated with it.
	// Completely identical key-value pairs are deduplicated: attaching already
	// attached metadata is a noop. Thus all metadata of an instance is a
	// multimap, where a key maps to a set of unique values.
	//
	// A metadata entry is identified by its fingerprint: a hash of concatenated
	// key and value (see InstanceMetadata message for details). It can be used,
	// for example, to point to an entry to detach in DetachMetadata.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a WRITER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	AttachMetadata(context.Context, *AttachMetadataRequest) (*emptypb.Empty, error)
	// Detaches one or more metadata entries if they were attached.
	//
	// Entries are identified by their fingerprints. They can either be calculated
	// from a key-value pair by the client (see InstanceMetadata message for
	// details), by the server (if InstanceMetadata messages inside
	// DetachMetadataRequest have 'key' and 'value' populated, but not
	// 'fingerprint') or taken from some existing InstanceMetadata message (e.g.
	// from inside a ListMetadataResponse).
	//
	// Detaching metadata that doesn't exist is a noop.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not an OWNER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	DetachMetadata(context.Context, *DetachMetadataRequest) (*emptypb.Empty, error)
	// Lists metadata entries attached to an instance.
	//
	// Either returns all metadata or only entries with requested keys. The list
	// is sorted by the registration time of metadata entries (the most recent
	// first).
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the package or the instance doesn't exist.
	ListMetadata(context.Context, *ListMetadataRequest) (*ListMetadataResponse, error)
	// Takes a version string and resolves it into a concrete package instance.
	//
	// A version string can be any of:
	//   * A string-encoded instance ID, e.g. "abcdef....".
	//   * A ref name, e.g. "latest".
	//   * A tag, e.g. "version:1.10.3".
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if there's no such package or version.
	//   FAILED_PRECONDITION if the tag resolves to multiple instances.
	ResolveVersion(context.Context, *ResolveVersionRequest) (*Instance, error)
	// Produces a signed URL that can be used to fetch the package instance file.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if there's no such instance.
	GetInstanceURL(context.Context, *GetInstanceURLRequest) (*ObjectURL, error)
	// Returns information about a package instance.
	//
	// Depending on fields set in the request, returns details such as when the
	// instance was registered and by whom, refs pointing to it, tags attached to
	// it, state of all processors that handled it (if any).
	//
	// May also be used as a simple instance presence check, if all describe_*
	// fields in the request are false. If the request succeeds, then the
	// instance exists.
	//
	// Returns:
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	//   NOT_FOUND if the instance doesn't exist.
	DescribeInstance(context.Context, *DescribeInstanceRequest) (*DescribeInstanceResponse, error)
	// Returns information about a CIPD client package.
	//
	// Used by the client self-update procedure.
	//
	// Returns:
	//   NOT_FOUND if the package or the instance doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed.
	//   ABORTED if the instance has some failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	DescribeClient(context.Context, *DescribeClientRequest) (*DescribeClientResponse, error)
	// Returns information about binaries extracted from bootstrap packages under
	// some prefix.
	//
	// This is a niche functionality used by some LUCI systems.
	//
	// Unlike other RPC methods here, it operates with a bunch of packages at
	// once. Errors that relate to a particular package instance (instead of the
	// request as a whole) are returned as google.rpc.Status inside the
	// corresponding BootstrapFile entry in DescribeBootstrapBundleResponse.
	// Possible statuses communicated that way:
	//   NOT_FOUND if the requested version of the package doesn't exist.
	//   FAILED_PRECONDITION if the instance is still being processed or it is not
	//       a bootstrap package at all.
	//   ABORTED if the instance has failed processors associated with it,
	//       such instance is effectively broken and should not be used.
	//
	// NOTE: The CIPD package server implements a REST endpoint which can be used
	// to retrieve the contents of bootstrap packages:
	//
	//   GET /bootstrap/<package>/+/<version>
	//
	// which will serve a 302 redirect to a signed url for the `file` contents.
	//
	// Returns:
	//   OK if the request was accepted and (perhaps partially) processed.
	//   NOT_FOUND if none of the requested instances exist.
	//   PERMISSION_DENIED if the caller is not a READER for the prefix.
	//   INVALID_ARGUMENT if the request is malformed.
	DescribeBootstrapBundle(context.Context, *DescribeBootstrapBundleRequest) (*DescribeBootstrapBundleResponse, error)
	// contains filtered or unexported methods
}

RepositoryServer is the server API for Repository service. All implementations must embed UnimplementedRepositoryServer for forward compatibility

type ResolveVersionRequest

type ResolveVersionRequest struct {

	// The package that contains the instance we are resolving version of.
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// The version string to resolve, see ResolveVersion for details.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveVersionRequest) Descriptor deprecated

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

Deprecated: Use ResolveVersionRequest.ProtoReflect.Descriptor instead.

func (*ResolveVersionRequest) GetPackage

func (x *ResolveVersionRequest) GetPackage() string

func (*ResolveVersionRequest) GetVersion

func (x *ResolveVersionRequest) GetVersion() string

func (*ResolveVersionRequest) ProtoMessage

func (*ResolveVersionRequest) ProtoMessage()

func (*ResolveVersionRequest) ProtoReflect

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

func (*ResolveVersionRequest) Reset

func (x *ResolveVersionRequest) Reset()

func (*ResolveVersionRequest) String

func (x *ResolveVersionRequest) String() string

type Role

type Role int32

Roles used in package prefix ACLs.

A user can have one or more such roles for a package prefix. They get inherited by all subprefixes.

const (
	Role_ROLE_UNSPECIFIED Role = 0
	// Readers can fetch package instances and package metadata (e.g. list of
	// instances, all tags, all refs), but not prefix metadata (e.g. ACLs).
	Role_READER Role = 1
	// Writers can do everything that readers can, plus create new packages,
	// upload package instances, attach tags, move refs.
	Role_WRITER Role = 2
	// Owners can do everything that writers can, plus read prefix metadata for
	// all parent prefixes and all subprefixes, and modify prefix metadata for
	// all subprefixes.
	Role_OWNER Role = 3
)

func (Role) Descriptor

func (Role) Descriptor() protoreflect.EnumDescriptor

func (Role) Enum

func (x Role) Enum() *Role

func (Role) EnumDescriptor deprecated

func (Role) EnumDescriptor() ([]byte, []int)

Deprecated: Use Role.Descriptor instead.

func (Role) Number

func (x Role) Number() protoreflect.EnumNumber

func (Role) String

func (x Role) String() string

func (Role) Type

func (Role) Type() protoreflect.EnumType

type RolesInPrefixResponse

type RolesInPrefixResponse struct {

	// Unordered set or roles the caller has in the requested prefix.
	Roles []*RolesInPrefixResponse_RoleInPrefix `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"`
	// contains filtered or unexported fields
}

func (*RolesInPrefixResponse) Descriptor deprecated

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

Deprecated: Use RolesInPrefixResponse.ProtoReflect.Descriptor instead.

func (*RolesInPrefixResponse) GetRoles

func (*RolesInPrefixResponse) ProtoMessage

func (*RolesInPrefixResponse) ProtoMessage()

func (*RolesInPrefixResponse) ProtoReflect

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

func (*RolesInPrefixResponse) Reset

func (x *RolesInPrefixResponse) Reset()

func (*RolesInPrefixResponse) String

func (x *RolesInPrefixResponse) String() string

type RolesInPrefixResponse_RoleInPrefix

type RolesInPrefixResponse_RoleInPrefix struct {
	Role Role `protobuf:"varint,1,opt,name=role,proto3,enum=cipd.Role" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*RolesInPrefixResponse_RoleInPrefix) Descriptor deprecated

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

Deprecated: Use RolesInPrefixResponse_RoleInPrefix.ProtoReflect.Descriptor instead.

func (*RolesInPrefixResponse_RoleInPrefix) GetRole

func (*RolesInPrefixResponse_RoleInPrefix) ProtoMessage

func (*RolesInPrefixResponse_RoleInPrefix) ProtoMessage()

func (*RolesInPrefixResponse_RoleInPrefix) ProtoReflect

func (*RolesInPrefixResponse_RoleInPrefix) Reset

func (*RolesInPrefixResponse_RoleInPrefix) String

type SearchInstancesRequest

type SearchInstancesRequest struct {

	// Name of a package to query instances of (required).
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// Tags to look for (the found instances have ALL these tags attached).
	//
	// Due to internal limitations, the query is most efficient only when it
	// specifies one tag to filter by. All additional tags are checked in a
	// separate step after the initial query. For that reason when searching for
	// multiple tags it is better to specify the most limiting tags first.
	Tags []*Tag `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// Number of instances to return on one page, default is 100.
	PageSize int32 `protobuf:"varint,20,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Value of 'next_page_token' from the previous response.
	//
	// Can be used to resume fetching.
	PageToken string `protobuf:"bytes,21,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchInstancesRequest) Descriptor deprecated

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

Deprecated: Use SearchInstancesRequest.ProtoReflect.Descriptor instead.

func (*SearchInstancesRequest) GetPackage

func (x *SearchInstancesRequest) GetPackage() string

func (*SearchInstancesRequest) GetPageSize

func (x *SearchInstancesRequest) GetPageSize() int32

func (*SearchInstancesRequest) GetPageToken

func (x *SearchInstancesRequest) GetPageToken() string

func (*SearchInstancesRequest) GetTags

func (x *SearchInstancesRequest) GetTags() []*Tag

func (*SearchInstancesRequest) ProtoMessage

func (*SearchInstancesRequest) ProtoMessage()

func (*SearchInstancesRequest) ProtoReflect

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

func (*SearchInstancesRequest) Reset

func (x *SearchInstancesRequest) Reset()

func (*SearchInstancesRequest) String

func (x *SearchInstancesRequest) String() string

type SearchInstancesResponse

type SearchInstancesResponse struct {

	// Package instances, sorted by registration time, most recent first.
	Instances []*Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// Value to pass as 'page_token' in SearchInstancesRequest to resume fetching
	// or empty string if there's no more results.
	NextPageToken string `protobuf:"bytes,20,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchInstancesResponse) Descriptor deprecated

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

Deprecated: Use SearchInstancesResponse.ProtoReflect.Descriptor instead.

func (*SearchInstancesResponse) GetInstances

func (x *SearchInstancesResponse) GetInstances() []*Instance

func (*SearchInstancesResponse) GetNextPageToken

func (x *SearchInstancesResponse) GetNextPageToken() string

func (*SearchInstancesResponse) ProtoMessage

func (*SearchInstancesResponse) ProtoMessage()

func (*SearchInstancesResponse) ProtoReflect

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

func (*SearchInstancesResponse) Reset

func (x *SearchInstancesResponse) Reset()

func (*SearchInstancesResponse) String

func (x *SearchInstancesResponse) String() string

type StorageClient

type StorageClient interface {
	// Produces a signed URL that can be used to fetch an object.
	//
	// Returns NOT_FOUND status code if there's no such object.
	GetObjectURL(ctx context.Context, in *GetObjectURLRequest, opts ...grpc.CallOption) (*ObjectURL, error)
	// Initiates an upload operation.
	//
	// Once the upload is initiated the client is responsible for uploading the
	// object to the temporary location (provided via 'upload_url' which should be
	// used as an upload URL in Google Storage Resumable Upload protocol) and
	// finishing the upload with a call to FinishUpload, which will launch
	// the verification of the object's hash on the server side.
	//
	// If the client knows the hash of the object it wants to upload already, it
	// can provide it via 'object' field. In that case Storage may reply right
	// away that such object already exists by retuning ALREADY_EXISTS status
	// code.
	//
	// If the client doesn't know the hash yet (perhaps if the object's body is
	// generated on the fly), it still can open an upload operation and start
	// streaming the data. When finalizing the upload the backend will calculate
	// and return the resulting hash of the object.
	//
	// An UploadOperation returned by this method contains tokens that grant
	// direct upload access to whoever possesses them, so it should be treated as
	// a secret. See UploadOperation for more info.
	BeginUpload(ctx context.Context, in *BeginUploadRequest, opts ...grpc.CallOption) (*UploadOperation, error)
	// Finishes the pending upload operation, returning its new status.
	//
	// Clients are expected to finish Google Storage Resumable protocol first
	// before calling FinishUpload. Failure to do so will cause the upload
	// operation to end up in ERROR state.
	//
	// This call is idempotent and it is expected that clients will keep polling
	// it if they want to wait for the server to verify the hash of the uploaded
	// object.
	//
	// Returns NOT_FOUND if the provided upload operation doesn't exist.
	//
	// Errors related to the uploaded file body are communicated through 'status'
	// field of the upload operation, since they are not directly related to this
	// RPC call, but rather to the upload operation itself.
	FinishUpload(ctx context.Context, in *FinishUploadRequest, opts ...grpc.CallOption) (*UploadOperation, error)
	// CancelUpload aborts the pending upload operation.
	//
	// It moves it to CANCELED state if it was in UPLOADING state and cleans up
	// any temporary garbage. Returns the most recent state of the upload
	// operation (whatever it may be).
	//
	// Does nothing if the operation is already canceled or failed.
	//
	// Returns:
	//   NOT_FOUND if the provided upload operation doesn't exist.
	//   FAILED_PRECONDITION if the upload operation is in PUBLISHED or VERIFYING
	//      state (i.e. finished or being finalized now).
	CancelUpload(ctx context.Context, in *CancelUploadRequest, opts ...grpc.CallOption) (*UploadOperation, error)
}

StorageClient is the client API for Storage 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 NewStorageClient

func NewStorageClient(cc grpc.ClientConnInterface) StorageClient

type StorageServer

type StorageServer interface {
	// Produces a signed URL that can be used to fetch an object.
	//
	// Returns NOT_FOUND status code if there's no such object.
	GetObjectURL(context.Context, *GetObjectURLRequest) (*ObjectURL, error)
	// Initiates an upload operation.
	//
	// Once the upload is initiated the client is responsible for uploading the
	// object to the temporary location (provided via 'upload_url' which should be
	// used as an upload URL in Google Storage Resumable Upload protocol) and
	// finishing the upload with a call to FinishUpload, which will launch
	// the verification of the object's hash on the server side.
	//
	// If the client knows the hash of the object it wants to upload already, it
	// can provide it via 'object' field. In that case Storage may reply right
	// away that such object already exists by retuning ALREADY_EXISTS status
	// code.
	//
	// If the client doesn't know the hash yet (perhaps if the object's body is
	// generated on the fly), it still can open an upload operation and start
	// streaming the data. When finalizing the upload the backend will calculate
	// and return the resulting hash of the object.
	//
	// An UploadOperation returned by this method contains tokens that grant
	// direct upload access to whoever possesses them, so it should be treated as
	// a secret. See UploadOperation for more info.
	BeginUpload(context.Context, *BeginUploadRequest) (*UploadOperation, error)
	// Finishes the pending upload operation, returning its new status.
	//
	// Clients are expected to finish Google Storage Resumable protocol first
	// before calling FinishUpload. Failure to do so will cause the upload
	// operation to end up in ERROR state.
	//
	// This call is idempotent and it is expected that clients will keep polling
	// it if they want to wait for the server to verify the hash of the uploaded
	// object.
	//
	// Returns NOT_FOUND if the provided upload operation doesn't exist.
	//
	// Errors related to the uploaded file body are communicated through 'status'
	// field of the upload operation, since they are not directly related to this
	// RPC call, but rather to the upload operation itself.
	FinishUpload(context.Context, *FinishUploadRequest) (*UploadOperation, error)
	// CancelUpload aborts the pending upload operation.
	//
	// It moves it to CANCELED state if it was in UPLOADING state and cleans up
	// any temporary garbage. Returns the most recent state of the upload
	// operation (whatever it may be).
	//
	// Does nothing if the operation is already canceled or failed.
	//
	// Returns:
	//   NOT_FOUND if the provided upload operation doesn't exist.
	//   FAILED_PRECONDITION if the upload operation is in PUBLISHED or VERIFYING
	//      state (i.e. finished or being finalized now).
	CancelUpload(context.Context, *CancelUploadRequest) (*UploadOperation, error)
	// contains filtered or unexported methods
}

StorageServer is the server API for Storage service. All implementations must embed UnimplementedStorageServer for forward compatibility

type Tag

type Tag struct {

	// Key is a lowercase string matching [a-z0-9_\-]+.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value is a string matching [A-Za-z0-9$()*+,\-./:;<=>@\\_{}~ ]+.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// User that attached this tag (output only).
	AttachedBy string `protobuf:"bytes,3,opt,name=attached_by,json=attachedBy,proto3" json:"attached_by,omitempty"`
	// When the tag was attached (output only).
	AttachedTs *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=attached_ts,json=attachedTs,proto3" json:"attached_ts,omitempty"`
	// contains filtered or unexported fields
}

Tag is a key:value pair attached to some instance.

Keys don't have to be unique, only the full pair should. For example, it is fine to have "version:1" and "version:2" tags attached to the same instance.

The total length of the tag (as "key:value" pair) should be less that 400 bytes.

func (*Tag) Descriptor deprecated

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetAttachedBy

func (x *Tag) GetAttachedBy() string

func (*Tag) GetAttachedTs

func (x *Tag) GetAttachedTs() *timestamppb.Timestamp

func (*Tag) GetKey

func (x *Tag) GetKey() string

func (*Tag) GetValue

func (x *Tag) GetValue() string

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect

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

func (*Tag) Reset

func (x *Tag) Reset()

func (*Tag) String

func (x *Tag) String() string

type UnimplementedRepositoryServer

type UnimplementedRepositoryServer struct {
}

UnimplementedRepositoryServer must be embedded to have forward compatible implementations.

func (UnimplementedRepositoryServer) AttachMetadata

func (UnimplementedRepositoryServer) AttachTags

func (UnimplementedRepositoryServer) CreateRef

func (UnimplementedRepositoryServer) DeletePackage

func (UnimplementedRepositoryServer) DeleteRef

func (UnimplementedRepositoryServer) DescribeClient

func (UnimplementedRepositoryServer) DescribeInstance

func (UnimplementedRepositoryServer) DetachMetadata

func (UnimplementedRepositoryServer) DetachTags

func (UnimplementedRepositoryServer) GetInheritedPrefixMetadata

func (UnimplementedRepositoryServer) GetInstanceURL

func (UnimplementedRepositoryServer) GetPrefixMetadata

func (UnimplementedRepositoryServer) GetRolesInPrefix

func (UnimplementedRepositoryServer) HidePackage

func (UnimplementedRepositoryServer) ListInstances

func (UnimplementedRepositoryServer) ListMetadata

func (UnimplementedRepositoryServer) ListPrefix

func (UnimplementedRepositoryServer) ListRefs

func (UnimplementedRepositoryServer) RegisterInstance

func (UnimplementedRepositoryServer) ResolveVersion

func (UnimplementedRepositoryServer) SearchInstances

func (UnimplementedRepositoryServer) UnhidePackage

func (UnimplementedRepositoryServer) UpdatePrefixMetadata

type UnimplementedStorageServer

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer must be embedded to have forward compatible implementations.

func (UnimplementedStorageServer) BeginUpload

func (UnimplementedStorageServer) CancelUpload

func (UnimplementedStorageServer) FinishUpload

func (UnimplementedStorageServer) GetObjectURL

type UnsafeRepositoryServer

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

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

type UnsafeStorageServer

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

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

type UploadOperation

type UploadOperation struct {

	// An opaque string that identifies this upload operation.
	//
	// It acts as a temporary authorization token for FinishUpload RPC. Treat it
	// as a secret.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// URL the client should use in Google Storage Resumable Upload protocol to
	// upload the object's body.
	//
	// No authentication is required to upload data to this URL, so it also should
	// be treated as a secret.
	UploadUrl string `protobuf:"bytes,2,opt,name=upload_url,json=uploadUrl,proto3" json:"upload_url,omitempty"`
	// Status of the upload operation.
	Status UploadStatus `protobuf:"varint,3,opt,name=status,proto3,enum=cipd.UploadStatus" json:"status,omitempty"`
	// For PUBLISHED status, the reference to the published object.
	//
	// This is in particular useful for uploads when the hash of the object is not
	// known until the upload is finished.
	Object *ObjectRef `protobuf:"bytes,4,opt,name=object,proto3" json:"object,omitempty"`
	// For ERRORED status, a human readable error message.
	ErrorMessage string `protobuf:"bytes,5,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadOperation) Descriptor deprecated

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

Deprecated: Use UploadOperation.ProtoReflect.Descriptor instead.

func (*UploadOperation) GetErrorMessage

func (x *UploadOperation) GetErrorMessage() string

func (*UploadOperation) GetObject

func (x *UploadOperation) GetObject() *ObjectRef

func (*UploadOperation) GetOperationId

func (x *UploadOperation) GetOperationId() string

func (*UploadOperation) GetStatus

func (x *UploadOperation) GetStatus() UploadStatus

func (*UploadOperation) GetUploadUrl

func (x *UploadOperation) GetUploadUrl() string

func (*UploadOperation) ProtoMessage

func (*UploadOperation) ProtoMessage()

func (*UploadOperation) ProtoReflect

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

func (*UploadOperation) Reset

func (x *UploadOperation) Reset()

func (*UploadOperation) String

func (x *UploadOperation) String() string

type UploadStatus

type UploadStatus int32
const (
	UploadStatus_UPLOAD_STATUS_UNSPECIFIED UploadStatus = 0
	UploadStatus_UPLOADING                 UploadStatus = 1 // the data is being uploaded now
	UploadStatus_VERIFYING                 UploadStatus = 2 // the object's hash is being verified now
	UploadStatus_PUBLISHED                 UploadStatus = 3 // the object has been published in the CAS
	UploadStatus_ERRORED                   UploadStatus = 4 // there were fatal errors during the finalization
	UploadStatus_CANCELED                  UploadStatus = 5 // the operation was canceled via CancelUpload
)

func (UploadStatus) Descriptor

func (UploadStatus) Enum

func (x UploadStatus) Enum() *UploadStatus

func (UploadStatus) EnumDescriptor deprecated

func (UploadStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use UploadStatus.Descriptor instead.

func (UploadStatus) Number

func (UploadStatus) String

func (x UploadStatus) String() string

func (UploadStatus) Type

type VerificationLogEntry

type VerificationLogEntry struct {
	OperationId        int64  `protobuf:"varint,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`                       // matches UploadOperation.ID
	InitiatedBy        string `protobuf:"bytes,2,opt,name=initiated_by,json=initiatedBy,proto3" json:"initiated_by,omitempty"`                        // e.g. "user:someone@example.com"
	TempGsPath         string `protobuf:"bytes,3,opt,name=temp_gs_path,json=tempGsPath,proto3" json:"temp_gs_path,omitempty"`                         // the GS object in the staging area being verified
	ExpectedInstanceId string `protobuf:"bytes,4,opt,name=expected_instance_id,json=expectedInstanceId,proto3" json:"expected_instance_id,omitempty"` // may be empty if not known
	VerifiedInstanceId string `protobuf:"bytes,5,opt,name=verified_instance_id,json=verifiedInstanceId,proto3" json:"verified_instance_id,omitempty"` // always populated on success
	Submitted          int64  `protobuf:"varint,6,opt,name=submitted,proto3" json:"submitted,omitempty"`                                              // microseconds since epoch
	Started            int64  `protobuf:"varint,7,opt,name=started,proto3" json:"started,omitempty"`                                                  // microseconds since epoch
	Finished           int64  `protobuf:"varint,8,opt,name=finished,proto3" json:"finished,omitempty"`                                                // microseconds since epoch
	ServiceVersion     string `protobuf:"bytes,9,opt,name=service_version,json=serviceVersion,proto3" json:"service_version,omitempty"`               // GAE service version e.g. "4123-abcdef"
	ProcessId          string `protobuf:"bytes,10,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`                             // identifier of the concrete backend process
	TraceId            string `protobuf:"bytes,11,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`                                   // Cloud Trace ID of the request
	FileSize           int64  `protobuf:"varint,12,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`                               // total file size in bytes
	VerificationSpeed  int64  `protobuf:"varint,13,opt,name=verification_speed,json=verificationSpeed,proto3" json:"verification_speed,omitempty"`    // file_size / duration, in bytes per second
	Outcome            string `protobuf:"bytes,14,opt,name=outcome,proto3" json:"outcome,omitempty"`                                                  // see cas.UploadStatus enum
	Error              string `protobuf:"bytes,15,opt,name=error,proto3" json:"error,omitempty"`                                                      // error message, if any
	// contains filtered or unexported fields
}

VerificationLogEntry defines a schema for `verification` BigQuery table.

It records details about hash verification jobs, in particular to collect information for https://crbug.com/1261988.

This is a best effort log populated using in-memory buffers. Some entries may be dropped if a process crashes before it flushes the buffer.

Field types must be compatible with BigQuery Storage Write API, see https://cloud.google.com/bigquery/docs/write-api#data_type_conversions

func (*VerificationLogEntry) Descriptor deprecated

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

Deprecated: Use VerificationLogEntry.ProtoReflect.Descriptor instead.

func (*VerificationLogEntry) GetError

func (x *VerificationLogEntry) GetError() string

func (*VerificationLogEntry) GetExpectedInstanceId

func (x *VerificationLogEntry) GetExpectedInstanceId() string

func (*VerificationLogEntry) GetFileSize

func (x *VerificationLogEntry) GetFileSize() int64

func (*VerificationLogEntry) GetFinished

func (x *VerificationLogEntry) GetFinished() int64

func (*VerificationLogEntry) GetInitiatedBy

func (x *VerificationLogEntry) GetInitiatedBy() string

func (*VerificationLogEntry) GetOperationId

func (x *VerificationLogEntry) GetOperationId() int64

func (*VerificationLogEntry) GetOutcome

func (x *VerificationLogEntry) GetOutcome() string

func (*VerificationLogEntry) GetProcessId

func (x *VerificationLogEntry) GetProcessId() string

func (*VerificationLogEntry) GetServiceVersion

func (x *VerificationLogEntry) GetServiceVersion() string

func (*VerificationLogEntry) GetStarted

func (x *VerificationLogEntry) GetStarted() int64

func (*VerificationLogEntry) GetSubmitted

func (x *VerificationLogEntry) GetSubmitted() int64

func (*VerificationLogEntry) GetTempGsPath

func (x *VerificationLogEntry) GetTempGsPath() string

func (*VerificationLogEntry) GetTraceId

func (x *VerificationLogEntry) GetTraceId() string

func (*VerificationLogEntry) GetVerificationSpeed

func (x *VerificationLogEntry) GetVerificationSpeed() int64

func (*VerificationLogEntry) GetVerifiedInstanceId

func (x *VerificationLogEntry) GetVerifiedInstanceId() string

func (*VerificationLogEntry) ProtoMessage

func (*VerificationLogEntry) ProtoMessage()

func (*VerificationLogEntry) ProtoReflect

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

func (*VerificationLogEntry) Reset

func (x *VerificationLogEntry) Reset()

func (*VerificationLogEntry) String

func (x *VerificationLogEntry) String() string

Jump to

Keyboard shortcuts

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