provider

Documentation

Index

• Constants
• func ParseProxyProvider(name string, mapping map[string]interface{}) (types.ProxyProvider, error)
• type CompatibleProvider
  • func NewCompatibleProvider(name string, proxies []C.Proxy, hc *HealthCheck) (*CompatibleProvider, error)
  • func (cp CompatibleProvider) HealthCheck()
  • func (cp CompatibleProvider) Initial() error
  • func (cp CompatibleProvider) MarshalJSON() ([]byte, error)
  • func (cp CompatibleProvider) Name() string
  • func (cp CompatibleProvider) Proxies() []C.Proxy
  • func (cp CompatibleProvider) ProxiesWithTouch() []C.Proxy
  • func (cp CompatibleProvider) Type() types.ProviderType
  • func (cp CompatibleProvider) Update() error
  • func (cp CompatibleProvider) VehicleType() types.VehicleType
• type FileVehicle
  • func NewFileVehicle(path string) *FileVehicle
  • func (f *FileVehicle) Path() string
  • func (f *FileVehicle) Read() ([]byte, error)
  • func (f *FileVehicle) Type() types.VehicleType
• type HTTPVehicle
  • func NewHTTPVehicle(url string, path string) *HTTPVehicle
  • func (h *HTTPVehicle) Path() string
  • func (h *HTTPVehicle) Read() ([]byte, error)
  • func (h *HTTPVehicle) Type() types.VehicleType
• type HealthCheck
  • func NewHealthCheck(proxies []C.Proxy, url string, interval uint, lazy bool) *HealthCheck
• type HealthCheckOption
• type ProxySchema
• type ProxySetProvider
  • func NewProxySetProvider(name string, interval time.Duration, filter string, vehicle types.Vehicle, ...) (*ProxySetProvider, error)
  • func (pp ProxySetProvider) HealthCheck()
  • func (pp ProxySetProvider) Initial() error
  • func (pp ProxySetProvider) MarshalJSON() ([]byte, error)
  • func (pp ProxySetProvider) Name() string
  • func (pp ProxySetProvider) Proxies() []C.Proxy
  • func (pp ProxySetProvider) ProxiesWithTouch() []C.Proxy
  • func (pp ProxySetProvider) Type() types.ProviderType
  • func (pp ProxySetProvider) Update() error

Constants

const (
	ReservedName = "default"
)

Functions

func ParseProxyProvider

func ParseProxyProvider(name string, mapping map[string]interface{}) (types.ProxyProvider, error)

Types

type CompatibleProvider

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

for auto gc

func NewCompatibleProvider

func NewCompatibleProvider(name string, proxies []C.Proxy, hc *HealthCheck) (*CompatibleProvider, error)

func (CompatibleProvider) HealthCheck

func (cp CompatibleProvider) HealthCheck()

func (CompatibleProvider) Initial

func (cp CompatibleProvider) Initial() error

func (CompatibleProvider) MarshalJSON

func (cp CompatibleProvider) MarshalJSON() ([]byte, error)

func (CompatibleProvider) Name

func (cp CompatibleProvider) Name() string

func (CompatibleProvider) Proxies

func (cp CompatibleProvider) Proxies() []C.Proxy

func (CompatibleProvider) ProxiesWithTouch

func (cp CompatibleProvider) ProxiesWithTouch() []C.Proxy

func (CompatibleProvider) Type

func (cp CompatibleProvider) Type() types.ProviderType

func (CompatibleProvider) Update

func (cp CompatibleProvider) Update() error

func (CompatibleProvider) VehicleType

func (cp CompatibleProvider) VehicleType() types.VehicleType

type FileVehicle

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

func NewFileVehicle

func NewFileVehicle(path string) *FileVehicle

func (*FileVehicle) Path

func (f *FileVehicle) Path() string

func (*FileVehicle) Read

func (f *FileVehicle) Read() ([]byte, error)

func (*FileVehicle) Type

func (f *FileVehicle) Type() types.VehicleType

type HTTPVehicle

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

func NewHTTPVehicle

func NewHTTPVehicle(url string, path string) *HTTPVehicle

func (*HTTPVehicle) Path

func (h *HTTPVehicle) Path() string

func (*HTTPVehicle) Read

func (h *HTTPVehicle) Read() ([]byte, error)

func (*HTTPVehicle) Type

func (h *HTTPVehicle) Type() types.VehicleType

type HealthCheck

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

func NewHealthCheck

func NewHealthCheck(proxies []C.Proxy, url string, interval uint, lazy bool) *HealthCheck

type HealthCheckOption

type HealthCheckOption struct {
	URL      string
	Interval uint
}

type ProxySchema

type ProxySchema struct {
	Proxies []map[string]interface{} `yaml:"proxies"`
}

type ProxySetProvider

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

for auto gc

func NewProxySetProvider

func NewProxySetProvider(name string, interval time.Duration, filter string, vehicle types.Vehicle, hc *HealthCheck) (*ProxySetProvider, error)

func (ProxySetProvider) HealthCheck

func (pp ProxySetProvider) HealthCheck()

func (ProxySetProvider) Initial

func (pp ProxySetProvider) Initial() error

func (ProxySetProvider) MarshalJSON

func (pp ProxySetProvider) MarshalJSON() ([]byte, error)

func (ProxySetProvider) Name

func (pp ProxySetProvider) Name() string

func (ProxySetProvider) Proxies

func (pp ProxySetProvider) Proxies() []C.Proxy

func (ProxySetProvider) ProxiesWithTouch

func (pp ProxySetProvider) ProxiesWithTouch() []C.Proxy

func (ProxySetProvider) Type

func (pp ProxySetProvider) Type() types.ProviderType

func (ProxySetProvider) Update

func (pp ProxySetProvider) Update() error