Documentation ¶
Index ¶
- Variables
- func RegisterRegistryAPIHandler(s server.Server, hdlr RegistryAPIHandler, opts ...server.HandlerOption) error
- func RegisterRegistryAPIServer(s *grpc.Server, srv RegistryAPIServer)
- type GetHomeRequest
- type GetHomeResponse
- func (*GetHomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetHomeResponse) GetOpaque() *v1beta1.Opaque
- func (x *GetHomeResponse) GetProvider() *ProviderInfo
- func (x *GetHomeResponse) GetStatus() *v1beta11.Status
- func (*GetHomeResponse) ProtoMessage()
- func (x *GetHomeResponse) ProtoReflect() protoreflect.Message
- func (x *GetHomeResponse) Reset()
- func (x *GetHomeResponse) String() string
- type GetStorageProviderRequest
- func (*GetStorageProviderRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetStorageProviderRequest) GetOpaque() *v1beta1.Opaque
- func (x *GetStorageProviderRequest) GetRef() *v1beta12.Reference
- func (*GetStorageProviderRequest) ProtoMessage()
- func (x *GetStorageProviderRequest) ProtoReflect() protoreflect.Message
- func (x *GetStorageProviderRequest) Reset()
- func (x *GetStorageProviderRequest) String() string
- type GetStorageProviderResponse
- func (*GetStorageProviderResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStorageProviderResponse) GetOpaque() *v1beta1.Opaque
- func (x *GetStorageProviderResponse) GetProvider() *ProviderInfo
- func (x *GetStorageProviderResponse) GetStatus() *v1beta11.Status
- func (*GetStorageProviderResponse) ProtoMessage()
- func (x *GetStorageProviderResponse) ProtoReflect() protoreflect.Message
- func (x *GetStorageProviderResponse) Reset()
- func (x *GetStorageProviderResponse) String() string
- type ListStorageProvidersRequest
- func (*ListStorageProvidersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListStorageProvidersRequest) GetOpaque() *v1beta1.Opaque
- func (*ListStorageProvidersRequest) ProtoMessage()
- func (x *ListStorageProvidersRequest) ProtoReflect() protoreflect.Message
- func (x *ListStorageProvidersRequest) Reset()
- func (x *ListStorageProvidersRequest) String() string
- type ListStorageProvidersResponse
- func (*ListStorageProvidersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListStorageProvidersResponse) GetOpaque() *v1beta1.Opaque
- func (x *ListStorageProvidersResponse) GetProviders() []*ProviderInfo
- func (x *ListStorageProvidersResponse) GetStatus() *v1beta11.Status
- func (*ListStorageProvidersResponse) ProtoMessage()
- func (x *ListStorageProvidersResponse) ProtoReflect() protoreflect.Message
- func (x *ListStorageProvidersResponse) Reset()
- func (x *ListStorageProvidersResponse) String() string
- type ProviderInfo
- func (*ProviderInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ProviderInfo) GetAddress() string
- func (x *ProviderInfo) GetDescription() string
- func (x *ProviderInfo) GetFeatures() *ProviderInfo_Features
- func (x *ProviderInfo) GetOpaque() *v1beta1.Opaque
- func (x *ProviderInfo) GetProviderId() string
- func (x *ProviderInfo) GetProviderPath() string
- func (*ProviderInfo) ProtoMessage()
- func (x *ProviderInfo) ProtoReflect() protoreflect.Message
- func (x *ProviderInfo) Reset()
- func (x *ProviderInfo) String() string
- type ProviderInfo_Features
- func (*ProviderInfo_Features) Descriptor() ([]byte, []int)deprecated
- func (x *ProviderInfo_Features) GetFileVersions() bool
- func (x *ProviderInfo_Features) GetRecycle() bool
- func (*ProviderInfo_Features) ProtoMessage()
- func (x *ProviderInfo_Features) ProtoReflect() protoreflect.Message
- func (x *ProviderInfo_Features) Reset()
- func (x *ProviderInfo_Features) String() string
- type RegistryAPIClient
- type RegistryAPIHandler
- type RegistryAPIServer
- type RegistryAPIService
- type UnimplementedRegistryAPIServer
- func (*UnimplementedRegistryAPIServer) GetHome(context.Context, *GetHomeRequest) (*GetHomeResponse, error)
- func (*UnimplementedRegistryAPIServer) GetStorageProvider(context.Context, *GetStorageProviderRequest) (*GetStorageProviderResponse, error)
- func (*UnimplementedRegistryAPIServer) ListStorageProviders(context.Context, *ListStorageProvidersRequest) (*ListStorageProvidersResponse, error)
Constants ¶
This section is empty.
Variables ¶
var File_cs3_storage_registry_v1beta1_registry_api_proto protoreflect.FileDescriptor
var File_cs3_storage_registry_v1beta1_resources_proto protoreflect.FileDescriptor
Functions ¶
func RegisterRegistryAPIHandler ¶
func RegisterRegistryAPIHandler(s server.Server, hdlr RegistryAPIHandler, opts ...server.HandlerOption) error
func RegisterRegistryAPIServer ¶
func RegisterRegistryAPIServer(s *grpc.Server, srv RegistryAPIServer)
Types ¶
type GetHomeRequest ¶
type GetHomeRequest struct { // OPTIONAL. // Opaque information. Opaque *v1beta1.Opaque `protobuf:"bytes,1,opt,name=opaque,proto3" json:"opaque,omitempty"` // contains filtered or unexported fields }
func (*GetHomeRequest) Descriptor
deprecated
func (*GetHomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetHomeRequest.ProtoReflect.Descriptor instead.
func (*GetHomeRequest) GetOpaque ¶
func (x *GetHomeRequest) GetOpaque() *v1beta1.Opaque
func (*GetHomeRequest) ProtoMessage ¶
func (*GetHomeRequest) ProtoMessage()
func (*GetHomeRequest) ProtoReflect ¶
func (x *GetHomeRequest) ProtoReflect() protoreflect.Message
func (*GetHomeRequest) Reset ¶
func (x *GetHomeRequest) Reset()
func (*GetHomeRequest) String ¶
func (x *GetHomeRequest) String() string
type GetHomeResponse ¶
type GetHomeResponse struct { // REQUIRED. // The response status. Status *v1beta11.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // OPTIONAL. // Opaque information. Opaque *v1beta1.Opaque `protobuf:"bytes,2,opt,name=opaque,proto3" json:"opaque,omitempty"` // REQUIRED. // The storage provider for the user home. Provider *ProviderInfo `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"` // contains filtered or unexported fields }
func (*GetHomeResponse) Descriptor
deprecated
func (*GetHomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetHomeResponse.ProtoReflect.Descriptor instead.
func (*GetHomeResponse) GetOpaque ¶
func (x *GetHomeResponse) GetOpaque() *v1beta1.Opaque
func (*GetHomeResponse) GetProvider ¶
func (x *GetHomeResponse) GetProvider() *ProviderInfo
func (*GetHomeResponse) GetStatus ¶
func (x *GetHomeResponse) GetStatus() *v1beta11.Status
func (*GetHomeResponse) ProtoMessage ¶
func (*GetHomeResponse) ProtoMessage()
func (*GetHomeResponse) ProtoReflect ¶
func (x *GetHomeResponse) ProtoReflect() protoreflect.Message
func (*GetHomeResponse) Reset ¶
func (x *GetHomeResponse) Reset()
func (*GetHomeResponse) String ¶
func (x *GetHomeResponse) String() string
type GetStorageProviderRequest ¶
type GetStorageProviderRequest struct { // OPTIONAL. // Opaque information. Opaque *v1beta1.Opaque `protobuf:"bytes,1,opt,name=opaque,proto3" json:"opaque,omitempty"` // REQUIRED. // The reference for the resource. Ref *v1beta12.Reference `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"` // contains filtered or unexported fields }
func (*GetStorageProviderRequest) Descriptor
deprecated
func (*GetStorageProviderRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStorageProviderRequest.ProtoReflect.Descriptor instead.
func (*GetStorageProviderRequest) GetOpaque ¶
func (x *GetStorageProviderRequest) GetOpaque() *v1beta1.Opaque
func (*GetStorageProviderRequest) GetRef ¶
func (x *GetStorageProviderRequest) GetRef() *v1beta12.Reference
func (*GetStorageProviderRequest) ProtoMessage ¶
func (*GetStorageProviderRequest) ProtoMessage()
func (*GetStorageProviderRequest) ProtoReflect ¶
func (x *GetStorageProviderRequest) ProtoReflect() protoreflect.Message
func (*GetStorageProviderRequest) Reset ¶
func (x *GetStorageProviderRequest) Reset()
func (*GetStorageProviderRequest) String ¶
func (x *GetStorageProviderRequest) String() string
type GetStorageProviderResponse ¶
type GetStorageProviderResponse struct { // REQUIRED. // The response status. Status *v1beta11.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // OPTIONAL. // Opaque information. Opaque *v1beta1.Opaque `protobuf:"bytes,2,opt,name=opaque,proto3" json:"opaque,omitempty"` // REQUIRED. // The storage provider handling the requested storage resource. Provider *ProviderInfo `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"` // contains filtered or unexported fields }
func (*GetStorageProviderResponse) Descriptor
deprecated
func (*GetStorageProviderResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStorageProviderResponse.ProtoReflect.Descriptor instead.
func (*GetStorageProviderResponse) GetOpaque ¶
func (x *GetStorageProviderResponse) GetOpaque() *v1beta1.Opaque
func (*GetStorageProviderResponse) GetProvider ¶
func (x *GetStorageProviderResponse) GetProvider() *ProviderInfo
func (*GetStorageProviderResponse) GetStatus ¶
func (x *GetStorageProviderResponse) GetStatus() *v1beta11.Status
func (*GetStorageProviderResponse) ProtoMessage ¶
func (*GetStorageProviderResponse) ProtoMessage()
func (*GetStorageProviderResponse) ProtoReflect ¶
func (x *GetStorageProviderResponse) ProtoReflect() protoreflect.Message
func (*GetStorageProviderResponse) Reset ¶
func (x *GetStorageProviderResponse) Reset()
func (*GetStorageProviderResponse) String ¶
func (x *GetStorageProviderResponse) String() string
type ListStorageProvidersRequest ¶
type ListStorageProvidersRequest struct { // OPTIONAL. // Opaque information. Opaque *v1beta1.Opaque `protobuf:"bytes,1,opt,name=opaque,proto3" json:"opaque,omitempty"` // TODO(labkode): maybe add some filter? // contains filtered or unexported fields }
func (*ListStorageProvidersRequest) Descriptor
deprecated
func (*ListStorageProvidersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListStorageProvidersRequest.ProtoReflect.Descriptor instead.
func (*ListStorageProvidersRequest) GetOpaque ¶
func (x *ListStorageProvidersRequest) GetOpaque() *v1beta1.Opaque
func (*ListStorageProvidersRequest) ProtoMessage ¶
func (*ListStorageProvidersRequest) ProtoMessage()
func (*ListStorageProvidersRequest) ProtoReflect ¶
func (x *ListStorageProvidersRequest) ProtoReflect() protoreflect.Message
func (*ListStorageProvidersRequest) Reset ¶
func (x *ListStorageProvidersRequest) Reset()
func (*ListStorageProvidersRequest) String ¶
func (x *ListStorageProvidersRequest) String() string
type ListStorageProvidersResponse ¶
type ListStorageProvidersResponse struct { // REQUIRED. // The response status. Status *v1beta11.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // OPTIONAL. // Opaque information. Opaque *v1beta1.Opaque `protobuf:"bytes,2,opt,name=opaque,proto3" json:"opaque,omitempty"` // REQUIRED. // The list of storage providers this registry knows about. Providers []*ProviderInfo `protobuf:"bytes,3,rep,name=providers,proto3" json:"providers,omitempty"` // contains filtered or unexported fields }
func (*ListStorageProvidersResponse) Descriptor
deprecated
func (*ListStorageProvidersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListStorageProvidersResponse.ProtoReflect.Descriptor instead.
func (*ListStorageProvidersResponse) GetOpaque ¶
func (x *ListStorageProvidersResponse) GetOpaque() *v1beta1.Opaque
func (*ListStorageProvidersResponse) GetProviders ¶
func (x *ListStorageProvidersResponse) GetProviders() []*ProviderInfo
func (*ListStorageProvidersResponse) GetStatus ¶
func (x *ListStorageProvidersResponse) GetStatus() *v1beta11.Status
func (*ListStorageProvidersResponse) ProtoMessage ¶
func (*ListStorageProvidersResponse) ProtoMessage()
func (*ListStorageProvidersResponse) ProtoReflect ¶
func (x *ListStorageProvidersResponse) ProtoReflect() protoreflect.Message
func (*ListStorageProvidersResponse) Reset ¶
func (x *ListStorageProvidersResponse) Reset()
func (*ListStorageProvidersResponse) String ¶
func (x *ListStorageProvidersResponse) String() string
type ProviderInfo ¶
type ProviderInfo struct { // OPTIONAL. // Opaque information (containing storage-specific information). // For example, additional metadata attached to the resource. Opaque *v1beta1.Opaque `protobuf:"bytes,1,opt,name=opaque,proto3" json:"opaque,omitempty"` // REQUIRED. // The storage provider id that will become part of the // resource id. // For example, if the provider_id is "home", resources obtained // from this storage provider will have a resource id like "home:1234". ProviderId string `protobuf:"bytes,2,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"` // REQUIRED. // The public path prefix this storage provider handles. // In Unix literature, the mount path. // For example, if the provider_path is "/home", resources obtained // from this storage provier will have a resource path lik "/home/docs". ProviderPath string `protobuf:"bytes,3,opt,name=provider_path,json=providerPath,proto3" json:"provider_path,omitempty"` // REQUIRED. // The address where the storage provider can be reached. // For example, tcp://localhost:1099. Address string `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"` // OPTIONAL. // Information to describe the functionalities // offered by the storage provider. Meant to be read // by humans. Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // REQUIRED. // List of available methods. Features *ProviderInfo_Features `protobuf:"bytes,6,opt,name=features,proto3" json:"features,omitempty"` // contains filtered or unexported fields }
The information for the storage provider.
func (*ProviderInfo) Descriptor
deprecated
func (*ProviderInfo) Descriptor() ([]byte, []int)
Deprecated: Use ProviderInfo.ProtoReflect.Descriptor instead.
func (*ProviderInfo) GetAddress ¶
func (x *ProviderInfo) GetAddress() string
func (*ProviderInfo) GetDescription ¶
func (x *ProviderInfo) GetDescription() string
func (*ProviderInfo) GetFeatures ¶
func (x *ProviderInfo) GetFeatures() *ProviderInfo_Features
func (*ProviderInfo) GetOpaque ¶
func (x *ProviderInfo) GetOpaque() *v1beta1.Opaque
func (*ProviderInfo) GetProviderId ¶
func (x *ProviderInfo) GetProviderId() string
func (*ProviderInfo) GetProviderPath ¶
func (x *ProviderInfo) GetProviderPath() string
func (*ProviderInfo) ProtoMessage ¶
func (*ProviderInfo) ProtoMessage()
func (*ProviderInfo) ProtoReflect ¶
func (x *ProviderInfo) ProtoReflect() protoreflect.Message
func (*ProviderInfo) Reset ¶
func (x *ProviderInfo) Reset()
func (*ProviderInfo) String ¶
func (x *ProviderInfo) String() string
type ProviderInfo_Features ¶
type ProviderInfo_Features struct { Recycle bool `protobuf:"varint,1,opt,name=recycle,proto3" json:"recycle,omitempty"` FileVersions bool `protobuf:"varint,2,opt,name=file_versions,json=fileVersions,proto3" json:"file_versions,omitempty"` // contains filtered or unexported fields }
REQUIRED. Represents the list of features available on this storage provider. If the feature is not supported, the related service methods MUST return CODE_UNIMPLEMENTED.
func (*ProviderInfo_Features) Descriptor
deprecated
func (*ProviderInfo_Features) Descriptor() ([]byte, []int)
Deprecated: Use ProviderInfo_Features.ProtoReflect.Descriptor instead.
func (*ProviderInfo_Features) GetFileVersions ¶
func (x *ProviderInfo_Features) GetFileVersions() bool
func (*ProviderInfo_Features) GetRecycle ¶
func (x *ProviderInfo_Features) GetRecycle() bool
func (*ProviderInfo_Features) ProtoMessage ¶
func (*ProviderInfo_Features) ProtoMessage()
func (*ProviderInfo_Features) ProtoReflect ¶
func (x *ProviderInfo_Features) ProtoReflect() protoreflect.Message
func (*ProviderInfo_Features) Reset ¶
func (x *ProviderInfo_Features) Reset()
func (*ProviderInfo_Features) String ¶
func (x *ProviderInfo_Features) String() string
type RegistryAPIClient ¶
type RegistryAPIClient interface { // Returns the storage provider that is reponsible for the given // resource reference. // MUST return CODE_NOT_FOUND if the reference does not exist. GetStorageProvider(ctx context.Context, in *GetStorageProviderRequest, opts ...grpc.CallOption) (*GetStorageProviderResponse, error) // Returns a list of the available storage providers known by this registry. ListStorageProviders(ctx context.Context, in *ListStorageProvidersRequest, opts ...grpc.CallOption) (*ListStorageProvidersResponse, error) // Gets the user home storage provider. GetHome(ctx context.Context, in *GetHomeRequest, opts ...grpc.CallOption) (*GetHomeResponse, error) }
RegistryAPIClient is the client API for RegistryAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRegistryAPIClient ¶
func NewRegistryAPIClient(cc grpc.ClientConnInterface) RegistryAPIClient
type RegistryAPIHandler ¶
type RegistryAPIHandler interface { // Returns the storage provider that is reponsible for the given // resource reference. // MUST return CODE_NOT_FOUND if the reference does not exist. GetStorageProvider(context.Context, *GetStorageProviderRequest, *GetStorageProviderResponse) error // Returns a list of the available storage providers known by this registry. ListStorageProviders(context.Context, *ListStorageProvidersRequest, *ListStorageProvidersResponse) error // Gets the user home storage provider. GetHome(context.Context, *GetHomeRequest, *GetHomeResponse) error }
type RegistryAPIServer ¶
type RegistryAPIServer interface { // Returns the storage provider that is reponsible for the given // resource reference. // MUST return CODE_NOT_FOUND if the reference does not exist. GetStorageProvider(context.Context, *GetStorageProviderRequest) (*GetStorageProviderResponse, error) // Returns a list of the available storage providers known by this registry. ListStorageProviders(context.Context, *ListStorageProvidersRequest) (*ListStorageProvidersResponse, error) // Gets the user home storage provider. GetHome(context.Context, *GetHomeRequest) (*GetHomeResponse, error) }
RegistryAPIServer is the server API for RegistryAPI service.
type RegistryAPIService ¶
type RegistryAPIService interface { // Returns the storage provider that is reponsible for the given // resource reference. // MUST return CODE_NOT_FOUND if the reference does not exist. GetStorageProvider(ctx context.Context, in *GetStorageProviderRequest, opts ...client.CallOption) (*GetStorageProviderResponse, error) // Returns a list of the available storage providers known by this registry. ListStorageProviders(ctx context.Context, in *ListStorageProvidersRequest, opts ...client.CallOption) (*ListStorageProvidersResponse, error) // Gets the user home storage provider. GetHome(ctx context.Context, in *GetHomeRequest, opts ...client.CallOption) (*GetHomeResponse, error) }
func NewRegistryAPIService ¶
func NewRegistryAPIService(name string, c client.Client) RegistryAPIService
type UnimplementedRegistryAPIServer ¶
type UnimplementedRegistryAPIServer struct { }
UnimplementedRegistryAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedRegistryAPIServer) GetHome ¶
func (*UnimplementedRegistryAPIServer) GetHome(context.Context, *GetHomeRequest) (*GetHomeResponse, error)
func (*UnimplementedRegistryAPIServer) GetStorageProvider ¶
func (*UnimplementedRegistryAPIServer) GetStorageProvider(context.Context, *GetStorageProviderRequest) (*GetStorageProviderResponse, error)
func (*UnimplementedRegistryAPIServer) ListStorageProviders ¶
func (*UnimplementedRegistryAPIServer) ListStorageProviders(context.Context, *ListStorageProvidersRequest) (*ListStorageProvidersResponse, error)