Products

中文

中文

Pipy 文档

Introduction

概述
概念

Getting Started

构建和安装
快速入门
获取帮助

Release

发布历史

0.10.0-1
0.22.0-31
0.30.0
0.50.0

Tutorial

01 你好
02 回显
03 代理
04 路由
05 负载均衡
06 配置
07 插件

Operating

开发控制台
CLI
Pipy Repo

介绍
快速开始
演示
REST API

Reference

API

Configuration

Data

from()
Data()
push()
shift()
shiftTo()
shiftWhile()
size
toArray()

Hessian

decode()
encode()

JSON

decode()
encode()
parse()
stringify()

Message

body
head
Message()
tail

MessageEnd

MessageEnd()
payload
tail

MessageStart

head
MessageStart()

Netmask

base
bitmask
broadcast
contains()
decompose()
first
hostmask
ip
last
mask
Netmask()
next()
size
version

StreamEnd

error
StreamEnd()

URL

auth
hash
host
hostname
href
URL()
origin
password
path
pathname
port
protocol
query
search
searchParams
username

URLSearchParams

get()
getAll()
URLSearchParams()
set()
toObject()

XML

Node

attributes
children
name
Node()

decode()
encode()
parse()
stringify()

algo

Cache

clear()
get()
Cache()
remove()
set()

HashingLoadBalancer

add()
HashingLoadBalancer()
next()

LeastWorkLoadBalancer

LeastWorkLoadBalancer()
next()
set()

LoadBalancer

allocate()
LoadBalancer()
provision()
schedule()

LoadBalancerResource

free()
target

Quota

consume()
current
initial
Quota()
produce()
reset()

RoundRobinLoadBalancer

RoundRobinLoadBalancer()
next()
set()

URLRouter

add()
find()
URLRouter()

hash()
uuid()

console

debug()
error()
info()
log()
warn()

crypto

Certificate

issuer
Certificate()
subject
subjectAltNames

CertificateChain

CertificateChain()

Cipher

final()
Cipher()
update()

Decipher

final()
Decipher()
update()

Hash

digest()
Hash()
update()

Hmac

digest()
Hmac()
update()

JWK

isValid
JWK()

JWT

header
isValid
JWT()
payload
verify()

PrivateKey

PrivateKey()

PublicKey

PublicKey()

Sign

Sign()
sign()
update()

Verify

Verify()
update()
verify()

http

Agent

new()
request()

Directory

new()
serve()

logging

BinaryLogger

log()
BinaryLogger()
toFile()
toHTTP()
toStderr()
toStdout()
toSyslog()

JSONLogger

log()
JSONLogger()
toFile()
toHTTP()
toStderr()
toStdout()
toSyslog()

TextLogger

log()
TextLogger()
toFile()
toHTTP()
toStderr()
toStdout()
toSyslog()

os

env
readDir()
readFile()
stat()
unlink()
writeFile()

pipy()

exit()
load()
restart()
solve()

stats

Counter

decrease()
increase()
Counter()
withLabels()
zero()

Gauge

decrease()
increase()
Gauge()
set()
withLabels()
zero()

Histogram

Histogram()
observe()
withLabels()
zero()

Configuration.tee()

Description

Appends a tee filter to the current pipeline layout.

A tee filter writes input Data to a file.

INPUT - Any types of Events.
OUTPUT - Same Events as the input.

This filter resembles what the Unix command tee does. The pathname of the output file is specified in the first parameter. It is expected to be a string or a function that returns a string. Use "-" for writing to the standard output.

When outputting to the standard output, this filter is different from print() in that, the output does not go to the logging system so won't be visible on the Admin GUI.

The content of the output file will be erased before writing. If the output file does not exist yet, it will be created. The directories containing the file are also created if not exist. Make sure the process has required privileges to create and write to the file and the directories.

This filter passes everything down unaltered. It doesn't change anything in the event stream. Only Data events are written to the output file as a continuous byte stream.

Syntax

pipy()
  .pipeline()
  .tee(filename)

pipy()
  .pipeline()
  .tee(() => getFilename())

Parameters

tee(filename)

filename

Pathname of the file to write to.

Return Value

The same Configuration object.

See Also

Products

© 2024, Flomesh Team. ICP备案/许可证号：辽ICP备2023014827号