restartstream

package

v0.0.0-...-b349366 Latest Latest Go to latest Published: Aug 7, 2020 License: MIT Imports: 10 Imported by: 17

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/TheThingsNetwork/go-utils

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Interceptor(settings Settings) grpc.StreamClientInterceptor
type Settings

Constants ¶

This section is empty.

Variables ¶

View Source

var DefaultSettings = Settings{
	RetryableCodes: []codes.Code{
		codes.Canceled,
		codes.Unknown,
		codes.DeadlineExceeded,
		codes.Aborted,
		codes.Unavailable,
	},
	Backoff: backoff.DefaultConfig,
}

DefaultSettings for Interceptor

View Source

var ErrStreamClosed = errors.New("grpc: stream closed")

ErrStreamClosed is returned when trying to call SendMsg or RecvMsg on a closed stream

Functions ¶

func Interceptor ¶

func Interceptor(settings Settings) grpc.StreamClientInterceptor

Interceptor automatically restarts streams on non-expected errors To do so, the application should create a for-loop around RecvMsg, which returns the same errors that are received from the server.

An io.EOF indicates the end of the stream ¶

To stop the reconnect behaviour, you have to cancel the context

Types ¶

type Settings ¶

type Settings struct {
	RetryableCodes []codes.Code
	Backoff        backoff.Config
}

Settings for Interceptor

Source Files ¶

View all Source files

restart.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL