问题[go](coding)

关于程序：我正在尝试通过我自己的一流类型实现管道intJob模式。聚合管道的主要功能正是ExecutePipeline2它导致了问题。

为什么我总是遇到死锁？对我来说，我似乎在每个 goroutine 之后都关闭了所有读者使用的通道。另外，创建带缓冲区的通道也无济于事，所以我完全没有主意了，非常感谢你的帮助。

重要提示main：当基础（提到的功能）保持不变时，我无法更改功能并仅从其他功能实现这个想法。

type intJob func(a, b chan int)

func ExecutePipeline2(jobs ...intJob) {
    outs := make([]chan int, len(jobs)+1)
    wg := sync.WaitGroup{}

    for i := 0; i < len(outs); i++ {
        outs[i] = make(chan int)
    }

    for i, job := range jobs {
        job := job
        in, out := outs[i], outs[i+1]
        i := i
        wg.Add(1)
        go func() {
            job(in, out)
            fmt.Printf("job %d closed\n", i)
            close(out)
            wg.Done()
        }()
    }

    wg.Wait()
}

func pipe(_, b chan int) {
    for i := 0; i < 5; i++ {
        b <- i
    }
}

func main() {
    inputData := []int{0, 1, 1, 2, 3, 5, 8}

    hashSignJobs := []intJob{
        intJob(func(in, out chan int) {
            for _, fibNum := range inputData {
                out <- fibNum
            }
        }),
        intJob(pipe),
        intJob(func(in, out chan int) {
            for val := range in {
                fmt.Println(val)
            }
        }),
    }

    ExecutePipeline2(hashSignJobs...)
}

问题

当前问题是Golang 中func() Foo无法分配类型的函数func() any。也许这是一个 XY 问题，所以我将解释为什么我处于这种情况。

例子

我本质上有类似健康检查包的东西（为了简单起见，这是一个简化的模型）：

//package: internal/health
type Check struct {
    Name  string
    Func func() (metadata any, err error)
}

type Manager struct {
    checks []Check
}

func (m *Manager) RegisterCheck(check Check) {
    m.checks = append(m.checks , check)
}

func (m *Manager) PrintHealth() {
    for _, check := m.checks {
        output, _ := check.Func()
        slog.Info("Health", slog.Any("output", output))
        // In the actual implementation, I aggregate the checks and JSONify them
    }
}

然后也许我有另一个包，其中包含我想要添加到检查的方法：

//package: internal/service
type Foo struct {}

func (f Foo) Health() (string, error) {
    return "baz", nil
}

type Bar struct {}

func (b Bar) Health() (map[string]int, error) {
    return map[string]int{"qux": 1} , nil
}

//package: cmd/app
func main() {
    foo := service.Foo{}
    bar := service.Bar{}

    h := health.Manager{}
    h.RegisterCheck(health.Check{
        Name: "Foo",
        Func: foo.Health, // This is where the type error occurs
    })
    h.RegisterCheck(health.Check{
        Name: "Bar",
        Func: bar.Health, // This is where the type error occurs
    })
}

我尝试过/考虑过什么？

• 将类型参数添加Manager到Check
  • 问题？Manager将只能添加特定类型的检查，这意味着Foo和Bar将无法添加到同一个Manager，这实际上是由整个应用程序共享的。
• 将类型参数添加RegisterCheck到Check
  • 问题？Golang 不支持方法的类型参数。

查看 gobyexample.com 的示例：https://gobyexample.com/timers

timer2 := time.NewTimer(time.Second)
go func() {
    <-timer2.C
    fmt.Println("Timer 2 fired")
}()
stop2 := timer2.Stop()
if stop2 {
    fmt.Println("Timer 2 stopped")
}

问题：停止后计时器会go func()永远卡住吗？如果是，处理这种情况的正确方法是什么？

我正在尝试使用 go-playground/validator/v10 包验证 Golang 中的结构字段。具体来说，我想使用 oneof 标签来验证字段值是否与预定义值之一匹配，其中包括带单引号 (') 的字符串。这是我使用的代码：

package main

import (
    "fmt"

    "github.com/go-playground/validator/v10"
)

// Struct with validation tag
type Award struct {
    Title string `validate:"oneof=palm'dor level'dor 'state award'"`
}

func main() {
    validate := validator.New()

    // Test cases
    testCases := []Award{
        {"palm'dor"},    // Expected: Valid
        {"level'dor"},   // Expected: Valid
        {"state award"}, // Expected: Valid
        {"other"},       // Expected: Invalid
    }

    for _, testCase := range testCases {
        err := validate.Struct(testCase)
        if err != nil {
            fmt.Printf("Input: %q - Invalid (%v)\n", testCase.Title, err)
        } else {
            fmt.Printf("Input: %q - Valid\n", testCase.Title)
        }
    }
}

预期行为：程序应验证“palm'dor”、“level'dor”和“state award”是否为有效输入。任何其他值都应标记为无效。

问题：当我运行该程序时，我得到以下输出：

Input: "palm'dor" - Invalid (Key: 'Award.Title' Error:Field validation for 'Title' failed on the 'oneof' tag)
Input: "level'dor" - Invalid (Key: 'Award.Title' Error:Field validation for 'Title' failed on the 'oneof' tag)
Input: "state award" - Valid
Input: "other" - Invalid (Key: 'Award.Title' Error:Field validation for 'Title' failed on the 'oneof' tag)

我正在尝试构建一个程序，从 JSON 中提取数据并将其放入自定义结构中。JSON 包含“foo\u00a0”之类的键，因此我不能只使用Unmarshal。我尝试使用结构标记，它对于“常规”标记完美无缺，但当我使用类似 的格式时却不行\u...。

我尝试过这个：

package main

import (
        "encoding/json"
        "fmt"
)

type MyStruct struct {
        x string `json:"foobar\u0062"`
        Name string `json:"Username"`
}

func main() {
        data := []byte(`{"foobar\u0062": "some value", "Username": "xxx"}`)

        var ms MyStruct
        err := json.Unmarshal(data, &ms)
        if err != nil {
                panic(err)
        }

        fmt.Println(ms.x)
        fmt.Println(ms.Name)
}

在上面的例子中，UsernameJSON 中的 key 可以通过Namestruct 的字段访问ms。但 key 却不能foobar\u0062。

为什么？我怎样才能获得 的值foobar\u0062（在这种情况下是“某个值”）？

我很少在 Stack Overflow 上提问，但这次我却陷入了困境。

TLDR我需要知道它channel.Close()是如何golang.org/x/crypto/ssh工作的以及我应该在哪里调用它（假设这是我需要的）。

我正在编写一个“小”程序来自动同步我的 Git 存储库，包括存储、额外文件等。我使用go-ssh来处理服务器上最重要的部分。该项目的当前状态可以在 GitHub 上找到

我试图将其缩小到一个简单的示例。这是我从Golang 存储库中的官方示例中调整的少数内容之一。我删除了terminal引用，并使其明确处理（随机）命令：

go func(in <-chan *ssh.Request) {
    for req := range in {
        switch req.Type {
        case "exec":
            channel.Stderr().Write([]byte("Request received!\n"))
            req.Reply(true, nil)
            // Do some more work here
            channel.Close() // ???
        default:
            req.Reply(false, nil)
        }
    }
    wg.Done()
}(requests)

要点在这里。这里还有另一个来自其他人的例子。

每当我尝试连接类似ssh localhost -T -vvvv -p 2022 git-receive-pack foo示例的内容时，我都会得到以下信息：

Authenticated to localhost ([::1]:2022) using "publickey".
debug1: channel 0: new session [client-session] (inactive timeout: 0)
debug3: ssh_session2_open: channel_new: 0
debug2: channel 0: send open
debug3: send packet: type 90
debug1: Entering interactive session.
debug1: pledge: filesystem
debug3: client_repledge: enter
debug3: receive packet: type 91
debug2: channel_input_open_confirmation: channel 0: callback start
debug2: fd 3 setting TCP_NODELAY
debug3: set_sock_tos: set socket 3 IPV6_TCLASS 0x20
debug2: client_session2_setup: id 0
debug1: Sending command: git-receive-pack foo
debug2: channel 0: request exec confirm 1
debug3: send packet: type 98
debug3: client_repledge: enter
debug2: channel_input_open_confirmation: channel 0: callback done
debug2: channel 0: open confirm rwindow 2097152 rmax 32768
debug2: channel 0: rcvd ext data 6
debug3: receive packet: type 99
debug2: channel_input_status_confirm: type 99 id 0
debug2: exec request accepted on channel 0
debug3: receive packet: type 97
debug2: channel 0: rcvd close
debug2: channel 0: output open -> drain
debug2: chan_shutdown_read: channel 0: (i0 o1 sock -1 wfd 4 efd 6 [write])
debug2: channel 0: input open -> closed
debug3: channel 0: will not send data after close
debug2: channel 0: obuf_empty delayed efd 6/(6)
Request received!
debug2: channel 0: written 6 to efd 6
debug3: channel 0: will not send data after close
debug2: channel 0: obuf empty
debug2: chan_shutdown_write: channel 0: (i3 o1 sock -1 wfd 5 efd 6 [write])
debug2: channel 0: output drain -> closed
debug2: channel 0: almost dead
debug2: channel 0: gc: notify user
debug2: channel 0: gc: user detached
debug2: channel 0: send_close2
debug2: channel 0: send close for remote id 0
debug3: send packet: type 97
debug2: channel 0: is dead
debug2: channel 0: garbage collecting
debug1: channel 0: free: client-session, nchannels 1
debug3: channel 0: status: The following connections are open:
  #0 client-session (t4 [session] r0 nm0 i3/0 o3/0 e[write]/0 fd -1/-1/6 sock -1 cc -1 nc0 io 0x00/0x00)

debug3: send packet: type 1
Transferred: sent 3624, received 2892 bytes, in 0.0 seconds
Bytes per second: sent 3203530.2, received 2556459.6
debug1: Exit status -1

在我的个人项目中，也会出现“破管”的情况。

有谁知道如何解决这个问题？

因此，我成功地从 Admin API 读取了分页的用户列表。我可以看到NextPageToken以及第一页结果。但返回的UsersListCall对象中似乎没有任何内容可供我迭代？没有地方可以指定下一页令牌，就像我们对 HTTP 样式调用所做的那样。有人可以提示我从哪里开始迭代这些页面吗？

    adminService, err := admin.NewService(ctx,
        option.WithCredentials(credentials),
    )
    [...]
    users, err := adminService.Users.List().Customer("my_customer").Do()
    if err != nil {
        if e, ok := err.(*googleapi.Error); ok {
            fmt.Printf("Error code: %v\n", e.Code)
            fmt.Printf("Message: %v\n", e.Message)
        } else {
            fmt.Printf("Error: %v\n", err)
        }
        os.Exit(1)
    }

    fmt.Printf("token: %s\n", users.NextPageToken)

    for _, user := range users.Users {
        fmt.Printf("User: %s (%s)\n", user.Name.FullName, user.PrimaryEmail)
    }

目录结构：

src
    go.mod
    lib/migrate
        migrate.go
        /driver/source
            local.go

我试图像这样local导入：migrate.go

package migrate

import (
    local "app/lib/migrate/driver/source/local"
)

type Migrate struct {
}

我收到此错误：

could not import app/lib/migrate/driver/source/local (no required module provides package "app/lib/migrate/driver/source/local")

我检查了以下项目：

1. go.mod 声明module app
2. local.go 声明package local
3. 转到环境-w GO111MODULE=on

我正在学习 Go 的内存管理和垃圾收集，当指针指向的变量超出范围后尝试取消引用指针时遇到了一些意外行为。

在 Go 中，我知道垃圾回收 (GC) 是自动的，并且指针有时会引用不再有效的内存。我预计取消引用指向范围外变量的指针会引发错误，但 Go 似乎不会在这样做时引发错误

这是一个演示该问题的最小示例：

package main

import (
    "fmt"
    "runtime"
)

func main() {
    var p *int
    {
        x := 42
        p = &x  // p points to x
        fmt.Println(*p) // Prints 42
    }

    // Force garbage collection (for testing)
    runtime.GC()

    // Dereferencing p here should cause an error (since x is out of scope)
    fmt.Println(*p) // This does NOT throw any error
}

我的预期是：

• 我预计在 x 超出范围的内部块之后，指针 p 将成为一个“悬垂指针”，并且在取消引用时会立即导致运行时错误。
• 我预期的错误是这样的：运行时：无效的内存地址或空指针取消引用。

实际情况：

• 即使在强制垃圾回收后，程序在取消引用 *p 时也不会崩溃或抛出错误。即使 x 超出范围，打印的值仍然是 x 的地址。

如何使用变量的值来引用 Go 模板中的另一个变量？

模板：

Hello, {{ index $.planet }}!

数据：

{ 
"planet": "neptune",
"planet_field": "planet"
}

我需要在模板中使用planet_field而不是打印。planetneptune

注意：我无法更改我的数据结构，用例是仅通过标签获取数据的 Prometheus 警报模板。

我正在这个网站上测试：gotemplate.io（将上面的模板/数据复制/粘贴到该网站）。