dspv1alpha1

package
v0.0.3-alpha1 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	ClientService_Ping_FullMethodName                                  = "/dsp.v1alpha1.ClientService/Ping"
	ClientService_GetProviderCatalogue_FullMethodName                  = "/dsp.v1alpha1.ClientService/GetProviderCatalogue"
	ClientService_GetProviderDataset_FullMethodName                    = "/dsp.v1alpha1.ClientService/GetProviderDataset"
	ClientService_GetProviderDatasetDownloadInformation_FullMethodName = "/dsp.v1alpha1.ClientService/GetProviderDatasetDownloadInformation"
	ClientService_SignalTransferComplete_FullMethodName                = "/dsp.v1alpha1.ClientService/SignalTransferComplete"
	ClientService_SignalTransferCancelled_FullMethodName               = "/dsp.v1alpha1.ClientService/SignalTransferCancelled"
	ClientService_SignalTransferSuspend_FullMethodName                 = "/dsp.v1alpha1.ClientService/SignalTransferSuspend"
	ClientService_SignalTransferResume_FullMethodName                  = "/dsp.v1alpha1.ClientService/SignalTransferResume"
)
View Source 
const (
	ProviderService_Ping_FullMethodName                      = "/dsp.v1alpha1.ProviderService/Ping"
	ProviderService_GetCatalogue_FullMethodName              = "/dsp.v1alpha1.ProviderService/GetCatalogue"
	ProviderService_GetDataset_FullMethodName                = "/dsp.v1alpha1.ProviderService/GetDataset"
	ProviderService_PublishDataset_FullMethodName            = "/dsp.v1alpha1.ProviderService/PublishDataset"
	ProviderService_UnpublishDataset_FullMethodName          = "/dsp.v1alpha1.ProviderService/UnpublishDataset"
	ProviderService_SuspendPublishedDataset_FullMethodName   = "/dsp.v1alpha1.ProviderService/SuspendPublishedDataset"
	ProviderService_UnsuspendPublishedDataset_FullMethodName = "/dsp.v1alpha1.ProviderService/UnsuspendPublishedDataset"
)

Variables

View Source 
var (
	AuthenticationType_name = map[int32]string{
		0: "AUTHENTICATION_TYPE_UNSPECIFIED",
		1: "AUTHENTICATION_TYPE_BEARER",
		2: "AUTHENTICATION_TYPE_BASIC",
	}
	AuthenticationType_value = map[string]int32{
		"AUTHENTICATION_TYPE_UNSPECIFIED": 0,
		"AUTHENTICATION_TYPE_BEARER":      1,
		"AUTHENTICATION_TYPE_BASIC":       2,
	}
)

Enum value maps for AuthenticationType.

View Source 
var ClientService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dsp.v1alpha1.ClientService",
	HandlerType: (*ClientServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _ClientService_Ping_Handler,
		},
		{
			MethodName: "GetProviderCatalogue",
			Handler:    _ClientService_GetProviderCatalogue_Handler,
		},
		{
			MethodName: "GetProviderDataset",
			Handler:    _ClientService_GetProviderDataset_Handler,
		},
		{
			MethodName: "GetProviderDatasetDownloadInformation",
			Handler:    _ClientService_GetProviderDatasetDownloadInformation_Handler,
		},
		{
			MethodName: "SignalTransferComplete",
			Handler:    _ClientService_SignalTransferComplete_Handler,
		},
		{
			MethodName: "SignalTransferCancelled",
			Handler:    _ClientService_SignalTransferCancelled_Handler,
		},
		{
			MethodName: "SignalTransferSuspend",
			Handler:    _ClientService_SignalTransferSuspend_Handler,
		},
		{
			MethodName: "SignalTransferResume",
			Handler:    _ClientService_SignalTransferResume_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dsp/v1alpha1/client.proto",
}

ClientService_ServiceDesc is the grpc.ServiceDesc for ClientService 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_dsp_v1alpha1_client_proto protoreflect.FileDescriptor
View Source 
var File_dsp_v1alpha1_provider_proto protoreflect.FileDescriptor
View Source 
var File_dsp_v1alpha1_types_proto protoreflect.FileDescriptor
View Source 
var ProviderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dsp.v1alpha1.ProviderService",
	HandlerType: (*ProviderServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _ProviderService_Ping_Handler,
		},
		{
			MethodName: "GetCatalogue",
			Handler:    _ProviderService_GetCatalogue_Handler,
		},
		{
			MethodName: "GetDataset",
			Handler:    _ProviderService_GetDataset_Handler,
		},
		{
			MethodName: "PublishDataset",
			Handler:    _ProviderService_PublishDataset_Handler,
		},
		{
			MethodName: "UnpublishDataset",
			Handler:    _ProviderService_UnpublishDataset_Handler,
		},
		{
			MethodName: "SuspendPublishedDataset",
			Handler:    _ProviderService_SuspendPublishedDataset_Handler,
		},
		{
			MethodName: "UnsuspendPublishedDataset",
			Handler:    _ProviderService_UnsuspendPublishedDataset_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dsp/v1alpha1/provider.proto",
}

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

Functions

func RegisterClientServiceServer 

func RegisterClientServiceServer(s grpc.ServiceRegistrar, srv ClientServiceServer)

func RegisterProviderServiceServer 

func RegisterProviderServiceServer(s grpc.ServiceRegistrar, srv ProviderServiceServer)

Types

type AuthenticationType 

type AuthenticationType int32

AuthenticationType represents the way to authenticate to get a published information. 

const (
	AuthenticationType_AUTHENTICATION_TYPE_UNSPECIFIED AuthenticationType = 0
	AuthenticationType_AUTHENTICATION_TYPE_BEARER      AuthenticationType = 1
	AuthenticationType_AUTHENTICATION_TYPE_BASIC       AuthenticationType = 2
)

func (AuthenticationType) Descriptor 

func (AuthenticationType) Descriptor() protoreflect.EnumDescriptor

func (AuthenticationType) Enum 

func (x AuthenticationType) Enum() *AuthenticationType

func (AuthenticationType) EnumDescriptor deprecated 

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

Deprecated: Use AuthenticationType.Descriptor instead.

func (AuthenticationType) Number 

func (x AuthenticationType) Number() protoreflect.EnumNumber

func (AuthenticationType) String 

func (x AuthenticationType) String() string

func (AuthenticationType) Type 

func (AuthenticationType) Type() protoreflect.EnumType

type Checksum 

