v1

package
v0.4.580 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modelaapi_services_objectstored_v1_objectstored_proto protoreflect.FileDescriptor

Functions

func RegisterObjectstoreServiceServer 

func RegisterObjectstoreServiceServer(s *grpc.Server, srv ObjectstoreServiceServer)

Types

type ExistInVirtualBucketResponse 

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

func (*ExistInVirtualBucketResponse) Descriptor deprecated 

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

Deprecated: Use ExistInVirtualBucketResponse.ProtoReflect.Descriptor instead.

func (*ExistInVirtualBucketResponse) GetExist 

func (x *ExistInVirtualBucketResponse) GetExist() bool

func (*ExistInVirtualBucketResponse) ProtoMessage 

func (*ExistInVirtualBucketResponse) ProtoMessage()

func (*ExistInVirtualBucketResponse) ProtoReflect 

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

func (*ExistInVirtualBucketResponse) Reset 

func (x *ExistInVirtualBucketResponse) Reset()

func (*ExistInVirtualBucketResponse) String 

func (x *ExistInVirtualBucketResponse) String() string

type IngestResponse 

type IngestResponse struct {
	LiveKey string `protobuf:"bytes,1,opt,name=liveKey,proto3" json:"liveKey,omitempty"` // the new live key
	// contains filtered or unexported fields
}

func (*IngestResponse) Descriptor deprecated 

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

Deprecated: Use IngestResponse.ProtoReflect.Descriptor instead.

func (*IngestResponse) GetLiveKey 

func (x *IngestResponse) GetLiveKey() string

func (*IngestResponse) ProtoMessage 

func (*IngestResponse) ProtoMessage()

func (*IngestResponse) ProtoReflect 

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

func (*IngestResponse) Reset 

func (x *IngestResponse) Reset()

func (*IngestResponse) String 

func (x *IngestResponse) String() string

type ObjectRequest 

type ObjectRequest struct {
	Bucket     *v1alpha1.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha1.Connection    `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte       ``                                                            /* 153-byte string literal not displayed */
	Key        string                  `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"` // the depot location of the object
	// contains filtered or unexported fields
}

A request to recover archived object from the archive into the depot.

func (*ObjectRequest) Descriptor deprecated 

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

Deprecated: Use ObjectRequest.ProtoReflect.Descriptor instead.

func (*ObjectRequest) GetBucket 

func (x *ObjectRequest) GetBucket() *v1alpha1.VirtualBucket

func (*ObjectRequest) GetConnection 

func (x *ObjectRequest) GetConnection() *v1alpha1.Connection

func (*ObjectRequest) GetKey 

func (x *ObjectRequest) GetKey() string

func (*ObjectRequest) GetSecret 

func (x *ObjectRequest) GetSecret() map[string][]byte

func (*ObjectRequest) ProtoMessage 

func (*ObjectRequest) ProtoMessage()

func (*ObjectRequest) ProtoReflect 

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

func (*ObjectRequest) Reset 

func (x *ObjectRequest) Reset()

func (*ObjectRequest) String 

func (x *ObjectRequest) String() string

type ObjectResponse 

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

func (*ObjectResponse) Descriptor deprecated 

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

Deprecated: Use ObjectResponse.ProtoReflect.Descriptor instead.

func (*ObjectResponse) GetArchivePath 

func (x *ObjectResponse) GetArchivePath() string

func (*ObjectResponse) ProtoMessage 

func (*ObjectResponse) ProtoMessage()

func (*ObjectResponse) ProtoReflect 

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

func (*ObjectResponse) Reset 

func (x *ObjectResponse) Reset()

func (*ObjectResponse) String 

func (x *ObjectResponse) String() string

type ObjectstoreServiceClient 

type ObjectstoreServiceClient interface {
	// Ingest a new dataset to the store, the store creates a new layouts and set of keys
	// for the new dataset
	Ingest(ctx context.Context, in *ObjectRequest, opts ...grpc.CallOption) (*ObjectResponse, error)
	// Delete a dataset from the store. Datasets are not deleted but moved to archive mode
	Archive(ctx context.Context, in *ObjectRequest, opts ...grpc.CallOption) (*ObjectResponse, error)
	// Recover an item from the archive into the depot
	Recover(ctx context.Context, in *ObjectRequest, opts ...grpc.CallOption) (*ObjectResponse, error)
	// Check if a dataset exist in bucket
	ExistInVirtualBucket(ctx context.Context, in *ObjectRequest, opts ...grpc.CallOption) (*ExistInVirtualBucketResponse, error)
}

ObjectstoreServiceClient is the client API for ObjectstoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewObjectstoreServiceClient 

func NewObjectstoreServiceClient(cc grpc.ClientConnInterface) ObjectstoreServiceClient

type ObjectstoreServiceServer 

type ObjectstoreServiceServer interface {
	// Ingest a new dataset to the store, the store creates a new layouts and set of keys
	// for the new dataset
	Ingest(context.Context, *ObjectRequest) (*ObjectResponse, error)
	// Delete a dataset from the store. Datasets are not deleted but moved to archive mode
	Archive(context.Context, *ObjectRequest) (*ObjectResponse, error)
	// Recover an item from the archive into the depot
	Recover(context.Context, *ObjectRequest) (*ObjectResponse, error)
	// Check if a dataset exist in bucket
	ExistInVirtualBucket(context.Context, *ObjectRequest) (*ExistInVirtualBucketResponse, error)
}

ObjectstoreServiceServer is the server API for ObjectstoreService service.

type UnimplementedObjectstoreServiceServer 

type UnimplementedObjectstoreServiceServer struct {
}

UnimplementedObjectstoreServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedObjectstoreServiceServer) Archive 

func (*UnimplementedObjectstoreServiceServer) Archive(context.Context, *ObjectRequest) (*ObjectResponse, error)

func (*UnimplementedObjectstoreServiceServer) ExistInVirtualBucket 

func (*UnimplementedObjectstoreServiceServer) ExistInVirtualBucket(context.Context, *ObjectRequest) (*ExistInVirtualBucketResponse, error)

func (*UnimplementedObjectstoreServiceServer) Ingest 

func (*UnimplementedObjectstoreServiceServer) Ingest(context.Context, *ObjectRequest) (*ObjectResponse, error)

func (*UnimplementedObjectstoreServiceServer) Recover 

func (*UnimplementedObjectstoreServiceServer) Recover(context.Context, *ObjectRequest) (*ObjectResponse, error)

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.