Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewStreamInterceptor ¶
func NewStreamInterceptor(interval time.Duration) grpc.StreamClientInterceptor
NewStreamInterceptor returns a gRPC StreamClientInterceptor which performs server health checks on the given interval for any stream which is initiated.
health := grpchealthcheck.NewStreamInterceptor(30 * time.Second)
conn, _ := grpc.Dial("server", grpc.WithStreamInterceptor(health))
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.