Lines Matching defs:Endpoint

69 type Endpoint struct {  struct
70 	pb.DRPCMetainfoUnimplementedServer
72 	log                  *zap.Logger
73 	buckets              *buckets.Service
74 	metabase             *metabase.DB
75 	deletePieces         *piecedeletion.Service
76 	orders               *orders.Service
77 	overlay              *overlay.Service
78 	attributions         attribution.DB
79 	partners             *rewards.PartnersService
80 	pointerVerification  *pointerverification.Service
81 	projectUsage         *accounting.Service
82 	projects             console.Projects
83 	apiKeys              APIKeys
84 	satellite            signing.Signer
85 	limiterCache         *lrucache.ExpiringLRU
86 	encInlineSegmentSize int64 // max inline segment size + encryption overhead
87 	revocations          revocation.DB
88 	defaultRS            *pb.RedundancyScheme
89 	config               Config
90 	versionCollector     *versionCollector
145 func (endpoint *Endpoint) Close() error { return nil }
153 …ojectInfo(ctx context.Context, req *pb.ProjectInfoRequest) (_ *pb.ProjectInfoResponse, err error) {
177 … GetBucket(ctx context.Context, req *pb.BucketGetRequest) (resp *pb.BucketGetResponse, err error) {
215 …cket(ctx context.Context, req *pb.BucketCreateRequest) (resp *pb.BucketCreateResponse, err error) {
299 …cket(ctx context.Context, req *pb.BucketDeleteRequest) (resp *pb.BucketDeleteResponse, err error) {
397 … *Endpoint) deleteBucket(ctx context.Context, bucketName []byte, projectID uuid.UUID) (err error) {
412 …ndpoint) isBucketEmpty(ctx context.Context, projectID uuid.UUID, bucketName []byte) (bool, error) {
422 …ucketNotEmpty(ctx context.Context, projectID uuid.UUID, bucketName []byte) ([]byte, int64, error) {
445 …teBucketObjects(ctx context.Context, projectID uuid.UUID, bucketName []byte) (_ int64, err error) {
461 …tBuckets(ctx context.Context, req *pb.BucketListRequest) (resp *pb.BucketListResponse, err error) {
511 …endpoint *Endpoint) CountBuckets(ctx context.Context, projectID uuid.UUID) (count int, err error) {
576 …Object(ctx context.Context, req *pb.ObjectBeginRequest) (resp *pb.ObjectBeginResponse, err error) {
726 …ject(ctx context.Context, req *pb.ObjectCommitRequest) (resp *pb.ObjectCommitResponse, err error) {
805 … GetObject(ctx context.Context, req *pb.ObjectGetRequest) (resp *pb.ObjectGetResponse, err error) {
881 …(ctx context.Context, req *pb.ObjectDownloadRequest) (resp *pb.ObjectDownloadResponse, err error) {
1107 …StreamRange, segment metabase.Segment, encryptionParams storj.EncryptionParameters) downloadSizes {
1219 …tObjects(ctx context.Context, req *pb.ObjectListRequest) (resp *pb.ObjectListResponse, err error) {
1319 …, req *pb.ObjectListPendingStreamsRequest) (resp *pb.ObjectListPendingStreamsResponse, err error) {
1406 …ontext.Context, req *pb.ObjectBeginDeleteRequest) (resp *pb.ObjectBeginDeleteResponse, err error) {
1516 …tIPs(ctx context.Context, req *pb.ObjectGetIPsRequest) (resp *pb.ObjectGetIPsResponse, err error) {
1593 ….Context, req *pb.ObjectUpdateMetadataRequest) (resp *pb.ObjectUpdateMetadataResponse, err error) {
1652 …ment(ctx context.Context, req *pb.SegmentBeginRequest) (resp *pb.SegmentBeginResponse, err error) {
1762 …nt(ctx context.Context, req *pb.SegmentCommitRequest) (resp *pb.SegmentCommitResponse, err error) {
1945 …ontext.Context, req *pb.SegmentMakeInlineRequest) (resp *pb.SegmentMakeInlineResponse, err error) {
2042 …gments(ctx context.Context, req *pb.SegmentListRequest) (resp *pb.SegmentListResponse, err error) {
2121 …tx context.Context, req *pb.SegmentDownloadRequest) (resp *pb.SegmentDownloadResponse, err error) {
2294 …letePart(ctx context.Context, req *pb.PartDeleteRequest) (resp *pb.PartDeleteResponse, err error) {
2300 …eamID(ctx context.Context, satStreamID *internalpb.StreamID) (streamID storj.StreamID, err error) {
2320 …D(ctx context.Context, satSegmentID *internalpb.SegmentID) (segmentID storj.SegmentID, err error) {
2340 …shalSatStreamID(ctx context.Context, streamID storj.StreamID) (_ *internalpb.StreamID, err error) {
2357 …SatSegmentID(ctx context.Context, segmentID storj.SegmentID) (_ *internalpb.SegmentID, err error) {
2386 func (endpoint *Endpoint) DeleteCommittedObject(
2421 …c (endpoint *Endpoint) DeleteObjectAnyStatus(ctx context.Context, location metabase.ObjectLocation,
2451 …bject(ctx context.Context, stream metabase.ObjectStream) (deletedObjects []*pb.Object, err error) {
2463 …ctx context.Context, result metabase.DeleteObjectResult) (deletedObjects []*pb.Object, err error) {
2481 …point *Endpoint) deleteSegmentPieces(ctx context.Context, segments []metabase.DeletedSegmentInfo) {
2505 …ToProto(ctx context.Context, object metabase.Object, rs *pb.RedundancyScheme) (*pb.Object, error) {
2593 func (endpoint *Endpoint) objectEntryToProtoListItem(ctx context.Context, bucket []byte,
2693 …IKey(ctx context.Context, req *pb.RevokeAPIKeyRequest) (resp *pb.RevokeAPIKeyResponse, err error) {
2719 …ndpoint *Endpoint) checkExceedsStorageUsage(ctx context.Context, projectID uuid.UUID) (err error) {
2747 …tx context.Context, req *pb.ObjectBeginMoveRequest) (resp *pb.ObjectBeginMoveResponse, err error) {
2914 … context.Context, req *pb.ObjectFinishMoveRequest) (resp *pb.ObjectFinishMoveResponse, err error) {
2977 func (endpoint *Endpoint) convertMetabaseErr(err error) error {