Update Coordinator client, add datagram assembly.

logdog/client/cmd/logdog_cat/subcommandQuery.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package main
 
 import (
         "bufio"
         "encoding/json"
         "io"
@@ skipping 204 matching lines @@
                 Updated          clockflag.Time `json:"updated,omitempty"`
                 TerminalIndex    int64          `json:"terminalIndex"`
                 ArchiveIndexURL  string         `json:"archiveIndexUrl,omitempty"`
                 ArchiveStreamURL string         `json:"archiveStreamUrl,omitempty"`
                 ArchiveDataURL   string         `json:"archiveDataUrl,omitempty"`
                 Purged           bool           `json:"purged,omitempty"`
         }{
                 Project: string(s.Project),
                 Path:    string(s.Path),
         }
-        if s.State != nil {
-                o.Created = clockflag.Time(s.State.Created)
-                o.Updated = clockflag.Time(s.State.Updated)
-                o.TerminalIndex = int64(s.State.TerminalIndex)
-                o.ArchiveIndexURL = s.State.ArchiveIndexURL
-                o.ArchiveStreamURL = s.State.ArchiveStreamURL
-                o.ArchiveDataURL = s.State.ArchiveDataURL
-                o.Purged = s.State.Purged
-                o.Descriptor = s.Desc
-        }
+        o.Created = clockflag.Time(s.State.Created)
+        o.Updated = clockflag.Time(s.State.Updated)
+        o.TerminalIndex = int64(s.State.TerminalIndex)
+        o.ArchiveIndexURL = s.State.ArchiveIndexURL
+        o.ArchiveStreamURL = s.State.ArchiveStreamURL
+        o.ArchiveDataURL = s.State.ArchiveDataURL
+        o.Purged = s.State.Purged
+        o.Descriptor = &s.Desc
 
         if p.enc == nil {
                 p.enc = json.NewEncoder(p)
         }
         if err := p.enc.Encode(&o); err != nil {
                 return err
         }
 
         return p.Flush()
 }
 
 func (p *jsonQueryOutput) ensureStart() error {
         if p.count > 0 {
                 return nil
         }
         _, err := p.WriteString("[\n")
         return err
 }
 
 func (p *jsonQueryOutput) end() error {
         if err := p.ensureStart(); err != nil {
                 return err
         }
 
         _, err := p.WriteRune(']')
         return err
 }