discovery

type AnalysisBin struct {
	Count    int               `json:"count"`
	Errors   []AnalysisFinding `json:"errors,omitempty"`
	Warnings []AnalysisFinding `json:"warnings,omitempty"`
}

type AnalysisContext struct {
	Provider string
	Service  string
	Resource string
	Method   string
}

type AnalysisFinding struct {
	Level          string                               `json:"level"`
	Bin            string                               `json:"bin,omitempty"`
	Provider       string                               `json:"provider,omitempty"`
	Service        string                               `json:"service,omitempty"`
	Resource       string                               `json:"resource,omitempty"`
	Method         string                               `json:"method,omitempty"`
	Message        string                               `json:"message"`
	FixedTemplate  string                               `json:"fixed_template,omitempty"`
	EmpiricalTests *stream_transform.EmpiricalTestSuite `json:"empirical_tests,omitempty"`
	SampleResponse *SampleResponsePair                  `json:"sample_response,omitempty"`
}

type AnalysisSummary struct {
	TotalOK       int                       `json:"total_ok"`
	TotalWarnings int                       `json:"total_warnings"`
	TotalErrors   int                       `json:"total_errors"`
	Bins          map[string]AnalysisBin    `json:"bins"`
	Services      map[string]ServiceSummary `json:"services"`
	Errors        []string                  `json:"errors,omitempty"`
}

type AnalyzedFullHierarchy interface {
	AnalyzedPartialHierarchy
	GetMethod() anysdk.StandardOperationStore
}

type AnalyzedPartialHierarchy interface {
	GetProvider() anysdk.Provider
	GetService() anysdk.ProviderService
	GetResource() anysdk.Resource
	GetMethods() anysdk.Methods
	GetRegistryAPI() anysdk.RegistryAPI
}

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

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

type FindingsAware interface {
	GetFindings() []AnalysisFinding
}

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
}

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

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

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

type MethodAggregateStaticAnalyzer interface {
	StaticAnalyzer
	GetFullHierarchy() (AnalyzedFullHierarchy, bool)
}

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

type ResourceAggregateStaticAnalyzer interface {
	StaticAnalyzer
	GetPartialHierarchy() (AnalyzedPartialHierarchy, bool)
	FindMethodByVerbAndParameters(sqlVerb string, params map[string]any) (anysdk.StandardOperationStore, map[string]any, bool)
}

type SampleResponsePair struct {
	PreTransform  string `json:"pre_transform"`
	PostTransform string `json:"post_transform"`
}

type ServiceSummary struct {
	ErrorCount   int `json:"error_count"`
	WarningCount int `json:"warning_count"`
}

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

type StaticAnalyzerFactory interface {
	CreateStaticAnalyzer(
		providerURL string,
	) (StaticAnalyzer, error)
	CreateProviderServiceLevelStaticAnalyzer(
		providerURL string,
		serviceName string,
	) (ProviderServiceResourceAnalyzer, error)
	CreateServiceLevelStaticAnalyzer(
		providerURL string,
		serviceName string,
	) (StaticAnalyzer, error)
	CreateMethodAggregateStaticAnalyzer(
		providerURL string,
		providerName string,
		serviceName string,
		resourceName string,
		methodSelectorName string,
		isFuzzy bool,
	) (MethodAggregateStaticAnalyzer, error)
	CreateResourceAggregateStaticAnalyzer(
		providerURL string,
		providerName string,
		serviceName string,
		resourceName string,
	) (ResourceAggregateStaticAnalyzer, error)
}

type StaticAnalyzerFactoryFactory interface {
	CreateNaiveSQLiteStaticAnalyzerFactory(
		registryAPI anysdk.RegistryAPI,
		rtCtx dto.RuntimeCtx,
	) (StaticAnalyzerFactory, error)
	CreateStaticAnalyzerFactoryFromPersistenceSystem(
		registryAPI anysdk.RegistryAPI,
		rtCtx dto.RuntimeCtx,
		persistenceSystem persistence.PersistenceSystem,
	) (StaticAnalyzerFactory, error)
}

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