discovery

Documentation

Index

• type AnalyzerCfg
  • func NewAnalyzerCfg(protocolType string, registryRootDir string, docRoot string) AnalyzerCfg
• type BasicDiscoveryAdapter
  • func (adp *BasicDiscoveryAdapter) GetProvider(providerKey string) (anysdk.Provider, error)
  • func (adp *BasicDiscoveryAdapter) GetResourcesMap(prov anysdk.Provider, serviceKey string) (map[string]anysdk.Resource, error)
  • func (adp *BasicDiscoveryAdapter) GetServiceHandle(prov anysdk.Provider, serviceKey string) (anysdk.ProviderService, error)
  • func (adp *BasicDiscoveryAdapter) GetServiceHandlesMap(prov anysdk.Provider) (map[string]anysdk.ProviderService, error)
  • func (adp *BasicDiscoveryAdapter) GetServiceShard(prov anysdk.Provider, serviceKey, resourceKey string) (anysdk.Service, error)
  • func (adp *BasicDiscoveryAdapter) PersistStaticExternalSQLDataSource(prov anysdk.Provider) error
• type IDiscoveryAdapter
  • func NewBasicDiscoveryAdapter(alias string, apiDiscoveryDocURL string, discoveryStore IDiscoveryStore, ...) IDiscoveryAdapter
• type IDiscoveryStore
  • func NewTTLDiscoveryStore(persistenceSystem persistence.PersistenceSystem, registry anysdk.RegistryAPI, ...) IDiscoveryStore
• type Interrogator
  • func NewInterrogator(providerRootDoc, registryRootDir string) Interrogator
• type ProviderServiceResourceAnalyzer
  • func NewProviderServiceResourceAnalyzer(cfg AnalyzerCfg, discoveryAdapter IDiscoveryAdapter, ...) ProviderServiceResourceAnalyzer
• type StaticAnalyzer
  • func NewServiceLevelStaticAnalyzer(cfg AnalyzerCfg, discoveryAdapter IDiscoveryAdapter, ...) StaticAnalyzer
  • func NewStaticAnalyzer(analysisCfg AnalyzerCfg, persistenceSystem persistence.PersistenceSystem, ...) (StaticAnalyzer, error)
• type StaticAnalyzerFactory
  • func NewSimpleSQLiteAnalyzerFactory(registryURL string, rtCtx dto.RuntimeCtx) StaticAnalyzerFactory
• type TTLDiscoveryStore
  • func (store *TTLDiscoveryStore) PersistServiceShard(pr anysdk.Provider, serviceHandle anysdk.ProviderService, resourceKey string) (anysdk.Service, error)
  • func (store *TTLDiscoveryStore) ProcessProviderDiscoveryDoc(url string, alias string) (anysdk.Provider, error)

Types

type AnalyzerCfg

type AnalyzerCfg interface {
	GetProtocolType() string
	GetDocRoot() string
	GetRegistryRootDir() string
	GetProviderStr() string
	GetRootURL() string
	IsProviderServicesMustExpand() bool
	IsVerbose() bool
	SetIsVerbose(bool)
	SetIsProviderServicesMustExpand(bool)
}

func NewAnalyzerCfg

func NewAnalyzerCfg(
	protocolType string,
	registryRootDir string,
	docRoot string,
) AnalyzerCfg

type BasicDiscoveryAdapter

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

func (*BasicDiscoveryAdapter) GetProvider

func (adp *BasicDiscoveryAdapter) GetProvider(providerKey string) (anysdk.Provider, error)

func (*BasicDiscoveryAdapter) GetResourcesMap

func (adp *BasicDiscoveryAdapter) GetResourcesMap(
	prov anysdk.Provider,
	serviceKey string,
) (map[string]anysdk.Resource, error)

func (*BasicDiscoveryAdapter) GetServiceHandle

func (adp *BasicDiscoveryAdapter) GetServiceHandle(
	prov anysdk.Provider,
	serviceKey string,
) (anysdk.ProviderService, error)

func (*BasicDiscoveryAdapter) GetServiceHandlesMap

func (adp *BasicDiscoveryAdapter) GetServiceHandlesMap(
	prov anysdk.Provider,
) (map[string]anysdk.ProviderService, error)

func (*BasicDiscoveryAdapter) GetServiceShard

func (adp *BasicDiscoveryAdapter) GetServiceShard(
	prov anysdk.Provider,
	serviceKey,
	resourceKey string,
) (anysdk.Service, error)

func (*BasicDiscoveryAdapter) PersistStaticExternalSQLDataSource

func (adp *BasicDiscoveryAdapter) PersistStaticExternalSQLDataSource(prov anysdk.Provider) error

