discovery

package
v0.5.405 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 21, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicDiscoveryAdapter

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

func (*BasicDiscoveryAdapter) GetProvider

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

func (*BasicDiscoveryAdapter) GetResourcesMap

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

func (*BasicDiscoveryAdapter) GetServiceHandle

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

func (*BasicDiscoveryAdapter) GetServiceHandlesMap

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

func (*BasicDiscoveryAdapter) GetServiceShard

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

func (*BasicDiscoveryAdapter) PersistStaticExternalSQLDataSource

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

type IDiscoveryAdapter

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

func NewBasicDiscoveryAdapter

func NewBasicDiscoveryAdapter(
	alias string,
	apiDiscoveryDocURL string,
	discoveryStore IDiscoveryStore,
	runtimeCtx *dto.RuntimeCtx,
	registry openapistackql.RegistryAPI,
	sqlSystem sql_system.SQLSystem,
) IDiscoveryAdapter

type IDiscoveryStore

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

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

func NewTTLDiscoveryStore

func NewTTLDiscoveryStore(
	sqlSystem sql_system.SQLSystem,
	registry openapistackql.RegistryAPI,
	runtimeCtx dto.RuntimeCtx,
) IDiscoveryStore

type TTLDiscoveryStore

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

func (*TTLDiscoveryStore) PersistServiceShard

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

func (*TTLDiscoveryStore) ProcessProviderDiscoveryDoc

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL