c28fd92d10
etcdserver: extend storeRecorder to test parameters
2014-09-24 14:33:51 -07:00
c8c55aa378
scripts: consolidate and standardize protobuf generation
2014-09-24 13:45:00 -07:00
a9caa24f8a
etcdhttp: add test for streaming watches
2014-09-24 11:27:36 -07:00
ddc30c0a33
etcdserver: use Context to communicate timeout, and add tests
2014-09-24 11:27:36 -07:00
172a32e5e3
etcdserver: correct timeout and streaming handling
...
This reintroduces the 'stream' parameter to support long-lived watch
sessions. These sessions respect a server timeout (set to 5 minutes by
default).
2014-09-24 11:27:36 -07:00
e97134e767
etcdserver: eliminate race in sync test
2014-09-23 15:49:20 -07:00
b85ad9bbc2
Merge pull request #1082 from jonboulle/1082_x_etcd_index
...
X-Etcd-Index returns the node's modifiedIndex
2014-09-23 15:14:21 -07:00
dcdc7913c0
Merge pull request #1100 from unihorn/129
...
raft: add Configure
2014-09-23 13:50:10 -07:00
c6cb635e01
etcdserver: refine comments of config change tests
2014-09-23 13:03:30 -07:00
bc7b0108dc
raft: ConfigChange -> ConfChange
2014-09-23 12:02:44 -07:00
99e9f561ee
etcdserver: add Peers.Addrs
2014-09-23 10:56:41 -07:00
10220335f7
etcdserver: determine scheme based on TLSClientConfig
2014-09-23 10:14:12 -07:00
e19b0442f8
etcdserver: pass scheme into send
2014-09-23 10:14:11 -07:00
fb7968d704
etcdserver: Peers.Pick returns just an addr
2014-09-23 10:09:34 -07:00
5470a6d3d6
etcdserver: pass http client into Sender
2014-09-23 10:02:23 -07:00
d92931853e
raft: Config -> ConfigChange
...
Configure -> ProposeConfigChange
AddNode, RemoveNode -> ApplyConfigChange
2014-09-22 23:39:53 -07:00
5441c6aa54
etcdserver: correct X-Etcd-Index header
...
This adds an EtcdIndex field to store.Event and uses that as the header
instead of the node's modifiedIndex. To facilitate this in a non-racy
way, we set the EtcdIndex while holding the lock.
2014-09-22 18:56:12 -07:00
ec8f493fde
raft: refine comments for Configure
2014-09-22 15:44:47 -07:00
dc36ae7058
raft: use pb.Config instead of []byte for Configure
2014-09-22 15:44:47 -07:00
4203569da2
etcdserver: use ConfigType in protobuf
2014-09-22 15:44:46 -07:00
b82d70871f
raft: use EntryType in protobuf
2014-09-22 15:44:46 -07:00
abdb2cad15
etcdserver: Config.Id -> Config.ID
2014-09-22 15:44:46 -07:00
aaffb9eb78
etcdserver: add AddNode, RemoveNode
...
AddNode and RemoveNode is used to propose config change to the cluster.
If succeeds, it will add/remove node from the cluster.
2014-09-22 15:44:46 -07:00
7d1126fb35
etcdserver: init time.Time only if Expiration > 0
...
golang's concept of "zero" time does not align with the zero value of
a unix timestamp. Initializing time.Time with a unix timestamp of 0
makes time.Time.IsZero fail. Solve this by initializing time.Time only
if we care about the time.
2014-09-22 15:31:31 -07:00
e08df4c8d2
store: fix recursive/dir arguments
2014-09-22 14:44:01 -07:00
8ba801ec06
etcdserver: fix sync tests
...
This is to fix possible testing failures caused by sync tests.
Changes:
1. Get rid of time sleep operations, which introduces uncertainty.
2. Use fake Store.
2014-09-20 17:41:30 -07:00
ddfcb67ce3
Merge pull request #1118 from unihorn/133
...
etcdserver: add TestRecvSnapshot
2014-09-20 17:10:01 -07:00
fac38aad33
etcdserver: add TestRecvSlowSnapshot
2014-09-19 15:09:04 -07:00
b8e59a3c6a
etcdserver: not push ready to readyNode automatically
2014-09-19 14:40:11 -07:00
f2ebd64a1b
*: add testutil pkg
2014-09-19 14:32:38 -07:00
4eb156a324
Merge pull request #1104 from unihorn/132
...
etcdserver: add TestDoBadLocalAction
2014-09-19 09:30:34 -07:00
d5988c3ec2
etcdserver: add TestDoBadLocalAction
2014-09-19 09:22:26 -07:00
44ab66d858
etcdserver: add TestRecvSnapshot
2014-09-18 23:19:00 -07:00
91003cb994
*: s/prevExists/prevExist/
2014-09-18 21:25:08 -07:00
a42d52482c
etcdserver: use simple PRNG for GenID
2014-09-17 15:29:14 -07:00
f2e92d9140
Merge pull request #1097 from unihorn/130
...
etcdserver: use Action to fix possible data race
2014-09-17 14:28:37 -07:00
b66a40495d
raft: introduce Node interface
2014-09-17 14:18:56 -07:00
ab61a8aa9a
*: init for on disk snap support
2014-09-17 13:56:12 -07:00
0ad0e24a86
etcdserver: use Action to fix possible data race
2014-09-17 13:48:03 -07:00
f786de13d0
Merge pull request #1081 from unihorn/125
...
make TTL work
2014-09-16 15:14:44 -07:00
a91d745c46
etcdserver: refine printout
2014-09-16 14:54:22 -07:00
023dc7cba2
etcdserver: add SYNC request
2014-09-16 13:42:03 -07:00
67e57ffca4
etcdserver: split out client and server listeners
2014-09-16 11:36:37 -07:00
30b70e18c5
etcdserver/etcdhttp: add simple test for peers send
2014-09-15 21:10:00 -07:00
a7ec09c877
etcdserver/etcdhttp: use empty node for test
2014-09-15 20:34:14 -07:00
f846c5286a
etcdserver/etcdhttp: fix comment, simplify resServer
2014-09-15 19:01:40 -07:00
27cf7747ea
etcdserver/etcdhttp: add tests for serveKeys
2014-09-15 18:33:10 -07:00
7ac3b32de6
etcdserver: change raft endpoint to send StatusNoContent
2014-09-15 16:10:31 -07:00
3e2c160eed
etcdserver/etcdhttp: add test coverage for serveRaft
2014-09-15 16:07:06 -07:00
e04c028d64
etcdserver/etcdhttp: switch to using http.ServeMux
2014-09-15 16:05:20 -07:00
8a5ab2ec06
etcdserver: introduce Server interface
...
This changes etcdserver.Server to an interface, with the former Server
(now "EtcdServer") becoming the canonical/production implementation.
This will facilitate better testing of the http server et al with mock
implementations of the interface.
It also more clearly defines the boundary for users of the Server.
2014-09-15 15:11:01 -07:00
d9cfc35bed
etcdhttp: check method for every endpoint, add tests
2014-09-15 14:56:43 -07:00
9bf2c2ed9d
Merge pull request #1052 from unihorn/121
...
server: add unit tests
2014-09-15 13:20:50 -07:00
6cd4434ff3
server: add unit tests
...
Make test coverage >= 90%
2014-09-15 13:16:48 -07:00
e085cc4e06
Merge pull request #1042 from unihorn/118
...
raft: set none to be 0
2014-09-14 22:32:37 -07:00
54b9c55af3
etcdserver: remove useless sleep
...
etcdserver.Do will block until there exists leader
2014-09-12 13:01:33 -07:00
0e0fc2bd24
raft: use [1,n] as address list for raft state machines
2014-09-11 19:23:05 -07:00
20776f1947
etcdserver: use int64slice directly
2014-09-11 19:17:07 -07:00
e18b8c12be
etcdserver: switch to proper int64Slice for sorting
2014-09-11 17:28:08 -07:00
5f66b35852
etcdserver/etcdhttp: split out peers and add tests
2014-09-11 16:53:55 -07:00
c03798f99b
Merge pull request #1011 from jonboulle/clean_http
...
Validate HTTP API user input
2014-09-11 15:31:25 -07:00
786982d8e5
simplify
2014-09-11 15:13:56 -07:00
52ddd389ff
etcdhttp: use Form values over query parameters
2014-09-11 15:12:31 -07:00
7c03704b19
etcdserver: restructure to hopefully simplify
...
Obviate parseBool helper, define emptyReq locally to parseRequest,
have writeEvent return an error which gets logged
2014-09-11 08:50:41 -07:00
bafe960dba
etcdhttp: add Peers.Endpoints
2014-09-10 18:02:02 -07:00
c251304068
*: s/Id/ID/
...
golang convention dictates that the individual characters in an
abbreviation should all have the same case. Use ID instead of Id.
The protobuf generator still generates code that does not meet
this convention, but that's a fight for another day.
2014-09-10 16:09:08 -07:00
e2d01eff35
etcdserver: switch to using etcd.Error
2014-09-10 15:46:13 -07:00
2342402434
etcdserver: address style comments
2014-09-10 14:14:14 -07:00
bed63cddf7
etcdhttp: add tests for ParseBool/ParseUint64 helpers
2014-09-10 12:05:36 -07:00
e736a11ac4
etcdhttp: perform validation of query parameters
...
Add basic input validation of all query parameters supported by
serveKeys. Also restructures etcdhttp a bit to better facilitate
testing.
Test coverage is slightly improved.
2014-09-10 12:01:58 -07:00
51e4bbfeb0
http: check err return from http.NewRequest
2014-09-09 20:46:56 -07:00
4e31bb308d
raft: use const firstId to track ids
2014-09-09 19:07:20 -07:00
8c58684fb7
etcdserver: fix testServer
2014-09-09 16:59:42 -07:00
01871e7c29
http: use sort.Strings
2014-09-09 16:20:02 -07:00
d519491545
http: add TODO for peers var
2014-09-09 15:55:42 -07:00
961a61d708
http: add allow func
...
For further extendability
2014-09-09 15:45:34 -07:00
4087fa5c7a
http: allow GET, HEAD for /v2/machines
2014-09-09 15:22:52 -07:00
0c1d1b7aeb
etcdhttp: add /v2/machines endpoint
2014-09-09 15:00:29 -07:00
44acd57ea4
etcdserver: remove superfluous context
2014-09-09 11:18:25 -07:00
07ce8bc4bc
etcdserver: split out functional test to new package
2014-09-09 11:18:24 -07:00
8473f3bf52
api: address review comments
2014-09-09 11:17:53 -07:00
c78239a629
etcdserver: add test coverage for parseRequest
2014-09-09 11:17:53 -07:00
b33b85870d
etcdserver: add waitForEvent and encodeResponse coverage
2014-09-09 11:17:53 -07:00
f7444ff300
store: convert Watch to interface
2014-09-09 11:17:53 -07:00
9997c9488a
*: fix a few small issues identified by go vet
2014-09-08 23:52:36 -07:00
55b4267c30
Merge pull request #1001 from coreos/sender
...
etcdhttp: non-blocking sender
2014-09-08 23:36:10 -07:00
908d326e22
etcdhttp: use peer.String() in test
2014-09-08 20:50:35 -07:00
378cadf073
etcdhttp: implment Peers.String()
2014-09-08 20:45:10 -07:00
f4a33dd6df
etcdhttp: simple test for peer set cleanup
2014-09-08 17:04:36 -07:00
5c8839387d
etcdhttp: set peer should clean up previous values
2014-09-08 16:38:01 -07:00
cbec48e8f6
etcdhttp: non-blocking sender
2014-09-05 13:54:40 -07:00
f1856abe60
etcdhttp: add v2prefix
2014-09-03 21:52:16 -07:00
d844377ca6
*: vendor context
2014-09-03 20:06:16 -07:00
172c1eae5d
etcdhttp: fix test build
2014-09-03 20:01:54 -07:00
99c7371337
etcdserver: use vendored gogoproto
2014-09-03 19:47:05 -07:00
3c77693881
raft: make tick send out messages. all state machine actions should be taken inside step function.
2014-09-03 10:17:09 -07:00
2ba57ee75d
*: remove unused pkgs
2014-09-03 09:20:20 -07:00
3699f2e5f9
etcdserver: rename someMachineMessage->machineMessage
2014-09-03 09:20:11 -07:00
4c116a5a01
etcd: add consistent get
2014-09-03 09:20:10 -07:00
f6a9599eb4
*: rename etcd to etcdserver
2014-09-03 09:20:10 -07:00
Jonathan Boulle