kitworker

type ClientOption struct {
	// Host holds the host's name
	Host string

	// ZipkinCollector holds the collector for zipkin tracing
	Tracer stdopentracing.Tracer

	// DisableCircuitBreaker disables circuit breaking functionality
	DisableCircuitBreaker bool

	// CircuitBreaker holds the custom circuit breaker, if not set a default one
	// will be created with default settings
	CircuitBreaker *gobreaker.CircuitBreaker

	// DisableRateLimiter disables rate limiting functionality
	DisableRateLimiter bool

	// QPS holds the configration parameter for rate limiting outgoing requests
	// to remote client. Must be set othervise all requests will be blocked
	// unless rate limiting is disabled
	QPS int

	// RateLimiter holds the custom rate limiter, if not set a default one will be created automatically
	RateLimiter *jujuratelimit.Bucket

	// TransportOpts holds custom httptransport.ClientOption array will be
	// appended to the end of the autogenerated ClientOptions
	TransportOpts []httptransport.ClientOption

	// Middlewares holds custom endpoint.Middleware array will be appended to
	// the end of the autogenerated Middlewares
	Middlewares []endpoint.Middleware

	// LoadBalancerCreator creates the loadbalancing strategy after getting the factory
	LoadBalancerCreator LoadBalancerF
}

type LoadBalancerF func(factory sd.Factory) lb.Balancer

type ServerOption struct {
	// Host holds the host's name
	Host string

	// Tracer holds the collector for zipkin tracing
	Tracer stdopentracing.Tracer

	// LogErrors configures whether server should log error responses or not
	LogErrors bool

	// LogRequests configures if the server should log incoming requests or not
	LogRequests bool

	// Latency holds the metric metric for request latency metric collection, if
	// not set Latency metrics will not be collected
	Latency metrics.Histogram

	// Counter holds the metrics.Counter metric for request count metric
	// collection, if not set RequestCountMetrics will not be collected
	Counter metrics.Counter

	// ServerOptions holds custom httptransport.ServerOption array, will be
	// appended to the end of the autogenerated
	ServerOptions []httptransport.ServerOption

	// Middlewares holds custom endpoint.Middleware array will be appended to
	// the end of the autogenerated Middlewares
	Middlewares []endpoint.Middleware
}