util

Documentation

Index

• Constants
• func Bytes2String(b []byte) string
• func HTTPResponse(success bool, message string, data interface{}, httpCode int, ...) error
• func NewPool() *sync.Pool
• func String2Bytes(s string) []byte
• type DB
  • func NewDB(UserName string, Password string, IP string, Port int, DBName string, ...) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) Open() error
• type Duration
  • func (d Duration) ToDuration() time.Duration
  • func (d Duration) UnmarshalYAML(unmarshal func(v interface{}) error) error
• type HTTPd
  • func NewHTTPd(config HTTPdConfig) (*HTTPd, error)
  • func (s *HTTPd) Close() error
  • func (s *HTTPd) Open() error
  • func (s *HTTPd) ReadBodyFail(w http.ResponseWriter, err error)
  • func (s *HTTPd) Response(success bool, message string, data interface{}, httpCode int, ...)
  • func (s *HTTPd) Serve()
  • func (s *HTTPd) SetHandler(router *mux.Router)
  • func (s *HTTPd) UnmarshalFail(w http.ResponseWriter, err error)
  • func (s *HTTPd) ValidateFail(w http.ResponseWriter, err error)
  • func (s *HTTPd) WithLogger(logger *zap.Logger)
• type HTTPdConfig
  • func NewHTTPdConfig() HTTPdConfig
• type HttpResponse
  • func GetResponseWrapper() *HttpResponse
  • func GetResponseWrapperFromBytes(bs []byte) (*HttpResponse, error)
  • func GetResponseWrapperFromString(s string) (*HttpResponse, error)
  • func (hr *HttpResponse) Free()
  • func (hr *HttpResponse) GetData() interface{}
  • func (hr *HttpResponse) GetMessage() string
  • func (hr *HttpResponse) GetResponse() *response
  • func (hr *HttpResponse) GetSuccess() bool
  • func (hr *HttpResponse) SetData(d interface{})
  • func (hr *HttpResponse) SetMessage(m string)
  • func (hr *HttpResponse) SetSuccess(s bool)

Constants

const (
	DefaultAddr              = ":1409"
	DefaultWriteTimeout      = Duration(1000 * time.Millisecond)
	DefaultReadTimeout       = Duration(1000 * time.Millisecond)
	DefaultReadHeaderTimeout = Duration(1000 * time.Millisecond)
	DefaultIdleTimeout       = Duration(1000 * time.Millisecond)
	DefaultCloseTimeout      = Duration(5 * time.Second)
	DefaultMonitorInterval   = Duration(10 * time.Second)
)

Functions

func Bytes2String

func Bytes2String(b []byte) string

func HTTPResponse

func HTTPResponse(success bool, message string, data interface{}, httpCode int, w http.ResponseWriter) error

func NewPool

func NewPool() *sync.Pool

func String2Bytes

func String2Bytes(s string) []byte

Types

type DB

type DB struct {
	*gorm.DB
	UserName string
	Password string
	IP       string
	Port     int
	DBName   string
	Charset  string

	Logger *zap.Logger
}

func NewDB

func NewDB(UserName string, Password string, IP string, Port int, DBName string, Charset string) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) Open

func (db *DB) Open() error

type Duration

type Duration time.Duration

func (Duration) ToDuration

func (d Duration) ToDuration() time.Duration

func (Duration) UnmarshalYAML

func (d Duration) UnmarshalYAML(unmarshal func(v interface{}) error) error

type HTTPd

type HTTPd struct {
	Config HTTPdConfig

	Closing chan struct{}
	Closed  chan struct{}

	Logger *zap.Logger

	Validator *validator.Validate
	// contains filtered or unexported fields
}

func NewHTTPd

func NewHTTPd(config HTTPdConfig) (*HTTPd, error)

func (*HTTPd) Close

func (s *HTTPd) Close() error

func (*HTTPd) Open

func (s *HTTPd) Open() error

func (*HTTPd) ReadBodyFail

func (s *HTTPd) ReadBodyFail(w http.ResponseWriter, err error)

func (*HTTPd) Response

func (s *HTTPd) Response(success bool, message string, data interface{}, httpCode int, w http.ResponseWriter)

func (*HTTPd) Serve

func (s *HTTPd) Serve()

func (*HTTPd) SetHandler

func (s *HTTPd) SetHandler(router *mux.Router)

func (*HTTPd) UnmarshalFail

func (s *HTTPd) UnmarshalFail(w http.ResponseWriter, err error)

func (*HTTPd) ValidateFail

func (s *HTTPd) ValidateFail(w http.ResponseWriter, err error)

func (*HTTPd) WithLogger

func (s *HTTPd) WithLogger(logger *zap.Logger)

type HTTPdConfig

type HTTPdConfig struct {
	Addr              string   `yaml:"Addr,omitempty" mapstructure:"Addr,omitempty"`
	WriteTimeout      Duration `yaml:"WriteTimeout,omitempty" mapstructure:"WriteTimeout,omitempty"`
	ReadTimeout       Duration `yaml:"ReadTimeout,omitempty" mapstructure:"ReadTimeout,omitempty"`
	ReadHeaderTimeout Duration `yaml:"ReadHeaderTimeout,omitempty" mapstructure:"ReadHeaderTimeout,omitempty"`
	IdleTimeout       Duration `yaml:"IdleTimeout,omitempty" mapstructure:"IdleTimeout,omitempty"`
	CloseTimeout      Duration `yaml:"CloseTimeout,omitempty" mapstructure:"CloseTimeout,omitempty"`
	MonitorInterval   Duration `yaml:"MonitorInterval,omitempty" mapstructure:"MonitorInterval,omitempty"`
}

func NewHTTPdConfig

func NewHTTPdConfig() HTTPdConfig

type HttpResponse

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

func GetResponseWrapper

func GetResponseWrapper() *HttpResponse

func GetResponseWrapperFromBytes

func GetResponseWrapperFromBytes(bs []byte) (*HttpResponse, error)

func GetResponseWrapperFromString

func GetResponseWrapperFromString(s string) (*HttpResponse, error)

func (*HttpResponse) Free

func (hr *HttpResponse) Free()

func (*HttpResponse) GetData

func (hr *HttpResponse) GetData() interface{}

func (*HttpResponse) GetMessage

func (hr *HttpResponse) GetMessage() string

func (*HttpResponse) GetResponse

func (hr *HttpResponse) GetResponse() *response

func (*HttpResponse) GetSuccess

func (hr *HttpResponse) GetSuccess() bool

func (*HttpResponse) SetData

func (hr *HttpResponse) SetData(d interface{})

func (*HttpResponse) SetMessage

func (hr *HttpResponse) SetMessage(m string)

func (*HttpResponse) SetSuccess

func (hr *HttpResponse) SetSuccess(s bool)