ingress

Documentation

Index

• type APIClient
  • func (w APIClient) Get(nextID int) (*http.Response, error)
• type BindingFetcher
  • func NewBindingFetcher(g Getter) *BindingFetcher
  • func (f *BindingFetcher) FetchBindings() ([]v1.Binding, error)
• type BindingReader
• type BlacklistRange
• type BlacklistRanges
  • func NewBlacklistRanges(ranges ...BlacklistRange) (*BlacklistRanges, error)
  • func (i *BlacklistRanges) CheckBlacklist(ip net.IP) error
  • func (i *BlacklistRanges) ParseHost(drainURL string) (string, string, error)
  • func (i *BlacklistRanges) ResolveAddr(host string) (net.IP, error)
  • func (i *BlacklistRanges) UnmarshalEnv(v string) error
• type FilteredBindingFetcher
  • func NewFilteredBindingFetcher(c IPChecker, b BindingReader, lc LogClient) *FilteredBindingFetcher
  • func (f *FilteredBindingFetcher) FetchBindings() ([]v1.Binding, int, error)
• type Getter
• type IPChecker
• type LogClient

Types

type APIClient

type APIClient struct {
	Client    *http.Client
	Addr      string
	BatchSize int
}

func (APIClient) Get

func (w APIClient) Get(nextID int) (*http.Response, error)

type BindingFetcher

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

BindingFetcher uses a Getter to fetch and decode Bindings

func NewBindingFetcher

func NewBindingFetcher(g Getter) *BindingFetcher

NewBindingFetcher returns a new BindingFetcher

func (*BindingFetcher) FetchBindings

func (f *BindingFetcher) FetchBindings() ([]v1.Binding, error)

FetchBindings reaches out to the syslog drain binding provider via the Getter and decodes the response. If it does not get a 200, it returns an error.

type BindingReader

type BindingReader interface {
	FetchBindings() (appBindings []v1.Binding, err error)
}

type BlacklistRange

type BlacklistRange struct {
	Start string
	End   string
}

type BlacklistRanges

type BlacklistRanges struct {
	Ranges []BlacklistRange
}

func NewBlacklistRanges

func NewBlacklistRanges(ranges ...BlacklistRange) (*BlacklistRanges, error)

func (*BlacklistRanges) CheckBlacklist

func (i *BlacklistRanges) CheckBlacklist(ip net.IP) error

func (*BlacklistRanges) ParseHost

func (i *BlacklistRanges) ParseHost(drainURL string) (string, string, error)

func (*BlacklistRanges) ResolveAddr

func (i *BlacklistRanges) ResolveAddr(host string) (net.IP, error)

func (*BlacklistRanges) UnmarshalEnv

func (i *BlacklistRanges) UnmarshalEnv(v string) error

UnmarshalEnv implements envstruct.Unmarshaller. Example input: 10.0.0.5-10.0.0.9,123.4.5.6-123.4.5.7

type FilteredBindingFetcher

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

func NewFilteredBindingFetcher

func NewFilteredBindingFetcher(c IPChecker, b BindingReader, lc LogClient) *FilteredBindingFetcher

func (*FilteredBindingFetcher) FetchBindings

func (f *FilteredBindingFetcher) FetchBindings() ([]v1.Binding, int, error)

type Getter

type Getter interface {
	Get(nextID int) (resp *http.Response, err error)
}

Getter is configured to fetch HTTP responses

type IPChecker

type IPChecker interface {
	ParseHost(url string) (string, string, error)
	ResolveAddr(host string) (net.IP, error)
	CheckBlacklist(ip net.IP) error
}

type LogClient

type LogClient interface {
	EmitLog(message string, opts ...loggregator.EmitLogOption)
}

LogClient is used to emit logs about an applications syslog drain.