Function grpcStreamUpResource

pkg/ratelimit/resource.go:116–121

grpcStreamUpResource represents client messages for a gRPC server stream.

(ctx context.Context, fullMethod string)

// grpcStreamUpResource represents client messages for a gRPC server stream.
func grpcStreamUpResource(ctx context.Context, fullMethod string) Resource {
	return &resource{
		key:     fmt.Sprintf("grpc:stream:up:%s:id:%s", fullMethod, events.NewCorrelationID()),
		classes: []string{fmt.Sprintf("grpc:stream:up:%s", fullMethod), "grpc:stream:up"},
	}
}

// GatewayUpResource represents uplink traffic from a gateway.
func GatewayUpResource(ctx context.Context, ids *ttnpb.GatewayIdentifiers) Resource {