binding

type Binding struct {
	AppID    string   `json:"app_id"`
	Drains   []string `json:"drains"`
	Hostname string   `json:"hostname"`
}

type Connector interface {
	Connect(context.Context, syslog.Binding) (egress.Writer, error)
}

type Fetcher interface {
	FetchBindings() ([]syslog.Binding, error)
	DrainLimit() int
}

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

type Metrics interface {
	NewGauge(name string, o ...metrics.MetricOption) metrics.Gauge
	NewCounter(name string, o ...metrics.MetricOption) metrics.Counter
}

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

type Setter interface {
	Set([]Binding)
}

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