grpc

Documentation

Overview

Package grpc implements a proxy that applies disruptions to gRPC requests This package is inspired by and extensively copies code from https://github.com/mwitkow/grpc-proxy

Index

• func NewHandler(disruption Disruption, forwardConn *grpc.ClientConn, ...) grpc.StreamHandler
• func NewProxy(listener net.Listener, upstreamAddress string, d Disruption) (protocol.Proxy, error)
• type Disruption

Functions

func NewHandler

func NewHandler(disruption Disruption, forwardConn *grpc.ClientConn, metrics *protocol.MetricMap) grpc.StreamHandler

NewHandler returns a StreamHandler that attempts to proxy all requests that are not registered in the server.

func NewProxy

func NewProxy(listener net.Listener, upstreamAddress string, d Disruption) (protocol.Proxy, error)

NewProxy return a new Proxy

Types

type Disruption

type Disruption struct {
	// Average delay introduced to requests
	AverageDelay time.Duration
	// Variation in the delay (with respect of the average delay)
	DelayVariation time.Duration
	// Fraction (in the range 0.0 to 1.0) of requests that will return an error
	ErrorRate float32
	// Status code to be returned by requests selected to return an error
	StatusCode int32
	// Status message to be returned in requests selected to return an error
	StatusMessage string
	// List of grpc services to be excluded from disruptions
	Excluded []string
}

Disruption specifies disruptions in grpc requests