Documentation
¶
Overview ¶
Package grpc implements helper functions to interact with grpc
Index ¶
- Variables
- func AuthInterceptor(verifier verifierFunc) grpc_auth.AuthFunc
- func DoWithTimeout(f func() error, d time.Duration) error
- func GetDDAgentClient(ctx context.Context, ipcAddress string, cmdPort string, ...) (pb.AgentClient, error)
- func GetDDAgentSecureClient(ctx context.Context, ipcAddress string, cmdPort string, ...) (pb.AgentSecureClient, error)
- func NewLogger() grpclog.LoggerV2
- func NewMuxedGRPCServer(addr string, tlsConfig *tls.Config, grpcServer *grpc.Server, ...) *http.Server
- func TimeoutHandlerFunc(httpHandler http.Handler, timeout time.Duration) http.Handler
Constants ¶
This section is empty.
Variables ¶
var ConnContextKey = &contextKey{"http-connection"}
ConnContextKey is a contextKey with http-connection key
Functions ¶
func AuthInterceptor ¶
AuthInterceptor is a gRPC interceptor that extracts an auth token from the request headers, and validates it using the provided func.
func DoWithTimeout ¶
DoWithTimeout runs f and returns its error. If the deadline d elapses first, it returns a grpc DeadlineExceeded error instead.
func GetDDAgentClient ¶
func GetDDAgentClient(ctx context.Context, ipcAddress string, cmdPort string, opts ...grpc.DialOption) (pb.AgentClient, error)
GetDDAgentClient creates a pb.AgentClient for IPC with the main agent via gRPC. This call is blocking by default, so it is up to the caller to supply a context with appropriate timeout/cancel options
func GetDDAgentSecureClient ¶
func GetDDAgentSecureClient(ctx context.Context, ipcAddress string, cmdPort string, opts ...grpc.DialOption) (pb.AgentSecureClient, error)
GetDDAgentSecureClient creates a pb.AgentSecureClient for IPC with the main agent via gRPC. This call is blocking by default, so it is up to the caller to supply a context with appropriate timeout/cancel options
func NewLogger ¶
NewLogger returns a gRPC logger that logs to the Datadog logger instead of directly to stderr.
func NewMuxedGRPCServer ¶
func NewMuxedGRPCServer(addr string, tlsConfig *tls.Config, grpcServer *grpc.Server, httpHandler http.Handler) *http.Server
NewMuxedGRPCServer returns an http.Server that multiplexes connections between a gRPC server and an HTTP handler.
func TimeoutHandlerFunc ¶
TimeoutHandlerFunc returns an HTTP handler that times out after a duration. This is useful for muxed gRPC servers where http.Server cannot have a timeout when handling streaming, long running connections.
Types ¶
This section is empty.
Source Files