v2

package
v2.0.0-beta.12 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package v2 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package v2 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	BundlerService_CreateBundle_FullMethodName = "/aruna.api.dataproxy.services.v2.BundlerService/CreateBundle"
	BundlerService_DeleteBundle_FullMethodName = "/aruna.api.dataproxy.services.v2.BundlerService/DeleteBundle"
)
View Source 
const (
	DataproxyReplicationService_PullReplication_FullMethodName = "/aruna.api.dataproxy.services.v2.DataproxyReplicationService/PullReplication"
	DataproxyReplicationService_PushReplication_FullMethodName = "/aruna.api.dataproxy.services.v2.DataproxyReplicationService/PushReplication"
)
View Source 
const (
	DataproxyBackendService_PutObject_FullMethodName               = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/PutObject"
	DataproxyBackendService_GetObject_FullMethodName               = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/GetObject"
	DataproxyBackendService_HeadObject_FullMethodName              = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/HeadObject"
	DataproxyBackendService_InitMultiPartUpload_FullMethodName     = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/InitMultiPartUpload"
	DataproxyBackendService_UploadPart_FullMethodName              = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/UploadPart"
	DataproxyBackendService_CompleteMultiPartUpload_FullMethodName = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/CompleteMultiPartUpload"
	DataproxyBackendService_CreateBucket_FullMethodName            = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/CreateBucket"
	DataproxyBackendService_DeleteBucket_FullMethodName            = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/DeleteBucket"
	DataproxyBackendService_DeleteObject_FullMethodName            = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/DeleteObject"
	DataproxyBackendService_InitLocation_FullMethodName            = "/aruna.api.dataproxy.services.v2.DataproxyBackendService/InitLocation"
)
View Source 
const (
	DataproxyUserService_GetCredentials_FullMethodName            = "/aruna.api.dataproxy.services.v2.DataproxyUserService/GetCredentials"
	DataproxyUserService_CreateOrUpdateCredentials_FullMethodName = "/aruna.api.dataproxy.services.v2.DataproxyUserService/CreateOrUpdateCredentials"
	DataproxyUserService_RevokeCredentials_FullMethodName         = "/aruna.api.dataproxy.services.v2.DataproxyUserService/RevokeCredentials"
	DataproxyUserService_PushReplica_FullMethodName               = "/aruna.api.dataproxy.services.v2.DataproxyUserService/PushReplica"
	DataproxyUserService_PullReplica_FullMethodName               = "/aruna.api.dataproxy.services.v2.DataproxyUserService/PullReplica"
	DataproxyUserService_ReplicationStatus_FullMethodName         = "/aruna.api.dataproxy.services.v2.DataproxyUserService/ReplicationStatus"
)
View Source 
const (
	DataproxyIngestionService_IngestExistingObject_FullMethodName = "/aruna.api.dataproxy.services.v2.DataproxyIngestionService/IngestExistingObject"
)

Variables

View Source 
var (
	ReplicationStatus_name = map[int32]string{
		0: "REPLICATION_STATUS_UNSPECIFIED",
		1: "REPLICATION_STATUS_PENDING",
		2: "REPLICATION_STATUS_RUNNING",
		3: "REPLICATION_STATUS_FINISHED",
		4: "REPLICATION_STATUS_ERROR",
	}
	ReplicationStatus_value = map[string]int32{
		"REPLICATION_STATUS_UNSPECIFIED": 0,
		"REPLICATION_STATUS_PENDING":     1,
		"REPLICATION_STATUS_RUNNING":     2,
		"REPLICATION_STATUS_FINISHED":    3,
		"REPLICATION_STATUS_ERROR":       4,
	}
)

Enum value maps for ReplicationStatus.

View Source 
var BundlerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.dataproxy.services.v2.BundlerService",
	HandlerType: (*BundlerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBundle",
			Handler:    _BundlerService_CreateBundle_Handler,
		},
		{
			MethodName: "DeleteBundle",
			Handler:    _BundlerService_DeleteBundle_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/dataproxy/services/v2/bundler_service.proto",
}

BundlerService_ServiceDesc is the grpc.ServiceDesc for BundlerService 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 DataproxyBackendService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.dataproxy.services.v2.DataproxyBackendService",
	HandlerType: (*DataproxyBackendServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HeadObject",
			Handler:    _DataproxyBackendService_HeadObject_Handler,
		},
		{
			MethodName: "InitMultiPartUpload",
			Handler:    _DataproxyBackendService_InitMultiPartUpload_Handler,
		},
		{
			MethodName: "CompleteMultiPartUpload",
			Handler:    _DataproxyBackendService_CompleteMultiPartUpload_Handler,
		},
		{
			MethodName: "CreateBucket",
			Handler:    _DataproxyBackendService_CreateBucket_Handler,
		},
		{
			MethodName: "DeleteBucket",
			Handler:    _DataproxyBackendService_DeleteBucket_Handler,
		},
		{
			MethodName: "DeleteObject",
			Handler:    _DataproxyBackendService_DeleteObject_Handler,
		},
		{
			MethodName: "InitLocation",
			Handler:    _DataproxyBackendService_InitLocation_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PutObject",
			Handler:       _DataproxyBackendService_PutObject_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "GetObject",
			Handler:       _DataproxyBackendService_GetObject_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UploadPart",
			Handler:       _DataproxyBackendService_UploadPart_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "aruna/api/dataproxy/services/v2/dataproxy_service.proto",
}

DataproxyBackendService_ServiceDesc is the grpc.ServiceDesc for DataproxyBackendService 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 DataproxyIngestionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.dataproxy.services.v2.DataproxyIngestionService",
	HandlerType: (*DataproxyIngestionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IngestExistingObject",
			Handler:    _DataproxyIngestionService_IngestExistingObject_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/dataproxy/services/v2/dataproxy_service.proto",
}

DataproxyIngestionService_ServiceDesc is the grpc.ServiceDesc for DataproxyIngestionService 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 DataproxyReplicationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.dataproxy.services.v2.DataproxyReplicationService",
	HandlerType: (*DataproxyReplicationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushReplication",
			Handler:    _DataproxyReplicationService_PushReplication_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PullReplication",
			Handler:       _DataproxyReplicationService_PullReplication_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "aruna/api/dataproxy/services/v2/dataproxy_service.proto",
}

DataproxyReplicationService_ServiceDesc is the grpc.ServiceDesc for DataproxyReplicationService 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 DataproxyUserService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aruna.api.dataproxy.services.v2.DataproxyUserService",
	HandlerType: (*DataproxyUserServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCredentials",
			Handler:    _DataproxyUserService_GetCredentials_Handler,
		},
		{
			MethodName: "CreateOrUpdateCredentials",
			Handler:    _DataproxyUserService_CreateOrUpdateCredentials_Handler,
		},
		{
			MethodName: "RevokeCredentials",
			Handler:    _DataproxyUserService_RevokeCredentials_Handler,
		},
		{
			MethodName: "PushReplica",
			Handler:    _DataproxyUserService_PushReplica_Handler,
		},
		{
			MethodName: "PullReplica",
			Handler:    _DataproxyUserService_PullReplica_Handler,
		},
		{
			MethodName: "ReplicationStatus",
			Handler:    _DataproxyUserService_ReplicationStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aruna/api/dataproxy/services/v2/dataproxy_service.proto",
}

DataproxyUserService_ServiceDesc is the grpc.ServiceDesc for DataproxyUserService 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 File_aruna_api_dataproxy_services_v2_bundler_service_proto protoreflect.FileDescriptor
View Source 
var File_aruna_api_dataproxy_services_v2_dataproxy_service_proto protoreflect.FileDescriptor

Functions

func RegisterBundlerServiceHandler 

func RegisterBundlerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBundlerServiceHandler registers the http handlers for service BundlerService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBundlerServiceHandlerClient 

func RegisterBundlerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BundlerServiceClient) error

RegisterBundlerServiceHandlerClient registers the http handlers for service BundlerService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BundlerServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BundlerServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BundlerServiceClient" to call the correct interceptors.

func RegisterBundlerServiceHandlerFromEndpoint 

func RegisterBundlerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBundlerServiceHandlerFromEndpoint is same as RegisterBundlerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBundlerServiceHandlerServer 

func RegisterBundlerServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BundlerServiceServer) error

RegisterBundlerServiceHandlerServer registers the http handlers for service BundlerService to "mux". UnaryRPC :call BundlerServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBundlerServiceHandlerFromEndpoint instead.

func RegisterBundlerServiceServer 

func RegisterBundlerServiceServer(s grpc.ServiceRegistrar, srv BundlerServiceServer)

func RegisterDataproxyBackendServiceServer 

func RegisterDataproxyBackendServiceServer(s grpc.ServiceRegistrar, srv DataproxyBackendServiceServer)

func RegisterDataproxyIngestionServiceServer 

func RegisterDataproxyIngestionServiceServer(s grpc.ServiceRegistrar, srv DataproxyIngestionServiceServer)

func RegisterDataproxyReplicationServiceServer 

func RegisterDataproxyReplicationServiceServer(s grpc.ServiceRegistrar, srv DataproxyReplicationServiceServer)

func RegisterDataproxyUserServiceHandler 

func RegisterDataproxyUserServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDataproxyUserServiceHandler registers the http handlers for service DataproxyUserService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDataproxyUserServiceHandlerClient 

func RegisterDataproxyUserServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataproxyUserServiceClient) error

RegisterDataproxyUserServiceHandlerClient registers the http handlers for service DataproxyUserService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DataproxyUserServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DataproxyUserServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DataproxyUserServiceClient" to call the correct interceptors.

func RegisterDataproxyUserServiceHandlerFromEndpoint 

func RegisterDataproxyUserServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDataproxyUserServiceHandlerFromEndpoint is same as RegisterDataproxyUserServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDataproxyUserServiceHandlerServer 

func RegisterDataproxyUserServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataproxyUserServiceServer) error

RegisterDataproxyUserServiceHandlerServer registers the http handlers for service DataproxyUserService to "mux". UnaryRPC :call DataproxyUserServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDataproxyUserServiceHandlerFromEndpoint instead.

func RegisterDataproxyUserServiceServer 

func RegisterDataproxyUserServiceServer(s grpc.ServiceRegistrar, srv DataproxyUserServiceServer)

Types

type BundlerServiceClient 

