modcall

type AsyncCaller interface {
	CallAsync(ctx context.Context, module, method string, payload []byte) error
}

type Caller interface {
	Call(ctx context.Context, module, method string, payload []byte) ([]byte, error)
}

type Config struct {
	Modules map[string]Target `json:"modules,omitempty"`
}

type Error struct {
	Code    string `json:"code"`
	Message string `json:"message,omitempty"`
	// contains filtered or unexported fields
}

type HTTPCaller struct {
	// URLs maps a module to its Service's base URL; Audiences to the audience of
	// the bearer it verifies (the module's name when absent).
	URLs      map[string]string
	Audiences map[string]string
	Token     TokenSource
	Client    *http.Client
	// MaxBytes bounds a request payload and a result ([DefaultMaxBytes] when 0);
	// raise it only for a callee that registered a larger [MaxBytes].
	MaxBytes int
}

type HandlerOption func(*handlerConfig)

type Local map[string]*Server

type Method struct {
	Name string
	// Allow is the caller classes the method answers, sorted. Nil is any
	// caller the transport let in: no [Allow] was registered.
	Allow []string
	// MaxBytes is the bound of the request payload and of the result.
	MaxBytes int
}

type Option func(*handler)

type Pending struct {
	// contains filtered or unexported fields
}

type Request struct {
	// V is the protocol version; absent is 1.
	V       int             `json:"v,omitempty"`
	Kind    string          `json:"kind"`
	Module  string          `json:"module"`
	Method  string          `json:"method"`
	Payload json.RawMessage `json:"payload,omitempty"`

	// Version 2 and later. A version 1 request has none of them, and a callee
	// ignores them on one.
	//
	// Traceparent and Tracestate are the caller's W3C trace context; the callee
	// continues the trace with a span of its own.
	Traceparent string `json:"traceparent,omitempty"`
	Tracestate  string `json:"tracestate,omitempty"`
	// Deadline is the caller's deadline as Unix milliseconds. The callee bounds
	// its work by it, and refuses a call that arrives after it. It is read
	// against the callee's clock, so hosts need ordinary time sync.
	Deadline int64 `json:"deadline,omitempty"`
}

type Response struct {
	V      int             `json:"v,omitempty"`
	Result json.RawMessage `json:"result,omitempty"`
	Error  *Error          `json:"error,omitempty"`
}

type Router struct {
	// contains filtered or unexported fields
}

type Server struct {
	// contains filtered or unexported fields
}

type Target struct {
	Function string `json:"function,omitempty"`
	URL      string `json:"url,omitempty"`
	Audience string `json:"audience,omitempty"`
	// TokenFile is where the pod's projected token for a URL target is mounted;
	// [DefaultTokenFile] when unset.
	TokenFile string `json:"tokenFile,omitempty"`
	// MaxBytes bounds a request payload and a result to this module in bytes,
	// above [DefaultMaxBytes] for a module whose methods list ([MaxBytes]); zero
	// is the default.
	MaxBytes int `json:"maxBytes,omitempty"`
}

type TokenSource func(ctx context.Context, audience string) (string, error)

type Verifier func(ctx context.Context, bearer string) (subject string, err error)