config

Documentation

Index

• func MakeReplaceOrAppendEndpointFn(origin []*configv1.Endpoint) func([]*configv1.Endpoint, *configv1.Endpoint) []*configv1.Endpoint
• type ConfigLoader
• type FileLoader
  • func NewFileLoader(confPath string, priorityDirectory string) (*FileLoader, error)
  • func (f *FileLoader) Close()
  • func (f *FileLoader) DebugHandler() http.Handler
  • func (f *FileLoader) Load(_ context.Context) (*configv1.Gateway, error)
  • func (f *FileLoader) Watch(fn OnChange)
• type InspectFileLoader
• type OnChange

Functions

func MakeReplaceOrAppendEndpointFn

func MakeReplaceOrAppendEndpointFn(origin []*configv1.Endpoint) func([]*configv1.Endpoint, *configv1.Endpoint) []*configv1.Endpoint

Types

type ConfigLoader

type ConfigLoader interface {
	Load(context.Context) (*configv1.Gateway, error)
	Watch(OnChange)
	Close()
}

type FileLoader

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

func NewFileLoader

func NewFileLoader(confPath string, priorityDirectory string) (*FileLoader, error)

func (*FileLoader) Close

func (f *FileLoader) Close()

func (*FileLoader) DebugHandler

func (f *FileLoader) DebugHandler() http.Handler

func (*FileLoader) Load

func (f *FileLoader) Load(_ context.Context) (*configv1.Gateway, error)

func (*FileLoader) Watch

func (f *FileLoader) Watch(fn OnChange)

type InspectFileLoader

type InspectFileLoader struct {
	ConfPath           string            `json:"confPath"`
	ConfSHA256         string            `json:"confSha256"`
	PriorityConfigHash map[string]string `json:"priorityConfigHash"`
	OnChangeHandlers   int64             `json:"onChangeHandlers"`
}

type OnChange

type OnChange func() error