karputils

package

v0.1.2 Latest Latest Go to latest Published: Nov 17, 2025 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/thedolphin/karp

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func MessageFmt(id uint64, topic string, partition int32, offset int64) string
func SetLogLevel(level string) error
func SetupLogger()
func XdgSha256ScramClientGenerator() sarama.SCRAMClient
func XdgSha512ScramClientGenerator() sarama.SCRAMClient
type SlogGrpcLogger
- func NewSlogGrpcLogger() *SlogGrpcLogger
type XDGSCRAMClient
- func (sc *XDGSCRAMClient) Begin(userName, password, authzID string) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	LogLevel  slog.LevelVar
	LogLevels = map[string]slog.Level{
		"debug": slog.LevelDebug,
		"info":  slog.LevelInfo,
		"warn":  slog.LevelWarn,
		"error": slog.LevelError,
	}
)

Functions ¶

func MessageFmt ¶

func MessageFmt(id uint64, topic string, partition int32, offset int64) string

func SetLogLevel ¶

func SetLogLevel(level string) error

func SetupLogger ¶

func SetupLogger()

func XdgSha256ScramClientGenerator ¶

func XdgSha256ScramClientGenerator() sarama.SCRAMClient

func XdgSha512ScramClientGenerator ¶

func XdgSha512ScramClientGenerator() sarama.SCRAMClient

Types ¶

type SlogGrpcLogger ¶

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

func NewSlogGrpcLogger ¶

func NewSlogGrpcLogger() *SlogGrpcLogger

func (*SlogGrpcLogger) Error ¶

func (s *SlogGrpcLogger) Error(args ...any)

func (*SlogGrpcLogger) Errorf ¶

func (s *SlogGrpcLogger) Errorf(format string, args ...any)

func (*SlogGrpcLogger) Errorln ¶

func (s *SlogGrpcLogger) Errorln(args ...any)

func (*SlogGrpcLogger) Fatal ¶

func (s *SlogGrpcLogger) Fatal(args ...any)

func (*SlogGrpcLogger) Fatalf ¶

func (s *SlogGrpcLogger) Fatalf(format string, args ...any)

func (*SlogGrpcLogger) Fatalln ¶

func (s *SlogGrpcLogger) Fatalln(args ...any)

func (*SlogGrpcLogger) Info ¶

func (s *SlogGrpcLogger) Info(args ...any)

func (*SlogGrpcLogger) Infof ¶

func (s *SlogGrpcLogger) Infof(format string, args ...any)

func (*SlogGrpcLogger) Infoln ¶

func (s *SlogGrpcLogger) Infoln(args ...any)

func (*SlogGrpcLogger) V ¶

func (s *SlogGrpcLogger) V(l int) bool

V reports whether verbosity level l is at least the requested verbose level.

func (*SlogGrpcLogger) Warning ¶

func (s *SlogGrpcLogger) Warning(args ...any)

func (*SlogGrpcLogger) Warningf ¶

func (s *SlogGrpcLogger) Warningf(format string, args ...any)

func (*SlogGrpcLogger) Warningln ¶

func (s *SlogGrpcLogger) Warningln(args ...any)

type XDGSCRAMClient ¶

type XDGSCRAMClient struct {
	*scram.ClientConversation
	// contains filtered or unexported fields
}

func (*XDGSCRAMClient) Begin ¶

func (sc *XDGSCRAMClient) Begin(userName, password, authzID string) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL