cleanup

backends/backend.go

@@ -123,7 +123,6 @@ type processorShutdowner interface {
 }
 
 type InitializeWith func(backendConfig BackendConfig) error
-type InitializeStreamWith func(conf ConfigGroup) error
 type ShutdownWith func() error
 
 // Satisfy ProcessorInitializer interface
@@ -133,11 +132,6 @@ func (i InitializeWith) Initialize(backendConfig BackendConfig) error {
 	return i(backendConfig)
 }
 
-func (i InitializeStreamWith) Initialize(conf ConfigGroup) error {
-	// delegate to the anonymous function
-	return i(conf)
-}
-
 // satisfy ProcessorShutdowner interface, same concept as InitializeWith type
 func (s ShutdownWith) Shutdown() error {
 	// delegate

backends/gateway.go

@@ -111,13 +111,6 @@ func (s *streamer) close() error {
 	return err
 }
 
-func (s *streamer) configure(cfg BackendConfig) error {
-	//for i := range s.d {
-	//s.d[i].Configure(cg)
-	//}
-	return nil
-}
-
 type backendState int
 
 // possible values for state
@@ -416,7 +409,6 @@ func (gw *BackendGateway) newStreamStack(stackConfig string) (streamer, error) {
 			return streamer{nil, decorators}, c.notFound(c.list[i].name)
 		}
 	}
-	//decorators[0].
 	// build the call-stack of decorators
 	sp, decorators := DecorateStream(&DefaultStreamProcessor{}, decorators)
 	return streamer{sp, decorators}, nil