timeout

README

Timeout - Jet Middleware

Timeout middleware for Jet.

Usage Example

package main

import (
	"context"
	"log"
	"time"

	"github.com/go-kratos-ecosystem/components/v2/hyperf/jet"
	"github.com/go-kratos-ecosystem/components/v2/hyperf/jet/middleware/timeout"
)

func main() {
	client, err := jet.NewClient(
		jet.WithTransporter(nil),
		// ...
	)
	if err != nil {
		log.Fatal(err)
	}

	// base usage
	client.Use(timeout.New()) // default 5s

	// custom timeout
	client.Use(timeout.New(
		timeout.Timeout(10 * time.Second),
	))

	// call service
	client.Invoke(context.Background(), "method", []any{"..."}, nil)
}

Documentation

Index

• Variables
• func New(opts ...Option) jet.Middleware
• type Option
  • func Timeout(timeout time.Duration) Option

Variables

var (
	ErrTimeout = fmt.Errorf("jet/timeout: request timeout")
)

Functions

func New

func New(opts ...Option) jet.Middleware

Types

type Option

type Option func(*options)

func Timeout

func Timeout(timeout time.Duration) Option