mappingprovider

package

v0.64.1 Latest Latest Go to latest Published: Dec 25, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(
	filePath string,
	opts ...Option,
) (*MappingProvider, error)

func (p *MappingProvider) GetMapping() seq.Mapping

func (p *MappingProvider) GetRawMapping() *seq.RawMapping

func (p *MappingProvider) WatchUpdates(ctx context.Context)

WatchUpdates periodically reads the contents at filePath and when it detects changes it updates the mapping

type Option func(*MappingProvider)

func WithIndexAllFields(enabled bool) Option

func WithMapping(m seq.Mapping) Option

func WithUpdatePeriod(up time.Duration) Option