type Checksum struct {
	Algorithm string `protobuf:"bytes,1,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	Value     string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Checksum represents the checksum of a dataset.

func (*Checksum) Descriptor deprecated 

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

Deprecated: Use Checksum.ProtoReflect.Descriptor instead.

func (*Checksum) GetAlgorithm 

func (x *Checksum) GetAlgorithm() string

func (*Checksum) GetValue 

func (x *Checksum) GetValue() string

func (*Checksum) ProtoMessage 

func (*Checksum) ProtoMessage()

func (*Checksum) ProtoReflect 

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

func (*Checksum) Reset 

func (x *Checksum) Reset()

func (*Checksum) String 

func (x *Checksum) String() string

type ClientServiceClient 

type ClientServiceClient interface {
	// Ping is a request to test if the provider is working, and to test the auth information.
	Ping(ctx context.Context, in *ClientServicePingRequest, opts ...grpc.CallOption) (*ClientServicePingResponse, error)
	// Gets the catalogue based on the query parameters and the authorization header.
	GetProviderCatalogue(ctx context.Context, in *GetProviderCatalogueRequest, opts ...grpc.CallOption) (*GetProviderCatalogueResponse, error)
	// Gets information about a single dataset.
	GetProviderDataset(ctx context.Context, in *GetProviderDatasetRequest, opts ...grpc.CallOption) (*GetProviderDatasetResponse, error)
	// Publishes a dataset,
	GetProviderDatasetDownloadInformation(ctx context.Context, in *GetProviderDatasetDownloadInformationRequest, opts ...grpc.CallOption) (*GetProviderDatasetDownloadInformationResponse, error)
	// Tells provider that we have finished our transfer.
	SignalTransferComplete(ctx context.Context, in *SignalTransferCompleteRequest, opts ...grpc.CallOption) (*SignalTransferCompleteResponse, error)
	// Tells provider to cancel file transfer
	SignalTransferCancelled(ctx context.Context, in *SignalTransferCancelledRequest, opts ...grpc.CallOption) (*SignalTransferCancelledResponse, error)
	// Tells provider to suspend file transfer
	SignalTransferSuspend(ctx context.Context, in *SignalTransferSuspendRequest, opts ...grpc.CallOption) (*SignalTransferSuspendResponse, error)
	// Tells provider to resume file transfer
	SignalTransferResume(ctx context.Context, in *SignalTransferResumeRequest, opts ...grpc.CallOption) (*SignalTransferResumeResponse, error)
}

ClientServiceClient is the client API for ClientService 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.

The ClientService is the expected grpc service that RUN-DSP will interface with. Outside of the defined calls, RUN-DSP will also forward the `authorization` header. The reason for this is that authorization will vary between dataspaces. Also, the provider will want to show different data dependent on the credentials.

func NewClientServiceClient 

func NewClientServiceClient(cc grpc.ClientConnInterface) ClientServiceClient

type ClientServicePingRequest 

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

ClientServicePingRequest is an empty message, used instead of the Empty type in case we want to add parameters.

func (*ClientServicePingRequest) Descriptor deprecated 

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

Deprecated: Use ClientServicePingRequest.ProtoReflect.Descriptor instead.

func (*ClientServicePingRequest) ProtoMessage 

func (*ClientServicePingRequest) ProtoMessage()

func (*ClientServicePingRequest) ProtoReflect 

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

func (*ClientServicePingRequest) Reset 

func (x *ClientServicePingRequest) Reset()

func (*ClientServicePingRequest) String 

func (x *ClientServicePingRequest) String() string

type ClientServicePingResponse 

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

ClientServicePingResponse is an empty message for checking GRPC connection.

func (*ClientServicePingResponse) Descriptor deprecated 

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

Deprecated: Use ClientServicePingResponse.ProtoReflect.Descriptor instead.

func (*ClientServicePingResponse) ProtoMessage 

func (*ClientServicePingResponse) ProtoMessage()

func (*ClientServicePingResponse) ProtoReflect 

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

func (*ClientServicePingResponse) Reset 

func (x *ClientServicePingResponse) Reset()

func (*ClientServicePingResponse) String 

func (x *ClientServicePingResponse) String() string

type ClientServiceServer 

type ClientServiceServer interface {
	// Ping is a request to test if the provider is working, and to test the auth information.
	Ping(context.Context, *ClientServicePingRequest) (*ClientServicePingResponse, error)
	// Gets the catalogue based on the query parameters and the authorization header.
	GetProviderCatalogue(context.Context, *GetProviderCatalogueRequest) (*GetProviderCatalogueResponse, error)
	// Gets information about a single dataset.
	GetProviderDataset(context.Context, *GetProviderDatasetRequest) (*GetProviderDatasetResponse, error)
	// Publishes a dataset,
	GetProviderDatasetDownloadInformation(context.Context, *GetProviderDatasetDownloadInformationRequest) (*GetProviderDatasetDownloadInformationResponse, error)
	// Tells provider that we have finished our transfer.
	SignalTransferComplete(context.Context, *SignalTransferCompleteRequest) (*SignalTransferCompleteResponse, error)
	// Tells provider to cancel file transfer
	SignalTransferCancelled(context.Context, *SignalTransferCancelledRequest) (*SignalTransferCancelledResponse, error)
	// Tells provider to suspend file transfer
	SignalTransferSuspend(context.Context, *SignalTransferSuspendRequest) (*SignalTransferSuspendResponse, error)
	// Tells provider to resume file transfer
	SignalTransferResume(context.Context, *SignalTransferResumeRequest) (*SignalTransferResumeResponse, error)
	// contains filtered or unexported methods
}

ClientServiceServer is the server API for ClientService service. All implementations must embed UnimplementedClientServiceServer for forward compatibility.

The ClientService is the expected grpc service that RUN-DSP will interface with. Outside of the defined calls, RUN-DSP will also forward the `authorization` header. The reason for this is that authorization will vary between dataspaces. Also, the provider will want to show different data dependent on the credentials.

type Dataset 

type Dataset struct {
	Id             string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Title          string                 `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	AccessMethods  string                 `protobuf:"bytes,3,opt,name=access_methods,json=accessMethods,proto3" json:"access_methods,omitempty"`
	Description    []*Multilingual        `protobuf:"bytes,4,rep,name=description,proto3" json:"description,omitempty"`
	Keywords       []string               `protobuf:"bytes,5,rep,name=keywords,proto3" json:"keywords,omitempty"`
	Creator        *string                `protobuf:"bytes,6,opt,name=creator,proto3,oneof" json:"creator,omitempty"`
	Issued         *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=issued,proto3,oneof" json:"issued,omitempty"`
	Modified       *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=modified,proto3,oneof" json:"modified,omitempty"`
	Metadata       map[string]string      `` /* 157-byte string literal not displayed */
	License        *string                `protobuf:"bytes,10,opt,name=license,proto3,oneof" json:"license,omitempty"`
	AccessRights   *string                `protobuf:"bytes,11,opt,name=access_rights,json=accessRights,proto3,oneof" json:"access_rights,omitempty"`
	Rights         *string                `protobuf:"bytes,12,opt,name=rights,proto3,oneof" json:"rights,omitempty"`
	ByteSize       int64                  `protobuf:"varint,13,opt,name=byte_size,json=byteSize,proto3" json:"byte_size,omitempty"`
	MediaType      string                 `protobuf:"bytes,14,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
	Format         *string                `protobuf:"bytes,15,opt,name=format,proto3,oneof" json:"format,omitempty"`
	CompressFormat *string                `protobuf:"bytes,16,opt,name=compress_format,json=compressFormat,proto3,oneof" json:"compress_format,omitempty"`
	PackageFormat  *string                `protobuf:"bytes,17,opt,name=package_format,json=packageFormat,proto3,oneof" json:"package_format,omitempty"`
	Checksum       *Checksum              `protobuf:"bytes,18,opt,name=checksum,proto3,oneof" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

Dataset represents a dataset. What exactly is in a dataset is up to the service. An example of a dataset could be a file that's served, or multiple files that are considered a set.

func (*Dataset) Descriptor deprecated 

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

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) GetAccessMethods 

