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 IsPathExist(path string) bool
• func JoinStringAny(sep string, a ...fmt.Stringer) string
• func MaxInt(a, b int) int
• func MinInt(a, b int) int
• 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 IsPathExist

func IsPathExist(path string) 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 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)