meta

Documentation

Overview

Package meta provides tool for reading metadata from services declaring "MetaProvider" support

Index

• Constants
• func EnrichNodesMetaFromProviders(ctx context.Context, ...)
• type MetaProviderCloser
  • func InitMetaProviderClients(ctx context.Context, withCoreMeta bool) ([]tree.NodeProviderStreamer_ReadNodeStreamClient, MetaProviderCloser, []string)
• type NamespacesProvider
  • func NewNamespacesProvider() *NamespacesProvider
  • func (p *NamespacesProvider) Clear()
  • func (p *NamespacesProvider) CloseStreamers() error
  • func (p *NamespacesProvider) ExcludeIndexes() map[string]struct{}
  • func (p *NamespacesProvider) InitStreamers(ctx context.Context) error
  • func (p *NamespacesProvider) Load()
  • func (p *NamespacesProvider) Namespaces() map[string]*idm.UserMetaNamespace
  • func (p *NamespacesProvider) ReadNode(node *tree.Node) (*tree.Node, error)
  • func (p *NamespacesProvider) Watch()

Constants

const (
	ServiceMetaProvider   = "MetaProvider"
	ServiceMetaNsProvider = "MetaNsProvider"
)

Functions

func EnrichNodesMetaFromProviders

func EnrichNodesMetaFromProviders(ctx context.Context, streamers []tree.NodeProviderStreamer_ReadNodeStreamClient, names []string, nodes ...*tree.Node)

Types

type MetaProviderCloser

type MetaProviderCloser func()

func InitMetaProviderClients

func InitMetaProviderClients(ctx context.Context, withCoreMeta bool) ([]tree.NodeProviderStreamer_ReadNodeStreamClient, MetaProviderCloser, []string)

type NamespacesProvider

type NamespacesProvider struct {
	sync.RWMutex // this handles a lock for the namespaces field
	// contains filtered or unexported fields
}

NamespaceProvider list all namespaces info from services declared ServiceMetaNsProvider It watches events to maintain the list

func NewNamespacesProvider

func NewNamespacesProvider() *NamespacesProvider

func (*NamespacesProvider) Clear

func (p *NamespacesProvider) Clear()

func (*NamespacesProvider) CloseStreamers

func (p *NamespacesProvider) CloseStreamers() error

func (*NamespacesProvider) ExcludeIndexes

func (p *NamespacesProvider) ExcludeIndexes() map[string]struct{}

func (*NamespacesProvider) InitStreamers

func (p *NamespacesProvider) InitStreamers(ctx context.Context) error

func (*NamespacesProvider) Load

func (p *NamespacesProvider) Load()

func (*NamespacesProvider) Namespaces

func (p *NamespacesProvider) Namespaces() map[string]*idm.UserMetaNamespace

func (*NamespacesProvider) ReadNode

func (p *NamespacesProvider) ReadNode(node *tree.Node) (*tree.Node, error)

func (*NamespacesProvider) Watch

func (p *NamespacesProvider) Watch()