info

Documentation

Index

• Constants
• Variables
• func Get(i AccessInfo, keys ...string) []any
• type AccessInfo
• type BaseResponse
• type GrpcAccessInfo
  • func NewGrpcAccessInfo(ctx context.Context, grpcInfo *grpc.UnaryServerInfo, req interface{}) *GrpcAccessInfo
  • func (i *GrpcAccessInfo) Address() string
  • func (i *GrpcAccessInfo) ClusterPrefix() string
  • func (i *GrpcAccessInfo) CollectionName() string
  • func (i *GrpcAccessInfo) DbName() string
  • func (i *GrpcAccessInfo) ErrorCode() string
  • func (i *GrpcAccessInfo) ErrorMsg() string
  • func (i *GrpcAccessInfo) Expression() string
  • func (i *GrpcAccessInfo) MethodName() string
  • func (i *GrpcAccessInfo) MethodStatus() string
  • func (i *GrpcAccessInfo) OutputFields() string
  • func (i *GrpcAccessInfo) PartitionName() string
  • func (i *GrpcAccessInfo) ResponseSize() string
  • func (i *GrpcAccessInfo) SdkVersion() string
  • func (i *GrpcAccessInfo) SetResult(resp interface{}, err error)
  • func (i *GrpcAccessInfo) TimeCost() string
  • func (i *GrpcAccessInfo) TimeEnd() string
  • func (i *GrpcAccessInfo) TimeNow() string
  • func (i *GrpcAccessInfo) TimeStart() string
  • func (i *GrpcAccessInfo) TraceID() string
  • func (i *GrpcAccessInfo) UpdateCtx(ctx context.Context)
  • func (i *GrpcAccessInfo) UserName() string
• type SizeResponse

Constants

const (
	Unknown = "Unknown"

	ClientRequestIDKey = "client_request_id"
)

Variables

var ClusterPrefix atomic.String

var MetricFuncMap = map[string]getMetricFunc{
	"$method_name":     getMethodName,
	"$method_status":   getMethodStatus,
	"$trace_id":        getTraceID,
	"$user_addr":       getAddr,
	"$user_name":       getUserName,
	"$response_size":   getResponseSize,
	"$error_code":      getErrorCode,
	"$error_msg":       getErrorMsg,
	"$database_name":   getDbName,
	"$collection_name": getCollectionName,
	"$partition_name":  getPartitionName,
	"$time_cost":       getTimeCost,
	"$time_now":        getTimeNow,
	"$time_start":      getTimeStart,
	"$time_end":        getTimeEnd,
	"$method_expr":     getExpr,
	"$output_fields":   getOutputFields,
	"$sdk_version":     getSdkVersion,
	"$cluster_prefix":  getClusterPrefix,
}

supported metrics

Functions

func Get

func Get(i AccessInfo, keys ...string) []any

Types

type AccessInfo

type AccessInfo interface {
	TimeCost() string
	TimeNow() string
	TimeStart() string
	TimeEnd() string
	MethodName() string
	Address() string
	TraceID() string
	MethodStatus() string
	UserName() string
	ResponseSize() string
	ErrorCode() string
	ErrorMsg() string
	DbName() string
	CollectionName() string
	PartitionName() string
	Expression() string
	OutputFields() string
	SdkVersion() string
}

type BaseResponse

type BaseResponse interface {
	GetStatus() *commonpb.Status
}

type GrpcAccessInfo

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

func NewGrpcAccessInfo

func NewGrpcAccessInfo(ctx context.Context, grpcInfo *grpc.UnaryServerInfo, req interface{}) *GrpcAccessInfo

func (*GrpcAccessInfo) Address

func (i *GrpcAccessInfo) Address() string

func (*GrpcAccessInfo) ClusterPrefix

func (i *GrpcAccessInfo) ClusterPrefix() string

func (*GrpcAccessInfo) CollectionName

func (i *GrpcAccessInfo) CollectionName() string

func (*GrpcAccessInfo) DbName

func (i *GrpcAccessInfo) DbName() string

func (*GrpcAccessInfo) ErrorCode

func (i *GrpcAccessInfo) ErrorCode() string

func (*GrpcAccessInfo) ErrorMsg

func (i *GrpcAccessInfo) ErrorMsg() string

func (*GrpcAccessInfo) Expression

func (i *GrpcAccessInfo) Expression() string

func (*GrpcAccessInfo) MethodName

func (i *GrpcAccessInfo) MethodName() string

func (*GrpcAccessInfo) MethodStatus

func (i *GrpcAccessInfo) MethodStatus() string

func (*GrpcAccessInfo) OutputFields

func (i *GrpcAccessInfo) OutputFields() string

func (*GrpcAccessInfo) PartitionName

func (i *GrpcAccessInfo) PartitionName() string

func (*GrpcAccessInfo) ResponseSize

func (i *GrpcAccessInfo) ResponseSize() string

func (*GrpcAccessInfo) SdkVersion

func (i *GrpcAccessInfo) SdkVersion() string

func (*GrpcAccessInfo) SetResult

func (i *GrpcAccessInfo) SetResult(resp interface{}, err error)

func (*GrpcAccessInfo) TimeCost

func (i *GrpcAccessInfo) TimeCost() string

func (*GrpcAccessInfo) TimeEnd

func (i *GrpcAccessInfo) TimeEnd() string

func (*GrpcAccessInfo) TimeNow

func (i *GrpcAccessInfo) TimeNow() string

func (*GrpcAccessInfo) TimeStart

func (i *GrpcAccessInfo) TimeStart() string

func (*GrpcAccessInfo) TraceID

func (i *GrpcAccessInfo) TraceID() string

func (*GrpcAccessInfo) UpdateCtx

func (i *GrpcAccessInfo) UpdateCtx(ctx context.Context)

update context for more info

func (*GrpcAccessInfo) UserName

func (i *GrpcAccessInfo) UserName() string

type SizeResponse

type SizeResponse interface {
	XXX_Size() int
}