broker refactor
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
		
							
								
								
									
										154
									
								
								changes
									
									
									
									
									
								
							
							
						
						
									
										154
									
								
								changes
									
									
									
									
									
								
							| @@ -1,154 +0,0 @@ | |||||||
| broker/broker.go |  | ||||||
| broker/context.go |  | ||||||
| broker/context_test.go |  | ||||||
| broker/memory.go |  | ||||||
| broker/memory/memory.go |  | ||||||
| broker/memory_test.go |  | ||||||
| broker/noop.go |  | ||||||
| broker/noop_test.go |  | ||||||
| broker/options.go |  | ||||||
| broker/subscriber.go |  | ||||||
| client/backoff.go |  | ||||||
| client/backoff_test.go |  | ||||||
| client/client.go |  | ||||||
| client/client_call_options.go |  | ||||||
| client/client_call_options_test.go |  | ||||||
| client/context.go |  | ||||||
| client/context_test.go |  | ||||||
| client/noop.go |  | ||||||
| client/noop_test.go |  | ||||||
| client/options.go |  | ||||||
| codec/codec.go |  | ||||||
| codec/context.go |  | ||||||
| codec/frame.go |  | ||||||
| codec/frame.proto |  | ||||||
| codec/options.go |  | ||||||
| config/config.go |  | ||||||
| config/context.go |  | ||||||
| config/context_test.go |  | ||||||
| config/default.go |  | ||||||
| config/default_test.go |  | ||||||
| config/options.go |  | ||||||
| database/dsn.go |  | ||||||
| errors/errors.go |  | ||||||
| errors/errors.proto |  | ||||||
| errors/errors_test.go |  | ||||||
| flow/context.go |  | ||||||
| flow/context_test.go |  | ||||||
| flow/default.go |  | ||||||
| flow/flow.go |  | ||||||
| flow/flow_test.go |  | ||||||
| flow/options.go |  | ||||||
| meter/context.go |  | ||||||
| meter/context_test.go |  | ||||||
| meter/meter.go |  | ||||||
| meter/noop.go |  | ||||||
| meter/options.go |  | ||||||
| meter/wrapper/wrapper.go |  | ||||||
| micro_test.go |  | ||||||
| mtls/mtls.go |  | ||||||
| mtls/options.go |  | ||||||
| options.go |  | ||||||
| options/hooks.go |  | ||||||
| options/options.go |  | ||||||
| options/options_test.go |  | ||||||
| profiler/http/http.go |  | ||||||
| profiler/noop.go |  | ||||||
| profiler/pprof/pprof.go |  | ||||||
| profiler/profile.go |  | ||||||
| proxy/options.go |  | ||||||
| proxy/proxy.go |  | ||||||
| register/context.go |  | ||||||
| register/extractor.go |  | ||||||
| register/extractor_test.go |  | ||||||
| register/memory/memory.go |  | ||||||
| register/memory/memory_test.go |  | ||||||
| register/options.go |  | ||||||
| register/register.go |  | ||||||
| register/watcher.go |  | ||||||
| resolver/dns/dns.go |  | ||||||
| resolver/dnssrv/dnssrv.go |  | ||||||
| resolver/http/http.go |  | ||||||
| resolver/noop/noop.go |  | ||||||
| resolver/registry/registry.go |  | ||||||
| resolver/resolver.go |  | ||||||
| resolver/static/static.go |  | ||||||
| router/context.go |  | ||||||
| router/options.go |  | ||||||
| router/router.go |  | ||||||
| selector/random/random.go |  | ||||||
| selector/roundrobin/roundrobin.go |  | ||||||
| selector/selector.go |  | ||||||
| semconv/broker.go |  | ||||||
| semconv/cache.go |  | ||||||
| semconv/client.go |  | ||||||
| semconv/logger.go |  | ||||||
| semconv/metadata.go |  | ||||||
| semconv/pool.go |  | ||||||
| semconv/server.go |  | ||||||
| semconv/store.go |  | ||||||
| server/context.go |  | ||||||
| server/context_test.go |  | ||||||
| server/noop.go |  | ||||||
| server/noop_test.go |  | ||||||
| server/options.go |  | ||||||
| server/registry.go |  | ||||||
| server/server.go |  | ||||||
| server/wrapper.go |  | ||||||
| service.go |  | ||||||
| service_test.go |  | ||||||
| store/context.go |  | ||||||
| store/context_test.go |  | ||||||
| store/memory.go |  | ||||||
| store/memory/memory.go |  | ||||||
| store/memory_test.go |  | ||||||
| store/options.go |  | ||||||
| store/store.go |  | ||||||
| store/wrapper.go |  | ||||||
| sync/memory.go |  | ||||||
| sync/sync.go |  | ||||||
| tools.go |  | ||||||
| tracer/context.go |  | ||||||
| tracer/memory/memory.go |  | ||||||
| tracer/memory/memory_test.go |  | ||||||
| tracer/noop.go |  | ||||||
| tracer/options.go |  | ||||||
| tracer/tracer.go |  | ||||||
| tracer/tracer_test.go |  | ||||||
| tracer/wrapper/wrapper.go |  | ||||||
| util/addr/addr.go |  | ||||||
| util/backoff/backoff.go |  | ||||||
| util/buf/buf.go |  | ||||||
| util/buffer/buffer.go |  | ||||||
| util/buffer/buffer_test.go |  | ||||||
| util/ctx/ctx.go |  | ||||||
| util/dns/cache.go |  | ||||||
| util/dns/cache_test.go |  | ||||||
| util/dns/conn.go |  | ||||||
| util/grpc/tracer.go |  | ||||||
| util/http/clienttracer.go |  | ||||||
| util/http/http.go |  | ||||||
| util/http/trie.go |  | ||||||
| util/http/trie_test.go |  | ||||||
| util/io/redirect.go |  | ||||||
| util/io/redirect_test.go |  | ||||||
| util/io/redirect_unix.go |  | ||||||
| util/io/redirect_windows.go |  | ||||||
| util/net/net.go |  | ||||||
| util/pki/pki.go |  | ||||||
| util/rand/rand.go |  | ||||||
| util/reflect/path.go |  | ||||||
| util/reflect/reflect.go |  | ||||||
| util/reflect/reflect_test.go |  | ||||||
| util/reflect/struct.go |  | ||||||
| util/reflect/struct_test.go |  | ||||||
| util/register/util.go |  | ||||||
| util/ring/buffer.go |  | ||||||
| util/sort/sort.go |  | ||||||
| util/sort/sort_test.go |  | ||||||
| util/stream/stream.go |  | ||||||
| util/structfs/metadata_digitalocean.go |  | ||||||
| util/structfs/metadata_ec2.go |  | ||||||
| util/structfs/structfs.go |  | ||||||
| util/structfs/structfs_test.go |  | ||||||
| util/test/test.go |  | ||||||
		Reference in New Issue
	
	Block a user