meta

Documentation

Overview

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

Index

• Constants
• type Loader
  • func NewStreamLoader(ctx context.Context) Loader
• type MetaProviderCloser
• 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()
• type StreamLoader
  • func (l *StreamLoader) Close() error
  • func (l *StreamLoader) LoadMetas(ctx context.Context, nodes ...*tree.Node)

Constants

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

Types

type Loader

type Loader interface {
	io.Closer
	LoadMetas(ctx context.Context, nodes ...*tree.Node)
}

func NewStreamLoader

func NewStreamLoader(ctx context.Context) Loader

type MetaProviderCloser

type MetaProviderCloser func() error

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()

type StreamLoader

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

func (*StreamLoader) Close

func (l *StreamLoader) Close() error

func (*StreamLoader) LoadMetas

func (l *StreamLoader) LoadMetas(ctx context.Context, nodes ...*tree.Node)