grpcx

Documentation

Overview

Package grpcx contains utilities for working with gRPC.

Index

• func Dial(ctx context.Context, endpoint string, timeout time.Duration) (*grpc.ClientConn, error)
• func ReadWorkerID(ctx context.Context) (string, error)
• func WriteWorkerID(ctx context.Context, id string) context.Context

Functions

func Dial

func Dial(ctx context.Context, endpoint string, timeout time.Duration) (*grpc.ClientConn, error)

Dial is a convenience wrapper over grpc.Dial that specifies an insecure, blocking connection with a timeout.

func ReadWorkerID

func ReadWorkerID(ctx context.Context) (string, error)

ReadWorkerID reads the worker ID from an incoming gRPC request context.

func WriteWorkerID

func WriteWorkerID(ctx context.Context, id string) context.Context

WriteWorkerID write the worker ID to an outgoing gRPC request context. It merges the information with any existing gRPC metadata.