Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(36)

Side by Side Diff: server/logdog/storage/bigtable/storage_test.go

Issue 1672833003: LogDog: Add log rendering view. Base URL: https://github.com/luci/luci-go@master
Patch Set: Clean up, add tests, little reorg. Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « server/logdog/storage/bigtable/bigtable.go ('k') | server/logdog/storage/memory/memory.go » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 package bigtable 5 package bigtable
6 6
7 import ( 7 import (
8 "bytes" 8 "bytes"
9 "testing" 9 "testing"
10 10
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after
66 if item, _ := coll.Get(enc); item != nil { 66 if item, _ := coll.Get(enc); item != nil {
67 return storage.ErrExists 67 return storage.ErrExists
68 } 68 }
69 69
70 if err := coll.Set(enc, d); err != nil { 70 if err := coll.Set(enc, d); err != nil {
71 panic(err) 71 panic(err)
72 } 72 }
73 return nil 73 return nil
74 } 74 }
75 75
76 func (t *btTableTest) getLogData(c context.Context, rk *rowKey, limit int, keysO nly bool, cb btGetCallback) error { 76 func (t *btTableTest) getLogData(c context.Context, rk *rowKey, limit int64, key sOnly bool, cb btGetCallback) error {
77 if t.err != nil { 77 if t.err != nil {
78 return t.err 78 return t.err
79 } 79 }
80 80
81 enc := []byte(rk.encode()) 81 enc := []byte(rk.encode())
82 prefix := rk.pathPrefix() 82 prefix := rk.pathPrefix()
83 var ierr error 83 var ierr error
84 err := t.collection().VisitItemsAscend(enc, !keysOnly, func(i *gkvlite.I tem) bool { 84 err := t.collection().VisitItemsAscend(enc, !keysOnly, func(i *gkvlite.I tem) bool {
85 var drk *rowKey 85 var drk *rowKey
86 drk, ierr = decodeRowKey(string(i.Key)) 86 drk, ierr = decodeRowKey(string(i.Key))
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after
159 Project: "test-project", 159 Project: "test-project",
160 Zone: "test-zone", 160 Zone: "test-zone",
161 Cluster: "test-cluster", 161 Cluster: "test-cluster",
162 LogTable: "test-log-table", 162 LogTable: "test-log-table",
163 }, 163 },
164 ctx: context.Background(), 164 ctx: context.Background(),
165 client: nil, 165 client: nil,
166 table: &bt, 166 table: &bt,
167 } 167 }
168 168
169 » » get := func(path string, index int, limit int) ([]string, error) { 169 » » get := func(path string, index int, limit int64) ([]string, erro r) {
170 req := storage.GetRequest{ 170 req := storage.GetRequest{
171 Path: types.StreamPath(path), 171 Path: types.StreamPath(path),
172 Index: types.MessageIndex(index), 172 Index: types.MessageIndex(index),
173 Limit: limit, 173 Limit: limit,
174 } 174 }
175 got := []string{} 175 got := []string{}
176 err := s.Get(&req, func(idx types.MessageIndex, d []byte ) bool { 176 err := s.Get(&req, func(idx types.MessageIndex, d []byte ) bool {
177 got = append(got, string(d)) 177 got = append(got, string(d))
178 return true 178 return true
179 }) 179 })
(...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after
339 Convey(`Will fail to extract if the family does not exis t.`, func() { 339 Convey(`Will fail to extract if the family does not exis t.`, func() {
340 So(getReadItem(fakeRow, "invalid", "invalid"), S houldBeNil) 340 So(getReadItem(fakeRow, "invalid", "invalid"), S houldBeNil)
341 }) 341 })
342 342
343 Convey(`Will fail to extract if the column does not exis t.`, func() { 343 Convey(`Will fail to extract if the column does not exis t.`, func() {
344 So(getReadItem(fakeRow, "log", "invalid"), Shoul dBeNil) 344 So(getReadItem(fakeRow, "log", "invalid"), Shoul dBeNil)
345 }) 345 })
346 }) 346 })
347 }) 347 })
348 } 348 }
OLDNEW
« no previous file with comments | « server/logdog/storage/bigtable/bigtable.go ('k') | server/logdog/storage/memory/memory.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698