utils

Documentation

Index

• func BytesToUint64(bytes []byte) uint64
• func MarshalToReader(s any) (io.Reader, error)
• func MetricsHandler() http.Handler
• func NewWorkerContext(processorCtx context.Context, workerIndex int, processorName string, ...) context.Context
• func NewWorkerId(workerIndex int, processorName string, topicName string) string
• func SafeJsonIndent(s any) string
• func Uint64ToBytes(num uint64) []byte
• func WorkerId(ctx context.Context) (string, bool)
• func WorkerIndex(ctx context.Context) (string, bool)
• type MetricsClient
  • func NewMetricsClient(processorName string) *MetricsClient
  • func (m *MetricsClient) EmitCounter(name string, help string, val float64) error

Functions

func BytesToUint64

func BytesToUint64(bytes []byte) uint64

func MarshalToReader

func MarshalToReader(s any) (io.Reader, error)

MarshalToReader transforms a struct to io.Reader.

func MetricsHandler

func MetricsHandler() http.Handler

func NewWorkerContext

func NewWorkerContext(processorCtx context.Context, workerIndex int, processorName string,
	topicName string) context.Context

func NewWorkerId

func NewWorkerId(workerIndex int, processorName string, topicName string) string

func SafeJsonIndent

func SafeJsonIndent(s any) string

func Uint64ToBytes

func Uint64ToBytes(num uint64) []byte

func WorkerId

func WorkerId(ctx context.Context) (string, bool)

func WorkerIndex

func WorkerIndex(ctx context.Context) (string, bool)

Types

type MetricsClient

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

func NewMetricsClient

func NewMetricsClient(processorName string) *MetricsClient

func (*MetricsClient) EmitCounter

func (m *MetricsClient) EmitCounter(name string, help string, val float64) error