extract

Documentation

Index

• Constants
• Variables
• func ExtractAttributes(ctx context.Context, reqHeaders api.HeaderMap, respHeaders api.HeaderMap, ...) attribute.Bag
• func RegisterAttributeGenerator(f func(s string) map[string]interface{})

Constants

const (
	// KContext const string
	KContext = "ctx"
)

Define attribute names for mosn

Variables

var Attributemanifest = map[string]attribute.Kind{

	"origin.ip":                        attribute.IP_ADDRESS,
	"origin.uid":                       attribute.STRING,
	"origin.user":                      attribute.STRING,
	"request.headers":                  attribute.STRING_MAP,
	"request.id":                       attribute.STRING,
	"request.host":                     attribute.STRING,
	"request.method":                   attribute.STRING,
	"request.path":                     attribute.STRING,
	"request.url_path":                 attribute.STRING,
	"request.query_params":             attribute.STRING_MAP,
	"request.reason":                   attribute.STRING,
	"request.referer":                  attribute.STRING,
	"request.scheme":                   attribute.STRING,
	"request.total_size":               attribute.INT64,
	"request.size":                     attribute.INT64,
	"request.time":                     attribute.TIMESTAMP,
	"request.useragent":                attribute.STRING,
	"response.code":                    attribute.INT64,
	"response.duration":                attribute.DURATION,
	"response.headers":                 attribute.STRING_MAP,
	"response.total_size":              attribute.INT64,
	"response.size":                    attribute.INT64,
	"response.time":                    attribute.TIMESTAMP,
	"response.grpc_status":             attribute.STRING,
	"response.grpc_message":            attribute.STRING,
	"source.uid":                       attribute.STRING,
	"source.user":                      attribute.STRING,
	"source.principal":                 attribute.STRING,
	"destination.uid":                  attribute.STRING,
	"destination.principal":            attribute.STRING,
	"destination.port":                 attribute.INT64,
	"connection.event":                 attribute.STRING,
	"connection.id":                    attribute.STRING,
	"connection.received.bytes":        attribute.INT64,
	"connection.received.bytes_total":  attribute.INT64,
	"connection.sent.bytes":            attribute.INT64,
	"connection.sent.bytes_total":      attribute.INT64,
	"connection.duration":              attribute.DURATION,
	"connection.mtls":                  attribute.BOOL,
	"connection.requested_server_name": attribute.STRING,
	"context.protocol":                 attribute.STRING,
	"context.proxy_error_code":         attribute.STRING,
	"context.timestamp":                attribute.TIMESTAMP,
	"context.time":                     attribute.TIMESTAMP,

	"context.reporter.local":              attribute.BOOL,
	"context.reporter.kind":               attribute.STRING,
	"context.reporter.uid":                attribute.STRING,
	"context.proxy_version":               attribute.STRING,
	"api.service":                         attribute.STRING,
	"api.version":                         attribute.STRING,
	"api.operation":                       attribute.STRING,
	"api.protocol":                        attribute.STRING,
	"request.auth.principal":              attribute.STRING,
	"request.auth.audiences":              attribute.STRING,
	"request.auth.presenter":              attribute.STRING,
	"request.auth.claims":                 attribute.STRING_MAP,
	"request.auth.raw_claims":             attribute.STRING,
	"request.api_key":                     attribute.STRING,
	"rbac.permissive.response_code":       attribute.STRING,
	"rbac.permissive.effective_policy_id": attribute.STRING,
	"check.error_code":                    attribute.INT64,
	"check.error_message":                 attribute.STRING,
	"check.cache_hit":                     attribute.BOOL,
	"quota.cache_hit":                     attribute.BOOL,

	"source.ip":                      attribute.IP_ADDRESS,
	"source.labels":                  attribute.STRING_MAP,
	"source.metadata":                attribute.STRING_MAP,
	"source.name":                    attribute.STRING,
	"source.namespace":               attribute.STRING,
	"source.owner":                   attribute.STRING,
	"source.serviceAccount":          attribute.STRING,
	"source.services":                attribute.STRING,
	"source.workload.uid":            attribute.STRING,
	"source.workload.name":           attribute.STRING,
	"source.workload.namespace":      attribute.STRING,
	"destination.ip":                 attribute.IP_ADDRESS,
	"destination.labels":             attribute.STRING_MAP,
	"destination.metadata":           attribute.STRING_MAP,
	"destination.owner":              attribute.STRING,
	"destination.name":               attribute.STRING,
	"destination.container.name":     attribute.STRING,
	"destination.namespace":          attribute.STRING,
	"destination.service.uid":        attribute.STRING,
	"destination.service.name":       attribute.STRING,
	"destination.service.namespace":  attribute.STRING,
	"destination.service.host":       attribute.STRING,
	"destination.serviceAccount":     attribute.STRING,
	"destination.workload.uid":       attribute.STRING,
	"destination.workload.name":      attribute.STRING,
	"destination.workload.namespace": attribute.STRING,

	KContext: attribute.MOSN_CTX,
}

Functions

func ExtractAttributes

func ExtractAttributes(ctx context.Context, reqHeaders api.HeaderMap, respHeaders api.HeaderMap, requestInfo api.RequestInfo, buf buffer.IoBuffer, trailers api.HeaderMap, now time.Time) attribute.Bag

func RegisterAttributeGenerator

func RegisterAttributeGenerator(f func(s string) map[string]interface{})