rest

package

v0.4.31 Latest Latest Go to latest Published: May 15, 2020 License: GPL-3.0 Imports: 24 Imported by: 0

Details

This section is empty.

This section is empty.

func HTTPStatusFromCode(code codes.Code) int

func HTTPStatusFromError(err error) int

type AESDecoderEncoder struct {
	// contains filtered or unexported fields
}

func NewAESDecoderEncoder(key []byte) (*AESDecoderEncoder, error)

func (d *AESDecoderEncoder) DecodeBody(request *http.Request) (io.Reader, error)

func (d *AESDecoderEncoder) Encode(rw http.ResponseWriter) (http.ResponseWriter, error)

type AESResponseWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

func (a *AESResponseWriter) Write(msg []byte) (int, error)

type Decoder interface {
	DecodeBody(request *http.Request) (io.Reader, error)
}

type Encoder interface {
	Encode(rw http.ResponseWriter) (http.ResponseWriter, error)
}

type Method struct {
	// contains filtered or unexported fields
}

type Option func(options *options)

Option func is for applying any params to hub options

func WithDecoder(d Decoder) Option

func WithEncoder(e Encoder) Option

func WithInterceptors(interceptors ...grpc.UnaryServerInterceptor) Option

func WithLog(log *zap.Logger) Option

type Server struct {
	// contains filtered or unexported fields
}

func NewServer(opts ...Option) *Server

func (s *Server) Close()

func (s *Server) RegisterService(interfacePtr, concretePtr interface{}) error

func (s *Server) Serve(listeners ...net.Listener) error

func (s *Server) ServeHTTP(rw http.ResponseWriter, request *http.Request)

func (s *Server) Services() []string

type Service struct {
	// contains filtered or unexported fields
}