net

package

v0.0.2 Latest Latest Go to latest Published: Feb 5, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

View Source

const (
	ResponseTimeout = time.Minute * 10 // 10 minutes timeout for requests
)

This section is empty.

func RPCManagerSendRequest[T any](rpcMgr *GuestRPCManager, method transport.Method,
	params []byte) (*T, error)

func SendRequest(url string, data *bytes.Buffer, contentType interface{}, apiKey string) ([]byte, error)

type ContentType int

const (
	ContentTypeJSON ContentType = iota
	ContentTypeText
	ContentTypeMultipart
)

type CustomRequestHandler func(req *custom.CustomRequest) (*custom.CustomResponse, error)

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

func NewGuestRPCManager() *GuestRPCManager

func (g *GuestRPCManager) ClearRequestCallback(id int64)

func (g *GuestRPCManager) RegisterIncomingCustomRequestHandler(method string,
	handler CustomRequestHandler) error

func (g *GuestRPCManager) RegisterIncomingRequestHandler(method transport.Method,
	handler RequestHandler) error

func (g *GuestRPCManager) Run()

func (g *GuestRPCManager) SendRequest(method transport.Method,
	params []byte) ([]byte, error)

high level function to send a request

func (g *GuestRPCManager) SendTransportRequest(
	req *transport.TransportRequest) (*transport.TransportResponse, error)

low level function to send a json request

func (g *GuestRPCManager) SendTransportResponse(id int64,
	resp *transport.TransportResponse) error

func (g *GuestRPCManager) SetInput(i io.Reader)

func (g *GuestRPCManager) SetOutput(o io.Writer)

func (g *GuestRPCManager) SetRequestCallback(id int64, callback ResponseHandler,
	autoClear bool)

type RequestHandler func(req *transport.TransportRequest) (*transport.TransportResponse, error)

type ResponseHandler func(resp *transport.TransportResponse) error