type BundlerServiceClient interface {
	// CreateBundle
	//
	// Status: ALPHA
	//
	// Creates a bundle with multiple resources, dataproxy only.
	CreateBundle(ctx context.Context, in *CreateBundleRequest, opts ...grpc.CallOption) (*CreateBundleResponse, error)
	// DeleteBundle
	//
	// Status: ALPHA
	//
	// Delete an existing bundle, dataproxy only.
	DeleteBundle(ctx context.Context, in *DeleteBundleRequest, opts ...grpc.CallOption) (*DeleteBundleResponse, error)
}

BundlerServiceClient is the client API for BundlerService 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 NewBundlerServiceClient 

func NewBundlerServiceClient(cc grpc.ClientConnInterface) BundlerServiceClient

type BundlerServiceServer 

type BundlerServiceServer interface {
	// CreateBundle
	//
	// Status: ALPHA
	//
	// Creates a bundle with multiple resources, dataproxy only.
	CreateBundle(context.Context, *CreateBundleRequest) (*CreateBundleResponse, error)
	// DeleteBundle
	//
	// Status: ALPHA
	//
	// Delete an existing bundle, dataproxy only.
	DeleteBundle(context.Context, *DeleteBundleRequest) (*DeleteBundleResponse, error)
}

BundlerServiceServer is the server API for BundlerService service. All implementations should embed UnimplementedBundlerServiceServer for forward compatibility

type Chunk 

type Chunk struct {
	ObjectId string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ChunkIdx int64  `protobuf:"varint,2,opt,name=chunk_idx,json=chunkIdx,proto3" json:"chunk_idx,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Checksum string `protobuf:"bytes,4,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*Chunk) Descriptor deprecated 

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

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetChecksum 

func (x *Chunk) GetChecksum() string

func (*Chunk) GetChunkIdx 

func (x *Chunk) GetChunkIdx() int64

func (*Chunk) GetData 

func (x *Chunk) GetData() []byte

func (*Chunk) GetObjectId 

func (x *Chunk) GetObjectId() string

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect 

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

func (*Chunk) Reset 

func (x *Chunk) Reset()

func (*Chunk) String 

func (x *Chunk) String() string

type ChunkAckMessage 

type ChunkAckMessage struct {
	ObjectId string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ChunkIdx int64  `protobuf:"varint,2,opt,name=chunk_idx,json=chunkIdx,proto3" json:"chunk_idx,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkAckMessage) Descriptor deprecated 

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

Deprecated: Use ChunkAckMessage.ProtoReflect.Descriptor instead.

func (*ChunkAckMessage) GetChunkIdx 

func (x *ChunkAckMessage) GetChunkIdx() int64

func (*ChunkAckMessage) GetObjectId 

func (x *ChunkAckMessage) GetObjectId() string

func (*ChunkAckMessage) ProtoMessage 

func (*ChunkAckMessage) ProtoMessage()

func (*ChunkAckMessage) ProtoReflect 

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

func (*ChunkAckMessage) Reset 

func (x *ChunkAckMessage) Reset()

func (*ChunkAckMessage) String 

func (x *ChunkAckMessage) String() string

type CompleteMultiPartUploadRequest 

type CompleteMultiPartUploadRequest struct {
	Location       *ObjectLocation  `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	CompletedParts []*CompletedPart `protobuf:"bytes,2,rep,name=completed_parts,json=completedParts,proto3" json:"completed_parts,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteMultiPartUploadRequest) Descriptor deprecated 

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

Deprecated: Use CompleteMultiPartUploadRequest.ProtoReflect.Descriptor instead.

func (*CompleteMultiPartUploadRequest) GetCompletedParts 

func (x *CompleteMultiPartUploadRequest) GetCompletedParts() []*CompletedPart

func (*CompleteMultiPartUploadRequest) GetLocation 

func (x *CompleteMultiPartUploadRequest) GetLocation() *ObjectLocation

func (*CompleteMultiPartUploadRequest) ProtoMessage 

func (*CompleteMultiPartUploadRequest) ProtoMessage()

func (*CompleteMultiPartUploadRequest) ProtoReflect 

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

func (*CompleteMultiPartUploadRequest) Reset 

func (x *CompleteMultiPartUploadRequest) Reset()

func (*CompleteMultiPartUploadRequest) String 

func (x *CompleteMultiPartUploadRequest) String() string

type CompleteMultiPartUploadResponse 

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

func (*CompleteMultiPartUploadResponse) Descriptor deprecated 

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

Deprecated: Use CompleteMultiPartUploadResponse.ProtoReflect.Descriptor instead.

func (*CompleteMultiPartUploadResponse) ProtoMessage 

func (*CompleteMultiPartUploadResponse) ProtoMessage()

func (*CompleteMultiPartUploadResponse) ProtoReflect 

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

func (*CompleteMultiPartUploadResponse) Reset 

func (x *CompleteMultiPartUploadResponse) Reset()

func (*CompleteMultiPartUploadResponse) String 

func (x *CompleteMultiPartUploadResponse) String() string

type CompletedPart 

type CompletedPart struct {
	PartNumber int32  `protobuf:"varint,1,opt,name=part_number,json=partNumber,proto3" json:"part_number,omitempty"`
	Etag       string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

func (*CompletedPart) Descriptor deprecated 

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

Deprecated: Use CompletedPart.ProtoReflect.Descriptor instead.

func (*CompletedPart) GetEtag 

func (x *CompletedPart) GetEtag() string

func (*CompletedPart) GetPartNumber 

func (x *CompletedPart) GetPartNumber() int32

func (*CompletedPart) ProtoMessage 

func (*CompletedPart) ProtoMessage()

func (*CompletedPart) ProtoReflect 

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

func (*CompletedPart) Reset 

func (x *CompletedPart) Reset()

func (*CompletedPart) String 

func (x *CompletedPart) String() string

type CreateBucketRequest 

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

func (*CreateBucketRequest) Descriptor deprecated 

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

Deprecated: Use CreateBucketRequest.ProtoReflect.Descriptor instead.

func (*CreateBucketRequest) GetBucket 

func (x *CreateBucketRequest) GetBucket() string

func (*CreateBucketRequest) ProtoMessage 

func (*CreateBucketRequest) ProtoMessage()

func (*CreateBucketRequest) ProtoReflect 

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

func (*CreateBucketRequest) Reset 

func (x *CreateBucketRequest) Reset()

func (*CreateBucketRequest) String 

func (x *CreateBucketRequest) String() string

type CreateBucketResponse 

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

func (*CreateBucketResponse) Descriptor deprecated 

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

Deprecated: Use CreateBucketResponse.ProtoReflect.Descriptor instead.

func (*CreateBucketResponse) ProtoMessage 

func (*CreateBucketResponse) ProtoMessage()

func (*CreateBucketResponse) ProtoReflect 

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

func (*CreateBucketResponse) Reset 

func (x *CreateBucketResponse) Reset()

func (*CreateBucketResponse) String 

func (x *CreateBucketResponse) String() string

type CreateBundleRequest 

type CreateBundleRequest struct {
	ResourceIds []string               `protobuf:"bytes,1,rep,name=resource_ids,json=resourceIds,proto3" json:"resource_ids,omitempty"`
	Filename    string                 `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`                    // .tar.gz / .zip
	ExpiresAt   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"` // Default 1 Month
	Once        bool                   `protobuf:"varint,4,opt,name=once,proto3" json:"once,omitempty"`                           // Default false (expires after first download)
	// contains filtered or unexported fields
}

func (*CreateBundleRequest) Descriptor deprecated 

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

Deprecated: Use CreateBundleRequest.ProtoReflect.Descriptor instead.

func (*CreateBundleRequest) GetExpiresAt 

func (x *CreateBundleRequest) GetExpiresAt() *timestamppb.Timestamp

func (*CreateBundleRequest) GetFilename 

func (x *CreateBundleRequest) GetFilename() string

func (*CreateBundleRequest) GetOnce 

func (x *CreateBundleRequest) GetOnce() bool

func (*CreateBundleRequest) GetResourceIds 

func (x *CreateBundleRequest) GetResourceIds() []string

func (*CreateBundleRequest) ProtoMessage 

func (*CreateBundleRequest) ProtoMessage()

func (*CreateBundleRequest) ProtoReflect 

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

func (*CreateBundleRequest) Reset 

func (x *CreateBundleRequest) Reset()

func (*CreateBundleRequest) String 

func (x *CreateBundleRequest) String() string

type CreateBundleResponse 

type CreateBundleResponse struct {
	BundleId  string `protobuf:"bytes,1,opt,name=bundle_id,json=bundleId,proto3" json:"bundle_id,omitempty"`
	BundleUrl string `protobuf:"bytes,2,opt,name=bundle_url,json=bundleUrl,proto3" json:"bundle_url,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBundleResponse) Descriptor deprecated 

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

Deprecated: Use CreateBundleResponse.ProtoReflect.Descriptor instead.

func (*CreateBundleResponse) GetBundleId 

func (x *CreateBundleResponse) GetBundleId() string

func (*CreateBundleResponse) GetBundleUrl 

func (x *CreateBundleResponse) GetBundleUrl() string

func (*CreateBundleResponse) ProtoMessage 

func (*CreateBundleResponse) ProtoMessage()

func (*CreateBundleResponse) ProtoReflect 

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

func (*CreateBundleResponse) Reset 

func (x *CreateBundleResponse) Reset()

func (*CreateBundleResponse) String 

func (x *CreateBundleResponse) String() string

type CreateOrUpdateCredentialsRequest 

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

func (*CreateOrUpdateCredentialsRequest) Descriptor deprecated 

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

Deprecated: Use CreateOrUpdateCredentialsRequest.ProtoReflect.Descriptor instead.

func (*CreateOrUpdateCredentialsRequest) ProtoMessage 

func (*CreateOrUpdateCredentialsRequest) ProtoMessage()

func (*CreateOrUpdateCredentialsRequest) ProtoReflect 

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

func (*CreateOrUpdateCredentialsRequest) Reset 

func (x *CreateOrUpdateCredentialsRequest) Reset()

func (*CreateOrUpdateCredentialsRequest) String 

func (x *CreateOrUpdateCredentialsRequest) String() string

type CreateOrUpdateCredentialsResponse 

type CreateOrUpdateCredentialsResponse struct {
	AccessKey string `protobuf:"bytes,1,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey string `protobuf:"bytes,2,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateOrUpdateCredentialsResponse) Descriptor deprecated 

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

Deprecated: Use CreateOrUpdateCredentialsResponse.ProtoReflect.Descriptor instead.

func (*CreateOrUpdateCredentialsResponse) GetAccessKey 

func (x *CreateOrUpdateCredentialsResponse) GetAccessKey() string

func (*CreateOrUpdateCredentialsResponse) GetSecretKey 

func (x *CreateOrUpdateCredentialsResponse) GetSecretKey() string

func (*CreateOrUpdateCredentialsResponse) ProtoMessage 

func (*CreateOrUpdateCredentialsResponse) ProtoMessage()

func (*CreateOrUpdateCredentialsResponse) ProtoReflect 

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

func (*CreateOrUpdateCredentialsResponse) Reset 

func (x *CreateOrUpdateCredentialsResponse) Reset()

func (*CreateOrUpdateCredentialsResponse) String 

func (x *CreateOrUpdateCredentialsResponse) String() string

type DataInfo 

type DataInfo struct {
	ObjectId      string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	DownloadUrl   string `protobuf:"bytes,2,opt,name=download_url,json=downloadUrl,proto3" json:"download_url,omitempty"`
	EncryptionKey string `protobuf:"bytes,3,opt,name=encryption_key,json=encryptionKey,proto3" json:"encryption_key,omitempty"`
	IsCompressed  bool   `protobuf:"varint,4,opt,name=is_compressed,json=isCompressed,proto3" json:"is_compressed,omitempty"`
	// contains filtered or unexported fields
}

func (*DataInfo) Descriptor deprecated 

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

Deprecated: Use DataInfo.ProtoReflect.Descriptor instead.

func (*DataInfo) GetDownloadUrl 

func (x *DataInfo) GetDownloadUrl() string

func (*DataInfo) GetEncryptionKey 

func (x *DataInfo) GetEncryptionKey() string

func (*DataInfo) GetIsCompressed 

func (x *DataInfo) GetIsCompressed() bool

func (*DataInfo) GetObjectId 

func (x *DataInfo) GetObjectId() string

func (*DataInfo) ProtoMessage 

func (*DataInfo) ProtoMessage()

func (*DataInfo) ProtoReflect 

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

func (*DataInfo) Reset 

func (x *DataInfo) Reset()

func (*DataInfo) String 

func (x *DataInfo) String() string

type DataInfos 

type DataInfos struct {
	DataInfo []*DataInfo `protobuf:"bytes,1,rep,name=data_info,json=dataInfo,proto3" json:"data_info,omitempty"`
	// contains filtered or unexported fields
}

func (*DataInfos) Descriptor deprecated 

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

Deprecated: Use DataInfos.ProtoReflect.Descriptor instead.

func (*DataInfos) GetDataInfo 

func (x *DataInfos) GetDataInfo() []*DataInfo

func (*DataInfos) ProtoMessage 

func (*DataInfos) ProtoMessage()

func (*DataInfos) ProtoReflect 

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

func (*DataInfos) Reset 

func (x *DataInfos) Reset()

func (*DataInfos) String 

func (x *DataInfos) String() string

type DataproxyBackendServiceClient 

type DataproxyBackendServiceClient interface {
	PutObject(ctx context.Context, opts ...grpc.CallOption) (DataproxyBackendService_PutObjectClient, error)
	GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (DataproxyBackendService_GetObjectClient, error)
	HeadObject(ctx context.Context, in *HeadObjectRequest, opts ...grpc.CallOption) (*HeadObjectResponse, error)
	InitMultiPartUpload(ctx context.Context, in *InitMultiPartUploadRequest, opts ...grpc.CallOption) (*InitMultiPartUploadResponse, error)
	UploadPart(ctx context.Context, opts ...grpc.CallOption) (DataproxyBackendService_UploadPartClient, error)
	CompleteMultiPartUpload(ctx context.Context, in *CompleteMultiPartUploadRequest, opts ...grpc.CallOption) (*CompleteMultiPartUploadResponse, error)
	CreateBucket(ctx context.Context, in *CreateBucketRequest, opts ...grpc.CallOption) (*CreateBucketResponse, error)
	DeleteBucket(ctx context.Context, in *DeleteBucketRequest, opts ...grpc.CallOption) (*DeleteBucketResponse, error)
	DeleteObject(ctx context.Context, in *DeleteObjectRequest, opts ...grpc.CallOption) (*DeleteObjectResponse, error)
	InitLocation(ctx context.Context, in *InitLocationRequest, opts ...grpc.CallOption) (*InitLocationResponse, error)
}

DataproxyBackendServiceClient is the client API for DataproxyBackendService 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 NewDataproxyBackendServiceClient 

func NewDataproxyBackendServiceClient(cc grpc.ClientConnInterface) DataproxyBackendServiceClient

type DataproxyBackendServiceServer 

type DataproxyBackendServiceServer interface {
	PutObject(DataproxyBackendService_PutObjectServer) error
	GetObject(*GetObjectRequest, DataproxyBackendService_GetObjectServer) error
	HeadObject(context.Context, *HeadObjectRequest) (*HeadObjectResponse, error)
	InitMultiPartUpload(context.Context, *InitMultiPartUploadRequest) (*InitMultiPartUploadResponse, error)
	UploadPart(DataproxyBackendService_UploadPartServer) error
	CompleteMultiPartUpload(context.Context, *CompleteMultiPartUploadRequest) (*CompleteMultiPartUploadResponse, error)
	CreateBucket(context.Context, *CreateBucketRequest) (*CreateBucketResponse, error)
	DeleteBucket(context.Context, *DeleteBucketRequest) (*DeleteBucketResponse, error)
	DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)
	InitLocation(context.Context, *InitLocationRequest) (*InitLocationResponse, error)
}

