shared

Documentation

Index

• Variables
• func HandleError(err error, hops int32) error
• func PrintDeadlineReached[Int int | int32](hops Int)
• func PrintDone[Int int | int32](ctx context.Context, hops Int)
• func PrintHop[Int int | int32](hops Int)
• func PrintResponse[Int int | int32](hops Int, resp *pb.DeadlineResponse)
• func PrintStart[Int int | int32](todo, timeout Int)
• func RandomTimer() *time.Timer
• type ExampleHTTPClient
  • func NewExampleHTTPClient(client *http.Client) *ExampleHTTPClient
  • func (c *ExampleHTTPClient) Deadline(ctx context.Context, todo, timeout int32) (*pb.DeadlineResponse, error)
• type ExampleResponse

Variables

var GRPCPort = "8081"

var HTTPPort = "8080"

var Host = "localhost"

var Target = Host + ":" + GRPCPort

Functions

func HandleError

func HandleError(err error, hops int32) error

func PrintDeadlineReached

func PrintDeadlineReached[Int int | int32](hops Int)

func PrintDone

func PrintDone[Int int | int32](ctx context.Context, hops Int)

func PrintHop

func PrintHop[Int int | int32](hops Int)

func PrintResponse

func PrintResponse[Int int | int32](hops Int, resp *pb.DeadlineResponse)

func PrintStart

func PrintStart[Int int | int32](todo, timeout Int)

func RandomTimer

func RandomTimer() *time.Timer

Types

type ExampleHTTPClient

type ExampleHTTPClient struct {
	*http.Client
	// contains filtered or unexported fields
}

func NewExampleHTTPClient

func NewExampleHTTPClient(client *http.Client) *ExampleHTTPClient

func (*ExampleHTTPClient) Deadline

func (c *ExampleHTTPClient) Deadline(ctx context.Context, todo, timeout int32) (*pb.DeadlineResponse, error)

type ExampleResponse

type ExampleResponse struct{}