rpc

type Client struct {
	// DecodeError maps a wire error back to a Go error; the default returns
	// the *WireError itself.
	DecodeError func(*WireError) error
	// contains filtered or unexported fields
}

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

type ConnOptions struct {
	MaxMessage    int           // largest inbound line, 16 MB
	MaxActive     int           // in-flight requests plus live streams, 32
	QueueMessages int           // send queue, 1024 messages …
	QueueBytes    int           // … or 32 MB; overflow drops the connection
	WriteTimeout  time.Duration // per write, 10 s
	// Hello, if set, must authenticate the connection: the first request
	// must be "hello"; its allow func then runs before every later call is
	// dispatched. ErrForbidden refuses the call as forbidden; any other error
	// stops it and is answered through EncodeError.
	Hello       func(params []json.RawMessage) (allow func(method string, params []json.RawMessage) error, result any, err error)
	AuthTimeout time.Duration // 5 s
	// EncodeError turns a target's error into a wire error; the default
	// reveals nothing ("internal error").
	EncodeError func(error) *WireError
	// contains filtered or unexported fields
}

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

type RemoteError struct {
	Code    int
	Message string
}

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

type ServerOptions struct {
	Conn     ConnOptions // per connection; Hello and EncodeError are set by the Server
	MaxConns int         // simultaneous connections, 16
	Version  string      // hello answers "godwit/<Version>"
	// Codec encodes errors (nil: every error is "internal error"). Every
	// string it sends, and every error logged, has the API token and then
	// whatever Redact (nil = nothing more) finds replaced.
	Codec  *Codec
	Redact func(string) string
	// Audit, if set, runs before an authorized call is dispatched, with the
	// connection's role. An error stops the call and is answered and logged
	// like any error the call could have returned.
	Audit func(role, method string, params []json.RawMessage) error
}

type WireError struct {
	Code    int            `json:"code"`
	Message string         `json:"message"`
	Data    *WireErrorData `json:"data,omitempty"`
}

type WireErrorData struct {
	Code   string          `json:"code"`
	Detail json.RawMessage `json:"detail,omitempty"`
	Cause  string          `json:"cause,omitempty"`
}