middleware

Documentation

Index

• Constants
• Variables
• func ReadBytesLogger(logger logger.Logger) client.MiddlewareFunc
• func ReadBytesMetric(informer logger.Informer, metric *metric.Metric) client.MiddlewareFunc
• func ReadTimeout(config *ReadConfig, informer logger.Informer) client.MiddlewareFunc
• func ReadTimeoutComponentBindFlags(flagSet *pflag.FlagSet, container container.Container) error
• func WriteBytesLogger(logger logger.Logger) client.MiddlewareFunc
• func WriteBytesMetric(informer logger.Informer, metric *metric.Metric) client.MiddlewareFunc
• func WriteTimeout(config *WriteConfig, informer logger.Informer) client.MiddlewareFunc
• func WriteTimeoutComponentBindFlags(flagSet *pflag.FlagSet, container container.Container) error
• type ReadConfig
  • func NewReadConfig() *ReadConfig
  • func ReadConfigConfiguration(config *ReadConfig, configurator configurator.Configurator) *ReadConfig
• type WriteConfig
  • func NewWriteConfig() *WriteConfig
  • func WriteConfigConfiguration(config *WriteConfig, configurator configurator.Configurator) *WriteConfig

Constants

const (
	WriteTimeoutFieldName = "client.socket.timeout.write"
	ReadTimeoutFieldName  = "client.socket.timeout.read"

	WriteTimeoutDefault = 10 * time.Second
	ReadTimeoutDefault  = 10 * time.Second
)

Variables

var (
	ReadBytesLoggerComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger) {
				socketClient.Use(ReadBytesLogger(logger))
			})
		}),
	}

	ReadBytesMetricComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
			metric.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger, metric *metric.Metric) {
				socketClient.Use(ReadBytesMetric(logger, metric))
			})
		}),
	}

	ReadTimeoutComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			configurator.Component,
			client.Component,
		},
		Constructor: app.Constructor(func(container container.Container) error {
			return container.Provide(NewReadConfig)
		}),
		BindFlags: app.BindFlags(ReadTimeoutComponentBindFlags),
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, config *ReadConfig, logger logger.Logger, configurator configurator.Configurator) {
				socketClient.Use(ReadTimeout(ReadConfigConfiguration(config, configurator), logger))
			})
		}),
	}

	ReadComponent = &app.Component{
		Dependencies: app.Components{
			ReadBytesLoggerComponent,
			ReadBytesMetricComponent,
			ReadTimeoutComponent,
		},
	}

	WriteBytesLoggerComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger) {
				socketClient.Use(WriteBytesLogger(logger))
			})
		}),
	}

	WriteBytesMetricComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
			metric.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger, metric *metric.Metric) {
				socketClient.Use(WriteBytesMetric(logger, metric))
			})
		}),
	}

	WriteTimeoutComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			configurator.Component,
			client.Component,
		},
		Constructor: app.Constructor(func(container container.Container) error {
			return container.Provide(NewWriteConfig)
		}),
		BindFlags: app.BindFlags(WriteTimeoutComponentBindFlags),
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, config *WriteConfig, logger logger.Logger, configurator configurator.Configurator) {
				socketClient.Use(WriteTimeout(WriteConfigConfiguration(config, configurator), logger))
			})
		}),
	}

	WriteComponent = &app.Component{
		Dependencies: app.Components{
			WriteBytesLoggerComponent,
			WriteBytesMetricComponent,
			WriteTimeoutComponent,
		},
	}

	Component = &app.Component{Dependencies: app.Components{ReadComponent, WriteComponent}}
)

Functions

func ReadBytesLogger

func ReadBytesLogger(logger logger.Logger) client.MiddlewareFunc

func ReadBytesMetric

func ReadBytesMetric(informer logger.Informer, metric *metric.Metric) client.MiddlewareFunc

func ReadTimeout

func ReadTimeout(config *ReadConfig, informer logger.Informer) client.MiddlewareFunc

func ReadTimeoutComponentBindFlags

func ReadTimeoutComponentBindFlags(flagSet *pflag.FlagSet, container container.Container) error

func WriteBytesLogger

func WriteBytesLogger(logger logger.Logger) client.MiddlewareFunc

func WriteBytesMetric

func WriteBytesMetric(informer logger.Informer, metric *metric.Metric) client.MiddlewareFunc

func WriteTimeout

func WriteTimeout(config *WriteConfig, informer logger.Informer) client.MiddlewareFunc

func WriteTimeoutComponentBindFlags

func WriteTimeoutComponentBindFlags(flagSet *pflag.FlagSet, container container.Container) error

Types

type ReadConfig

type ReadConfig struct {
	Timeout time.Duration
}

func NewReadConfig

func NewReadConfig() *ReadConfig

func ReadConfigConfiguration

func ReadConfigConfiguration(config *ReadConfig, configurator configurator.Configurator) *ReadConfig

type WriteConfig

type WriteConfig struct {
	Timeout time.Duration
}

func NewWriteConfig

func NewWriteConfig() *WriteConfig

func WriteConfigConfiguration

func WriteConfigConfiguration(config *WriteConfig, configurator configurator.Configurator) *WriteConfig