dspv1alpha2

package
v0.0.7-alpha2 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ContractService_Configure_FullMethodName            = "/dsp.v1alpha2.ContractService/Configure"
	ContractService_RequestReceived_FullMethodName      = "/dsp.v1alpha2.ContractService/RequestReceived"
	ContractService_OfferReceived_FullMethodName        = "/dsp.v1alpha2.ContractService/OfferReceived"
	ContractService_AcceptedReceived_FullMethodName     = "/dsp.v1alpha2.ContractService/AcceptedReceived"
	ContractService_AgreementReceived_FullMethodName    = "/dsp.v1alpha2.ContractService/AgreementReceived"
	ContractService_VerificationReceived_FullMethodName = "/dsp.v1alpha2.ContractService/VerificationReceived"
	ContractService_FinalizationReceived_FullMethodName = "/dsp.v1alpha2.ContractService/FinalizationReceived"
	ContractService_TerminationReceived_FullMethodName  = "/dsp.v1alpha2.ContractService/TerminationReceived"
)
View Source 
const (
	ControlService_GetProviderDatasetDownloadInformation_FullMethodName = "/dsp.v1alpha2.ControlService/GetProviderDatasetDownloadInformation"
	ControlService_VerifyConnection_FullMethodName                      = "/dsp.v1alpha2.ControlService/VerifyConnection"
	ControlService_GetProviderCatalogue_FullMethodName                  = "/dsp.v1alpha2.ControlService/GetProviderCatalogue"
	ControlService_GetProviderDataset_FullMethodName                    = "/dsp.v1alpha2.ControlService/GetProviderDataset"
	ControlService_ContractRequest_FullMethodName                       = "/dsp.v1alpha2.ControlService/ContractRequest"
	ControlService_ContractOffer_FullMethodName                         = "/dsp.v1alpha2.ControlService/ContractOffer"
	ControlService_ContractAccept_FullMethodName                        = "/dsp.v1alpha2.ControlService/ContractAccept"
	ControlService_ContractAgree_FullMethodName                         = "/dsp.v1alpha2.ControlService/ContractAgree"
	ControlService_ContractVerify_FullMethodName                        = "/dsp.v1alpha2.ControlService/ContractVerify"
	ControlService_ContractFinalize_FullMethodName                      = "/dsp.v1alpha2.ControlService/ContractFinalize"
	ControlService_ContractTerminate_FullMethodName                     = "/dsp.v1alpha2.ControlService/ContractTerminate"
	ControlService_SignalTransferComplete_FullMethodName                = "/dsp.v1alpha2.ControlService/SignalTransferComplete"
	ControlService_SignalTransferCancelled_FullMethodName               = "/dsp.v1alpha2.ControlService/SignalTransferCancelled"
	ControlService_SignalTransferSuspend_FullMethodName                 = "/dsp.v1alpha2.ControlService/SignalTransferSuspend"
	ControlService_SignalTransferResume_FullMethodName                  = "/dsp.v1alpha2.ControlService/SignalTransferResume"
)
View Source 
const (
	ProviderService_Ping_FullMethodName                      = "/dsp.v1alpha2.ProviderService/Ping"
	ProviderService_GetCatalogue_FullMethodName              = "/dsp.v1alpha2.ProviderService/GetCatalogue"
	ProviderService_GetDataset_FullMethodName                = "/dsp.v1alpha2.ProviderService/GetDataset"
	ProviderService_PublishDataset_FullMethodName            = "/dsp.v1alpha2.ProviderService/PublishDataset"
	ProviderService_UnpublishDataset_FullMethodName          = "/dsp.v1alpha2.ProviderService/UnpublishDataset"
	ProviderService_SuspendPublishedDataset_FullMethodName   = "/dsp.v1alpha2.ProviderService/SuspendPublishedDataset"
	ProviderService_UnsuspendPublishedDataset_FullMethodName = "/dsp.v1alpha2.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 ContractService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dsp.v1alpha2.ContractService",
	HandlerType: (*ContractServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _ContractService_Configure_Handler,
		},
		{
			MethodName: "RequestReceived",
			Handler:    _ContractService_RequestReceived_Handler,
		},
		{
			MethodName: "OfferReceived",
			Handler:    _ContractService_OfferReceived_Handler,
		},
		{
			MethodName: "AcceptedReceived",
			Handler:    _ContractService_AcceptedReceived_Handler,
		},
		{
			MethodName: "AgreementReceived",
			Handler:    _ContractService_AgreementReceived_Handler,
		},
		{
			MethodName: "VerificationReceived",
			Handler:    _ContractService_VerificationReceived_Handler,
		},
		{
			MethodName: "FinalizationReceived",
			Handler:    _ContractService_FinalizationReceived_Handler,
		},
		{
			MethodName: "TerminationReceived",
			Handler:    _ContractService_TerminationReceived_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dsp/v1alpha2/contract.proto",
}

ContractService_ServiceDesc is the grpc.ServiceDesc for ContractService 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 ControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dsp.v1alpha2.ControlService",
	HandlerType: (*ControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetProviderDatasetDownloadInformation",
			Handler:    _ControlService_GetProviderDatasetDownloadInformation_Handler,
		},
		{
			MethodName: "VerifyConnection",
			Handler:    _ControlService_VerifyConnection_Handler,
		},
		{
			MethodName: "GetProviderCatalogue",
			Handler:    _ControlService_GetProviderCatalogue_Handler,
		},
		{
			MethodName: "GetProviderDataset",
			Handler:    _ControlService_GetProviderDataset_Handler,
		},
		{
			MethodName: "ContractRequest",
			Handler:    _ControlService_ContractRequest_Handler,
		},
		{
			MethodName: "ContractOffer",
			Handler:    _ControlService_ContractOffer_Handler,
		},
		{
			MethodName: "ContractAccept",
			Handler:    _ControlService_ContractAccept_Handler,
		},
		{
			MethodName: "ContractAgree",
			Handler:    _ControlService_ContractAgree_Handler,
		},
		{
			MethodName: "ContractVerify",
			Handler:    _ControlService_ContractVerify_Handler,
		},
		{
			MethodName: "ContractFinalize",
			Handler:    _ControlService_ContractFinalize_Handler,
		},
		{
			MethodName: "ContractTerminate",
			Handler:    _ControlService_ContractTerminate_Handler,
		},
		{
			MethodName: "SignalTransferComplete",
			Handler:    _ControlService_SignalTransferComplete_Handler,
		},
		{
			MethodName: "SignalTransferCancelled",
			Handler:    _ControlService_SignalTransferCancelled_Handler,
		},
		{
			MethodName: "SignalTransferSuspend",
			Handler:    _ControlService_SignalTransferSuspend_Handler,
		},
		{
			MethodName: "SignalTransferResume",
			Handler:    _ControlService_SignalTransferResume_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dsp/v1alpha2/control.proto",
}

ControlService_ServiceDesc is the grpc.ServiceDesc for ControlService 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_v1alpha2_contract_proto protoreflect.FileDescriptor
View Source 
var File_dsp_v1alpha2_control_proto protoreflect.FileDescriptor
View Source 
var File_dsp_v1alpha2_provider_proto protoreflect.FileDescriptor
View Source 
var File_dsp_v1alpha2_types_proto protoreflect.FileDescriptor
View Source 
var ProviderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dsp.v1alpha2.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/v1alpha2/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 RegisterContractServiceServer 

func RegisterContractServiceServer(s grpc.ServiceRegistrar, srv ContractServiceServer)

func RegisterControlServiceServer 

func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)

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 ContractAcceptRequest 

type ContractAcceptRequest struct {
	Pid        string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	AutoAccept bool   `protobuf:"varint,2,opt,name=auto_accept,json=autoAccept,proto3" json:"auto_accept,omitempty"`
	// contains filtered or unexported fields
}

ContractAcceptRequest contains the pid of the contract negotiation to be accepted.

func (*ContractAcceptRequest) Descriptor deprecated 

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

Deprecated: Use ContractAcceptRequest.ProtoReflect.Descriptor instead.

func (*ContractAcceptRequest) GetAutoAccept 

func (x *ContractAcceptRequest) GetAutoAccept() bool

func (*ContractAcceptRequest) GetPid 

func (x *ContractAcceptRequest) GetPid() string

func (*ContractAcceptRequest) ProtoMessage 

func (*ContractAcceptRequest) ProtoMessage()

func (*ContractAcceptRequest) ProtoReflect 

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

func (*ContractAcceptRequest) Reset 

func (x *ContractAcceptRequest) Reset()

func (*ContractAcceptRequest) String 

func (x *ContractAcceptRequest) String() string

type ContractAcceptResponse 

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

func (*ContractAcceptResponse) Descriptor deprecated 

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

Deprecated: Use ContractAcceptResponse.ProtoReflect.Descriptor instead.

func (*ContractAcceptResponse) ProtoMessage 

func (*ContractAcceptResponse) ProtoMessage()

func (*ContractAcceptResponse) ProtoReflect 

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

func (*ContractAcceptResponse) Reset 

func (x *ContractAcceptResponse) Reset()

func (*ContractAcceptResponse) String 

func (x *ContractAcceptResponse) String() string

type ContractAgreeRequest 

