Package grpcx contains utilities for working with gRPC.
Dial is a convenience wrapper over grpc.Dial. It can be overridden to provide a customized dialing behavior.
DefaultDial is a dialer that specifies an insecure blocking connection with a timeout.
EnableHook is called to request the use of the gRPC hook in a pipeline.
ReadWorkerID reads the worker ID from an incoming gRPC request context.
RegisterHook registers a HookFactory for the supplied identifier. It panics if the same identifier is registered twice.
WriteWorkerID write the worker ID to an outgoing gRPC request context. It merges the information with any existing gRPC metadata.
Hook allow a runner to customize various aspects of gRPC communication with the FnAPI harness. Each member of the struct is optional; the default behavior will be used if a value is not supplied.
HookFactory is a function that creates hooks from supplied arguments.