func (x *Dataset) GetAccessMethods() string

func (*Dataset) GetAccessRights 

func (x *Dataset) GetAccessRights() string

func (*Dataset) GetByteSize 

func (x *Dataset) GetByteSize() int64

func (*Dataset) GetChecksum 

func (x *Dataset) GetChecksum() *Checksum

func (*Dataset) GetCompressFormat 

func (x *Dataset) GetCompressFormat() string

func (*Dataset) GetCreator 

func (x *Dataset) GetCreator() string

func (*Dataset) GetDescription 

func (x *Dataset) GetDescription() []*Multilingual

func (*Dataset) GetFormat 

func (x *Dataset) GetFormat() string

func (*Dataset) GetId 

func (x *Dataset) GetId() string

func (*Dataset) GetIssued 

func (x *Dataset) GetIssued() *timestamppb.Timestamp

func (*Dataset) GetKeywords 

func (x *Dataset) GetKeywords() []string

func (*Dataset) GetLicense 

func (x *Dataset) GetLicense() string

func (*Dataset) GetMediaType 

func (x *Dataset) GetMediaType() string

func (*Dataset) GetMetadata 

func (x *Dataset) GetMetadata() map[string]string

func (*Dataset) GetModified 

func (x *Dataset) GetModified() *timestamppb.Timestamp

func (*Dataset) GetPackageFormat 

func (x *Dataset) GetPackageFormat() string

func (*Dataset) GetRights 

func (x *Dataset) GetRights() string

func (*Dataset) GetTitle 

func (x *Dataset) GetTitle() string

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) ProtoReflect 

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

func (*Dataset) Reset 

func (x *Dataset) Reset()

func (*Dataset) String 

func (x *Dataset) String() string

type GetCatalogueRequest 

type GetCatalogueRequest struct {

	// query_parameters is just a key/value map. These are not specified in the dataspace standard.
	// RUN-DSP also does not define them yet, so for now this is a placeholder.
	QueryParameters map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetCatalogRequest represents the parameters for the GetCatalog call.

func (*GetCatalogueRequest) Descriptor deprecated 

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

Deprecated: Use GetCatalogueRequest.ProtoReflect.Descriptor instead.

func (*GetCatalogueRequest) GetQueryParameters 

func (x *GetCatalogueRequest) GetQueryParameters() map[string]string

func (*GetCatalogueRequest) ProtoMessage 

func (*GetCatalogueRequest) ProtoMessage()

func (*GetCatalogueRequest) ProtoReflect 

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

func (*GetCatalogueRequest) Reset 

func (x *GetCatalogueRequest) Reset()

func (*GetCatalogueRequest) String 

func (x *GetCatalogueRequest) String() string

type GetCatalogueResponse 

type GetCatalogueResponse struct {
	Datasets []*Dataset `protobuf:"bytes,1,rep,name=datasets,proto3" json:"datasets,omitempty"`
	// contains filtered or unexported fields
}

GetCatalogueResponse returns all the datasets matched by GetCatalogue.

func (*GetCatalogueResponse) Descriptor deprecated 

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

Deprecated: Use GetCatalogueResponse.ProtoReflect.Descriptor instead.

func (*GetCatalogueResponse) GetDatasets 

func (x *GetCatalogueResponse) GetDatasets() []*Dataset

func (*GetCatalogueResponse) ProtoMessage 

func (*GetCatalogueResponse) ProtoMessage()

func (*GetCatalogueResponse) ProtoReflect 

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

func (*GetCatalogueResponse) Reset 

func (x *GetCatalogueResponse) Reset()

func (*GetCatalogueResponse) String 

func (x *GetCatalogueResponse) String() string

type GetDatasetRequest 

type GetDatasetRequest struct {
	DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// contains filtered or unexported fields
}

GetDatasetRequest contains the dataset ID.

func (*GetDatasetRequest) Descriptor deprecated 

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

Deprecated: Use GetDatasetRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetRequest) GetDatasetId 

func (x *GetDatasetRequest) GetDatasetId() string

func (*GetDatasetRequest) ProtoMessage 

func (*GetDatasetRequest) ProtoMessage()

func (*GetDatasetRequest) ProtoReflect 

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

func (*GetDatasetRequest) Reset 

func (x *GetDatasetRequest) Reset()

func (*GetDatasetRequest) String 

func (x *GetDatasetRequest) String() string

type GetDatasetResponse 

type GetDatasetResponse struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

GetDatasetResponse contains the requested dataset.

func (*GetDatasetResponse) Descriptor deprecated 

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

Deprecated: Use GetDatasetResponse.ProtoReflect.Descriptor instead.

func (*GetDatasetResponse) GetDataset 

func (x *GetDatasetResponse) GetDataset() *Dataset

func (*GetDatasetResponse) ProtoMessage 