DataproxyBackendServiceServer is the server API for DataproxyBackendService service. All implementations should embed UnimplementedDataproxyBackendServiceServer for forward compatibility

type DataproxyBackendService_GetObjectClient 

type DataproxyBackendService_GetObjectClient interface {
	Recv() (*GetObjectResponse, error)
	grpc.ClientStream
}

type DataproxyBackendService_GetObjectServer 

type DataproxyBackendService_GetObjectServer interface {
	Send(*GetObjectResponse) error
	grpc.ServerStream
}

type DataproxyBackendService_PutObjectClient 

type DataproxyBackendService_PutObjectClient interface {
	Send(*PutObjectRequest) error
	CloseAndRecv() (*PutObjectResponse, error)
	grpc.ClientStream
}

type DataproxyBackendService_PutObjectServer 

type DataproxyBackendService_PutObjectServer interface {
	SendAndClose(*PutObjectResponse) error
	Recv() (*PutObjectRequest, error)
	grpc.ServerStream
}

type DataproxyBackendService_UploadPartClient 

type DataproxyBackendService_UploadPartClient interface {
	Send(*UploadPartRequest) error
	CloseAndRecv() (*UploadPartResponse, error)
	grpc.ClientStream
}

type DataproxyBackendService_UploadPartServer 

type DataproxyBackendService_UploadPartServer interface {
	SendAndClose(*UploadPartResponse) error
	Recv() (*UploadPartRequest, error)
	grpc.ServerStream
}

type DataproxyIngestionServiceClient 

type DataproxyIngestionServiceClient interface {
	// IngestExistingObject
	//
	// Status: ALPHA
	//
	// Ingest an existing object into backend
	IngestExistingObject(ctx context.Context, in *IngestExistingObjectRequest, opts ...grpc.CallOption) (*IngestExistingObjectResponse, error)
}

DataproxyIngestionServiceClient is the client API for DataproxyIngestionService 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 NewDataproxyIngestionServiceClient 

func NewDataproxyIngestionServiceClient(cc grpc.ClientConnInterface) DataproxyIngestionServiceClient

type DataproxyIngestionServiceServer 

type DataproxyIngestionServiceServer interface {
	// IngestExistingObject
	//
	// Status: ALPHA
	//
	// Ingest an existing object into backend
	IngestExistingObject(context.Context, *IngestExistingObjectRequest) (*IngestExistingObjectResponse, error)
}

DataproxyIngestionServiceServer is the server API for DataproxyIngestionService service. All implementations should embed UnimplementedDataproxyIngestionServiceServer for forward compatibility

type DataproxyReplicationServiceClient 

type DataproxyReplicationServiceClient interface {
	// RequestReplication
	//
	// Status: ALPHA
	//
	// Creates a replication stream
	PullReplication(ctx context.Context, opts ...grpc.CallOption) (DataproxyReplicationService_PullReplicationClient, error)
	// InitReplication
	//
	// Status: UNIMPLEMENTED
	//
	// Provides the necessary url to init replication
	PushReplication(ctx context.Context, in *PushReplicationRequest, opts ...grpc.CallOption) (*PushReplicationResponse, error)
}

DataproxyReplicationServiceClient is the client API for DataproxyReplicationService 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 NewDataproxyReplicationServiceClient 

func NewDataproxyReplicationServiceClient(cc grpc.ClientConnInterface) DataproxyReplicationServiceClient

type DataproxyReplicationServiceServer 

type DataproxyReplicationServiceServer interface {
	// RequestReplication
	//
	// Status: ALPHA
	//
	// Creates a replication stream
	PullReplication(DataproxyReplicationService_PullReplicationServer) error
	// InitReplication
	//
	// Status: UNIMPLEMENTED
	//
	// Provides the necessary url to init replication
	PushReplication(context.Context, *PushReplicationRequest) (*PushReplicationResponse, error)
}

DataproxyReplicationServiceServer is the server API for DataproxyReplicationService service. All implementations should embed UnimplementedDataproxyReplicationServiceServer for forward compatibility

type DataproxyReplicationService_PullReplicationClient 

type DataproxyReplicationService_PullReplicationClient interface {
	Send(*PullReplicationRequest) error
	Recv() (*PullReplicationResponse, error)
	grpc.ClientStream
}

type DataproxyReplicationService_PullReplicationServer 

type DataproxyReplicationService_PullReplicationServer interface {
	Send(*PullReplicationResponse) error
	Recv() (*PullReplicationRequest, error)
	grpc.ServerStream
}

type DataproxyUserServiceClient 

