control

package

v0.0.5 Latest Latest Go to latest Published: Mar 10, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/go-dataspace/run-dsp

Documentation ¶

Index ¶

type Server
- func New(requester shared.Requester, store persistence.StorageProvider, ...) *Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Server ¶

type Server struct {
	dspcontrol.ControlServiceServer
	// contains filtered or unexported fields
}

func New ¶

func New(
	requester shared.Requester,
	store persistence.StorageProvider,
	reconciler statemachine.Reconciler,
	provider dspcontrol.ProviderServiceClient,
	contractService dspcontrol.ContractServiceClient,
	selfURL *url.URL,
) *Server

func (*Server) ContractAccept ¶ added in v0.0.5

func (s *Server) ContractAccept(
	ctx context.Context,
	req *dspcontrol.ContractAcceptRequest,
) (*dspcontrol.ContractAcceptResponse, error)

ContractAccept sends an accepted event message.

func (*Server) ContractAgree ¶ added in v0.0.5

func (s *Server) ContractAgree(
	ctx context.Context,
	req *dspcontrol.ContractAgreeRequest,
) (*dspcontrol.ContractAgreeResponse, error)

ContractAgree sends a ContractAcceptedMessage.

func (*Server) ContractFinalize ¶ added in v0.0.5

func (s *Server) ContractFinalize(
	ctx context.Context,
	req *dspcontrol.ContractFinalizeRequest,
) (*dspcontrol.ContractFinalizeResponse, error)

ContractFinalize sends a finalization event.

func (*Server) ContractOffer ¶ added in v0.0.5

func (s *Server) ContractOffer(
	ctx context.Context,
	req *dspcontrol.ContractOfferRequest,
) (*dspcontrol.ContractOfferResponse, error)

ContractOffer sends a ContractOfferMessage.

func (*Server) ContractRequest ¶ added in v0.0.5

func (s *Server) ContractRequest(
	ctx context.Context,
	req *dspcontrol.ContractRequestRequest,
) (*dspcontrol.ContractRequestResponse, error)

ContractRequest sends a ContractRequestMessage.

func (*Server) ContractTerminate ¶ added in v0.0.5

func (s *Server) ContractTerminate(
	ctx context.Context,
	req *dspcontrol.ContractTerminateRequest,
) (*dspcontrol.ContractTerminateResponse, error)

ContractTerminate sends a ContractTerminationMessage.

func (*Server) ContractVerify ¶ added in v0.0.5

func (s *Server) ContractVerify(
	ctx context.Context,
	req *dspcontrol.ContractVerifyRequest,
) (*dspcontrol.ContractVerifyResponse, error)

ContractVerify sends a ContractVerificationMessage.

func (*Server) GetProviderCatalogue ¶

func (s *Server) GetProviderCatalogue(
	ctx context.Context, req *dspcontrol.GetProviderCatalogueRequest,
) (*dspcontrol.GetProviderCatalogueResponse, error)

Gets the catalogue based on the query parameters and the authorization header.

func (*Server) GetProviderDataset ¶

func (s *Server) GetProviderDataset(
	ctx context.Context, req *dspcontrol.GetProviderDatasetRequest,
) (*dspcontrol.GetProviderDatasetResponse, error)

Gets information about a single dataset.

func (*Server) GetProviderDatasetDownloadInformation ¶

func (s *Server) GetProviderDatasetDownloadInformation(
	ctx context.Context, req *dspcontrol.GetProviderDatasetDownloadInformationRequest,
) (*dspcontrol.GetProviderDatasetDownloadInformationResponse, error)

Publishes a dataset.

func (*Server) SignalTransferCancelled ¶

func (s *Server) SignalTransferCancelled(
	_ context.Context, _ *dspcontrol.SignalTransferCancelledRequest,
) (*dspcontrol.SignalTransferCancelledResponse, error)

Tells provider to cancel file transfer.

func (*Server) SignalTransferComplete ¶

func (s *Server) SignalTransferComplete(
	ctx context.Context, req *dspcontrol.SignalTransferCompleteRequest,
) (*dspcontrol.SignalTransferCompleteResponse, error)

Tells provider that we have finished our transfer.

func (*Server) SignalTransferResume ¶

func (s *Server) SignalTransferResume(
	_ context.Context, _ *dspcontrol.SignalTransferResumeRequest,
) (*dspcontrol.SignalTransferResumeResponse, error)

Tells provider to resume file transfer.

func (*Server) SignalTransferSuspend ¶

func (s *Server) SignalTransferSuspend(
	_ context.Context, _ *dspcontrol.SignalTransferSuspendRequest,
) (*dspcontrol.SignalTransferSuspendResponse, error)

Tells provider to suspend file transfer.

func (*Server) VerifyConnection ¶ added in v0.0.5

func (s *Server) VerifyConnection(
	ctx context.Context,
	req *dspcontrol.VerifyConnectionRequest,
) (*dspcontrol.VerifyConnectionResponse, error)

VerifyConnection takes a token and verifies it's the same token it passed to the contract service.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL