utils

Documentation

Index

• func CloseLogErrZap(closer io.Closer, logger *zap.Logger)
• func DistinctStringSlice(s []string) []string
• func Dos2UnixWriter(w io.Writer) io.WriteCloser
• func InStringSlice(slice []string, s string) bool
• func IsDir(path string) bool
• func IsFile(path string) bool
• func IsHttpTimeout(e error) bool
• func IsPathExist(path string) bool
• func IsTlsCertError(e error) bool
• func JoinStringAny(sep string, a ...fmt.Stringer) string
• func MaxInt(a, b int) int
• func MinInt(a, b int) int
• func NewNoCrlfWriter(w io.Writer) io.WriteCloser
• func ReadFileLimited(p string, maxRead int64) ([]byte, error)
• func Reverse[S ~[]E, E any](s S)
• func Unix2DosWriter(w io.Writer) io.WriteCloser
• func UseLogger(ctx context.Context) *zap.Logger
• func WithLogger(ctx context.Context, logger *zap.Logger) context.Context
• type LogPipe
  • func NewLogPipe(logger *zap.Logger, prefix string) *LogPipe
  • func (l *LogPipe) Close() error
  • func (l *LogPipe) Write(data []byte) (int, error)
• type SuffixBuffer
  • func MkSuffixBuffer(capacity int) *SuffixBuffer
  • func (r *SuffixBuffer) Bytes() (rs []byte)
  • func (r *SuffixBuffer) Write(data []byte) (int, error)

Functions

func CloseLogErrZap

func CloseLogErrZap(closer io.Closer, logger *zap.Logger)

func DistinctStringSlice

func DistinctStringSlice(s []string) []string

func Dos2UnixWriter

func Dos2UnixWriter(w io.Writer) io.WriteCloser

func InStringSlice

func InStringSlice(slice []string, s string) bool

func IsDir

func IsDir(path string) bool

func IsFile

func IsFile(path string) bool

func IsHttpTimeout

func IsHttpTimeout(e error) bool

func IsPathExist

func IsPathExist(path string) bool

func IsTlsCertError

func IsTlsCertError(e error) bool

func JoinStringAny

func JoinStringAny(sep string, a ...fmt.Stringer) string

func MaxInt

func MaxInt(a, b int) int

func MinInt

func MinInt(a, b int) int

func NewNoCrlfWriter

func NewNoCrlfWriter(w io.Writer) io.WriteCloser

func ReadFileLimited

func ReadFileLimited(p string, maxRead int64) ([]byte, error)

func Reverse

func Reverse[S ~[]E, E any](s S)

func Unix2DosWriter

func Unix2DosWriter(w io.Writer) io.WriteCloser

func UseLogger

func UseLogger(ctx context.Context) *zap.Logger

UseLogger returns *zap.Logger in the context. If no Logger exists, returns zap.NewNop()

func WithLogger

func WithLogger(ctx context.Context, logger *zap.Logger) context.Context

Types

type LogPipe

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

func NewLogPipe

func NewLogPipe(logger *zap.Logger, prefix string) *LogPipe

func (*LogPipe) Close

func (l *LogPipe) Close() error

func (*LogPipe) Write

func (l *LogPipe) Write(data []byte) (int, error)

type SuffixBuffer

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

func MkSuffixBuffer

func MkSuffixBuffer(capacity int) *SuffixBuffer

func (*SuffixBuffer) Bytes

func (r *SuffixBuffer) Bytes() (rs []byte)

func (*SuffixBuffer) Write

func (r *SuffixBuffer) Write(data []byte) (int, error)