control

Documentation

Index

• type Server
  • func New(requester shared.Requester, store persistence.StorageProvider, ...) *Server
  • func (s *Server) GetProviderCatalogue(ctx context.Context, req *dspv1alpha1.GetProviderCatalogueRequest) (*dspv1alpha1.GetProviderCatalogueResponse, error)
  • func (s *Server) GetProviderDataset(ctx context.Context, req *dspv1alpha1.GetProviderDatasetRequest) (*dspv1alpha1.GetProviderDatasetResponse, error)
  • func (s *Server) GetProviderDatasetDownloadInformation(ctx context.Context, ...) (*dspv1alpha1.GetProviderDatasetDownloadInformationResponse, error)
  • func (s *Server) Ping(_ context.Context, _ *dspv1alpha1.ClientServicePingRequest) (*dspv1alpha1.ClientServicePingResponse, error)
  • func (s *Server) SignalTransferCancelled(_ context.Context, _ *dspv1alpha1.SignalTransferCancelledRequest) (*dspv1alpha1.SignalTransferCancelledResponse, error)
  • func (s *Server) SignalTransferComplete(ctx context.Context, req *dspv1alpha1.SignalTransferCompleteRequest) (*dspv1alpha1.SignalTransferCompleteResponse, error)
  • func (s *Server) SignalTransferResume(_ context.Context, _ *dspv1alpha1.SignalTransferResumeRequest) (*dspv1alpha1.SignalTransferResumeResponse, error)
  • func (s *Server) SignalTransferSuspend(_ context.Context, _ *dspv1alpha1.SignalTransferSuspendRequest) (*dspv1alpha1.SignalTransferSuspendResponse, error)

Types

type Server

type Server struct {
	dspv1alpha1.ClientServiceServer
	// contains filtered or unexported fields
}

func New

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

func (*Server) GetProviderCatalogue

func (s *Server) GetProviderCatalogue(
	ctx context.Context, req *dspv1alpha1.GetProviderCatalogueRequest,
) (*dspv1alpha1.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 *dspv1alpha1.GetProviderDatasetRequest,
) (*dspv1alpha1.GetProviderDatasetResponse, error)

Gets information about a single dataset.

func (*Server) GetProviderDatasetDownloadInformation

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

Publishes a dataset.

func (*Server) Ping

func (s *Server) Ping(
	_ context.Context, _ *dspv1alpha1.ClientServicePingRequest,
) (*dspv1alpha1.ClientServicePingResponse, error)

Ping is a request to test if the provider is working, and to test the auth information.

func (*Server) SignalTransferCancelled

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

Tells provider to cancel file transfer.

func (*Server) SignalTransferComplete

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

Tells provider that we have finished our transfer.

func (*Server) SignalTransferResume

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

Tells provider to resume file transfer.

func (*Server) SignalTransferSuspend

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

Tells provider to suspend file transfer.