Documentation
¶
Index ¶
- func BatchId(ctx context.Context, watermark int64) string
- func BatchIdFromWorkerId(workerId string, watermark int64) string
- func BytesToUint64(bytes []byte) uint64
- func MarshalToReader(s any) (io.Reader, error)
- func MetricsHandler() http.Handler
- func NewRecordId() fmt.Stringer
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchIdFromWorkerId ¶ added in v0.5.1
func BytesToUint64 ¶
func MarshalToReader ¶
MarshalToReader transforms a struct to io.Reader.
func MetricsHandler ¶
func NewRecordId ¶ added in v0.5.1
func NewWorkerContext ¶
func SafeJsonIndent ¶
func Uint64ToBytes ¶
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
func (*MetricsClient) EmitHistogram ¶ added in v0.5.21
func (m *MetricsClient) EmitHistogram(name string, help string, val float64) error
Source Files
Click to show internal directories.
Click to hide internal directories.