( ctx context.Context, credentials agentidentity.Credentials, )
| 5084 | } |
| 5085 | |
| 5086 | func (c *unixSocketClient) AgentChannels( |
| 5087 | ctx context.Context, |
| 5088 | credentials agentidentity.Credentials, |
| 5089 | ) ([]AgentChannelRecord, error) { |
| 5090 | var response contract.AgentChannelsResponse |
| 5091 | if err := c.doAgentJSON(ctx, http.MethodGet, "/api/agent/channels", nil, nil, credentials, &response); err != nil { |
| 5092 | return nil, err |
| 5093 | } |
| 5094 | return response.Channels, nil |
| 5095 | } |
| 5096 | |
| 5097 | func (c *unixSocketClient) AgentChannelRecv( |
| 5098 | ctx context.Context, |