| 2001 | } |
| 2002 | |
| 2003 | func (c *unixSocketClient) NetworkThreads( |
| 2004 | ctx context.Context, |
| 2005 | query NetworkThreadsQuery, |
| 2006 | ) ([]NetworkThreadRecord, error) { |
| 2007 | channel, err := requireNetworkPathValue("channel", query.Channel) |
| 2008 | if err != nil { |
| 2009 | return nil, err |
| 2010 | } |
| 2011 | var response struct { |
| 2012 | Threads []NetworkThreadRecord `json:"threads"` |
| 2013 | } |
| 2014 | path, err := networkChannelPath(query.WorkspaceRef, channel) |
| 2015 | if err != nil { |
| 2016 | return nil, err |
| 2017 | } |
| 2018 | path += "/threads" |
| 2019 | if err := c.doJSON(ctx, http.MethodGet, path, networkThreadsValues(query), nil, &response); err != nil { |
| 2020 | return nil, err |
| 2021 | } |
| 2022 | return response.Threads, nil |
| 2023 | } |
| 2024 | |
| 2025 | func (c *unixSocketClient) NetworkThread( |
| 2026 | ctx context.Context, |