type DataproxyUserServiceClient interface {
	// GetCredentials
	//
	// Status: BETA
	//
	// Authorized method that needs a aruna-token to exchange for dataproxy
	// specific S3AccessKey and S3SecretKey
	GetCredentials(ctx context.Context, in *GetCredentialsRequest, opts ...grpc.CallOption) (*GetCredentialsResponse, error)
	// CreateOrUpdateCredentials
	//
	// Status: BETA
	//
	// Authorized method that needs a aruna-token to exchange for dataproxy
	// specific S3AccessKey and S3SecretKey
	CreateOrUpdateCredentials(ctx context.Context, in *CreateOrUpdateCredentialsRequest, opts ...grpc.CallOption) (*CreateOrUpdateCredentialsResponse, error)
	// RevokeCredentials
	//
	// Status: BETA
	//
	// Authorized method that needs a aruna-token
	// Revokes the current credentials
	RevokeCredentials(ctx context.Context, in *RevokeCredentialsRequest, opts ...grpc.CallOption) (*RevokeCredentialsResponse, error)
	// PushReplica
	//
	// Status: UNIMPLEMENTED
	//
	// Manually transfers a replica to another data-proxy
	PushReplica(ctx context.Context, in *PushReplicaRequest, opts ...grpc.CallOption) (*PushReplicaResponse, error)
	// PullReplica
	//
	// Status: UNIMPLEMENTED
	//
	// Manually request data to be transferred to this data-proxy
	PullReplica(ctx context.Context, in *PullReplicaRequest, opts ...grpc.CallOption) (*PullReplicaResponse, error)
	// ReplicationStatus
	//
	// Status: UNIMPLEMENTED
	//
	// Status of the previous replication request
	ReplicationStatus(ctx context.Context, in *ReplicationStatusRequest, opts ...grpc.CallOption) (*ReplicationStatusResponse, error)
}

DataproxyUserServiceClient is the client API for DataproxyUserService 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 NewDataproxyUserServiceClient 

func NewDataproxyUserServiceClient(cc grpc.ClientConnInterface) DataproxyUserServiceClient

type DataproxyUserServiceServer 

type DataproxyUserServiceServer interface {
	// GetCredentials
	//
	// Status: BETA
	//
	// Authorized method that needs a aruna-token to exchange for dataproxy
	// specific S3AccessKey and S3SecretKey
	GetCredentials(context.Context, *GetCredentialsRequest) (*GetCredentialsResponse, error)
	// CreateOrUpdateCredentials
	//
	// Status: BETA
	//
	// Authorized method that needs a aruna-token to exchange for dataproxy
	// specific S3AccessKey and S3SecretKey
	CreateOrUpdateCredentials(context.Context, *CreateOrUpdateCredentialsRequest) (*CreateOrUpdateCredentialsResponse, error)
	// RevokeCredentials
	//
	// Status: BETA
	//
	// Authorized method that needs a aruna-token
	// Revokes the current credentials
	RevokeCredentials(context.Context, *RevokeCredentialsRequest) (*RevokeCredentialsResponse, error)
	// PushReplica
	//
	// Status: UNIMPLEMENTED
	//
	// Manually transfers a replica to another data-proxy
	PushReplica(context.Context, *PushReplicaRequest) (*PushReplicaResponse, error)
	// PullReplica
	//
	// Status: UNIMPLEMENTED
	//
	// Manually request data to be transferred to this data-proxy
	PullReplica(context.Context, *PullReplicaRequest) (*PullReplicaResponse, error)
	// ReplicationStatus
	//
	// Status: UNIMPLEMENTED
	//
	// Status of the previous replication request
	ReplicationStatus(context.Context, *ReplicationStatusRequest) (*ReplicationStatusResponse, error)
}

DataproxyUserServiceServer is the server API for DataproxyUserService service. All implementations should embed UnimplementedDataproxyUserServiceServer for forward compatibility

type DeleteBucketRequest 

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

func (*DeleteBucketRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBucketRequest.ProtoReflect.Descriptor instead.

func (*DeleteBucketRequest) GetBucket 

func (x *DeleteBucketRequest) GetBucket() string

func (*DeleteBucketRequest) ProtoMessage 

func (*DeleteBucketRequest) ProtoMessage()

func (*DeleteBucketRequest) ProtoReflect 

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

func (*DeleteBucketRequest) Reset 

func (x *DeleteBucketRequest) Reset()

func (*DeleteBucketRequest) String 

func (x *DeleteBucketRequest) String() string

type DeleteBucketResponse 

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

func (*DeleteBucketResponse) Descriptor deprecated 

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

Deprecated: Use DeleteBucketResponse.ProtoReflect.Descriptor instead.

func (*DeleteBucketResponse) ProtoMessage 

func (*DeleteBucketResponse) ProtoMessage()

func (*DeleteBucketResponse) ProtoReflect 

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

func (*DeleteBucketResponse) Reset 

func (x *DeleteBucketResponse) Reset()

func (*DeleteBucketResponse) String 

func (x *DeleteBucketResponse) String() string

type DeleteBundleRequest 

type DeleteBundleRequest struct {
	BundleId string `protobuf:"bytes,1,opt,name=bundle_id,json=bundleId,proto3" json:"bundle_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBundleRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBundleRequest.ProtoReflect.Descriptor instead.

func (*DeleteBundleRequest) GetBundleId 

func (x *DeleteBundleRequest) GetBundleId() string

func (*DeleteBundleRequest) ProtoMessage 

func (*DeleteBundleRequest) ProtoMessage()

func (*DeleteBundleRequest) ProtoReflect 

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

func (*DeleteBundleRequest) Reset 

func (x *DeleteBundleRequest) Reset()

func (*DeleteBundleRequest) String 

func (x *DeleteBundleRequest) String() string

type DeleteBundleResponse 

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

func (*DeleteBundleResponse) Descriptor deprecated 

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

Deprecated: Use DeleteBundleResponse.ProtoReflect.Descriptor instead.

func (*DeleteBundleResponse) ProtoMessage 

func (*DeleteBundleResponse) ProtoMessage()

func (*DeleteBundleResponse) ProtoReflect 

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

func (*DeleteBundleResponse) Reset 

func (x *DeleteBundleResponse) Reset()

func (*DeleteBundleResponse) String 

func (x *DeleteBundleResponse) String() string

type DeleteObjectRequest 

type DeleteObjectRequest struct {
	Location *ObjectLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteObjectRequest) Descriptor deprecated 

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

Deprecated: Use DeleteObjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteObjectRequest) GetLocation 

func (x *DeleteObjectRequest) GetLocation() *ObjectLocation

func (*DeleteObjectRequest) ProtoMessage 

func (*DeleteObjectRequest) ProtoMessage()

func (*DeleteObjectRequest) ProtoReflect 

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

func (*DeleteObjectRequest) Reset 

func (x *DeleteObjectRequest) Reset()

func (*DeleteObjectRequest) String 

func (x *DeleteObjectRequest) String() string

type DeleteObjectResponse 

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

func (*DeleteObjectResponse) Descriptor deprecated 

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

Deprecated: Use DeleteObjectResponse.ProtoReflect.Descriptor instead.

func (*DeleteObjectResponse) ProtoMessage 

func (*DeleteObjectResponse) ProtoMessage()

func (*DeleteObjectResponse) ProtoReflect 

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

func (*DeleteObjectResponse) Reset 

func (x *DeleteObjectResponse) Reset()

func (*DeleteObjectResponse) String 

func (x *DeleteObjectResponse) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ErrorMessage 

type ErrorMessage struct {

	// Types that are assignable to Error:
	//
	//	*ErrorMessage_RetryChunk
	//	*ErrorMessage_Abort
	//	*ErrorMessage_RetryObjectId
	Error isErrorMessage_Error `protobuf_oneof:"error"`
	// contains filtered or unexported fields
}

func (*ErrorMessage) Descriptor deprecated 

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

Deprecated: Use ErrorMessage.ProtoReflect.Descriptor instead.

func (*ErrorMessage) GetAbort 

func (x *ErrorMessage) GetAbort() *Empty

func (*ErrorMessage) GetError 

func (m *ErrorMessage) GetError() isErrorMessage_Error

func (*ErrorMessage) GetRetryChunk 

func (x *ErrorMessage) GetRetryChunk() *RetryChunkMessage

func (*ErrorMessage) GetRetryObjectId 

func (x *ErrorMessage) GetRetryObjectId() string

func (*ErrorMessage) ProtoMessage 

func (*ErrorMessage) ProtoMessage()

func (*ErrorMessage) ProtoReflect 

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

func (*ErrorMessage) Reset 

func (x *ErrorMessage) Reset()

func (*ErrorMessage) String 

func (x *ErrorMessage) String() string

type ErrorMessage_Abort 

type ErrorMessage_Abort struct {
	Abort *Empty `protobuf:"bytes,2,opt,name=abort,proto3,oneof"`
}

type ErrorMessage_RetryChunk 

type ErrorMessage_RetryChunk struct {
	RetryChunk *RetryChunkMessage `protobuf:"bytes,1,opt,name=retry_chunk,json=retryChunk,proto3,oneof"`
}

type ErrorMessage_RetryObjectId 

type ErrorMessage_RetryObjectId struct {
	RetryObjectId string `protobuf:"bytes,3,opt,name=retry_object_id,json=retryObjectId,proto3,oneof"`
}

type GetCredentialsRequest 

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

func (*GetCredentialsRequest) Descriptor deprecated 

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

Deprecated: Use GetCredentialsRequest.ProtoReflect.Descriptor instead.

func (*GetCredentialsRequest) ProtoMessage 

func (*GetCredentialsRequest) ProtoMessage()

func (*GetCredentialsRequest) ProtoReflect 

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

func (*GetCredentialsRequest) Reset 

func (x *GetCredentialsRequest) Reset()

func (*GetCredentialsRequest) String 

func (x *GetCredentialsRequest) String() string

type GetCredentialsResponse 

type GetCredentialsResponse struct {
	AccessKey string `protobuf:"bytes,1,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey string `protobuf:"bytes,2,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCredentialsResponse) Descriptor deprecated 

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

Deprecated: Use GetCredentialsResponse.ProtoReflect.Descriptor instead.

func (*GetCredentialsResponse) GetAccessKey 

func (x *GetCredentialsResponse) GetAccessKey() string

func (*GetCredentialsResponse) GetSecretKey 

func (x *GetCredentialsResponse) GetSecretKey() string

func (*GetCredentialsResponse) ProtoMessage 

func (*GetCredentialsResponse) ProtoMessage()

func (*GetCredentialsResponse) ProtoReflect 

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

func (*GetCredentialsResponse) Reset 

func (x *GetCredentialsResponse) Reset()

func (*GetCredentialsResponse) String 

func (x *GetCredentialsResponse) String() string

type GetObjectRequest 

type GetObjectRequest struct {
	Location *ObjectLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectRequest.ProtoReflect.Descriptor instead.

func (*GetObjectRequest) GetLocation 

func (x *GetObjectRequest) GetLocation() *ObjectLocation

func (*GetObjectRequest) ProtoMessage 

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) ProtoReflect 

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

func (*GetObjectRequest) Reset 

func (x *GetObjectRequest) Reset()

func (*GetObjectRequest) String 

func (x *GetObjectRequest) String() string

type GetObjectResponse 

type GetObjectResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectResponse.ProtoReflect.Descriptor instead.

func (*GetObjectResponse) GetData 

func (x *GetObjectResponse) GetData() []byte

func (*GetObjectResponse) ProtoMessage 

func (*GetObjectResponse) ProtoMessage()

func (*GetObjectResponse) ProtoReflect 

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

func (*GetObjectResponse) Reset 

func (x *GetObjectResponse) Reset()

func (*GetObjectResponse) String 

func (x *GetObjectResponse) String() string

type HeadObjectRequest 

type HeadObjectRequest struct {
	Location *ObjectLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*HeadObjectRequest) Descriptor deprecated 

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

Deprecated: Use HeadObjectRequest.ProtoReflect.Descriptor instead.

func (*HeadObjectRequest) GetLocation 

func (x *HeadObjectRequest) GetLocation() *ObjectLocation

func (*HeadObjectRequest) ProtoMessage 

func (*HeadObjectRequest) ProtoMessage()

func (*HeadObjectRequest) ProtoReflect 

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

func (*HeadObjectRequest) Reset 

func (x *HeadObjectRequest) Reset()

func (*HeadObjectRequest) String 

func (x *HeadObjectRequest) String() string

type HeadObjectResponse 

type HeadObjectResponse struct {
	ContentLength string `protobuf:"bytes,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	Exists        bool   `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*HeadObjectResponse) Descriptor deprecated 

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

Deprecated: Use HeadObjectResponse.ProtoReflect.Descriptor instead.

func (*HeadObjectResponse) GetContentLength 

func (x *HeadObjectResponse) GetContentLength() string

func (*HeadObjectResponse) GetExists 

func (x *HeadObjectResponse) GetExists() bool

func (*HeadObjectResponse) ProtoMessage 

func (*HeadObjectResponse) ProtoMessage()

func (*HeadObjectResponse) ProtoReflect 

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

func (*HeadObjectResponse) Reset 

func (x *HeadObjectResponse) Reset()

func (*HeadObjectResponse) String 

func (x *HeadObjectResponse) String() string

type InfoAckMessage 

type InfoAckMessage struct {
	ObjectId string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoAckMessage) Descriptor deprecated 

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

Deprecated: Use InfoAckMessage.ProtoReflect.Descriptor instead.

func (*InfoAckMessage) GetObjectId 

func (x *InfoAckMessage) GetObjectId() string

func (*InfoAckMessage) ProtoMessage 

func (*InfoAckMessage) ProtoMessage()

func (*InfoAckMessage) ProtoReflect 

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

func (*InfoAckMessage) Reset 

func (x *InfoAckMessage) Reset()

func (*InfoAckMessage) String 

func (x *InfoAckMessage) String() string

type IngestExistingObjectRequest 

type IngestExistingObjectRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Types that are assignable to Collection:
	//
	//	*IngestExistingObjectRequest_CollectionId
	//	*IngestExistingObjectRequest_CollectionResource
	Collection isIngestExistingObjectRequest_Collection `protobuf_oneof:"collection"`
	// Types that are assignable to Dataset:
	//
	//	*IngestExistingObjectRequest_DatasetId
	//	*IngestExistingObjectRequest_DatasetResource
	Dataset isIngestExistingObjectRequest_Dataset `protobuf_oneof:"dataset"`
	Object  *IngestResource                       `protobuf:"bytes,6,opt,name=object,proto3" json:"object,omitempty"`
	Path    string                                `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"` // "s3://bucket/key" or "file:///foo/bar/baz.txt" must be a valid file
	// contains filtered or unexported fields
}

func (*IngestExistingObjectRequest) Descriptor deprecated 

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

Deprecated: Use IngestExistingObjectRequest.ProtoReflect.Descriptor instead.

func (*IngestExistingObjectRequest) GetCollection 

func (m *IngestExistingObjectRequest) GetCollection() isIngestExistingObjectRequest_Collection

func (*IngestExistingObjectRequest) GetCollectionId 

func (x *IngestExistingObjectRequest) GetCollectionId() string

func (*IngestExistingObjectRequest) GetCollectionResource 

func (x *IngestExistingObjectRequest) GetCollectionResource() *IngestResource

func (*IngestExistingObjectRequest) GetDataset 

func (m *IngestExistingObjectRequest) GetDataset() isIngestExistingObjectRequest_Dataset

func (*IngestExistingObjectRequest) GetDatasetId 

func (x *IngestExistingObjectRequest) GetDatasetId() string

func (*IngestExistingObjectRequest) GetDatasetResource 

func (x *IngestExistingObjectRequest) GetDatasetResource() *IngestResource

func (*IngestExistingObjectRequest) GetObject 

func (x *IngestExistingObjectRequest) GetObject() *IngestResource

func (*IngestExistingObjectRequest) GetPath 

func (x *IngestExistingObjectRequest) GetPath() string

func (*IngestExistingObjectRequest) GetProjectId 

func (x *IngestExistingObjectRequest) GetProjectId() string

func (*IngestExistingObjectRequest) ProtoMessage 

func (*IngestExistingObjectRequest) ProtoMessage()

func (*IngestExistingObjectRequest) ProtoReflect 

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

func (*IngestExistingObjectRequest) Reset 

func (x *IngestExistingObjectRequest) Reset()

func (*IngestExistingObjectRequest) String 

func (x *IngestExistingObjectRequest) String() string

type IngestExistingObjectRequest_CollectionId 

type IngestExistingObjectRequest_CollectionId struct {
	CollectionId string `protobuf:"bytes,2,opt,name=collection_id,json=collectionId,proto3,oneof"`
}

type IngestExistingObjectRequest_CollectionResource 

type IngestExistingObjectRequest_CollectionResource struct {
	CollectionResource *IngestResource `protobuf:"bytes,3,opt,name=collection_resource,json=collectionResource,proto3,oneof"`
}

type IngestExistingObjectRequest_DatasetId 

type IngestExistingObjectRequest_DatasetId struct {
	DatasetId string `protobuf:"bytes,4,opt,name=dataset_id,json=datasetId,proto3,oneof"`
}

type IngestExistingObjectRequest_DatasetResource 

type IngestExistingObjectRequest_DatasetResource struct {
	DatasetResource *IngestResource `protobuf:"bytes,5,opt,name=dataset_resource,json=datasetResource,proto3,oneof"`
}

type IngestExistingObjectResponse 

type IngestExistingObjectResponse struct {
	ObjectId string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestExistingObjectResponse) Descriptor deprecated 

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

Deprecated: Use IngestExistingObjectResponse.ProtoReflect.Descriptor instead.

func (*IngestExistingObjectResponse) GetObjectId 

func (x *IngestExistingObjectResponse) GetObjectId() string

func (*IngestExistingObjectResponse) ProtoMessage 

func (*IngestExistingObjectResponse) ProtoMessage()

func (*IngestExistingObjectResponse) ProtoReflect 

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

func (*IngestExistingObjectResponse) Reset 

func (x *IngestExistingObjectResponse) Reset()

func (*IngestExistingObjectResponse) String 

func (x *IngestExistingObjectResponse) String() string

type IngestResource 

type IngestResource struct {

	// object name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// title
	Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	// description
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Authors
	Authors []*v2.Author `protobuf:"bytes,4,rep,name=authors,proto3" json:"authors,omitempty"`
	// object specific labels / hooks
	KeyValues []*v2.KeyValue `protobuf:"bytes,5,rep,name=key_values,json=keyValues,proto3" json:"key_values,omitempty"`
	// Internal / External relations (URLs / IDs from external sources)
	Relations []*v2.Relation `protobuf:"bytes,6,rep,name=relations,proto3" json:"relations,omitempty"`
	// DataClass
	DataClass v2.DataClass `` /* 132-byte string literal not displayed */
	// Ignored if Collection | Dataset
	Hashes             []*v2.Hash `protobuf:"bytes,8,rep,name=hashes,proto3" json:"hashes,omitempty"`
	MetadataLicenseTag string     `protobuf:"bytes,9,opt,name=metadata_license_tag,json=metadataLicenseTag,proto3" json:"metadata_license_tag,omitempty"`
	DataLicenseTag     string     `protobuf:"bytes,10,opt,name=data_license_tag,json=dataLicenseTag,proto3" json:"data_license_tag,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestResource) Descriptor deprecated 

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

Deprecated: Use IngestResource.ProtoReflect.Descriptor instead.

func (*IngestResource) GetAuthors 

func (x *IngestResource) GetAuthors() []*v2.Author

func (*IngestResource) GetDataClass 

func (x *IngestResource) GetDataClass() v2.DataClass

func (*IngestResource) GetDataLicenseTag 

func (x *IngestResource) GetDataLicenseTag() string

func (*IngestResource) GetDescription 

func (x *IngestResource) GetDescription() string

func (*IngestResource) GetHashes 

func (x *IngestResource) GetHashes() []*v2.Hash

func (*IngestResource) GetKeyValues 

func (x *IngestResource) GetKeyValues() []*v2.KeyValue

func (*IngestResource) GetMetadataLicenseTag 

func (x *IngestResource) GetMetadataLicenseTag() string

func (*IngestResource) GetName 

func (x *IngestResource) GetName() string

func (*IngestResource) GetRelations 

func (x *IngestResource) GetRelations() []*v2.Relation

func (*IngestResource) GetTitle 

func (x *IngestResource) GetTitle() string

func (*IngestResource) ProtoMessage 

func (*IngestResource) ProtoMessage()

func (*IngestResource) ProtoReflect 

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

func (*IngestResource) Reset 

func (x *IngestResource) Reset()

func (*IngestResource) String 

func (x *IngestResource) String() string

type InitLocationRequest 

type InitLocationRequest struct {
	ObjectName  string `protobuf:"bytes,1,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	Size        int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	IsTemporary bool   `protobuf:"varint,3,opt,name=is_temporary,json=isTemporary,proto3" json:"is_temporary,omitempty"`
	// contains filtered or unexported fields
}

func (*InitLocationRequest) Descriptor deprecated 

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

Deprecated: Use InitLocationRequest.ProtoReflect.Descriptor instead.

func (*InitLocationRequest) GetIsTemporary 

func (x *InitLocationRequest) GetIsTemporary() bool

func (*InitLocationRequest) GetObjectName 

func (x *InitLocationRequest) GetObjectName() string

func (*InitLocationRequest) GetSize 

func (x *InitLocationRequest) GetSize() int64

func (*InitLocationRequest) ProtoMessage 