type ContractAgreeRequest struct {
	Agreement  string `protobuf:"bytes,1,opt,name=agreement,proto3" json:"agreement,omitempty"`
	Pid        string `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
	AutoAccept bool   `protobuf:"varint,3,opt,name=auto_accept,json=autoAccept,proto3" json:"auto_accept,omitempty"`
	// contains filtered or unexported fields
}

ContractAgreeRequest contains the agreement and pid of the contract negotiation to agree to.

func (*ContractAgreeRequest) Descriptor deprecated 

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

Deprecated: Use ContractAgreeRequest.ProtoReflect.Descriptor instead.

func (*ContractAgreeRequest) GetAgreement 

func (x *ContractAgreeRequest) GetAgreement() string

func (*ContractAgreeRequest) GetAutoAccept 

func (x *ContractAgreeRequest) GetAutoAccept() bool

func (*ContractAgreeRequest) GetPid 

func (x *ContractAgreeRequest) GetPid() string

func (*ContractAgreeRequest) ProtoMessage 

func (*ContractAgreeRequest) ProtoMessage()

func (*ContractAgreeRequest) ProtoReflect 

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

func (*ContractAgreeRequest) Reset 

func (x *ContractAgreeRequest) Reset()

func (*ContractAgreeRequest) String 

func (x *ContractAgreeRequest) String() string

type ContractAgreeResponse 

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

func (*ContractAgreeResponse) Descriptor deprecated 

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

Deprecated: Use ContractAgreeResponse.ProtoReflect.Descriptor instead.

func (*ContractAgreeResponse) ProtoMessage 

func (*ContractAgreeResponse) ProtoMessage()

func (*ContractAgreeResponse) ProtoReflect 

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

func (*ContractAgreeResponse) Reset 

func (x *ContractAgreeResponse) Reset()

func (*ContractAgreeResponse) String 

func (x *ContractAgreeResponse) String() string

type ContractFinalizeRequest 

type ContractFinalizeRequest struct {
	Pid        string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	AutoAccept bool   `protobuf:"varint,2,opt,name=auto_accept,json=autoAccept,proto3" json:"auto_accept,omitempty"`
	// contains filtered or unexported fields
}

ContractFinalizeRequest contains the pid of the contract negotiation to finalize.

func (*ContractFinalizeRequest) Descriptor deprecated 

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

Deprecated: Use ContractFinalizeRequest.ProtoReflect.Descriptor instead.

func (*ContractFinalizeRequest) GetAutoAccept 

func (x *ContractFinalizeRequest) GetAutoAccept() bool

func (*ContractFinalizeRequest) GetPid 

func (x *ContractFinalizeRequest) GetPid() string

func (*ContractFinalizeRequest) ProtoMessage 

func (*ContractFinalizeRequest) ProtoMessage()

func (*ContractFinalizeRequest) ProtoReflect 

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

func (*ContractFinalizeRequest) Reset 

func (x *ContractFinalizeRequest) Reset()

func (*ContractFinalizeRequest) String 

func (x *ContractFinalizeRequest) String() string

type ContractFinalizeResponse 

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

func (*ContractFinalizeResponse) Descriptor deprecated 

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

Deprecated: Use ContractFinalizeResponse.ProtoReflect.Descriptor instead.

func (*ContractFinalizeResponse) ProtoMessage 

func (*ContractFinalizeResponse) ProtoMessage()

func (*ContractFinalizeResponse) ProtoReflect 

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

func (*ContractFinalizeResponse) Reset 

func (x *ContractFinalizeResponse) Reset()

func (*ContractFinalizeResponse) String 

func (x *ContractFinalizeResponse) String() string

type ContractOfferRequest 

type ContractOfferRequest struct {
	Offer              string  `protobuf:"bytes,1,opt,name=offer,proto3" json:"offer,omitempty"`
	Pid                *string `protobuf:"bytes,2,opt,name=pid,proto3,oneof" json:"pid,omitempty"`
	ParticipantAddress *string `protobuf:"bytes,3,opt,name=participant_address,json=participantAddress,proto3,oneof" json:"participant_address,omitempty"`
	AutoAccept         bool    `protobuf:"varint,4,opt,name=auto_accept,json=autoAccept,proto3" json:"auto_accept,omitempty"`
	// contains filtered or unexported fields
}

ContractOfferRequest contains the offer, and a pid if this is needs to send an offer for an already existing offer, or a participant_address if this is a a new offer.

func (*ContractOfferRequest) Descriptor deprecated 

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

Deprecated: Use ContractOfferRequest.ProtoReflect.Descriptor instead.

func (*ContractOfferRequest) GetAutoAccept 

func (x *ContractOfferRequest) GetAutoAccept() bool

func (*ContractOfferRequest) GetOffer 

func (x *ContractOfferRequest) GetOffer() string

func (*ContractOfferRequest) GetParticipantAddress 

func (x *ContractOfferRequest) GetParticipantAddress() string

func (*ContractOfferRequest) GetPid 

func (x *ContractOfferRequest) GetPid() string

func (*ContractOfferRequest) ProtoMessage 

func (*ContractOfferRequest) ProtoMessage()

func (*ContractOfferRequest) ProtoReflect 

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

func (*ContractOfferRequest) Reset 

func (x *ContractOfferRequest) Reset()

func (*ContractOfferRequest) String 

func (x *ContractOfferRequest) String() string

type ContractOfferResponse 

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

func (*ContractOfferResponse) Descriptor deprecated 

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

Deprecated: Use ContractOfferResponse.ProtoReflect.Descriptor instead.

func (*ContractOfferResponse) ProtoMessage 

func (*ContractOfferResponse) ProtoMessage()

func (*ContractOfferResponse) ProtoReflect 

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

func (*ContractOfferResponse) Reset 

func (x *ContractOfferResponse) Reset()

func (*ContractOfferResponse) String 

func (x *ContractOfferResponse) String() string

type ContractRequestRequest 

type ContractRequestRequest struct {
	Offer              string  `protobuf:"bytes,1,opt,name=offer,proto3" json:"offer,omitempty"`
	Pid                *string `protobuf:"bytes,2,opt,name=pid,proto3,oneof" json:"pid,omitempty"`
	ParticipantAddress *string `protobuf:"bytes,3,opt,name=participant_address,json=participantAddress,proto3,oneof" json:"participant_address,omitempty"`
	AutoAccept         bool    `protobuf:"varint,4,opt,name=auto_accept,json=autoAccept,proto3" json:"auto_accept,omitempty"`
	// contains filtered or unexported fields
}

ContractRequestRequest contains the offer, and a pid if this is needs to send a request for an already existing offer, or a participant_address if this is a request for a new offer.

func (*ContractRequestRequest) Descriptor deprecated 

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

Deprecated: Use ContractRequestRequest.ProtoReflect.Descriptor instead.

func (*ContractRequestRequest) GetAutoAccept 

func (x *ContractRequestRequest) GetAutoAccept() bool

func (*ContractRequestRequest) GetOffer 

func (x *ContractRequestRequest) GetOffer() string

func (*ContractRequestRequest) GetParticipantAddress 

func (x *ContractRequestRequest) GetParticipantAddress() string

func (*ContractRequestRequest) GetPid 

func (x *ContractRequestRequest) GetPid() string

func (*ContractRequestRequest) ProtoMessage 

func (*ContractRequestRequest) ProtoMessage()

func (*ContractRequestRequest) ProtoReflect 

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

func (*ContractRequestRequest) Reset 

func (x *ContractRequestRequest) Reset()

func (*ContractRequestRequest) String 

func (x *ContractRequestRequest) String() string

type ContractRequestResponse 

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

func (*ContractRequestResponse) Descriptor deprecated 

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

Deprecated: Use ContractRequestResponse.ProtoReflect.Descriptor instead.

func (*ContractRequestResponse) ProtoMessage 

func (*ContractRequestResponse) ProtoMessage()

func (*ContractRequestResponse) ProtoReflect 

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

func (*ContractRequestResponse) Reset 

func (x *ContractRequestResponse) Reset()

func (*ContractRequestResponse) String 

func (x *ContractRequestResponse) String() string

type ContractServiceAcceptedReceivedRequest 

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

ContractServiceAcceptedReceivedRequest contains the pid RUN-DSP uses to refer to the negotiation that just got accepted.

func (*ContractServiceAcceptedReceivedRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceAcceptedReceivedRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceAcceptedReceivedRequest) GetPid 

func (x *ContractServiceAcceptedReceivedRequest) GetPid() string

func (*ContractServiceAcceptedReceivedRequest) ProtoMessage 

func (*ContractServiceAcceptedReceivedRequest) ProtoMessage()

func (*ContractServiceAcceptedReceivedRequest) ProtoReflect 

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

func (*ContractServiceAcceptedReceivedRequest) Reset 

func (x *ContractServiceAcceptedReceivedRequest) Reset()

func (*ContractServiceAcceptedReceivedRequest) String 

func (x *ContractServiceAcceptedReceivedRequest) String() string

type ContractServiceAcceptedReceivedResponse 

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

func (*ContractServiceAcceptedReceivedResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceAcceptedReceivedResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceAcceptedReceivedResponse) ProtoMessage 

func (*ContractServiceAcceptedReceivedResponse) ProtoMessage()

func (*ContractServiceAcceptedReceivedResponse) ProtoReflect 

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

func (*ContractServiceAcceptedReceivedResponse) Reset 

func (x *ContractServiceAcceptedReceivedResponse) Reset()

func (*ContractServiceAcceptedReceivedResponse) String 

func (x *ContractServiceAcceptedReceivedResponse) String() string

type ContractServiceAgreementReceivedRequest 

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

ContractServiceAgreementReceivedRequest contains the pid RUN-DSP uses to refer to the negotiation that just got agreed to.

func (*ContractServiceAgreementReceivedRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceAgreementReceivedRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceAgreementReceivedRequest) GetPid 

func (x *ContractServiceAgreementReceivedRequest) GetPid() string

func (*ContractServiceAgreementReceivedRequest) ProtoMessage 

func (*ContractServiceAgreementReceivedRequest) ProtoMessage()

func (*ContractServiceAgreementReceivedRequest) ProtoReflect 

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

func (*ContractServiceAgreementReceivedRequest) Reset 

func (x *ContractServiceAgreementReceivedRequest) Reset()

func (*ContractServiceAgreementReceivedRequest) String 

func (x *ContractServiceAgreementReceivedRequest) String() string

type ContractServiceAgreementReceivedResponse 

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

func (*ContractServiceAgreementReceivedResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceAgreementReceivedResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceAgreementReceivedResponse) ProtoMessage 

func (*ContractServiceAgreementReceivedResponse) ProtoMessage()

func (*ContractServiceAgreementReceivedResponse) ProtoReflect 

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

func (*ContractServiceAgreementReceivedResponse) Reset 

func (x *ContractServiceAgreementReceivedResponse) Reset()

func (*ContractServiceAgreementReceivedResponse) String 

func (x *ContractServiceAgreementReceivedResponse) String() string

type ContractServiceClient 

type ContractServiceClient interface {
	// Configure sets some callback configuration parameters.
	Configure(ctx context.Context, in *ContractServiceConfigureRequest, opts ...grpc.CallOption) (*ContractServiceConfigureResponse, error)
	// RequestReceived is called when RUN-DSP receives a ContractRequestMessage.
	RequestReceived(ctx context.Context, in *ContractServiceRequestReceivedRequest, opts ...grpc.CallOption) (*ContractServiceRequestReceivedResponse, error)
	// OfferReceived is called when RUN-DSP receives a ContractOfferMessage.
	OfferReceived(ctx context.Context, in *ContractServiceOfferReceivedRequest, opts ...grpc.CallOption) (*ContractServiceOfferReceivedResponse, error)
	// AcceptedReceived is called when RUN-DSP receives an Accepted event message.
	AcceptedReceived(ctx context.Context, in *ContractServiceAcceptedReceivedRequest, opts ...grpc.CallOption) (*ContractServiceAcceptedReceivedResponse, error)
	// AgreementReceived is called when RUN-DSP receives a ContractAgreementMessage.
	AgreementReceived(ctx context.Context, in *ContractServiceAgreementReceivedRequest, opts ...grpc.CallOption) (*ContractServiceAgreementReceivedResponse, error)
	// VerificationReceived is called when RUN-DSP receives a ContractVerificationMessage.
	VerificationReceived(ctx context.Context, in *ContractServiceVerificationReceivedRequest, opts ...grpc.CallOption) (*ContractServiceVerificationReceivedResponse, error)
	// FinalizationReceived is called when RUN-DSP receives a Finalized event message.
	FinalizationReceived(ctx context.Context, in *ContractServiceFinalizationReceivedRequest, opts ...grpc.CallOption) (*ContractServiceFinalizationReceivedResponse, error)
	// TerminationReceived is called when RUN-DSP receives a ContractTerminationMessage
	TerminationReceived(ctx context.Context, in *ContractServiceTerminationReceivedRequest, opts ...grpc.CallOption) (*ContractServiceTerminationReceivedResponse, error)
}

ContractServiceClient is the client API for ContractService 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 ContractService allows RUN-DSP to call an external service to approve/terminate contract negotiation steps. Outside of the defined calls, RUN-DSP will also forward the `authorization` header so that the caller can be verified by the service.

func NewContractServiceClient 

func NewContractServiceClient(cc grpc.ClientConnInterface) ContractServiceClient

type ContractServiceConfigureRequest 

type ContractServiceConfigureRequest struct {
	ConnectorAddress  string `protobuf:"bytes,1,opt,name=connector_address,json=connectorAddress,proto3" json:"connector_address,omitempty"`    // The gRPC address RUN-DSP will listen to for control directives.
	VerificationToken string `protobuf:"bytes,2,opt,name=verification_token,json=verificationToken,proto3" json:"verification_token,omitempty"` // The verification token generated by RUN-DSP to use when we are verifying the above address.
	// contains filtered or unexported fields
}

ContractServiceConfigureRequest represents the configuration request RUN-DSP does to the contract service.

func (*ContractServiceConfigureRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceConfigureRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceConfigureRequest) GetConnectorAddress 

func (x *ContractServiceConfigureRequest) GetConnectorAddress() string

func (*ContractServiceConfigureRequest) GetVerificationToken 

func (x *ContractServiceConfigureRequest) GetVerificationToken() string

func (*ContractServiceConfigureRequest) ProtoMessage 

func (*ContractServiceConfigureRequest) ProtoMessage()

func (*ContractServiceConfigureRequest) ProtoReflect 

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

func (*ContractServiceConfigureRequest) Reset 

func (x *ContractServiceConfigureRequest) Reset()

func (*ContractServiceConfigureRequest) String 

func (x *ContractServiceConfigureRequest) String() string

type ContractServiceConfigureResponse 

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

func (*ContractServiceConfigureResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceConfigureResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceConfigureResponse) ProtoMessage 

func (*ContractServiceConfigureResponse) ProtoMessage()

func (*ContractServiceConfigureResponse) ProtoReflect 

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

func (*ContractServiceConfigureResponse) Reset 

func (x *ContractServiceConfigureResponse) Reset()

func (*ContractServiceConfigureResponse) String 

func (x *ContractServiceConfigureResponse) String() string

type ContractServiceFinalizationReceivedRequest 

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

ContractServiceFinalizationReceivedRequest contains the pid RUN-DSP uses to refer to the negotiation that just got finalized.

func (*ContractServiceFinalizationReceivedRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceFinalizationReceivedRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceFinalizationReceivedRequest) GetPid 

func (x *ContractServiceFinalizationReceivedRequest) GetPid() string

func (*ContractServiceFinalizationReceivedRequest) ProtoMessage 

func (*ContractServiceFinalizationReceivedRequest) ProtoMessage()

func (*ContractServiceFinalizationReceivedRequest) ProtoReflect 

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

func (*ContractServiceFinalizationReceivedRequest) Reset 

func (x *ContractServiceFinalizationReceivedRequest) Reset()

func (*ContractServiceFinalizationReceivedRequest) String 

func (x *ContractServiceFinalizationReceivedRequest) String() string

type ContractServiceFinalizationReceivedResponse 

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

func (*ContractServiceFinalizationReceivedResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceFinalizationReceivedResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceFinalizationReceivedResponse) ProtoMessage 

func (*ContractServiceFinalizationReceivedResponse) ProtoMessage()

func (*ContractServiceFinalizationReceivedResponse) ProtoReflect 

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

func (*ContractServiceFinalizationReceivedResponse) Reset 

func (x *ContractServiceFinalizationReceivedResponse) Reset()

func (*ContractServiceFinalizationReceivedResponse) String 

func (x *ContractServiceFinalizationReceivedResponse) String() string

type ContractServiceOfferReceivedRequest 

type ContractServiceOfferReceivedRequest struct {
	Pid   string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Offer string `protobuf:"bytes,2,opt,name=offer,proto3" json:"offer,omitempty"`
	// contains filtered or unexported fields
}

ContractServiceOfferReceivedRequest contains the pid RUN-DSP uses to refer to the negotiation and the raw ODRL offer JSON.

func (*ContractServiceOfferReceivedRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceOfferReceivedRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceOfferReceivedRequest) GetOffer 

func (x *ContractServiceOfferReceivedRequest) GetOffer() string

func (*ContractServiceOfferReceivedRequest) GetPid 

func (x *ContractServiceOfferReceivedRequest) GetPid() string

func (*ContractServiceOfferReceivedRequest) ProtoMessage 

func (*ContractServiceOfferReceivedRequest) ProtoMessage()

func (*ContractServiceOfferReceivedRequest) ProtoReflect 

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

func (*ContractServiceOfferReceivedRequest) Reset 

func (x *ContractServiceOfferReceivedRequest) Reset()

func (*ContractServiceOfferReceivedRequest) String 

func (x *ContractServiceOfferReceivedRequest) String() string

type ContractServiceOfferReceivedResponse 

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

func (*ContractServiceOfferReceivedResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceOfferReceivedResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceOfferReceivedResponse) ProtoMessage 

func (*ContractServiceOfferReceivedResponse) ProtoMessage()

func (*ContractServiceOfferReceivedResponse) ProtoReflect 

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

func (*ContractServiceOfferReceivedResponse) Reset 

func (x *ContractServiceOfferReceivedResponse) Reset()

func (*ContractServiceOfferReceivedResponse) String 

func (x *ContractServiceOfferReceivedResponse) String() string

type ContractServiceRequestReceivedRequest 

type ContractServiceRequestReceivedRequest struct {
	Pid   string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Offer string `protobuf:"bytes,2,opt,name=offer,proto3" json:"offer,omitempty"`
	// contains filtered or unexported fields
}

ContractServiceRequestReceivedRequest contains the pid RUN-DSP uses to refer to the negotiation and offer contains the raw JSON of the offer ODRL.

func (*ContractServiceRequestReceivedRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceRequestReceivedRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceRequestReceivedRequest) GetOffer 

func (x *ContractServiceRequestReceivedRequest) GetOffer() string

func (*ContractServiceRequestReceivedRequest) GetPid 

func (x *ContractServiceRequestReceivedRequest) GetPid() string

func (*ContractServiceRequestReceivedRequest) ProtoMessage 

func (*ContractServiceRequestReceivedRequest) ProtoMessage()

func (*ContractServiceRequestReceivedRequest) ProtoReflect 

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

func (*ContractServiceRequestReceivedRequest) Reset 

func (x *ContractServiceRequestReceivedRequest) Reset()

func (*ContractServiceRequestReceivedRequest) String 

func (x *ContractServiceRequestReceivedRequest) String() string

type ContractServiceRequestReceivedResponse 

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

func (*ContractServiceRequestReceivedResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceRequestReceivedResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceRequestReceivedResponse) ProtoMessage 

func (*ContractServiceRequestReceivedResponse) ProtoMessage()

func (*ContractServiceRequestReceivedResponse) ProtoReflect 

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

func (*ContractServiceRequestReceivedResponse) Reset 

func (x *ContractServiceRequestReceivedResponse) Reset()

func (*ContractServiceRequestReceivedResponse) String 

func (x *ContractServiceRequestReceivedResponse) String() string

type ContractServiceServer 

type ContractServiceServer interface {
	// Configure sets some callback configuration parameters.
	Configure(context.Context, *ContractServiceConfigureRequest) (*ContractServiceConfigureResponse, error)
	// RequestReceived is called when RUN-DSP receives a ContractRequestMessage.
	RequestReceived(context.Context, *ContractServiceRequestReceivedRequest) (*ContractServiceRequestReceivedResponse, error)
	// OfferReceived is called when RUN-DSP receives a ContractOfferMessage.
	OfferReceived(context.Context, *ContractServiceOfferReceivedRequest) (*ContractServiceOfferReceivedResponse, error)
	// AcceptedReceived is called when RUN-DSP receives an Accepted event message.
	AcceptedReceived(context.Context, *ContractServiceAcceptedReceivedRequest) (*ContractServiceAcceptedReceivedResponse, error)
	// AgreementReceived is called when RUN-DSP receives a ContractAgreementMessage.
	AgreementReceived(context.Context, *ContractServiceAgreementReceivedRequest) (*ContractServiceAgreementReceivedResponse, error)
	// VerificationReceived is called when RUN-DSP receives a ContractVerificationMessage.
	VerificationReceived(context.Context, *ContractServiceVerificationReceivedRequest) (*ContractServiceVerificationReceivedResponse, error)
	// FinalizationReceived is called when RUN-DSP receives a Finalized event message.
	FinalizationReceived(context.Context, *ContractServiceFinalizationReceivedRequest) (*ContractServiceFinalizationReceivedResponse, error)
	// TerminationReceived is called when RUN-DSP receives a ContractTerminationMessage
	TerminationReceived(context.Context, *ContractServiceTerminationReceivedRequest) (*ContractServiceTerminationReceivedResponse, error)
	// contains filtered or unexported methods
}

ContractServiceServer is the server API for ContractService service. All implementations must embed UnimplementedContractServiceServer for forward compatibility.

The ContractService allows RUN-DSP to call an external service to approve/terminate contract negotiation steps. Outside of the defined calls, RUN-DSP will also forward the `authorization` header so that the caller can be verified by the service.

type ContractServiceTerminationReceivedRequest 

type ContractServiceTerminationReceivedRequest struct {
	Pid    string   `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Code   string   `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Reason []string `protobuf:"bytes,3,rep,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

ContractServiceTerminationReceivedRequest contains the pid RUN-DSP uses to refer to the negotiation got terminated. It also contains the reason for said termination.

func (*ContractServiceTerminationReceivedRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceTerminationReceivedRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceTerminationReceivedRequest) GetCode 

func (x *ContractServiceTerminationReceivedRequest) GetCode() string

func (*ContractServiceTerminationReceivedRequest) GetPid 

func (x *ContractServiceTerminationReceivedRequest) GetPid() string

func (*ContractServiceTerminationReceivedRequest) GetReason 

func (x *ContractServiceTerminationReceivedRequest) GetReason() []string

func (*ContractServiceTerminationReceivedRequest) ProtoMessage 

func (*ContractServiceTerminationReceivedRequest) ProtoMessage()

func (*ContractServiceTerminationReceivedRequest) ProtoReflect 

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

func (*ContractServiceTerminationReceivedRequest) Reset 

func (x *ContractServiceTerminationReceivedRequest) Reset()

func (*ContractServiceTerminationReceivedRequest) String 

func (x *ContractServiceTerminationReceivedRequest) String() string

type ContractServiceTerminationReceivedResponse 

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

func (*ContractServiceTerminationReceivedResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceTerminationReceivedResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceTerminationReceivedResponse) ProtoMessage 

func (*ContractServiceTerminationReceivedResponse) ProtoMessage()

func (*ContractServiceTerminationReceivedResponse) ProtoReflect 

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

func (*ContractServiceTerminationReceivedResponse) Reset 

func (x *ContractServiceTerminationReceivedResponse) Reset()

func (*ContractServiceTerminationReceivedResponse) String 

func (x *ContractServiceTerminationReceivedResponse) String() string

type ContractServiceVerificationReceivedRequest 

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

ContractServiceVerificationReceivedRequest contains the pid RUN-DSP uses to refer to the negotiation that just verified to.

func (*ContractServiceVerificationReceivedRequest) Descriptor deprecated 

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

Deprecated: Use ContractServiceVerificationReceivedRequest.ProtoReflect.Descriptor instead.

func (*ContractServiceVerificationReceivedRequest) GetPid 

func (x *ContractServiceVerificationReceivedRequest) GetPid() string

func (*ContractServiceVerificationReceivedRequest) ProtoMessage 

func (*ContractServiceVerificationReceivedRequest) ProtoMessage()

func (*ContractServiceVerificationReceivedRequest) ProtoReflect 

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

func (*ContractServiceVerificationReceivedRequest) Reset 

func (x *ContractServiceVerificationReceivedRequest) Reset()

func (*ContractServiceVerificationReceivedRequest) String 

func (x *ContractServiceVerificationReceivedRequest) String() string

type ContractServiceVerificationReceivedResponse 

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

func (*ContractServiceVerificationReceivedResponse) Descriptor deprecated 

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

Deprecated: Use ContractServiceVerificationReceivedResponse.ProtoReflect.Descriptor instead.

func (*ContractServiceVerificationReceivedResponse) ProtoMessage 

func (*ContractServiceVerificationReceivedResponse) ProtoMessage()

func (*ContractServiceVerificationReceivedResponse) ProtoReflect 

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

func (*ContractServiceVerificationReceivedResponse) Reset 

func (x *ContractServiceVerificationReceivedResponse) Reset()

func (*ContractServiceVerificationReceivedResponse) String 

func (x *ContractServiceVerificationReceivedResponse) String() string

type ContractTerminateRequest 

type ContractTerminateRequest struct {
	Pid    string   `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Code   string   `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Reason []string `protobuf:"bytes,3,rep,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

ContractTerminateRequest contains the pid, code, and reason of the contract negotiation to terminate.

func (*ContractTerminateRequest) Descriptor deprecated 

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

Deprecated: Use ContractTerminateRequest.ProtoReflect.Descriptor instead.

func (*ContractTerminateRequest) GetCode 

func (x *ContractTerminateRequest) GetCode() string

func (*ContractTerminateRequest) GetPid 

func (x *ContractTerminateRequest) GetPid() string

func (*ContractTerminateRequest) GetReason 

func (x *ContractTerminateRequest) GetReason() []string

func (*ContractTerminateRequest) ProtoMessage 

func (*ContractTerminateRequest) ProtoMessage()

func (*ContractTerminateRequest) ProtoReflect 

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

func (*ContractTerminateRequest) Reset 

func (x *ContractTerminateRequest) Reset()

func (*ContractTerminateRequest) String 

func (x *ContractTerminateRequest) String() string

type ContractTerminateResponse 

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

func (*ContractTerminateResponse) Descriptor deprecated 

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

Deprecated: Use ContractTerminateResponse.ProtoReflect.Descriptor instead.

func (*ContractTerminateResponse) ProtoMessage 

func (*ContractTerminateResponse) ProtoMessage()

func (*ContractTerminateResponse) ProtoReflect 

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

func (*ContractTerminateResponse) Reset 

func (x *ContractTerminateResponse) Reset()

func (*ContractTerminateResponse) String 

func (x *ContractTerminateResponse) String() string

type ContractVerifyRequest 

type ContractVerifyRequest struct {
	Pid        string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	AutoAccept bool   `protobuf:"varint,2,opt,name=auto_accept,json=autoAccept,proto3" json:"auto_accept,omitempty"` // signals to RUN-DSP that it should auto accept the negotiation and not wait for any requests of the contract service.
	// contains filtered or unexported fields
}

ContractVerifyRequest contains the pid of the contract negotiation to verify.

func (*ContractVerifyRequest) Descriptor deprecated 

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

Deprecated: Use ContractVerifyRequest.ProtoReflect.Descriptor instead.

func (*ContractVerifyRequest) GetAutoAccept 

func (x *ContractVerifyRequest) GetAutoAccept() bool

func (*ContractVerifyRequest) GetPid 

func (x *ContractVerifyRequest) GetPid() string

func (*ContractVerifyRequest) ProtoMessage 

func (*ContractVerifyRequest) ProtoMessage()

func (*ContractVerifyRequest) ProtoReflect 

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

func (*ContractVerifyRequest) Reset 

func (x *ContractVerifyRequest) Reset()

func (*ContractVerifyRequest) String 

func (x *ContractVerifyRequest) String() string

type ContractVerifyResponse 

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

func (*ContractVerifyResponse) Descriptor deprecated 

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

Deprecated: Use ContractVerifyResponse.ProtoReflect.Descriptor instead.

func (*ContractVerifyResponse) ProtoMessage 

func (*ContractVerifyResponse) ProtoMessage()

func (*ContractVerifyResponse) ProtoReflect 

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

func (*ContractVerifyResponse) Reset 

func (x *ContractVerifyResponse) Reset()

func (*ContractVerifyResponse) String 

func (x *ContractVerifyResponse) String() string

type ControlServiceClient 

type ControlServiceClient interface {
	// Publishes a dataset,
	GetProviderDatasetDownloadInformation(ctx context.Context, in *GetProviderDatasetDownloadInformationRequest, opts ...grpc.CallOption) (*GetProviderDatasetDownloadInformationResponse, error)
	// VerifyConnection takes a token and verifies it's the same token it passed to the contract service.
	VerifyConnection(ctx context.Context, in *VerifyConnectionRequest, opts ...grpc.CallOption) (*VerifyConnectionResponse, 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)
	// ContractRequest sends a ContractRequestMessage.
	ContractRequest(ctx context.Context, in *ContractRequestRequest, opts ...grpc.CallOption) (*ContractRequestResponse, error)
	// ContractOffer sends a ContractOfferMessage.
	ContractOffer(ctx context.Context, in *ContractOfferRequest, opts ...grpc.CallOption) (*ContractOfferResponse, error)
	// ContractAccept sends an accepted event message.
	ContractAccept(ctx context.Context, in *ContractAcceptRequest, opts ...grpc.CallOption) (*ContractAcceptResponse, error)
	// ContractAgree sends a ContractAcceptedMessage.
	ContractAgree(ctx context.Context, in *ContractAgreeRequest, opts ...grpc.CallOption) (*ContractAgreeResponse, error)
	// ContractVerify sends a ContractVerificationMessage.
	ContractVerify(ctx context.Context, in *ContractVerifyRequest, opts ...grpc.CallOption) (*ContractVerifyResponse, error)
	// ContractFinalize sends a finalization event.
	ContractFinalize(ctx context.Context, in *ContractFinalizeRequest, opts ...grpc.CallOption) (*ContractFinalizeResponse, error)
	// ContractTerminate sends a ContractTerminationMessage.
	ContractTerminate(ctx context.Context, in *ContractTerminateRequest, opts ...grpc.CallOption) (*ContractTerminateResponse, 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)
}

ControlServiceClient is the client API for ControlService 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.

ControlService contains methods that are not specific to catalogue, contract, or transfer operations. Configuration, and convenience methods will be put here.

func NewControlServiceClient 

func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient

type ControlServiceServer 

type ControlServiceServer interface {
	// Publishes a dataset,
	GetProviderDatasetDownloadInformation(context.Context, *GetProviderDatasetDownloadInformationRequest) (*GetProviderDatasetDownloadInformationResponse, error)
	// VerifyConnection takes a token and verifies it's the same token it passed to the contract service.
	VerifyConnection(context.Context, *VerifyConnectionRequest) (*VerifyConnectionResponse, 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)
	// ContractRequest sends a ContractRequestMessage.
	ContractRequest(context.Context, *ContractRequestRequest) (*ContractRequestResponse, error)
	// ContractOffer sends a ContractOfferMessage.
	ContractOffer(context.Context, *ContractOfferRequest) (*ContractOfferResponse, error)
	// ContractAccept sends an accepted event message.
	ContractAccept(context.Context, *ContractAcceptRequest) (*ContractAcceptResponse, error)
	// ContractAgree sends a ContractAcceptedMessage.
	ContractAgree(context.Context, *ContractAgreeRequest) (*ContractAgreeResponse, error)
	// ContractVerify sends a ContractVerificationMessage.
	ContractVerify(context.Context, *ContractVerifyRequest) (*ContractVerifyResponse, error)
	// ContractFinalize sends a finalization event.
	ContractFinalize(context.Context, *ContractFinalizeRequest) (*ContractFinalizeResponse, error)
	// ContractTerminate sends a ContractTerminationMessage.
	ContractTerminate(context.Context, *ContractTerminateRequest) (*ContractTerminateResponse, 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
}

ControlServiceServer is the server API for ControlService service. All implementations must embed UnimplementedControlServiceServer for forward compatibility.

ControlService contains methods that are not specific to catalogue, contract, or transfer operations. Configuration, and convenience methods will be put here.

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      `` /* 143-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 `` /* 180-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 `` /* 180-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 UnimplementedContractServiceServer 

type UnimplementedContractServiceServer struct{}

UnimplementedContractServiceServer 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 (UnimplementedContractServiceServer) AcceptedReceived 

func (UnimplementedContractServiceServer) AcceptedReceived(context.Context, *ContractServiceAcceptedReceivedRequest) (*ContractServiceAcceptedReceivedResponse, error)

func (UnimplementedContractServiceServer) AgreementReceived 

func (UnimplementedContractServiceServer) AgreementReceived(context.Context, *ContractServiceAgreementReceivedRequest) (*ContractServiceAgreementReceivedResponse, error)

func (UnimplementedContractServiceServer) Configure 

func (UnimplementedContractServiceServer) Configure(context.Context, *ContractServiceConfigureRequest) (*ContractServiceConfigureResponse, error)

func (UnimplementedContractServiceServer) FinalizationReceived 

func (UnimplementedContractServiceServer) FinalizationReceived(context.Context, *ContractServiceFinalizationReceivedRequest) (*ContractServiceFinalizationReceivedResponse, error)

func (UnimplementedContractServiceServer) OfferReceived 

func (UnimplementedContractServiceServer) OfferReceived(context.Context, *ContractServiceOfferReceivedRequest) (*ContractServiceOfferReceivedResponse, error)

func (UnimplementedContractServiceServer) RequestReceived 

func (UnimplementedContractServiceServer) RequestReceived(context.Context, *ContractServiceRequestReceivedRequest) (*ContractServiceRequestReceivedResponse, error)

func (UnimplementedContractServiceServer) TerminationReceived 

func (UnimplementedContractServiceServer) TerminationReceived(context.Context, *ContractServiceTerminationReceivedRequest) (*ContractServiceTerminationReceivedResponse, error)

func (UnimplementedContractServiceServer) VerificationReceived 

func (UnimplementedContractServiceServer) VerificationReceived(context.Context, *ContractServiceVerificationReceivedRequest) (*ContractServiceVerificationReceivedResponse, error)

type UnimplementedControlServiceServer 

type UnimplementedControlServiceServer struct{}

UnimplementedControlServiceServer 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 (UnimplementedControlServiceServer) ContractAccept 

func (UnimplementedControlServiceServer) ContractAccept(context.Context, *ContractAcceptRequest) (*ContractAcceptResponse, error)

func (UnimplementedControlServiceServer) ContractAgree 

func (UnimplementedControlServiceServer) ContractAgree(context.Context, *ContractAgreeRequest) (*ContractAgreeResponse, error)

func (UnimplementedControlServiceServer) ContractFinalize 

func (UnimplementedControlServiceServer) ContractFinalize(context.Context, *ContractFinalizeRequest) (*ContractFinalizeResponse, error)

func (UnimplementedControlServiceServer) ContractOffer 

func (UnimplementedControlServiceServer) ContractOffer(context.Context, *ContractOfferRequest) (*ContractOfferResponse, error)

func (UnimplementedControlServiceServer) ContractRequest 

func (UnimplementedControlServiceServer) ContractRequest(context.Context, *ContractRequestRequest) (*ContractRequestResponse, error)

func (UnimplementedControlServiceServer) ContractTerminate 

func (UnimplementedControlServiceServer) ContractTerminate(context.Context, *ContractTerminateRequest) (*ContractTerminateResponse, error)

func (UnimplementedControlServiceServer) ContractVerify 

func (UnimplementedControlServiceServer) ContractVerify(context.Context, *ContractVerifyRequest) (*ContractVerifyResponse, error)

func (UnimplementedControlServiceServer) GetProviderCatalogue 

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

func (UnimplementedControlServiceServer) GetProviderDataset 

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

func (UnimplementedControlServiceServer) GetProviderDatasetDownloadInformation 

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

func (UnimplementedControlServiceServer) SignalTransferCancelled 

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

func (UnimplementedControlServiceServer) SignalTransferComplete 

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

func (UnimplementedControlServiceServer) SignalTransferResume 

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

func (UnimplementedControlServiceServer) SignalTransferSuspend 

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

func (UnimplementedControlServiceServer) VerifyConnection 

func (UnimplementedControlServiceServer) VerifyConnection(context.Context, *VerifyConnectionRequest) (*VerifyConnectionResponse, 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 UnsafeContractServiceServer 

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

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

type UnsafeControlServiceServer 

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

UnsafeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServiceServer 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

type VerifyConnectionRequest 

type VerifyConnectionRequest struct {
	VerificationToken string `protobuf:"bytes,1,opt,name=verification_token,json=verificationToken,proto3" json:"verification_token,omitempty"`
	// contains filtered or unexported fields
}

VerifyConnectionRequest contains a verification token that can be compared to the one locally generated.

func (*VerifyConnectionRequest) Descriptor deprecated 

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

Deprecated: Use VerifyConnectionRequest.ProtoReflect.Descriptor instead.

func (*VerifyConnectionRequest) GetVerificationToken 

func (x *VerifyConnectionRequest) GetVerificationToken() string

func (*VerifyConnectionRequest) ProtoMessage 

func (*VerifyConnectionRequest) ProtoMessage()

func (*VerifyConnectionRequest) ProtoReflect 

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

func (*VerifyConnectionRequest) Reset 

func (x *VerifyConnectionRequest) Reset()

func (*VerifyConnectionRequest) String 

func (x *VerifyConnectionRequest) String() string

type VerifyConnectionResponse 

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

func (*VerifyConnectionResponse) Descriptor deprecated 

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

Deprecated: Use VerifyConnectionResponse.ProtoReflect.Descriptor instead.

func (*VerifyConnectionResponse) ProtoMessage 

func (*VerifyConnectionResponse) ProtoMessage()

func (*VerifyConnectionResponse) ProtoReflect 

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

func (*VerifyConnectionResponse) Reset 

func (x *VerifyConnectionResponse) Reset()

func (*VerifyConnectionResponse) String 

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