client

type Client struct {
	URL      string    `yaml:"url"`
	UserInfo *UserInfo `yaml:"user_info"`

	// AllowInsecure set whether to check the server certificates
	AllowInsecure bool

	// Dialer dial websocket connecting to graphql server for subscription.
	// If nil, websocket.DefaultDialer will be used.
	Dialer *websocket.Dialer

	// HTTPClient dial http connecting to graphql server for query.
	// If nil, http.DefaultClient will be used.
	HTTPClient *http.Client

	// If set, mutation will wait task down.
	TaskMonitor TaskMonitor
	// contains filtered or unexported fields
}

type ErrorCode string

type JSONRequest []byte

type Message struct {
	ID   string      `json:"id,omitempty"`
	Type MessageType `json:"type"`

	PayLoad json.RawMessage `json:"payload,omitempty"`
}

type MessageType string

type MultipartWriterRequest struct {
	*multipart.Writer
	// contains filtered or unexported fields
}

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

type RequestInterface interface {
	String() string       // humanreadable string
	GetReader() io.Reader // request body reader
	ContentType() string  // content-type in header
}

type Response struct {
	Data   json.RawMessage `json:"data"`
	Errors []ResponseError `json:"errors,omitempty"`
}

type ResponseError struct {
	Message string    `json:"message"`
	Code    ErrorCode `json:"code,omitempty"`
}

type TaskMonitor interface {
	WaitForTask(ctx context.Context, taskID string) (*schema.Task, error)
}

type Upload struct {
	FileName string
	File     io.Reader
}

type UserInfo struct {
	Username string `json:"username" yaml:"username"`
	Password string `json:"password" yaml:"password"`
	Source   string `json:"source" yaml:"source"`
}