public

Documentation

Index

• Constants
• type CatalogClient
  • func (c *CatalogClient) GetProviderInfo(ctx context.Context, providerType ProviderType, providerId string) (ProviderInfo, error)
  • func (c *CatalogClient) Search(ctx context.Context, providerType ProviderType, searchTerms, originPeer string) ([]ProviderInfo, error)
• type CatalogueApi
  • func NewClient(url string) CatalogueApi
• type ProviderInfo
• type ProviderType

Constants

const HEADER_ORIGIN_PEER = "X-Origin-Peer"

Types

type CatalogClient

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

func (*CatalogClient) GetProviderInfo

func (c *CatalogClient) GetProviderInfo(ctx context.Context, providerType ProviderType, providerId string) (ProviderInfo, error)

func (*CatalogClient) Search

func (c *CatalogClient) Search(ctx context.Context, providerType ProviderType, searchTerms, originPeer string) ([]ProviderInfo, error)

type CatalogueApi

type CatalogueApi interface {
	Search(ctx context.Context, providerType ProviderType, searchTerms, originPeer string) ([]ProviderInfo, error)
	GetProviderInfo(ctx context.Context, providerType ProviderType, providerId string) (ProviderInfo, error)
}

func NewClient

func NewClient(url string) CatalogueApi

type ProviderInfo

type ProviderInfo struct {
	Id                string                 `json:"id"`
	ProviderId        string                 `json:"providerId"`
	Type              ProviderType           `json:"providerType"`
	Version           string                 `json:"version"`
	Name              string                 `json:"name"`
	Description       string                 `json:"description"`
	Metadata          map[string]interface{} `json:"metadata"`
	EndpointLocation  string                 `json:"endpointLocation"`
	WorkflowStructure string                 `json:"workflowStructure"`
}

type ProviderType

type ProviderType string

const (
	Data      ProviderType = "data"
	Service   ProviderType = "service"
	Computing ProviderType = "computing"
)