jrpc

Aug 7, 2023

Changes in this version

type Destination

+ Client *http.Client

+ OkCodes sets.Set[int]

+ TLSConfig *tls.Config

Apr 6, 2023

Changes in this version

+ func ProcessRequest(r *http.Request) (*Q, error)

Jan 14, 2023

Changes in this version

type Destination

+ ClientTrace *httptrace.ClientTrace

+ Context context.Context

+ func (d *Destination) GetContext() context.Context

Oct 24, 2022

Changes in this version

+ func GetArray(url *Destination) ([]Q, error)

Sep 13, 2022

Changes in this version

type Destination

+ Method string

Sep 12, 2022

Changes in this version

+ func FetchBytes(url *Destination) (int, []byte, error)

+ func Get(url *Destination) (*Q, error)

+ func GetURL(url string) (*Q, error)

Sep 7, 2022

Changes in this version

+ const UserAgentHeader

+ var UserAgent = "fortio.org/fortio-" + version.Short()

+ func CallNoPayloadURL(url string) (*Q, error)

+ func CallURL(url string, payload *T) (*Q, error)

+ func FetchURL(url string) (int, []byte, error)

+ func SetHeaderIfMissing(headers http.Header, name, value string)

+ type Destination struct

+ Headers *http.Header

+ Timeout time.Duration

+ URL string

+ func NewDestination(url string) *Destination

Aug 18, 2022

Changes in this version

+ func Call(url string, payload *T) (*Q, error)

+ func CallNoPayload(url string) (*Q, error)

+ func CallWithPayload(url string, bytes []byte) (*Q, error)

+ func DebugSummary(buf []byte, max int) string

+ func Deserialize(bytes []byte) (*Q, error)

+ func EscapeBytes(buf []byte) string

+ func Fetch(url string) (int, []byte, error)

+ func HandleCall(w http.ResponseWriter, r *http.Request) (*Q, error)

+ func Reply(w http.ResponseWriter, code int, data *T) error

+ func ReplyClientError(w http.ResponseWriter, data *T) error

+ func ReplyError(w http.ResponseWriter, extraMsg string, err error) error

+ func ReplyNoPayload(w http.ResponseWriter, code int) error

+ func ReplyOk(w http.ResponseWriter, data *T) error

+ func ReplyServerError(w http.ResponseWriter, data *T) error

+ func Send(url string, jsonPayload []byte) (int, []byte, error)

+ func Serialize(obj interface{}) ([]byte, error)

+ func SetCallTimeout(t time.Duration) time.Duration

+ type FetchError struct

+ Bytes []byte

+ Code int

+ Err error

+ Message string

+ func (fe *FetchError) Error() string

+ func (fe *FetchError) Unwrap() error

+ type ServerReply struct

+ Error bool

+ Exception string

+ Message string

+ func NewErrorReply(message string, err error) *ServerReply