rpccontext

Documentation

Index

• func ClientFromContext[Client Pingable[Req, Resp, RespPtr], Req any, Resp any, ...](ctx context.Context) Client
• func ContextWithClient[Client Pingable[Req, Resp, RespPtr], Req any, Resp any, ...](ctx context.Context, client Client) context.Context
• func IsClientAvailableInContext[Client Pingable[Req, Resp, RespPtr], Req any, Resp any, ...](ctx context.Context) bool
• type PingResponse
• type Pingable

Functions

func ClientFromContext

func ClientFromContext[Client Pingable[Req, Resp, RespPtr], Req any, Resp any, RespPtr PingResponse[Resp]](ctx context.Context) Client

ClientFromContext returns the given RPC client from the context, or panics.

func ContextWithClient

func ContextWithClient[Client Pingable[Req, Resp, RespPtr], Req any, Resp any, RespPtr PingResponse[Resp]](ctx context.Context, client Client) context.Context

ContextWithClient returns a context with an RPC client attached.

func IsClientAvailableInContext

func IsClientAvailableInContext[Client Pingable[Req, Resp, RespPtr], Req any, Resp any, RespPtr PingResponse[Resp]](ctx context.Context) bool

Types

type PingResponse

type PingResponse[T any] interface {
	*T
	GetNotReady() string
}

type Pingable

type Pingable[Req any, Resp any, RespPtr PingResponse[Resp]] interface {
	Ping(ctx context.Context, req *connect.Request[Req]) (*connect.Response[Resp], error)
}