collector

package

v1.4.1 Latest Latest Go to latest Published: Feb 27, 2023 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ds2-lab/infinistore

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Collect(handle nanolog.Handle, args ...interface{}) error
func CollectRequest(handle nanolog.Handle, e interface{}, args ...interface{}) (interface{}, error)
func Create(prefix string)
func Flush() error
func Stop()
type DataEntry

Constants ¶

View Source

const (
	LogTypeCluster      = "cluster"
	LogTypeBucketRotate = "bucket"
)

Variables ¶

View Source

var (
	Enable bool

	LogChunk        nanolog.Handle
	LogEndtoEnd     nanolog.Handle
	LogCluster      nanolog.Handle
	LogBucketRotate nanolog.Handle

	// LogRequestStart Component of LogChunk, fields: cmd, reqId, chunk, startedAt
	LogRequestStart nanolog.Handle = 10001
	// LogRequestValidation Component of LogChunk, fields: validatedAt
	LogRequestValidation nanolog.Handle = 10002
	// LogRequestFuncResponse Component of LogChunk, fields: firstByteReceivedAt, headerReceivedAt, bodyReceivedAt, recoveryFlag
	LogRequestFuncResponse nanolog.Handle = 10003
	// LogRequestProxyResponse Component of LogChunk, fields: headerSentAt, bodySentAt, allSentAt, endedAt
	LogRequestProxyResponse nanolog.Handle = 10004
	// LogRequestAbadon Abandon request log entry.
	LogRequestAbandon nanolog.Handle = 10009

	ErrUnexpectedEntry = errors.New("unexpected log entry")
)

Functions ¶

func Collect ¶

func Collect(handle nanolog.Handle, args ...interface{}) error

func CollectRequest ¶

func CollectRequest(handle nanolog.Handle, e interface{}, args ...interface{}) (interface{}, error)

func Create ¶

func Create(prefix string)

func Flush ¶

func Flush() error

func Stop ¶

func Stop()

Types ¶

type DataEntry ¶

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

Source Files ¶

View all Source files

collector.go

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