type IDiscoveryAdapter

type IDiscoveryAdapter interface {
	GetResourcesMap(prov anysdk.Provider, serviceKey string) (map[string]anysdk.Resource, error)
	GetServiceShard(prov anysdk.Provider, serviceKey, resourceKey string) (anysdk.Service, error)
	GetServiceHandlesMap(prov anysdk.Provider) (map[string]anysdk.ProviderService, error)
	GetServiceHandle(prov anysdk.Provider, serviceKey string) (anysdk.ProviderService, error)
	GetProvider(providerKey string) (anysdk.Provider, error)
	PersistStaticExternalSQLDataSource(prov anysdk.Provider) error
	// contains filtered or unexported methods
}

func NewBasicDiscoveryAdapter

func NewBasicDiscoveryAdapter(
	alias string,
	apiDiscoveryDocURL string,
	discoveryStore IDiscoveryStore,
	runtimeCtx *dto.RuntimeCtx,
	registry anysdk.RegistryAPI,
	persistenceSystem persistence.PersistenceSystem,
) IDiscoveryAdapter

type IDiscoveryStore

type IDiscoveryStore interface {
	ProcessProviderDiscoveryDoc(string, string) (anysdk.Provider, error)

	PersistServiceShard(anysdk.Provider, anysdk.ProviderService, string) (anysdk.Service, error)
	// contains filtered or unexported methods
}

func NewTTLDiscoveryStore

func NewTTLDiscoveryStore(
	persistenceSystem persistence.PersistenceSystem,
	registry anysdk.RegistryAPI,
	runtimeCtx dto.RuntimeCtx,
) IDiscoveryStore

type Interrogator

type Interrogator interface {
	GetProviderServices() ([]string, error)
}

func NewInterrogator

func NewInterrogator(providerRootDoc, registryRootDir string) Interrogator

type ProviderServiceResourceAnalyzer

type ProviderServiceResourceAnalyzer interface {
	StaticAnalyzer
	GetResources() map[string]anysdk.Resource
	GetServiceFragments() map[string]anysdk.Service
}

func NewProviderServiceResourceAnalyzer

func NewProviderServiceResourceAnalyzer(
	cfg AnalyzerCfg,
	discoveryAdapter IDiscoveryAdapter,
	discoveryStore IDiscoveryStore,
	provider anysdk.Provider,
	providerService anysdk.ProviderService,
	resourceKey string,
	registryAPI anysdk.RegistryAPI,
) ProviderServiceResourceAnalyzer

type StaticAnalyzer

type StaticAnalyzer interface {
	Analyze() error
	GetErrors() []error
	GetWarnings() []string
	GetAffirmatives() []string
	GetRegistryAPI() (anysdk.RegistryAPI, bool)
}

func NewServiceLevelStaticAnalyzer

func NewServiceLevelStaticAnalyzer(
	cfg AnalyzerCfg,
	discoveryAdapter IDiscoveryAdapter,
	discoveryStore IDiscoveryStore,
	provider anysdk.Provider,
	providerService anysdk.ProviderService,
	providerServiceKey string,
	registryAPI anysdk.RegistryAPI,
) StaticAnalyzer

func NewStaticAnalyzer

func NewStaticAnalyzer(
	analysisCfg AnalyzerCfg,
	persistenceSystem persistence.PersistenceSystem,
	registryAPI anysdk.RegistryAPI,
	rtCtx dto.RuntimeCtx,
) (StaticAnalyzer, error)

type StaticAnalyzerFactory

type StaticAnalyzerFactory interface {
	CreateStaticAnalyzer(
		providerURL string,
	) (StaticAnalyzer, error)
	CreateProviderServiceLevelStaticAnalyzer(
		providerURL string,
		serviceName string,
	) (ProviderServiceResourceAnalyzer, error)
	CreateServiceLevelStaticAnalyzer(
		providerURL string,
		serviceName string,
	) (StaticAnalyzer, error)
}

func NewSimpleSQLiteAnalyzerFactory

func NewSimpleSQLiteAnalyzerFactory(
	registryURL string,
	rtCtx dto.RuntimeCtx,
) StaticAnalyzerFactory

type TTLDiscoveryStore

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

func (*TTLDiscoveryStore) PersistServiceShard

func (store *TTLDiscoveryStore) PersistServiceShard(
	pr anysdk.Provider,
	serviceHandle anysdk.ProviderService,
	resourceKey string,
) (anysdk.Service, error)

func (*TTLDiscoveryStore) ProcessProviderDiscoveryDoc

func (store *TTLDiscoveryStore) ProcessProviderDiscoveryDoc(url string, alias string) (anysdk.Provider, error)