func (*GetDatasetResponse) ProtoMessage()

func (*GetDatasetResponse) ProtoReflect 

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

func (*GetDatasetResponse) Reset 

func (x *GetDatasetResponse) Reset()

func (*GetDatasetResponse) String 

func (x *GetDatasetResponse) String() string

type GetProviderCatalogueRequest 

type GetProviderCatalogueRequest struct {
	ProviderUri     string            `protobuf:"bytes,1,opt,name=provider_uri,json=providerUri,proto3" json:"provider_uri,omitempty"`
	QueryParameters map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetProviderCatalogueRequest represents the parameters for the GetProviderCatalogue request

func (*GetProviderCatalogueRequest) Descriptor deprecated 

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

Deprecated: Use GetProviderCatalogueRequest.ProtoReflect.Descriptor instead.

func (*GetProviderCatalogueRequest) GetProviderUri 

func (x *GetProviderCatalogueRequest) GetProviderUri() string

func (*GetProviderCatalogueRequest) GetQueryParameters 

func (x *GetProviderCatalogueRequest) GetQueryParameters() map[string]string

func (*GetProviderCatalogueRequest) ProtoMessage 

func (*GetProviderCatalogueRequest) ProtoMessage()

func (*GetProviderCatalogueRequest) ProtoReflect 

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

func (*GetProviderCatalogueRequest) Reset 

func (x *GetProviderCatalogueRequest) Reset()

func (*GetProviderCatalogueRequest) String 

func (x *GetProviderCatalogueRequest) String() string

type GetProviderCatalogueResponse 

type GetProviderCatalogueResponse struct {
	Datasets []*Dataset `protobuf:"bytes,1,rep,name=datasets,proto3" json:"datasets,omitempty"`
	// contains filtered or unexported fields
}

GetProviderCatalogueResponse returns all the datasets matched by GetProviderCatalogue.

func (*GetProviderCatalogueResponse) Descriptor deprecated 

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

Deprecated: Use GetProviderCatalogueResponse.ProtoReflect.Descriptor instead.

func (*GetProviderCatalogueResponse) GetDatasets 

func (x *GetProviderCatalogueResponse) GetDatasets() []*Dataset

func (*GetProviderCatalogueResponse) ProtoMessage 

func (*GetProviderCatalogueResponse) ProtoMessage()

func (*GetProviderCatalogueResponse) ProtoReflect 

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

func (*GetProviderCatalogueResponse) Reset 

func (x *GetProviderCatalogueResponse) Reset()

func (*GetProviderCatalogueResponse) String 

func (x *GetProviderCatalogueResponse) String() string

type GetProviderDatasetDownloadInformationRequest 

type GetProviderDatasetDownloadInformationRequest struct {
	ProviderUrl string `protobuf:"bytes,1,opt,name=provider_url,json=providerUrl,proto3" json:"provider_url,omitempty"`
	DatasetId   string `protobuf:"bytes,2,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// contains filtered or unexported fields
}

GetProviderDatasetDownloadInformationRequest contains the ID for the dataset we want to be able to download.

func (*GetProviderDatasetDownloadInformationRequest) Descriptor deprecated 

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

Deprecated: Use GetProviderDatasetDownloadInformationRequest.ProtoReflect.Descriptor instead.

func (*GetProviderDatasetDownloadInformationRequest) GetDatasetId 

func (x *GetProviderDatasetDownloadInformationRequest) GetDatasetId() string

func (*GetProviderDatasetDownloadInformationRequest) GetProviderUrl 

func (x *GetProviderDatasetDownloadInformationRequest) GetProviderUrl() string

func (*GetProviderDatasetDownloadInformationRequest) ProtoMessage 

func (*GetProviderDatasetDownloadInformationRequest) ProtoMessage()

func (*GetProviderDatasetDownloadInformationRequest) ProtoReflect 

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

func (*GetProviderDatasetDownloadInformationRequest) Reset 

func (x *GetProviderDatasetDownloadInformationRequest) Reset()

func (*GetProviderDatasetDownloadInformationRequest) String 

func (x *GetProviderDatasetDownloadInformationRequest) String() string

type GetProviderDatasetDownloadInformationResponse 

type GetProviderDatasetDownloadInformationResponse struct {
	PublishInfo *PublishInfo `protobuf:"bytes,1,opt,name=publish_info,json=publishInfo,proto3" json:"publish_info,omitempty"`
	TransferId  string       `protobuf:"bytes,2,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

GetProviderDatasetDownloadInformationResponse contains the information needed to download a file, including authentication etc.

func (*GetProviderDatasetDownloadInformationResponse) Descriptor deprecated 

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

Deprecated: Use GetProviderDatasetDownloadInformationResponse.ProtoReflect.Descriptor instead.

func (*GetProviderDatasetDownloadInformationResponse) GetPublishInfo 

func (x *GetProviderDatasetDownloadInformationResponse) GetPublishInfo() *PublishInfo

func (*GetProviderDatasetDownloadInformationResponse) GetTransferId 

func (x *GetProviderDatasetDownloadInformationResponse) GetTransferId() string

func (*GetProviderDatasetDownloadInformationResponse) ProtoMessage 

func (*GetProviderDatasetDownloadInformationResponse) ProtoMessage()

func (*GetProviderDatasetDownloadInformationResponse) ProtoReflect 

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

func (*GetProviderDatasetDownloadInformationResponse) Reset 

func (x *GetProviderDatasetDownloadInformationResponse) Reset()

func (*GetProviderDatasetDownloadInformationResponse) String 

func (x *GetProviderDatasetDownloadInformationResponse) String() string

type GetProviderDatasetRequest 

type GetProviderDatasetRequest struct {
	ProviderUrl string `protobuf:"bytes,1,opt,name=provider_url,json=providerUrl,proto3" json:"provider_url,omitempty"`
	DatasetId   string `protobuf:"bytes,2,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// contains filtered or unexported fields
}

GetProviderDatasetRequest contains the dataset ID.

func (*GetProviderDatasetRequest) Descriptor deprecated 

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

Deprecated: Use GetProviderDatasetRequest.ProtoReflect.Descriptor instead.

func (*GetProviderDatasetRequest) GetDatasetId 

func (x *GetProviderDatasetRequest) GetDatasetId() string

func (*GetProviderDatasetRequest) GetProviderUrl 

func (x *GetProviderDatasetRequest) GetProviderUrl() string

func (*GetProviderDatasetRequest) ProtoMessage 

func (*GetProviderDatasetRequest) ProtoMessage()

func (*GetProviderDatasetRequest) ProtoReflect 

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

func (*GetProviderDatasetRequest) Reset 

func (x *GetProviderDatasetRequest) Reset()

func (*GetProviderDatasetRequest) String 

func (x *GetProviderDatasetRequest) String() string

type GetProviderDatasetResponse 

type GetProviderDatasetResponse struct {
	ProviderUrl string   `protobuf:"bytes,1,opt,name=provider_url,json=providerUrl,proto3" json:"provider_url,omitempty"`
	Dataset     *Dataset `protobuf:"bytes,2,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

GetProviderDatasetResponse contains the requested dataset.

func (*GetProviderDatasetResponse) Descriptor deprecated 

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

Deprecated: Use GetProviderDatasetResponse.ProtoReflect.Descriptor instead.

func (*GetProviderDatasetResponse) GetDataset 

func (x *GetProviderDatasetResponse) GetDataset() *Dataset

func (*GetProviderDatasetResponse) GetProviderUrl 

func (x *GetProviderDatasetResponse) GetProviderUrl() string

func (*GetProviderDatasetResponse) ProtoMessage 

func (*GetProviderDatasetResponse) ProtoMessage()

func (*GetProviderDatasetResponse) ProtoReflect 

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

func (*GetProviderDatasetResponse) Reset 

func (x *GetProviderDatasetResponse) Reset()

func (*GetProviderDatasetResponse) String 

func (x *GetProviderDatasetResponse) String() string

type Multilingual 

type Multilingual struct {
	Value    string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Language string `protobuf:"bytes,2,opt,name=language,proto3" json:"language,omitempty"`
	// contains filtered or unexported fields
}

Multilingual represents a message with language metadata attached.

func (*Multilingual) Descriptor deprecated 

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

Deprecated: Use Multilingual.ProtoReflect.Descriptor instead.

func (*Multilingual) GetLanguage 

func (x *Multilingual) GetLanguage() string

func (*Multilingual) GetValue 

func (x *Multilingual) GetValue() string

func (*Multilingual) ProtoMessage 

func (*Multilingual) ProtoMessage()

func (*Multilingual) ProtoReflect 

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

func (*Multilingual) Reset 

func (x *Multilingual) Reset()

func (*Multilingual) String 

func (x *Multilingual) String() string

type PingRequest 

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

PingRequest is an empty message, used instead of the Empty type in case we want to add parameters.

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	ProviderName        string `protobuf:"bytes,1,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"`
	ProviderDescription string `protobuf:"bytes,2,opt,name=provider_description,json=providerDescription,proto3" json:"provider_description,omitempty"`
	Authenticated       bool   `protobuf:"varint,3,opt,name=authenticated,proto3" json:"authenticated,omitempty"`
	DataserviceId       string `protobuf:"bytes,4,opt,name=dataservice_id,json=dataserviceId,proto3" json:"dataservice_id,omitempty"`    // An ID for the data service, can be any uuid as long as it's consistent.
	DataserviceUrl      string `protobuf:"bytes,5,opt,name=dataservice_url,json=dataserviceUrl,proto3" json:"dataservice_url,omitempty"` // dataservice URL where data is downloaded from.
	// contains filtered or unexported fields
}

PingResponse contains infomational data about the provider.

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetAuthenticated 

func (x *PingResponse) GetAuthenticated() bool

func (*PingResponse) GetDataserviceId 

func (x *PingResponse) GetDataserviceId() string

func (*PingResponse) GetDataserviceUrl 

func (x *PingResponse) GetDataserviceUrl() string

func (*PingResponse) GetProviderDescription 

func (x *PingResponse) GetProviderDescription() string

func (*PingResponse) GetProviderName 

func (x *PingResponse) GetProviderName() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type ProviderServiceClient 

type ProviderServiceClient interface {
	// Ping is a request to test if the provider is working, and to test the auth information.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Gets the catalogue based on the query parameters and the authorization header.
	GetCatalogue(ctx context.Context, in *GetCatalogueRequest, opts ...grpc.CallOption) (*GetCatalogueResponse, error)
	// Gets information about a single dataset.
	GetDataset(ctx context.Context, in *GetDatasetRequest, opts ...grpc.CallOption) (*GetDatasetResponse, error)
	// Publishes a dataset,
	PublishDataset(ctx context.Context, in *PublishDatasetRequest, opts ...grpc.CallOption) (*PublishDatasetResponse, error)
	// Unpublishes a dataset.
	UnpublishDataset(ctx context.Context, in *UnpublishDatasetRequest, opts ...grpc.CallOption) (*UnpublishDatasetResponse, error)
	// Asks provider to suspend a transfer
	SuspendPublishedDataset(ctx context.Context, in *SuspendPublishedDatasetRequest, opts ...grpc.CallOption) (*SuspendPublishedDatasetResponse, error)
	// Asks provider to unsuspend (re-publish?) a transfer
	UnsuspendPublishedDataset(ctx context.Context, in *UnsuspendPublishedDatasetRequest, opts ...grpc.CallOption) (*UnsuspendPublishedDatasetResponse, error)
}

ProviderServiceClient is the client API for ProviderService 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.

The ProviderService is the expected grpc service that RUN-DSP will interface with. Outside of the defined calls, RUN-DSP will also forward the `authorization` header. The reason for this is that authorization will vary between dataspaces. Also, the provider will want to show different data dependent on the credentials.

func NewProviderServiceClient 

func NewProviderServiceClient(cc grpc.ClientConnInterface) ProviderServiceClient

type ProviderServiceServer 

type ProviderServiceServer interface {
	// Ping is a request to test if the provider is working, and to test the auth information.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Gets the catalogue based on the query parameters and the authorization header.
	GetCatalogue(context.Context, *GetCatalogueRequest) (*GetCatalogueResponse, error)
	// Gets information about a single dataset.
	GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)
	// Publishes a dataset,
	PublishDataset(context.Context, *PublishDatasetRequest) (*PublishDatasetResponse, error)
	// Unpublishes a dataset.
	UnpublishDataset(context.Context, *UnpublishDatasetRequest) (*UnpublishDatasetResponse, error)
	// Asks provider to suspend a transfer
	SuspendPublishedDataset(context.Context, *SuspendPublishedDatasetRequest) (*SuspendPublishedDatasetResponse, error)
	// Asks provider to unsuspend (re-publish?) a transfer
	UnsuspendPublishedDataset(context.Context, *UnsuspendPublishedDatasetRequest) (*UnsuspendPublishedDatasetResponse, error)
	// contains filtered or unexported methods
}

ProviderServiceServer is the server API for ProviderService service. All implementations must embed UnimplementedProviderServiceServer for forward compatibility.

The ProviderService is the expected grpc service that RUN-DSP will interface with. Outside of the defined calls, RUN-DSP will also forward the `authorization` header. The reason for this is that authorization will vary between dataspaces. Also, the provider will want to show different data dependent on the credentials.

type PublishDatasetRequest 

type PublishDatasetRequest struct {
	DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	PublishId string `protobuf:"bytes,2,opt,name=publish_id,json=publishId,proto3" json:"publish_id,omitempty"`
	// contains filtered or unexported fields
}

PublishDatasetRequest contains the ID for the dataset, and a publish ID that's specific to this publish instance. A dataset can be published many concurrent times with different credentials.

func (*PublishDatasetRequest) Descriptor deprecated 

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

Deprecated: Use PublishDatasetRequest.ProtoReflect.Descriptor instead.

func (*PublishDatasetRequest) GetDatasetId 

func (x *PublishDatasetRequest) GetDatasetId() string

func (*PublishDatasetRequest) GetPublishId 

func (x *PublishDatasetRequest) GetPublishId() string

func (*PublishDatasetRequest) ProtoMessage 

func (*PublishDatasetRequest) ProtoMessage()

func (*PublishDatasetRequest) ProtoReflect 

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

func (*PublishDatasetRequest) Reset 

func (x *PublishDatasetRequest) Reset()

func (*PublishDatasetRequest) String 

func (x *PublishDatasetRequest) String() string

type PublishDatasetResponse 

type PublishDatasetResponse struct {
	PublishInfo *PublishInfo `protobuf:"bytes,1,opt,name=publish_info,json=publishInfo,proto3" json:"publish_info,omitempty"`
	// contains filtered or unexported fields
}

PublishDatasetResponse contains the publish information.

func (*PublishDatasetResponse) Descriptor deprecated 

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

Deprecated: Use PublishDatasetResponse.ProtoReflect.Descriptor instead.

func (*PublishDatasetResponse) GetPublishInfo 

func (x *PublishDatasetResponse) GetPublishInfo() *PublishInfo

func (*PublishDatasetResponse) ProtoMessage 

func (*PublishDatasetResponse) ProtoMessage()

func (*PublishDatasetResponse) ProtoReflect 

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

func (*PublishDatasetResponse) Reset 

func (x *PublishDatasetResponse) Reset()

func (*PublishDatasetResponse) String 

func (x *PublishDatasetResponse) String() string

type PublishInfo 

type PublishInfo struct {
	Url                string             `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	AuthenticationType AuthenticationType `` /* 153-byte string literal not displayed */
	Username           string             `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password           string             `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

PublishInfo represents a published file, where to get it and its authentication details.

func (*PublishInfo) Descriptor deprecated 

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

Deprecated: Use PublishInfo.ProtoReflect.Descriptor instead.

func (*PublishInfo) GetAuthenticationType 

func (x *PublishInfo) GetAuthenticationType() AuthenticationType

func (*PublishInfo) GetPassword 

func (x *PublishInfo) GetPassword() string

func (*PublishInfo) GetUrl 

func (x *PublishInfo) GetUrl() string

func (*PublishInfo) GetUsername 

func (x *PublishInfo) GetUsername() string

func (*PublishInfo) ProtoMessage 

func (*PublishInfo) ProtoMessage()

func (*PublishInfo) ProtoReflect 

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

func (*PublishInfo) Reset 

func (x *PublishInfo) Reset()

func (*PublishInfo) String 

func (x *PublishInfo) String() string

type SignalTransferCancelledRequest 

type SignalTransferCancelledRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

SignalTransferCancelledRequest is sent when the client wants to cancel a transfer.

func (*SignalTransferCancelledRequest) Descriptor deprecated 

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

Deprecated: Use SignalTransferCancelledRequest.ProtoReflect.Descriptor instead.

func (*SignalTransferCancelledRequest) GetTransferId 

func (x *SignalTransferCancelledRequest) GetTransferId() string

func (*SignalTransferCancelledRequest) ProtoMessage 

func (*SignalTransferCancelledRequest) ProtoMessage()

func (*SignalTransferCancelledRequest) ProtoReflect 

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

func (*SignalTransferCancelledRequest) Reset 

func (x *SignalTransferCancelledRequest) Reset()

func (*SignalTransferCancelledRequest) String 

func (x *SignalTransferCancelledRequest) String() string

type SignalTransferCancelledResponse 

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

SignalTransferCancelledResponse tells that the cancellation requests was received.

func (*SignalTransferCancelledResponse) Descriptor deprecated 

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

Deprecated: Use SignalTransferCancelledResponse.ProtoReflect.Descriptor instead.

func (*SignalTransferCancelledResponse) ProtoMessage 

func (*SignalTransferCancelledResponse) ProtoMessage()

func (*SignalTransferCancelledResponse) ProtoReflect 

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

func (*SignalTransferCancelledResponse) Reset 

func (x *SignalTransferCancelledResponse) Reset()

func (*SignalTransferCancelledResponse) String 

func (x *SignalTransferCancelledResponse) String() string

type SignalTransferCompleteRequest 

type SignalTransferCompleteRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

SignalTransferCompleteRequest is for telling the provider that we are done receiving the dataset.

func (*SignalTransferCompleteRequest) Descriptor deprecated 

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

Deprecated: Use SignalTransferCompleteRequest.ProtoReflect.Descriptor instead.

func (*SignalTransferCompleteRequest) GetTransferId 

func (x *SignalTransferCompleteRequest) GetTransferId() string

func (*SignalTransferCompleteRequest) ProtoMessage 

func (*SignalTransferCompleteRequest) ProtoMessage()

func (*SignalTransferCompleteRequest) ProtoReflect 

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

func (*SignalTransferCompleteRequest) Reset 

func (x *SignalTransferCompleteRequest) Reset()

func (*SignalTransferCompleteRequest) String 

func (x *SignalTransferCompleteRequest) String() string

type SignalTransferCompleteResponse 

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

SignalTransferCompleteResponse is received when we successfully sent a transfer complete request.

func (*SignalTransferCompleteResponse) Descriptor deprecated 

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

Deprecated: Use SignalTransferCompleteResponse.ProtoReflect.Descriptor instead.

func (*SignalTransferCompleteResponse) ProtoMessage 

func (*SignalTransferCompleteResponse) ProtoMessage()

func (*SignalTransferCompleteResponse) ProtoReflect 

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

func (*SignalTransferCompleteResponse) Reset 

func (x *SignalTransferCompleteResponse) Reset()

func (*SignalTransferCompleteResponse) String 

func (x *SignalTransferCompleteResponse) String() string

type SignalTransferResumeRequest 

type SignalTransferResumeRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

SignalTransferResumeRequest tells the provider that the client wants to resume transfer.

func (*SignalTransferResumeRequest) Descriptor deprecated 

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

Deprecated: Use SignalTransferResumeRequest.ProtoReflect.Descriptor instead.

func (*SignalTransferResumeRequest) GetTransferId 

func (x *SignalTransferResumeRequest) GetTransferId() string

func (*SignalTransferResumeRequest) ProtoMessage 

func (*SignalTransferResumeRequest) ProtoMessage()

func (*SignalTransferResumeRequest) ProtoReflect 

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

func (*SignalTransferResumeRequest) Reset 

func (x *SignalTransferResumeRequest) Reset()

func (*SignalTransferResumeRequest) String 

func (x *SignalTransferResumeRequest) String() string

type SignalTransferResumeResponse 

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

SignalTransferResumeResponse tells the client that the resume request was accepted.

func (*SignalTransferResumeResponse) Descriptor deprecated 

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

Deprecated: Use SignalTransferResumeResponse.ProtoReflect.Descriptor instead.

func (*SignalTransferResumeResponse) ProtoMessage 

func (*SignalTransferResumeResponse) ProtoMessage()

func (*SignalTransferResumeResponse) ProtoReflect 

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

func (*SignalTransferResumeResponse) Reset 

func (x *SignalTransferResumeResponse) Reset()

func (*SignalTransferResumeResponse) String 

func (x *SignalTransferResumeResponse) String() string

type SignalTransferSuspendRequest 

type SignalTransferSuspendRequest struct {
	TransferId string `protobuf:"bytes,1,opt,name=transfer_id,json=transferId,proto3" json:"transfer_id,omitempty"`
	// contains filtered or unexported fields
}

SignalTransferSuspendRequest is sent when the client wishes to pause the transfer.

func (*SignalTransferSuspendRequest) Descriptor deprecated 

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

Deprecated: Use SignalTransferSuspendRequest.ProtoReflect.Descriptor instead.

func (*SignalTransferSuspendRequest) GetTransferId 

func (x *SignalTransferSuspendRequest) GetTransferId() string

func (*SignalTransferSuspendRequest) ProtoMessage 

func (*SignalTransferSuspendRequest) ProtoMessage()

func (*SignalTransferSuspendRequest) ProtoReflect 

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

func (*SignalTransferSuspendRequest) Reset 

func (x *SignalTransferSuspendRequest) Reset()

func (*SignalTransferSuspendRequest) String 

func (x *SignalTransferSuspendRequest) String() string

type SignalTransferSuspendResponse 

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

SignalTransferSuspendResponse tells the client that the pause request was received.

func (*SignalTransferSuspendResponse) Descriptor deprecated 

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

Deprecated: Use SignalTransferSuspendResponse.ProtoReflect.Descriptor instead.

func (*SignalTransferSuspendResponse) ProtoMessage 

func (*SignalTransferSuspendResponse) ProtoMessage()

func (*SignalTransferSuspendResponse) ProtoReflect 

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

func (*SignalTransferSuspendResponse) Reset 

func (x *SignalTransferSuspendResponse) Reset()

func (*SignalTransferSuspendResponse) String 

func (x *SignalTransferSuspendResponse) String() string

type SuspendPublishedDatasetRequest 

type SuspendPublishedDatasetRequest struct {
	PublishId string `protobuf:"bytes,1,opt,name=publish_id,json=publishId,proto3" json:"publish_id,omitempty"`
	// contains filtered or unexported fields
}

SuspendPublishedDatasetRequest contains the publish ID of the published dataset.

func (*SuspendPublishedDatasetRequest) Descriptor deprecated 

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

Deprecated: Use SuspendPublishedDatasetRequest.ProtoReflect.Descriptor instead.

func (*SuspendPublishedDatasetRequest) GetPublishId 

func (x *SuspendPublishedDatasetRequest) GetPublishId() string

func (*SuspendPublishedDatasetRequest) ProtoMessage 

func (*SuspendPublishedDatasetRequest) ProtoMessage()

func (*SuspendPublishedDatasetRequest) ProtoReflect 

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

func (*SuspendPublishedDatasetRequest) Reset 

func (x *SuspendPublishedDatasetRequest) Reset()

func (*SuspendPublishedDatasetRequest) String 

func (x *SuspendPublishedDatasetRequest) String() string

type SuspendPublishedDatasetResponse 

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

SuspendPublshedDatasetResponse indicates success

func (*SuspendPublishedDatasetResponse) Descriptor deprecated 

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

Deprecated: Use SuspendPublishedDatasetResponse.ProtoReflect.Descriptor instead.

func (*SuspendPublishedDatasetResponse) ProtoMessage 

func (*SuspendPublishedDatasetResponse) ProtoMessage()

func (*SuspendPublishedDatasetResponse) ProtoReflect 

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

func (*SuspendPublishedDatasetResponse) Reset 

func (x *SuspendPublishedDatasetResponse) Reset()

func (*SuspendPublishedDatasetResponse) String 

func (x *SuspendPublishedDatasetResponse) String() string

type UnimplementedClientServiceServer 

type UnimplementedClientServiceServer struct{}

UnimplementedClientServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedClientServiceServer) GetProviderCatalogue 

func (UnimplementedClientServiceServer) GetProviderCatalogue(context.Context, *GetProviderCatalogueRequest) (*GetProviderCatalogueResponse, error)

func (UnimplementedClientServiceServer) GetProviderDataset 

func (UnimplementedClientServiceServer) GetProviderDataset(context.Context, *GetProviderDatasetRequest) (*GetProviderDatasetResponse, error)

func (UnimplementedClientServiceServer) GetProviderDatasetDownloadInformation 

func (UnimplementedClientServiceServer) GetProviderDatasetDownloadInformation(context.Context, *GetProviderDatasetDownloadInformationRequest) (*GetProviderDatasetDownloadInformationResponse, error)

func (UnimplementedClientServiceServer) Ping 

func (UnimplementedClientServiceServer) Ping(context.Context, *ClientServicePingRequest) (*ClientServicePingResponse, error)

func (UnimplementedClientServiceServer) SignalTransferCancelled 

func (UnimplementedClientServiceServer) SignalTransferCancelled(context.Context, *SignalTransferCancelledRequest) (*SignalTransferCancelledResponse, error)

func (UnimplementedClientServiceServer) SignalTransferComplete 

func (UnimplementedClientServiceServer) SignalTransferComplete(context.Context, *SignalTransferCompleteRequest) (*SignalTransferCompleteResponse, error)

func (UnimplementedClientServiceServer) SignalTransferResume 

func (UnimplementedClientServiceServer) SignalTransferResume(context.Context, *SignalTransferResumeRequest) (*SignalTransferResumeResponse, error)

func (UnimplementedClientServiceServer) SignalTransferSuspend 

func (UnimplementedClientServiceServer) SignalTransferSuspend(context.Context, *SignalTransferSuspendRequest) (*SignalTransferSuspendResponse, error)

type UnimplementedProviderServiceServer 

type UnimplementedProviderServiceServer struct{}

UnimplementedProviderServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedProviderServiceServer) GetCatalogue 

func (UnimplementedProviderServiceServer) GetCatalogue(context.Context, *GetCatalogueRequest) (*GetCatalogueResponse, error)

func (UnimplementedProviderServiceServer) GetDataset 

func (UnimplementedProviderServiceServer) GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)

func (UnimplementedProviderServiceServer) Ping 

func (UnimplementedProviderServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedProviderServiceServer) PublishDataset 

func (UnimplementedProviderServiceServer) PublishDataset(context.Context, *PublishDatasetRequest) (*PublishDatasetResponse, error)

func (UnimplementedProviderServiceServer) SuspendPublishedDataset 

func (UnimplementedProviderServiceServer) SuspendPublishedDataset(context.Context, *SuspendPublishedDatasetRequest) (*SuspendPublishedDatasetResponse, error)

func (UnimplementedProviderServiceServer) UnpublishDataset 

func (UnimplementedProviderServiceServer) UnpublishDataset(context.Context, *UnpublishDatasetRequest) (*UnpublishDatasetResponse, error)

func (UnimplementedProviderServiceServer) UnsuspendPublishedDataset 

func (UnimplementedProviderServiceServer) UnsuspendPublishedDataset(context.Context, *UnsuspendPublishedDatasetRequest) (*UnsuspendPublishedDatasetResponse, error)

type UnpublishDatasetRequest 

type UnpublishDatasetRequest struct {
	PublishId string `protobuf:"bytes,1,opt,name=publish_id,json=publishId,proto3" json:"publish_id,omitempty"`
	// contains filtered or unexported fields
}

UnpublishDatasetRequest contains the publish ID of the published dataset.

func (*UnpublishDatasetRequest) Descriptor deprecated 

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

Deprecated: Use UnpublishDatasetRequest.ProtoReflect.Descriptor instead.

func (*UnpublishDatasetRequest) GetPublishId 

func (x *UnpublishDatasetRequest) GetPublishId() string

func (*UnpublishDatasetRequest) ProtoMessage 

func (*UnpublishDatasetRequest) ProtoMessage()

func (*UnpublishDatasetRequest) ProtoReflect 

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

func (*UnpublishDatasetRequest) Reset 

func (x *UnpublishDatasetRequest) Reset()

func (*UnpublishDatasetRequest) String 

func (x *UnpublishDatasetRequest) String() string

type UnpublishDatasetResponse 

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

UnpublishDatasetResponse contains a boolean indicating success.

func (*UnpublishDatasetResponse) Descriptor deprecated 

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

Deprecated: Use UnpublishDatasetResponse.ProtoReflect.Descriptor instead.

func (*UnpublishDatasetResponse) GetSuccess 

func (x *UnpublishDatasetResponse) GetSuccess() bool

func (*UnpublishDatasetResponse) ProtoMessage 

func (*UnpublishDatasetResponse) ProtoMessage()

func (*UnpublishDatasetResponse) ProtoReflect 

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

func (*UnpublishDatasetResponse) Reset 

func (x *UnpublishDatasetResponse) Reset()

func (*UnpublishDatasetResponse) String 

func (x *UnpublishDatasetResponse) String() string

type UnsafeClientServiceServer 

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

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

type UnsafeProviderServiceServer 

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

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

type UnsuspendPublishedDatasetRequest 

type UnsuspendPublishedDatasetRequest struct {
	PublishId string `protobuf:"bytes,1,opt,name=publish_id,json=publishId,proto3" json:"publish_id,omitempty"`
	// contains filtered or unexported fields
}

UnsuspendPublishedDataset contains the publish ID of the published dataset.

func (*UnsuspendPublishedDatasetRequest) Descriptor deprecated 

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

Deprecated: Use UnsuspendPublishedDatasetRequest.ProtoReflect.Descriptor instead.

func (*UnsuspendPublishedDatasetRequest) GetPublishId 

func (x *UnsuspendPublishedDatasetRequest) GetPublishId() string

func (*UnsuspendPublishedDatasetRequest) ProtoMessage 

func (*UnsuspendPublishedDatasetRequest) ProtoMessage()

func (*UnsuspendPublishedDatasetRequest) ProtoReflect 

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

func (*UnsuspendPublishedDatasetRequest) Reset 

func (x *UnsuspendPublishedDatasetRequest) Reset()

func (*UnsuspendPublishedDatasetRequest) String 

func (x *UnsuspendPublishedDatasetRequest) String() string

type UnsuspendPublishedDatasetResponse 

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

UnsuspendPublishedDatasetResponse indicates success

func (*UnsuspendPublishedDatasetResponse) Descriptor deprecated 

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

Deprecated: Use UnsuspendPublishedDatasetResponse.ProtoReflect.Descriptor instead.

func (*UnsuspendPublishedDatasetResponse) ProtoMessage 

func (*UnsuspendPublishedDatasetResponse) ProtoMessage()

func (*UnsuspendPublishedDatasetResponse) ProtoReflect 

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

func (*UnsuspendPublishedDatasetResponse) Reset 

func (x *UnsuspendPublishedDatasetResponse) Reset()

func (*UnsuspendPublishedDatasetResponse) String 

func (x *UnsuspendPublishedDatasetResponse) 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.