rest

README

rest

Documentation

Index

• Constants
• func NewProductionLogger() (*zap.Logger, error)
• func WithShutdownTimeout(d time.Duration) func(*Server)
• type ReadCounter
  • func NewReadCounter(r io.Reader) *ReadCounter
  • func (rc *ReadCounter) Read(p []byte) (n int, err error)
  • func (rc *ReadCounter) Total() int64
• type Request
  • func R() *Request
  • func (r *Request) AddHeaders(headers map[string]string) *Request
  • func (r *Request) AddQueryParams(params map[string]string) *Request
  • func (r *Request) Delete() (*http.Response, error)
  • func (r *Request) Do(method string) (*http.Response, error)
  • func (r *Request) Get() (*http.Response, error)
  • func (r *Request) Post() (*http.Response, error)
  • func (r *Request) Put() (*http.Response, error)
  • func (r *Request) SetBasicAuth(user, pass string) *Request
  • func (r *Request) SetBody(rc io.ReadCloser) *Request
  • func (r *Request) SetClient(client *http.Client) *Request
  • func (r *Request) SetContext(ctx context.Context) *Request
  • func (r *Request) SetJSON(x interface{}) *Request
  • func (r *Request) SetURL(url string) *Request
  • func (r *Request) SetURLf(format string, args ...interface{}) *Request
• type Server
  • func NewServer(srv *http.Server, options ...func(*Server)) *Server
  • func (s *Server) ListenAndServeContext(ctx context.Context) error
  • func (s *Server) ListenAndServeTLSContext(ctx context.Context, certFile, keyFile string) error
• type WriteCounter
  • func NewWriteCounter(w io.Writer) *WriteCounter
  • func (wc *WriteCounter) Total() int64
  • func (wc *WriteCounter) Write(p []byte) (n int, err error)

Constants

const (
	DefaultRequestTimeout = 15 * time.Second
)

const (
	DefaultServerShutdownTimeout = 15 * time.Second
)

Functions

func NewProductionLogger

func NewProductionLogger() (*zap.Logger, error)

func WithShutdownTimeout

func WithShutdownTimeout(d time.Duration) func(*Server)

Types

type ReadCounter

type ReadCounter struct {
	io.Reader
	// contains filtered or unexported fields
}

func NewReadCounter

func NewReadCounter(r io.Reader) *ReadCounter

func (*ReadCounter) Read

func (rc *ReadCounter) Read(p []byte) (n int, err error)

func (*ReadCounter) Total

func (rc *ReadCounter) Total() int64

type Request

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

func R

func R() *Request

func (*Request) AddHeaders

func (r *Request) AddHeaders(headers map[string]string) *Request

func (*Request) AddQueryParams

func (r *Request) AddQueryParams(params map[string]string) *Request

func (*Request) Delete

func (r *Request) Delete() (*http.Response, error)

func (*Request) Do

func (r *Request) Do(method string) (*http.Response, error)

func (*Request) Get

func (r *Request) Get() (*http.Response, error)

func (*Request) Post

func (r *Request) Post() (*http.Response, error)

func (*Request) Put

func (r *Request) Put() (*http.Response, error)

func (*Request) SetBasicAuth

func (r *Request) SetBasicAuth(user, pass string) *Request

func (*Request) SetBody

func (r *Request) SetBody(rc io.ReadCloser) *Request

func (*Request) SetClient

func (r *Request) SetClient(client *http.Client) *Request

func (*Request) SetContext

func (r *Request) SetContext(ctx context.Context) *Request

func (*Request) SetJSON

func (r *Request) SetJSON(x interface{}) *Request

func (*Request) SetURL

func (r *Request) SetURL(url string) *Request

func (*Request) SetURLf

func (r *Request) SetURLf(format string, args ...interface{}) *Request

type Server

type Server struct {
	*http.Server
	// contains filtered or unexported fields
}

func NewServer

func NewServer(srv *http.Server, options ...func(*Server)) *Server

func (*Server) ListenAndServeContext

func (s *Server) ListenAndServeContext(ctx context.Context) error

func (*Server) ListenAndServeTLSContext

func (s *Server) ListenAndServeTLSContext(ctx context.Context, certFile, keyFile string) error

type WriteCounter

type WriteCounter struct {
	io.Writer
	// contains filtered or unexported fields
}

func NewWriteCounter

func NewWriteCounter(w io.Writer) *WriteCounter

func (*WriteCounter) Total

func (wc *WriteCounter) Total() int64

func (*WriteCounter) Write

func (wc *WriteCounter) Write(p []byte) (n int, err error)