func New(c *Config) *Collector {
	return &Collector{
		scpConfig: &scpConfig{
			user:            c.RemoteUser,
			port:            c.RemotePort,
			identifyKeyFile: c.RemoteKeyFile,
		},
		namespace: c.Namespace,
		k8s:       c.K8sClient,
	}
}
New returns *Collector given a *Config.
package collector
import (
	"io"
	"log"
	"path/filepath"
	"sync"
	"github.com/coreos/ktestutil/log-collector/pkg/fluentd"
	"github.com/coreos/ktestutil/log-collector/pkg/local"
	"github.com/coreos/ktestutil/log-collector/pkg/s3"
	"k8s.io/client-go/kubernetes"
)
type Output interface {
	Put(io.ReadSeeker, string) (string, error)
}
type Collector struct {
	scpConfig *scpConfig
	namespace string
	k8s       kubernetes.Interface
	Output Output
}
type Config struct {
	RemoteUser    string
	RemotePort    int32
	RemoteKeyFile string
	K8sClient     kubernetes.Interface
	Namespace     string
}