router

type AdapterFactory func(route *Route) (LogAdapter, error)

type AdapterTransport interface {
	Dial(addr string, options map[string]string) (net.Conn, error)
}

type HttpHandler func() http.Handler

type Job interface {
	Run() error
	Setup() error
	Name() string
}

type LogAdapter interface {
	Stream(logstream chan *Message)
}

type LogRouter interface {
	RoutingFrom(containerID string) bool
	Route(route *Route, logstream chan *Message)
}

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

type Message struct {
	Container *docker.Container
	Source    string
	Data      string
	Time      time.Time
}

type Route struct {
	ID            string            `json:"id"`
	FilterID      string            `json:"filter_id,omitempty"`
	FilterName    string            `json:"filter_name,omitempty"`
	FilterSources []string          `json:"filter_sources,omitempty"`
	Adapter       string            `json:"adapter"`
	Address       string            `json:"address"`
	Options       map[string]string `json:"options,omitempty"`
	// contains filtered or unexported fields
}

type RouteFileStore string

type RouteManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type RouteStore interface {
	Get(id string) (*Route, error)
	GetAll() ([]*Route, error)
	Add(route *Route) error
	Remove(id string) bool
}