Skip to content
This repository was archived by the owner on Aug 12, 2022. It is now read-only.

feat/implementation of parallel clients limit #103

Merged
roneli merged 11 commits into from
Oct 30, 2021
Merged

feat/implementation of parallel clients limit #103

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
973dc37
basic implementation of paralel clients limit
amanenk Oct 14, 2021
dcffd39
semaphore used. protobuf update
amanenk Oct 14, 2021
4ae3934
comment adjusted
amanenk Oct 14, 2021
da058b9
linter fix
amanenk Oct 14, 2021
f30e805
removed delay between multiplexes
amanenk Oct 14, 2021
d9da135
added tests for parallel limiter
amanenk Oct 29, 2021
40e3ef6
added tests for parallel limiter
amanenk Oct 29, 2021
084c1ae
Merge branch 'main' into paralel_clients_limit
amanenk Oct 29, 2021
1570bd9
protobuf regenerated after merge
amanenk Oct 29, 2021
732dbee
linter fixes
amanenk Oct 29, 2021
6edbb9d
function renamed
amanenk Oct 29, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion cqproto/grpc.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,7 @@ func (g GRPCClient) FetchResources(ctx context.Context, request *FetchResourcesR
res, err := g.client.FetchResources(ctx, &internal.FetchResources_Request{
Resources: request.Resources,
PartialFetchingEnabled: request.PartialFetchingEnabled,
ParallelFetchingLimit: request.ParallelFetchingLimit,
})
if err != nil {
return nil, err
Expand Down Expand Up @@ -156,7 +157,7 @@ func (g *GRPCServer) ConfigureProvider(ctx context.Context, request *internal.Co
func (g *GRPCServer) FetchResources(request *internal.FetchResources_Request, server internal.Provider_FetchResourcesServer) error {
return g.Impl.FetchResources(
server.Context(),
&FetchResourcesRequest{Resources: request.GetResources(), PartialFetchingEnabled: request.PartialFetchingEnabled},
&FetchResourcesRequest{Resources: request.GetResources(), PartialFetchingEnabled: request.PartialFetchingEnabled, ParallelFetchingLimit: request.ParallelFetchingLimit},
&GRPCFetchResourcesServer{server: server},
)
}
Expand Down
Loading