transport

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

type ConnOptions struct {
	Context context.Context
	URL     string
	Timeout time.Duration
}

type Func func(Request) Response

type Http struct {
	URL string
	// Client defaults to http.DefaultClient
	Client           *http.Client
	RequestOptions   []HttpRequestOption
	UseFormMultipart bool
}

type HttpRequestOption func(req *http.Request)

type Mock map[string]Func

type Operation string

type OperationMessage struct {
	ID      string               `json:"id,omitempty"`
	Type    OperationMessageType `json:"type"`
	Payload json.RawMessage      `json:"payload,omitempty"`
}

type OperationMessageType string

type OperationRequest struct {
	Query         string                 `json:"query,omitempty"`
	OperationName string                 `json:"operationName,omitempty"`
	Variables     map[string]interface{} `json:"variables,omitempty"`
	Extensions    map[string]interface{} `json:"extensions,omitempty"`
}

type OperationResponse struct {
	Data       json.RawMessage `json:"data,omitempty"`
	Errors     gqlerror.List   `json:"errors,omitempty"`
	Extensions RawExtensions   `json:"extensions,omitempty"`
}

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

type RawExtensions map[string]json.RawMessage

type Request struct {
	Context   context.Context
	Operation Operation

	OperationName string
	Query         string
	Variables     map[string]interface{}
	Extensions    map[string]interface{}
}

type Response interface {
	Next() bool
	Get() OperationResponse
	Close()
	CloseWithError(err error)
	Err() error
	Done() <-chan struct{}
}

type SendResponse interface {
	Response
	Send(OperationResponse)
}

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

type Status int

type Transport interface {
	Request(req Request) Response
}

type Upload struct {
	Name string
	File io.Reader
}

type WebsocketConn interface {
	ReadJSON(v interface{}) error
	WriteJSON(v interface{}) error
	Close() error
	// SetReadLimit sets the maximum size in bytes for a message read from the peer. If a
	// message exceeds the limit, the connection sends a close message to the peer
	// and returns ErrReadLimit to the application.
	SetReadLimit(limit int64)
}

type WebsocketConnProvider func(ctx context.Context, URL string) (WebsocketConn, error)

type WebsocketHandler struct {
	*websocket.Conn
	// contains filtered or unexported fields
}

type Ws struct {
	URL string
	// WebsocketConnProvider defaults to DefaultWebsocketConnProvider(30 * time.Second)
	WebsocketConnProvider WebsocketConnProvider
	// ConnectionParams will be sent during the connection init
	ConnectionParams interface{}
	// contains filtered or unexported fields
}

type WsDialOption func(o *websocket.DialOptions)