func (*InitLocationRequest) ProtoMessage()

func (*InitLocationRequest) ProtoReflect 

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

func (*InitLocationRequest) Reset 

func (x *InitLocationRequest) Reset()

func (*InitLocationRequest) String 

func (x *InitLocationRequest) String() string

type InitLocationResponse 

type InitLocationResponse struct {
	Location *ObjectLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*InitLocationResponse) Descriptor deprecated 

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

Deprecated: Use InitLocationResponse.ProtoReflect.Descriptor instead.

func (*InitLocationResponse) GetLocation 

func (x *InitLocationResponse) GetLocation() *ObjectLocation

func (*InitLocationResponse) ProtoMessage 

func (*InitLocationResponse) ProtoMessage()

func (*InitLocationResponse) ProtoReflect 

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

func (*InitLocationResponse) Reset 

func (x *InitLocationResponse) Reset()

func (*InitLocationResponse) String 

func (x *InitLocationResponse) String() string

type InitMessage 

type InitMessage struct {
	DataproxyId string   `protobuf:"bytes,1,opt,name=dataproxy_id,json=dataproxyId,proto3" json:"dataproxy_id,omitempty"`
	ObjectIds   []string `protobuf:"bytes,2,rep,name=object_ids,json=objectIds,proto3" json:"object_ids,omitempty"`
	// contains filtered or unexported fields
}

Messages (requests) from PROXY B

func (*InitMessage) Descriptor deprecated 

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

Deprecated: Use InitMessage.ProtoReflect.Descriptor instead.

func (*InitMessage) GetDataproxyId 

func (x *InitMessage) GetDataproxyId() string

func (*InitMessage) GetObjectIds 

func (x *InitMessage) GetObjectIds() []string

func (*InitMessage) ProtoMessage 

func (*InitMessage) ProtoMessage()

func (*InitMessage) ProtoReflect 

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

func (*InitMessage) Reset 

func (x *InitMessage) Reset()

func (*InitMessage) String 

func (x *InitMessage) String() string

type InitMultiPartUploadRequest 

type InitMultiPartUploadRequest struct {
	Location *ObjectLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*InitMultiPartUploadRequest) Descriptor deprecated 

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

Deprecated: Use InitMultiPartUploadRequest.ProtoReflect.Descriptor instead.

func (*InitMultiPartUploadRequest) GetLocation 

func (x *InitMultiPartUploadRequest) GetLocation() *ObjectLocation

func (*InitMultiPartUploadRequest) ProtoMessage 

func (*InitMultiPartUploadRequest) ProtoMessage()

func (*InitMultiPartUploadRequest) ProtoReflect 

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

func (*InitMultiPartUploadRequest) Reset 

func (x *InitMultiPartUploadRequest) Reset()

func (*InitMultiPartUploadRequest) String 

func (x *InitMultiPartUploadRequest) String() string

type InitMultiPartUploadResponse 

type InitMultiPartUploadResponse struct {
	UploadId string `protobuf:"bytes,1,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InitMultiPartUploadResponse) Descriptor deprecated 

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

Deprecated: Use InitMultiPartUploadResponse.ProtoReflect.Descriptor instead.

func (*InitMultiPartUploadResponse) GetUploadId 

func (x *InitMultiPartUploadResponse) GetUploadId() string

func (*InitMultiPartUploadResponse) ProtoMessage 

func (*InitMultiPartUploadResponse) ProtoMessage()

func (*InitMultiPartUploadResponse) ProtoReflect 

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

func (*InitMultiPartUploadResponse) Reset 

func (x *InitMultiPartUploadResponse) Reset()

func (*InitMultiPartUploadResponse) String 

func (x *InitMultiPartUploadResponse) String() string

type ObjectInfo 

type ObjectInfo struct {
	ObjectId       string  `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	Chunks         int64   `protobuf:"varint,2,opt,name=chunks,proto3" json:"chunks,omitempty"` // == (Compressed_size / (65536 + 28)) + 1
	RawSize        int64   `protobuf:"varint,3,opt,name=raw_size,json=rawSize,proto3" json:"raw_size,omitempty"`
	CompressedSize int64   `protobuf:"varint,4,opt,name=compressed_size,json=compressedSize,proto3" json:"compressed_size,omitempty"`
	Extra          *string `protobuf:"bytes,5,opt,name=extra,proto3,oneof" json:"extra,omitempty"` // JSON encoded proxy specific extra fields
	// contains filtered or unexported fields
}

Messages (responses) from PROXY A

func (*ObjectInfo) Descriptor deprecated 

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

Deprecated: Use ObjectInfo.ProtoReflect.Descriptor instead.

func (*ObjectInfo) GetChunks 

func (x *ObjectInfo) GetChunks() int64

func (*ObjectInfo) GetCompressedSize 

func (x *ObjectInfo) GetCompressedSize() int64

func (*ObjectInfo) GetExtra 

func (x *ObjectInfo) GetExtra() string

func (*ObjectInfo) GetObjectId 

func (x *ObjectInfo) GetObjectId() string

func (*ObjectInfo) GetRawSize 

func (x *ObjectInfo) GetRawSize() int64

func (*ObjectInfo) ProtoMessage 

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) ProtoReflect 

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

func (*ObjectInfo) Reset 

func (x *ObjectInfo) Reset()

func (*ObjectInfo) String 

func (x *ObjectInfo) String() string

type ObjectLocation 

