| 
									
										
										
										
											2018-06-29 12:44:16 +03:00
										 |  |  | package metadata
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | import (
 | 
					
						
							|  |  |  | 	"context"
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	"github.com/coredns/coredns/plugin"
 | 
					
						
							|  |  |  | 	"github.com/coredns/coredns/request"
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	"github.com/miekg/dns"
 | 
					
						
							|  |  |  | )
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | // Metadata implements collecting metadata information from all plugins that
 | 
					
						
							|  |  |  | // implement the Provider interface.
 | 
					
						
							|  |  |  | type Metadata struct {
 | 
					
						
							|  |  |  | 	Zones     []string
 | 
					
						
							|  |  |  | 	Providers []Provider
 | 
					
						
							|  |  |  | 	Next      plugin.Handler
 | 
					
						
							|  |  |  | }
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | // Name implements the Handler interface.
 | 
					
						
							|  |  |  | func (m *Metadata) Name() string { return "metadata" }
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2019-06-09 00:10:57 -07:00
										 |  |  | // ContextWithMetadata is exported for use by provider tests
 | 
					
						
							|  |  |  | func ContextWithMetadata(ctx context.Context) context.Context {
 | 
					
						
							|  |  |  | 	return context.WithValue(ctx, key{}, md{})
 | 
					
						
							|  |  |  | }
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-06-29 12:44:16 +03:00
										 |  |  | // ServeDNS implements the plugin.Handler interface.
 | 
					
						
							|  |  |  | func (m *Metadata) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error) {
 | 
					
						
							| 
									
										
										
										
											2022-09-08 14:56:27 -04:00
										 |  |  | 	rcode, err := plugin.NextOrFailure(m.Name(), m.Next, ctx, w, r)
 | 
					
						
							|  |  |  | 	return rcode, err
 | 
					
						
							|  |  |  | }
 | 
					
						
							| 
									
										
										
										
											2018-06-29 12:44:16 +03:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-09-08 14:56:27 -04:00
										 |  |  | // Collect will retrieve metadata functions from each metadata provider and update the context
 | 
					
						
							|  |  |  | func (m *Metadata) Collect(ctx context.Context, state request.Request) context.Context {
 | 
					
						
							|  |  |  | 	ctx = ContextWithMetadata(ctx)
 | 
					
						
							| 
									
										
										
										
											2018-06-29 12:44:16 +03:00
										 |  |  | 	if plugin.Zones(m.Zones).Matches(state.Name()) != "" {
 | 
					
						
							| 
									
										
										
										
											2018-06-29 15:03:25 +01:00
										 |  |  | 		// Go through all Providers and collect metadata.
 | 
					
						
							| 
									
										
										
										
											2018-07-01 20:01:17 +01:00
										 |  |  | 		for _, p := range m.Providers {
 | 
					
						
							|  |  |  | 			ctx = p.Metadata(ctx, state)
 | 
					
						
							| 
									
										
										
										
											2018-06-29 12:44:16 +03:00
										 |  |  | 		}
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							| 
									
										
										
										
											2022-09-08 14:56:27 -04:00
										 |  |  | 	return ctx
 | 
					
						
							| 
									
										
										
										
											2018-06-29 12:44:16 +03:00
										 |  |  | }
 |