WIP

Signed-off-by: Michael Fraenkel <fraenkel@us.ibm.com>
Signed-off-by: Nino Khodabandeh <nino.khodabandeh@hpe.com>

emitter/emit.go

@@ -23,7 +23,7 @@ type Emitter interface {
 }
 
 type LoggregatorEmitter struct {
-	LoggregatorClient loggregatorclient.LoggregatorClient
+	LoggregatorClient loggregatorclient.Client
 	sn                string
 	sId               string
 	sharedSecret      string
@@ -99,12 +99,18 @@ func NewEmitter(loggregatorServer, sourceName, sourceId, sharedSecret string, lo
 		logger = gosteno.NewLogger("loggregatorlib.emitter")
 	}
 
-	e := &LoggregatorEmitter{sharedSecret: sharedSecret}
+	client, err := loggregatorclient.NewUDPClient(logger, loggregatorServer, loggregatorclient.DefaultBufferSize)
+	if err != nil {
+		return nil, err
+	}
 
-	e.sn = sourceName
-	e.logger = logger
-	e.LoggregatorClient = loggregatorclient.NewLoggregatorClient(loggregatorServer, logger, loggregatorclient.DefaultBufferSize)
-	e.sId = sourceId
+	e := &LoggregatorEmitter{
+		sharedSecret:      sharedSecret,
+		sn:                sourceName,
+		sId:               sourceId,
+		LoggregatorClient: client,
+		logger:            logger,
+	}
 
 	e.logger.Debugf("Created new loggregator emitter: %#v", e)
 	return e, nil

loggregatorclient/fake/fake_loggregator_client.go

@@ -1,11 +1,20 @@
 package fake
 
 type FakeLoggregatorClient struct {
+	Addr     string
 	Received chan *[]byte
 }
 
-func (flc FakeLoggregatorClient) Send(data []byte) {
+func (flc *FakeLoggregatorClient) Scheme() string {
+	return "fake"
+}
+
+func (flc *FakeLoggregatorClient) Address() string {
+	return flc.Addr
+}
+
+func (flc *FakeLoggregatorClient) Send(data []byte) {
 	flc.Received <- &data
 }
 
-func (flc FakeLoggregatorClient) Stop() {}
+func (flc *FakeLoggregatorClient) Stop() {}

loggregatorclient/tlsclient.go

@@ -0,0 +1,31 @@
+package loggregatorclient
+
+import "github.com/cloudfoundry/gosteno"
+
+type tlsClient struct {
+	address string
+	logger  *gosteno.Logger
+}
+
+func NewTLSClient(logger *gosteno.Logger, address string) (Client, error) {
+	loggregatorClient := &tlsClient{
+		address: address,
+		logger:  logger,
+	}
+	return loggregatorClient, nil
+}
+
+func (c *tlsClient) Scheme() string {
+	return "tls"
+}
+
+func (c *tlsClient) Address() string {
+	return c.address
+}
+
+func (c *tlsClient) Stop() {
+}
+
+func (c *tlsClient) Send(data []byte) {
+	c.logger.Warn("Sending over TLS (unsupported)")
+}