| /dports/net/traefik/traefik-2.6.1/pkg/tcp/ |
| H A D | handler.go | 9 ServeTCP(conn WriteCloser)
17 func (f HandlerFunc) ServeTCP(conn WriteCloser) {
22 type WriteCloser interface { interface
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-msgio/ |
| H A D | msgio_test.go | 89 func SubtestReadWrite(t *testing.T, writer WriteCloser, reader ReadCloser) {
133 func SubtestReadWriteMsg(t *testing.T, writer WriteCloser, reader ReadCloser) {
172 func SubtestReadWriteMsgSync(t *testing.T, writer WriteCloser, reader ReadCloser) {
253 func SubtestReadClose(t *testing.T, writer WriteCloser, reader ReadCloser) {
270 func SubtestWriteClose(t *testing.T, writer WriteCloser, reader ReadCloser) {
304 func SubtestReadShortBuffer(t *testing.T, writer WriteCloser, reader ReadCloser) {
|
| /dports/security/gopass/gopass-1.13.0/internal/updater/ |
| H A D | extract.go | 57 func extractZip(buf []byte, dfh io.WriteCloser, dest string) error {
87 func extractTar(rd io.Reader, dfh io.WriteCloser, dest string) error {
|
| /dports/security/keybase/client-v5.7.1/go/libkb/ |
| H A D | saltpack_sign.go | 19 func SaltpackSign(g *GlobalContext, source io.ReadCloser, sink io.WriteCloser, key NaclSigningKeyPa…
33 func SaltpackSignDetached(g *GlobalContext, source io.ReadCloser, sink io.WriteCloser, key NaclSign…
47 func saltpackSign(g *GlobalContext, source io.ReadCloser, sink io.WriteCloser, key NaclSigningKeyPa…
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/drivers/mock/ |
| H A D | command.go | 14 func runCommand(c Command, stdout, stderr io.WriteCloser, cancelCh <-chan struct{}, pluginExitTimer…
64 func runCommandOutput(writer io.WriteCloser,
|
| /dports/sysutils/nomad/nomad-1.1.0/drivers/mock/ |
| H A D | command.go | 14 func runCommand(c Command, stdout, stderr io.WriteCloser, cancelCh <-chan struct{}, pluginExitTimer…
64 func runCommandOutput(writer io.WriteCloser,
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | invoke.go | 145 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
171 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | invoke.go | 145 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
171 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | invoke.go | 145 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
171 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/serf/serf-0.7.0/command/agent/ |
| H A D | invoke.go | 144 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
170 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | invoke.go | 145 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
171 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | invoke.go | 145 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
171 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/serf/command/agent/ |
| H A D | invoke.go | 144 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
170 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/sysutils/serf/serf-0.8.5/cmd/serf/command/agent/ |
| H A D | invoke.go | 145 func memberEventStdin(logger *log.Logger, stdin io.WriteCloser, e *serf.MemberEvent) {
171 func streamPayload(logger *log.Logger, stdin io.WriteCloser, buf []byte) {
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 128 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
143 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/net/concourse-fly/concourse-6.7.1/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 140 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
155 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 128 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
143 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/Microsoft/hcsshim/test/vendor/github.com/containerd/containerd/cio/ |
| H A D | io_windows.go | 128 func NewDirectIO(stdin io.WriteCloser, stdout, stderr io.ReadCloser, terminal bool) *DirectIO {
143 func NewDirectIOFromFIFOSet(ctx context.Context, stdin io.WriteCloser, stdout, stderr io.ReadCloser…
|