(ctx context.Context, workspaceAgentID uuid.UUID, m agentsdk.LogsNotifyMessage)
| 3036 | } |
| 3037 | |
| 3038 | func (api *API) publishWorkspaceAgentLogsUpdate(ctx context.Context, workspaceAgentID uuid.UUID, m agentsdk.LogsNotifyMessage) { |
| 3039 | b, err := json.Marshal(m) |
| 3040 | if err != nil { |
| 3041 | api.Logger.Warn(ctx, "failed to marshal logs notify message", slog.F("workspace_agent_id", workspaceAgentID), slog.Error(err)) |
| 3042 | } |
| 3043 | err = api.Pubsub.Publish(agentsdk.LogsNotifyChannel(workspaceAgentID), b) |
| 3044 | if err != nil { |
| 3045 | api.Logger.Warn(ctx, "failed to publish workspace agent logs update", slog.F("workspace_agent_id", workspaceAgentID), slog.Error(err)) |
| 3046 | } |
| 3047 | } |
| 3048 | |
| 3049 | type WorkspaceACLUpdateValidator codersdk.UpdateWorkspaceACL |
| 3050 |
no test coverage detected