57 Commits

Author	SHA1	Message	Date
Chris Lu	daf0a449f7	properly cancel context for streaming grpc	2020-09-09 12:07:15 -07:00
Chris Lu	387ab6796f	filer: cross cluster synchronization	2020-09-09 11:21:23 -07:00
Chris Lu	eb7929a971	rename filer2 to filer	2020-09-01 00:21:19 -07:00
Chris Lu	ef75ce8a34	use UTC for all time related folders	2020-08-29 21:01:14 -07:00
Chris Lu	b69cb74c03	read meta logs by timestamp ... pass in event ts when moving logs meta aggregator reads in memory logs only	2020-08-29 17:37:19 -07:00
Chris Lu	ca658a97c5	add signatures to messages to avoid double processing	2020-08-28 23:48:48 -07:00
Chris Lu	55e40b08fc	refactoring	2020-07-05 15:43:06 -07:00
Chris Lu	31e23e9783	filer: support active<=>active filer replication	2020-06-30 22:53:57 -07:00
Chris Lu	45a9d852d3	go fmt	2020-06-05 15:27:10 -07:00
Chris Lu	d3925d086c	add delete channel	2020-05-17 17:42:42 -07:00
Chris Lu	081ee6fe34	reduc logs	2020-05-17 17:38:31 -07:00
Chris Lu	bff09fb74f	fix looping	2020-05-17 17:38:21 -07:00
Chris Lu	f5684839a2	add DeleteTopic	2020-05-17 17:34:10 -07:00
Chris Lu	3a57aef7a9	sync subscribe()	2020-05-17 17:33:53 -07:00
Chris Lu	95ca9dd8a2	subscribe support cancel	2020-05-17 11:10:45 -07:00
Chris Lu	f11233cd49	simplify disconnected stream detection	2020-05-17 08:57:47 -07:00
Chris Lu	85b53ac510	detect disconnected subscribers	2020-05-16 18:53:54 -07:00
Chris Lu	b0de01ff3b	able to detect disconnected subscribers	2020-05-16 08:57:29 -07:00
Chris Lu	e02a8c67da	revert to one subscriber one thread	2020-05-15 21:38:42 -07:00
Chris Lu	ca4017dd87	rename	2020-05-12 22:55:55 -07:00
Chris Lu	25257acd51	rename	2020-05-12 21:26:49 -07:00
Chris Lu	a7959c1c48	multiple subscriber with same subscriberId shares the topic manager ... rename topicControl to topicCursor	2020-05-12 21:26:02 -07:00
Chris Lu	2f243f5b0b	refactor	2020-05-12 08:48:00 -07:00
Chris Lu	d5a8297a1c	able to connect publisher	2020-05-10 23:45:48 -07:00
Chris Lu	39e72fb23c	go fmt	2020-05-10 03:50:30 -07:00
Chris Lu	6bf3eb69cb	async chan write read, no write for closed chan	2020-05-10 03:48:35 -07:00
Chris Lu	d693e77418	add pub sub md5	2020-05-09 00:43:53 -07:00
Chris Lu	07d7abe428	add deleteTopic, refactoring	2020-05-09 00:31:34 -07:00
Chris Lu	dfccc3c263	able to read chan and write chan	2020-05-08 02:47:22 -07:00
Chris Lu	1e3e4b3072	add broker connects to filer	2020-05-05 02:05:28 -07:00
Chris Lu	871efa4fc1	refactoring ... some previous chunk etag was using md5, which should be wrong.	2020-04-30 17:20:47 -07:00
Chris Lu	ea809a45ab	add cipher key	2020-04-30 03:05:43 -07:00
Chris Lu	f9b6178b8f	log messages	2020-04-30 03:05:34 -07:00
Chris Lu	8c73410a51	subscribe from a timestamp	2020-04-30 02:19:51 -07:00
Chris Lu	9e72e9e4b8	able to subscribe any topic from any point of time	2020-04-29 17:40:08 -07:00
Chris Lu	ed3cf811f5	refactoring	2020-04-29 13:26:02 -07:00
Chris Lu	8ed490164e	refactoring	2020-04-28 02:05:44 -07:00
Chris Lu	66effaed9e	fix compilation	2020-04-28 02:05:32 -07:00
Chris Lu	5c348087dc	messaging: able to pub sub multiple partitions	2020-04-21 00:59:55 -07:00
Chris Lu	cb3985be70	go fmt	2020-04-20 17:48:06 -07:00
Chris Lu	df25ed3c5b	logs	2020-04-19 23:37:50 -07:00
Chris Lu	ce3cb25cfb	working for in memory single log buffer	2020-04-19 23:37:50 -07:00
Chris Lu	71ffb98475	broker: add profiling	2020-04-19 03:03:40 -07:00
Chris Lu	d278b4c228	basic pub and sub works!	2020-04-19 00:18:32 -07:00
Chris Lu	788578d4ea	add subscriber api	2020-04-18 16:05:29 -07:00
Chris Lu	076c8bd3bc	filer master start up with default ip address instead of just localhost	2020-04-18 15:17:27 -07:00
Chris Lu	5d346d44bd	Revert "move go client out" ... This reverts commit ef1274edc9.	2020-04-18 12:44:55 -07:00
Chris Lu	ef1274edc9	move go client out	2020-04-18 12:11:50 -07:00
Chris Lu	5af49c7aa5	adjust API	2020-04-18 11:45:57 -07:00
Chris Lu	11f5a6d913	messaging can compile now	2020-04-18 01:12:01 -07:00