processor_factory.go 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. /*
  2. * Licensed to the Apache Software Foundation (ASF) under one
  3. * or more contributor license agreements. See the NOTICE file
  4. * distributed with this work for additional information
  5. * regarding copyright ownership. The ASF licenses this file
  6. * to you under the Apache License, Version 2.0 (the
  7. * "License"); you may not use this file except in compliance
  8. * with the License. You may obtain a copy of the License at
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  12. * Unless required by applicable law or agreed to in writing,
  13. * software distributed under the License is distributed on an
  14. * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  15. * KIND, either express or implied. See the License for the
  16. * specific language governing permissions and limitations
  17. * under the License.
  18. */
  19. package thrift
  20. // The default processor factory just returns a singleton
  21. // instance.
  22. type TProcessorFactory interface {
  23. GetProcessor(trans TTransport) TProcessor
  24. }
  25. type tProcessorFactory struct {
  26. processor TProcessor
  27. }
  28. func NewTProcessorFactory(p TProcessor) TProcessorFactory {
  29. return &tProcessorFactory{processor: p}
  30. }
  31. func (p *tProcessorFactory) GetProcessor(trans TTransport) TProcessor {
  32. return p.processor
  33. }
  34. /**
  35. * The default processor factory just returns a singleton
  36. * instance.
  37. */
  38. type TProcessorFunctionFactory interface {
  39. GetProcessorFunction(trans TTransport) TProcessorFunction
  40. }
  41. type tProcessorFunctionFactory struct {
  42. processor TProcessorFunction
  43. }
  44. func NewTProcessorFunctionFactory(p TProcessorFunction) TProcessorFunctionFactory {
  45. return &tProcessorFunctionFactory{processor: p}
  46. }
  47. func (p *tProcessorFunctionFactory) GetProcessorFunction(trans TTransport) TProcessorFunction {
  48. return p.processor
  49. }