source

Documentation

Index

• Constants
• Variables
• func ListObjects(ctx context.Context) (objects []string)
• func ListSources(ctx context.Context) (sources []string)
• type Resolver
  • func NewResolver[T any](ctxKey any, srvPrefix string, provider SourcesProvider) *Resolver[T]
  • func (r *Resolver[T]) HeatCacheAndWatch(ctx context.Context, watchOpts ...configx.WatchOption) error
  • func (r *Resolver[T]) Lookup(ctx context.Context) (T, error)
  • func (r *Resolver[T]) Resolve(ctx context.Context) (T, error)
  • func (r *Resolver[T]) SetCleaner(cleaner func(context.Context, string, T) error)
  • func (r *Resolver[T]) SetLoader(loader func(context.Context, string) (T, error))
  • func (r *Resolver[T]) WatchConfig(ctx context.Context, opts ...configx.WatchOption)
• type SourcesProvider

Constants

const (
	DatasourceTplKey    = "DataSource"
	ObjectServiceTplKey = "Object"
)

Variables

var (
	DataSourceContextKey    = dsContextKey{}
	ObjectServiceContextKey = objContextKey{}
)

Functions

func ListObjects

func ListObjects(ctx context.Context) (objects []string)

ListObjects is a SourcesProvider returning *object.MinioConfig list

func ListSources

func ListSources(ctx context.Context) (sources []string)

ListSources is a SourcesProvider returning *object.Datasource list

Types

type Resolver

type Resolver[T any] struct {
	// contains filtered or unexported fields
}

Resolver is a util for iterating/resolving datasource injected in context

func NewResolver

func NewResolver[T any](ctxKey any, srvPrefix string, provider SourcesProvider) *Resolver[T]

NewResolver creates a new resolver with a SourcesProvider

func (*Resolver[T]) HeatCacheAndWatch

func (r *Resolver[T]) HeatCacheAndWatch(ctx context.Context, watchOpts ...configx.WatchOption) error

HeatCacheAndWatch use internal loader and SourcesProvider to put all data in cache. WatchOptions are used to start a watch on config

func (*Resolver[T]) Lookup

func (r *Resolver[T]) Lookup(ctx context.Context) (T, error)

Lookup tries to load from cache and return an error if not found, without triggering loader

func (*Resolver[T]) Resolve

func (r *Resolver[T]) Resolve(ctx context.Context) (T, error)

Resolve tries to load from cache or using loader

func (*Resolver[T]) SetCleaner

func (r *Resolver[T]) SetCleaner(cleaner func(context.Context, string, T) error)

SetCleaner registers a clean function to be called when a source is removed

func (*Resolver[T]) SetLoader

func (r *Resolver[T]) SetLoader(loader func(context.Context, string) (T, error))

SetLoader provides the initializer for a given source

func (*Resolver[T]) WatchConfig

func (r *Resolver[T]) WatchConfig(ctx context.Context, opts ...configx.WatchOption)

WatchConfig watches sources and triggers loader/cleaner for new/removed sources

type SourcesProvider

type SourcesProvider func(ctx context.Context) []string

SourcesProvider generates a source of keys based on context