southbound

Documentation

Index

• func Connect(ctx context.Context, address string, certPath string, keyPath string, ...) (*grpc.ClientConn, error)
• func RetryingStreamClientInterceptor(duration time.Duration) ...
• func RetryingUnaryClientInterceptor() func(ctx context.Context, method string, req, reply interface{}, ...) error

Functions

func Connect

func Connect(ctx context.Context, address string, certPath string, keyPath string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

Connect establishes a client-side connection to the gRPC end-point.

func RetryingStreamClientInterceptor

func RetryingStreamClientInterceptor(duration time.Duration) func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

RetryingStreamClientInterceptor returns a ClientStreamInterceptor that retries both requests and responses

func RetryingUnaryClientInterceptor

func RetryingUnaryClientInterceptor() func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

RetryingUnaryClientInterceptor returns a UnaryClientInterceptor that retries requests