type ObjectLocation struct {
	Bucket        string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key           string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	UploadId      string `protobuf:"bytes,3,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	ContentLength string `protobuf:"bytes,4,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectLocation) Descriptor deprecated 

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

Deprecated: Use ObjectLocation.ProtoReflect.Descriptor instead.

func (*ObjectLocation) GetBucket 

func (x *ObjectLocation) GetBucket() string

func (*ObjectLocation) GetContentLength 

func (x *ObjectLocation) GetContentLength() string

func (*ObjectLocation) GetKey 

func (x *ObjectLocation) GetKey() string

func (*ObjectLocation) GetUploadId 

func (x *ObjectLocation) GetUploadId() string

func (*ObjectLocation) ProtoMessage 

func (*ObjectLocation) ProtoMessage()

func (*ObjectLocation) ProtoReflect 

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

func (*ObjectLocation) Reset 

func (x *ObjectLocation) Reset()

func (*ObjectLocation) String 

func (x *ObjectLocation) String() string

type PullReplicaRequest 

type PullReplicaRequest struct {

	// Types that are assignable to Resource:
	//
	//	*PullReplicaRequest_ResourceId
	//	*PullReplicaRequest_S3Path
	Resource isPullReplicaRequest_Resource `protobuf_oneof:"resource"`
	// contains filtered or unexported fields
}

func (*PullReplicaRequest) Descriptor deprecated 

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

Deprecated: Use PullReplicaRequest.ProtoReflect.Descriptor instead.

func (*PullReplicaRequest) GetResource 

func (m *PullReplicaRequest) GetResource() isPullReplicaRequest_Resource

func (*PullReplicaRequest) GetResourceId 

func (x *PullReplicaRequest) GetResourceId() string

func (*PullReplicaRequest) GetS3Path 

func (x *PullReplicaRequest) GetS3Path() *S3Path

func (*PullReplicaRequest) ProtoMessage 

func (*PullReplicaRequest) ProtoMessage()

func (*PullReplicaRequest) ProtoReflect 

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

func (*PullReplicaRequest) Reset 

func (x *PullReplicaRequest) Reset()

func (*PullReplicaRequest) String 

func (x *PullReplicaRequest) String() string

type PullReplicaRequest_ResourceId 

type PullReplicaRequest_ResourceId struct {
	ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3,oneof"`
}

type PullReplicaRequest_S3Path 

type PullReplicaRequest_S3Path struct {
	S3Path *S3Path `protobuf:"bytes,2,opt,name=s3_path,json=s3Path,proto3,oneof"`
}

type PullReplicaResponse 

type PullReplicaResponse struct {
	ReplicationId string `protobuf:"bytes,1,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"` // why ?
	// contains filtered or unexported fields
}

func (*PullReplicaResponse) Descriptor deprecated 

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

Deprecated: Use PullReplicaResponse.ProtoReflect.Descriptor instead.

func (*PullReplicaResponse) GetReplicationId 

func (x *PullReplicaResponse) GetReplicationId() string

func (*PullReplicaResponse) ProtoMessage 

func (*PullReplicaResponse) ProtoMessage()

func (*PullReplicaResponse) ProtoReflect 

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

func (*PullReplicaResponse) Reset 

func (x *PullReplicaResponse) Reset()

func (*PullReplicaResponse) String 

func (x *PullReplicaResponse) String() string

type PullReplicationRequest 

type PullReplicationRequest struct {

	// Types that are assignable to Message:
	//
	//	*PullReplicationRequest_InitMessage
	//	*PullReplicationRequest_InfoAckMessage
	//	*PullReplicationRequest_ChunkAckMessage
	//	*PullReplicationRequest_ErrorMessage
	//	*PullReplicationRequest_FinishMessage
	Message isPullReplicationRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*PullReplicationRequest) Descriptor deprecated 

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

Deprecated: Use PullReplicationRequest.ProtoReflect.Descriptor instead.

func (*PullReplicationRequest) GetChunkAckMessage 

func (x *PullReplicationRequest) GetChunkAckMessage() *ChunkAckMessage

func (*PullReplicationRequest) GetErrorMessage 

func (x *PullReplicationRequest) GetErrorMessage() *ErrorMessage

func (*PullReplicationRequest) GetFinishMessage 

func (x *PullReplicationRequest) GetFinishMessage() *Empty

func (*PullReplicationRequest) GetInfoAckMessage 

func (x *PullReplicationRequest) GetInfoAckMessage() *InfoAckMessage

func (*PullReplicationRequest) GetInitMessage 

func (x *PullReplicationRequest) GetInitMessage() *InitMessage

func (*PullReplicationRequest) GetMessage 

func (m *PullReplicationRequest) GetMessage() isPullReplicationRequest_Message

func (*PullReplicationRequest) ProtoMessage 

func (*PullReplicationRequest) ProtoMessage()

func (*PullReplicationRequest) ProtoReflect 

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

func (*PullReplicationRequest) Reset 

func (x *PullReplicationRequest) Reset()

func (*PullReplicationRequest) String 

func (x *PullReplicationRequest) String() string

type PullReplicationRequest_ChunkAckMessage 

type PullReplicationRequest_ChunkAckMessage struct {
	ChunkAckMessage *ChunkAckMessage `protobuf:"bytes,3,opt,name=chunk_ack_message,json=chunkAckMessage,proto3,oneof"`
}

type PullReplicationRequest_ErrorMessage 

type PullReplicationRequest_ErrorMessage struct {
	ErrorMessage *ErrorMessage `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3,oneof"`
}

type PullReplicationRequest_FinishMessage 

type PullReplicationRequest_FinishMessage struct {
	FinishMessage *Empty `protobuf:"bytes,5,opt,name=finish_message,json=finishMessage,proto3,oneof"`
}

type PullReplicationRequest_InfoAckMessage 

type PullReplicationRequest_InfoAckMessage struct {
	InfoAckMessage *InfoAckMessage `protobuf:"bytes,2,opt,name=info_ack_message,json=infoAckMessage,proto3,oneof"`
}

type PullReplicationRequest_InitMessage 

type PullReplicationRequest_InitMessage struct {
	InitMessage *InitMessage `protobuf:"bytes,1,opt,name=init_message,json=initMessage,proto3,oneof"`
}

type PullReplicationResponse 

type PullReplicationResponse struct {

	// Types that are assignable to Message:
	//
	//	*PullReplicationResponse_ObjectInfo
	//	*PullReplicationResponse_Chunk
	//	*PullReplicationResponse_FinishMessage
	Message isPullReplicationResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*PullReplicationResponse) Descriptor deprecated 

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

Deprecated: Use PullReplicationResponse.ProtoReflect.Descriptor instead.

func (*PullReplicationResponse) GetChunk 

func (x *PullReplicationResponse) GetChunk() *Chunk

func (*PullReplicationResponse) GetFinishMessage 

func (x *PullReplicationResponse) GetFinishMessage() *Empty

func (*PullReplicationResponse) GetMessage 

func (m *PullReplicationResponse) GetMessage() isPullReplicationResponse_Message

func (*PullReplicationResponse) GetObjectInfo 

func (x *PullReplicationResponse) GetObjectInfo() *ObjectInfo

func (*PullReplicationResponse) ProtoMessage 

func (*PullReplicationResponse) ProtoMessage()

func (*PullReplicationResponse) ProtoReflect 

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

func (*PullReplicationResponse) Reset 

func (x *PullReplicationResponse) Reset()

func (*PullReplicationResponse) String 

func (x *PullReplicationResponse) String() string

type PullReplicationResponse_Chunk 

type PullReplicationResponse_Chunk struct {
	Chunk *Chunk `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"` // If no ack is received, the chunk will be resent
}

type PullReplicationResponse_FinishMessage 

type PullReplicationResponse_FinishMessage struct {
	FinishMessage *Empty `protobuf:"bytes,3,opt,name=finish_message,json=finishMessage,proto3,oneof"`
}

type PullReplicationResponse_ObjectInfo 

type PullReplicationResponse_ObjectInfo struct {
	ObjectInfo *ObjectInfo `protobuf:"bytes,1,opt,name=object_info,json=objectInfo,proto3,oneof"`
}

type PushReplicaRequest 

type PushReplicaRequest struct {

	// Types that are assignable to Resource:
	//
	//	*PushReplicaRequest_ResourceId
	//	*PushReplicaRequest_S3Path
	Resource         isPushReplicaRequest_Resource `protobuf_oneof:"resource"`
	TargetEndpointId string                        `protobuf:"bytes,3,opt,name=target_endpoint_id,json=targetEndpointId,proto3" json:"target_endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PushReplicaRequest) Descriptor deprecated 

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

Deprecated: Use PushReplicaRequest.ProtoReflect.Descriptor instead.

func (*PushReplicaRequest) GetResource 

func (m *PushReplicaRequest) GetResource() isPushReplicaRequest_Resource

func (*PushReplicaRequest) GetResourceId 

func (x *PushReplicaRequest) GetResourceId() string

func (*PushReplicaRequest) GetS3Path 

func (x *PushReplicaRequest) GetS3Path() *S3Path

func (*PushReplicaRequest) GetTargetEndpointId 

func (x *PushReplicaRequest) GetTargetEndpointId() string

func (*PushReplicaRequest) ProtoMessage 

func (*PushReplicaRequest) ProtoMessage()

func (*PushReplicaRequest) ProtoReflect 

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

func (*PushReplicaRequest) Reset 

func (x *PushReplicaRequest) Reset()

func (*PushReplicaRequest) String 

func (x *PushReplicaRequest) String() string

type PushReplicaRequest_ResourceId 

type PushReplicaRequest_ResourceId struct {
	ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3,oneof"`
}

type PushReplicaRequest_S3Path 

type PushReplicaRequest_S3Path struct {
	S3Path *S3Path `protobuf:"bytes,2,opt,name=s3_path,json=s3Path,proto3,oneof"`
}

type PushReplicaResponse 

type PushReplicaResponse struct {
	ReplicationId string `protobuf:"bytes,1,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PushReplicaResponse) Descriptor deprecated 

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

Deprecated: Use PushReplicaResponse.ProtoReflect.Descriptor instead.

func (*PushReplicaResponse) GetReplicationId 

func (x *PushReplicaResponse) GetReplicationId() string

func (*PushReplicaResponse) ProtoMessage 

func (*PushReplicaResponse) ProtoMessage()

func (*PushReplicaResponse) ProtoReflect 

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

func (*PushReplicaResponse) Reset 

func (x *PushReplicaResponse) Reset()

func (*PushReplicaResponse) String 

func (x *PushReplicaResponse) String() string

type PushReplicationRequest 

type PushReplicationRequest struct {
	DataInfos *DataInfos `protobuf:"bytes,1,opt,name=data_infos,json=dataInfos,proto3" json:"data_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*PushReplicationRequest) Descriptor deprecated 

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

Deprecated: Use PushReplicationRequest.ProtoReflect.Descriptor instead.

func (*PushReplicationRequest) GetDataInfos 

func (x *PushReplicationRequest) GetDataInfos() *DataInfos

func (*PushReplicationRequest) ProtoMessage 

func (*PushReplicationRequest) ProtoMessage()

func (*PushReplicationRequest) ProtoReflect 

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

func (*PushReplicationRequest) Reset 

func (x *PushReplicationRequest) Reset()

func (*PushReplicationRequest) String 

func (x *PushReplicationRequest) String() string

type PushReplicationResponse 

type PushReplicationResponse struct {
	Ack bool `protobuf:"varint,1,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

func (*PushReplicationResponse) Descriptor deprecated 

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

Deprecated: Use PushReplicationResponse.ProtoReflect.Descriptor instead.

func (*PushReplicationResponse) GetAck 

func (x *PushReplicationResponse) GetAck() bool

func (*PushReplicationResponse) ProtoMessage 

func (*PushReplicationResponse) ProtoMessage()

func (*PushReplicationResponse) ProtoReflect 

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

func (*PushReplicationResponse) Reset 

func (x *PushReplicationResponse) Reset()

func (*PushReplicationResponse) String 

func (x *PushReplicationResponse) String() string

type PutObjectRequest 

type PutObjectRequest struct {
	Location *ObjectLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	Data     []byte          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PutObjectRequest) Descriptor deprecated 

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

Deprecated: Use PutObjectRequest.ProtoReflect.Descriptor instead.

func (*PutObjectRequest) GetData 

func (x *PutObjectRequest) GetData() []byte

func (*PutObjectRequest) GetLocation 

func (x *PutObjectRequest) GetLocation() *ObjectLocation

func (*PutObjectRequest) ProtoMessage 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) ProtoReflect 

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

func (*PutObjectRequest) Reset 

func (x *PutObjectRequest) Reset()

func (*PutObjectRequest) String 

func (x *PutObjectRequest) String() string

type PutObjectResponse 

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

func (*PutObjectResponse) Descriptor deprecated 

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

Deprecated: Use PutObjectResponse.ProtoReflect.Descriptor instead.

func (*PutObjectResponse) ProtoMessage 

func (*PutObjectResponse) ProtoMessage()

func (*PutObjectResponse) ProtoReflect 

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

func (*PutObjectResponse) Reset 

func (x *PutObjectResponse) Reset()

func (*PutObjectResponse) String 

func (x *PutObjectResponse) String() string

type ReplicationStatus 

type ReplicationStatus int32
const (
	ReplicationStatus_REPLICATION_STATUS_UNSPECIFIED ReplicationStatus = 0
	ReplicationStatus_REPLICATION_STATUS_PENDING     ReplicationStatus = 1
	ReplicationStatus_REPLICATION_STATUS_RUNNING     ReplicationStatus = 2
	ReplicationStatus_REPLICATION_STATUS_FINISHED    ReplicationStatus = 3
	ReplicationStatus_REPLICATION_STATUS_ERROR       ReplicationStatus = 4
)

func (ReplicationStatus) Descriptor 

func (ReplicationStatus) Descriptor() protoreflect.EnumDescriptor

func (ReplicationStatus) Enum 

func (x ReplicationStatus) Enum() *ReplicationStatus

func (ReplicationStatus) EnumDescriptor deprecated 

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

Deprecated: Use ReplicationStatus.Descriptor instead.

func (ReplicationStatus) Number 

func (x ReplicationStatus) Number() protoreflect.EnumNumber

func (ReplicationStatus) String 

func (x ReplicationStatus) String() string

func (ReplicationStatus) Type 

func (ReplicationStatus) Type() protoreflect.EnumType

type ReplicationStatusRequest 

type ReplicationStatusRequest struct {
	ReplicationId string `protobuf:"bytes,1,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"` // why ?
	// contains filtered or unexported fields
}

func (*ReplicationStatusRequest) Descriptor deprecated 

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

Deprecated: Use ReplicationStatusRequest.ProtoReflect.Descriptor instead.

func (*ReplicationStatusRequest) GetReplicationId 

func (x *ReplicationStatusRequest) GetReplicationId() string

func (*ReplicationStatusRequest) ProtoMessage 

func (*ReplicationStatusRequest) ProtoMessage()

func (*ReplicationStatusRequest) ProtoReflect 

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

func (*ReplicationStatusRequest) Reset 

func (x *ReplicationStatusRequest) Reset()

func (*ReplicationStatusRequest) String 

func (x *ReplicationStatusRequest) String() string

type ReplicationStatusResponse 

type ReplicationStatusResponse struct {
	Status  ReplicationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=aruna.api.dataproxy.services.v2.ReplicationStatus" json:"status,omitempty"`
	Message string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationStatusResponse) Descriptor deprecated 

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

Deprecated: Use ReplicationStatusResponse.ProtoReflect.Descriptor instead.

func (*ReplicationStatusResponse) GetMessage 

func (x *ReplicationStatusResponse) GetMessage() string

func (*ReplicationStatusResponse) GetStatus 

func (x *ReplicationStatusResponse) GetStatus() ReplicationStatus

func (*ReplicationStatusResponse) ProtoMessage 

func (*ReplicationStatusResponse) ProtoMessage()

func (*ReplicationStatusResponse) ProtoReflect 

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

func (*ReplicationStatusResponse) Reset 

func (x *ReplicationStatusResponse) Reset()

func (*ReplicationStatusResponse) String 

func (x *ReplicationStatusResponse) String() string

type RetryChunkMessage 

type RetryChunkMessage struct {
	ObjectId string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	ChunkIdx int64  `protobuf:"varint,2,opt,name=chunk_idx,json=chunkIdx,proto3" json:"chunk_idx,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryChunkMessage) Descriptor deprecated 

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

Deprecated: Use RetryChunkMessage.ProtoReflect.Descriptor instead.

func (*RetryChunkMessage) GetChunkIdx 

func (x *RetryChunkMessage) GetChunkIdx() int64

func (*RetryChunkMessage) GetObjectId 

func (x *RetryChunkMessage) GetObjectId() string

func (*RetryChunkMessage) ProtoMessage 

func (*RetryChunkMessage) ProtoMessage()

func (*RetryChunkMessage) ProtoReflect 

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

func (*RetryChunkMessage) Reset 

func (x *RetryChunkMessage) Reset()

func (*RetryChunkMessage) String 

func (x *RetryChunkMessage) String() string

type RevokeCredentialsRequest 

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

func (*RevokeCredentialsRequest) Descriptor deprecated 

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

Deprecated: Use RevokeCredentialsRequest.ProtoReflect.Descriptor instead.

func (*RevokeCredentialsRequest) ProtoMessage 

func (*RevokeCredentialsRequest) ProtoMessage()

func (*RevokeCredentialsRequest) ProtoReflect 

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

func (*RevokeCredentialsRequest) Reset 

func (x *RevokeCredentialsRequest) Reset()

func (*RevokeCredentialsRequest) String 

func (x *RevokeCredentialsRequest) String() string

type RevokeCredentialsResponse 

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

func (*RevokeCredentialsResponse) Descriptor deprecated 

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

Deprecated: Use RevokeCredentialsResponse.ProtoReflect.Descriptor instead.

func (*RevokeCredentialsResponse) ProtoMessage 

func (*RevokeCredentialsResponse) ProtoMessage()

func (*RevokeCredentialsResponse) ProtoReflect 

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

func (*RevokeCredentialsResponse) Reset 

func (x *RevokeCredentialsResponse) Reset()

func (*RevokeCredentialsResponse) String 

func (x *RevokeCredentialsResponse) String() string

type S3Path 

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

func (*S3Path) Descriptor deprecated 

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

Deprecated: Use S3Path.ProtoReflect.Descriptor instead.

func (*S3Path) GetBucket 

func (x *S3Path) GetBucket() string

func (*S3Path) GetKey 

func (x *S3Path) GetKey() string

func (*S3Path) ProtoMessage 

func (*S3Path) ProtoMessage()

func (*S3Path) ProtoReflect 

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

func (*S3Path) Reset 

func (x *S3Path) Reset()

func (*S3Path) String 

func (x *S3Path) String() string

type UnimplementedBundlerServiceServer 

type UnimplementedBundlerServiceServer struct {
}

UnimplementedBundlerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBundlerServiceServer) CreateBundle 

func (UnimplementedBundlerServiceServer) CreateBundle(context.Context, *CreateBundleRequest) (*CreateBundleResponse, error)

func (UnimplementedBundlerServiceServer) DeleteBundle 

func (UnimplementedBundlerServiceServer) DeleteBundle(context.Context, *DeleteBundleRequest) (*DeleteBundleResponse, error)

type UnimplementedDataproxyBackendServiceServer 

type UnimplementedDataproxyBackendServiceServer struct {
}

UnimplementedDataproxyBackendServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataproxyBackendServiceServer) CompleteMultiPartUpload 

func (UnimplementedDataproxyBackendServiceServer) CompleteMultiPartUpload(context.Context, *CompleteMultiPartUploadRequest) (*CompleteMultiPartUploadResponse, error)

func (UnimplementedDataproxyBackendServiceServer) CreateBucket 

func (UnimplementedDataproxyBackendServiceServer) CreateBucket(context.Context, *CreateBucketRequest) (*CreateBucketResponse, error)

func (UnimplementedDataproxyBackendServiceServer) DeleteBucket 

func (UnimplementedDataproxyBackendServiceServer) DeleteBucket(context.Context, *DeleteBucketRequest) (*DeleteBucketResponse, error)

func (UnimplementedDataproxyBackendServiceServer) DeleteObject 

func (UnimplementedDataproxyBackendServiceServer) DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)

func (UnimplementedDataproxyBackendServiceServer) GetObject 

func (UnimplementedDataproxyBackendServiceServer) GetObject(*GetObjectRequest, DataproxyBackendService_GetObjectServer) error

func (UnimplementedDataproxyBackendServiceServer) HeadObject 

func (UnimplementedDataproxyBackendServiceServer) HeadObject(context.Context, *HeadObjectRequest) (*HeadObjectResponse, error)

func (UnimplementedDataproxyBackendServiceServer) InitLocation 

func (UnimplementedDataproxyBackendServiceServer) InitLocation(context.Context, *InitLocationRequest) (*InitLocationResponse, error)

func (UnimplementedDataproxyBackendServiceServer) InitMultiPartUpload 

func (UnimplementedDataproxyBackendServiceServer) InitMultiPartUpload(context.Context, *InitMultiPartUploadRequest) (*InitMultiPartUploadResponse, error)

func (UnimplementedDataproxyBackendServiceServer) PutObject 

func (UnimplementedDataproxyBackendServiceServer) PutObject(DataproxyBackendService_PutObjectServer) error

func (UnimplementedDataproxyBackendServiceServer) UploadPart 

func (UnimplementedDataproxyBackendServiceServer) UploadPart(DataproxyBackendService_UploadPartServer) error

type UnimplementedDataproxyIngestionServiceServer 

type UnimplementedDataproxyIngestionServiceServer struct {
}

UnimplementedDataproxyIngestionServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataproxyIngestionServiceServer) IngestExistingObject 

func (UnimplementedDataproxyIngestionServiceServer) IngestExistingObject(context.Context, *IngestExistingObjectRequest) (*IngestExistingObjectResponse, error)

type UnimplementedDataproxyReplicationServiceServer 

type UnimplementedDataproxyReplicationServiceServer struct {
}

UnimplementedDataproxyReplicationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataproxyReplicationServiceServer) PullReplication 

func (UnimplementedDataproxyReplicationServiceServer) PullReplication(DataproxyReplicationService_PullReplicationServer) error

func (UnimplementedDataproxyReplicationServiceServer) PushReplication 

func (UnimplementedDataproxyReplicationServiceServer) PushReplication(context.Context, *PushReplicationRequest) (*PushReplicationResponse, error)

type UnimplementedDataproxyUserServiceServer 

type UnimplementedDataproxyUserServiceServer struct {
}

UnimplementedDataproxyUserServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataproxyUserServiceServer) CreateOrUpdateCredentials 

func (UnimplementedDataproxyUserServiceServer) CreateOrUpdateCredentials(context.Context, *CreateOrUpdateCredentialsRequest) (*CreateOrUpdateCredentialsResponse, error)

func (UnimplementedDataproxyUserServiceServer) GetCredentials 

func (UnimplementedDataproxyUserServiceServer) GetCredentials(context.Context, *GetCredentialsRequest) (*GetCredentialsResponse, error)

func (UnimplementedDataproxyUserServiceServer) PullReplica 

func (UnimplementedDataproxyUserServiceServer) PullReplica(context.Context, *PullReplicaRequest) (*PullReplicaResponse, error)

func (UnimplementedDataproxyUserServiceServer) PushReplica 

func (UnimplementedDataproxyUserServiceServer) PushReplica(context.Context, *PushReplicaRequest) (*PushReplicaResponse, error)

func (UnimplementedDataproxyUserServiceServer) ReplicationStatus 

func (UnimplementedDataproxyUserServiceServer) ReplicationStatus(context.Context, *ReplicationStatusRequest) (*ReplicationStatusResponse, error)

func (UnimplementedDataproxyUserServiceServer) RevokeCredentials 

func (UnimplementedDataproxyUserServiceServer) RevokeCredentials(context.Context, *RevokeCredentialsRequest) (*RevokeCredentialsResponse, error)

type UnsafeBundlerServiceServer 

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

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

type UnsafeDataproxyBackendServiceServer 

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

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

type UnsafeDataproxyIngestionServiceServer 

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

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

type UnsafeDataproxyReplicationServiceServer 

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

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

type UnsafeDataproxyUserServiceServer 

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

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

type UploadPartRequest 

type UploadPartRequest struct {
	Location   *ObjectLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	PartNumber int32           `protobuf:"varint,3,opt,name=part_number,json=partNumber,proto3" json:"part_number,omitempty"`
	Data       []byte          `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadPartRequest) Descriptor deprecated 

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

Deprecated: Use UploadPartRequest.ProtoReflect.Descriptor instead.

func (*UploadPartRequest) GetData 

func (x *UploadPartRequest) GetData() []byte

func (*UploadPartRequest) GetLocation 

func (x *UploadPartRequest) GetLocation() *ObjectLocation

func (*UploadPartRequest) GetPartNumber 

func (x *UploadPartRequest) GetPartNumber() int32

func (*UploadPartRequest) ProtoMessage 

func (*UploadPartRequest) ProtoMessage()

func (*UploadPartRequest) ProtoReflect 

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

func (*UploadPartRequest) Reset 

func (x *UploadPartRequest) Reset()

func (*UploadPartRequest) String 

func (x *UploadPartRequest) String() string

type UploadPartResponse 

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

func (*UploadPartResponse) Descriptor deprecated 

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

Deprecated: Use UploadPartResponse.ProtoReflect.Descriptor instead.

func (*UploadPartResponse) GetEtag 

func (x *UploadPartResponse) GetEtag() string

func (*UploadPartResponse) ProtoMessage 

func (*UploadPartResponse) ProtoMessage()

func (*UploadPartResponse) ProtoReflect 

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

func (*UploadPartResponse) Reset 

func (x *UploadPartResponse) Reset()

func (*UploadPartResponse) String 

func (x *UploadPartResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.