option

func Address ¶

func Address(address string) MsOption

func ID ¶

func ID(id string) MsOption

func Name ¶

func Name(name string) MsOption

func WitStreamLoggingMiddleware ¶

func WitStreamLoggingMiddleware(logger *zap.Logger) MsOption

func WitStreamPrometheusMiddleware ¶

func WitStreamPrometheusMiddleware() MsOption

func WitUnaryLoggingMiddleware ¶

func WitUnaryLoggingMiddleware(logger *zap.Logger) MsOption

func WitUnaryPrometheusMiddleware ¶

func WitUnaryPrometheusMiddleware() MsOption

func WithConnTimeout ¶

func WithConnTimeout(t time.Duration) MsOption

WithStatsHandler ConnectionTimeout returns a ServerOption that sets the timeout for connection establishment (up to and including HTTP/2 handshaking) for all new connections. If this is not set, the default is 120 seconds.

func WithHTTPMiddleware ¶

func WithHTTPMiddleware(mw func(http.Handler) http.Handler) MsOption

func WithHealthz ¶

func WithHealthz() MsOption

func WithMaxConcurrentStreams ¶

func WithMaxConcurrentStreams(num uint32) MsOption

WithMaxConcurrentStreams returns a ServerOption that will apply a limit on the number of concurrent streams to each ServerTransport.

func WithReflection ¶

func WithReflection() MsOption

WithReflection adds grpc server reflection to the list of Services ref: https://godoc.org/google.golang.org/grpc/reflection

func WithRestIncomingHeaderMatcher ¶

func WithRestIncomingHeaderMatcher(matcher runtime.HeaderMatcherFunc) MsOption

func WithRestLoggingMiddleware ¶

func WithRestLoggingMiddleware(logger *zap.Logger) MsOption

func WithRestMarshaler ¶

func WithRestMarshaler(mime string, msh runtime.Marshaler) MsOption

grpc-gateway options

func WithRestOutgoingHeaderMatcher ¶

func WithRestOutgoingHeaderMatcher(matcher runtime.HeaderMatcherFunc) MsOption

func WithRestServices ¶

func WithRestServices(services ...restMw.RestService) MsOption

func WithServices ¶

func WithServices(services ...middleware.GrpcService) MsOption

func New ¶

func New(options ...MsOption) *MsOptions