This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import java.lang.reflect.Field; | |
import java.lang.reflect.InvocationTargetException; | |
import java.lang.reflect.Method; | |
import java.util.Arrays; | |
import java.util.Collection; | |
import java.util.Comparator; | |
import java.util.Random; | |
import java.util.concurrent.PriorityBlockingQueue; | |
import java.util.concurrent.ThreadLocalRandom; | |
import java.util.concurrent.locks.Lock; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import com.google.protobuf.Descriptors.MethodDescriptor; | |
import com.google.protobuf.Descriptors.ServiceDescriptor; | |
import com.google.protobuf.DescriptorProtos.MethodOptions; | |
import io.grpc.BindableService; | |
import io.grpc.Metadata; | |
import io.grpc.Server; | |
import io.grpc.ServerBuilder; | |
import io.grpc.ServerCall; | |
import io.grpc.ServerCallHandler; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// Code generated by protoc-gen-go. DO NOT EDIT. | |
// versions: | |
// protoc-gen-go v1.24.0-devel | |
// protoc v3.11.3 | |
// source: foo.proto | |
package main | |
import ( | |
context "context" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
//---------------------------- | |
// Start up our gRPC server | |
//---------------------------- | |
svr := grpc.NewServer() | |
// we need the reflection service, to power the UI | |
reflection.Register(svr) | |
// ... | |
// register our gRPC services and then start up the server in a goroutine |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// This is an example of a gRPC service that has admin endpoints for managing | |
// various aspects of configuration for FullStory customers. | |
syntax = "proto3"; | |
package fullstory.orgs; | |
import "google/protobuf/empty.proto"; | |
service Admin { | |
// Retrieves the details of the request org. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
syntax = "proto3"; | |
package fs.auth; | |
import "fs/shared/flags/flags.proto"; | |
import "google/protobuf/descriptor.proto"; | |
extend google.protobuf.MethodOptions { | |
repeated fs.flags.Flag required_flags = 20000; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
syntax = "proto3"; | |
package fs.operations.v1; | |
import "fs/auth/grpcauth.proto"; | |
import "fs/operations/ops.proto"; | |
import "google/api/annotations.proto"; | |
service Operations { | |
rpc GetOperationStatus (OperationId) returns (OperationStatus) { |