Documentation
¶
Index ¶
- type 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
- type IDiscoveryStore
- type PersistenceSystem
- type StaticAnalyzer
- type TTLDiscoveryStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AnalyzerCfg ¶
type AnalyzerCfg interface {
GetAnalysisType() string
}
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 (*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 (*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
}
func NewBasicDiscoveryAdapter ¶
func NewBasicDiscoveryAdapter( alias string, apiDiscoveryDocURL string, discoveryStore IDiscoveryStore, runtimeCtx *dto.RuntimeCtx, registry anysdk.RegistryAPI, persistenceSystem 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 PersistenceSystem, registry anysdk.RegistryAPI, runtimeCtx dto.RuntimeCtx, ) IDiscoveryStore
type PersistenceSystem ¶
type PersistenceSystem interface {
GetSystemName() string
HandleExternalTables(providerName string, externalTables map[string]anysdk.SQLExternalTable) error
HandleViewCollection([]anysdk.View) error
CacheStoreGet(key string) ([]byte, error)
CacheStorePut(key string, value []byte, expiration string, ttl int) error
}
type StaticAnalyzer ¶
func NewStaticAnalyzer ¶
func NewStaticAnalyzer(analysiscfg AnalyzerCfg) (StaticAnalyzer, error)
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 ¶
Click to show internal directories.
Click to hide internal directories.