transport

type CoderWebsocketImplementation struct {
	AcceptOptions coderws.AcceptOptions
}

type GET struct {
	// Map of all headers that are added to graphql response. If not
	// set, only one header: Content-Type: application/graphql-response+json will be set.
	ResponseHeaders map[string][]string
	// UseGrapQLResponseJsonByDefault determines whether to use 'application/graphql-response+json'
	// as the response content type
	// when the Accept header is empty or 'application/*' or '*/*'.
	UseGrapQLResponseJsonByDefault bool
}

type GRAPHQL struct {
	// Map of all headers that are added to graphql response. If not
	// set, only one header: Content-Type: application/json will be set.
	ResponseHeaders map[string][]string
}

type InitPayload map[string]any

type MultipartForm struct {
	// MaxUploadSize sets the maximum number of bytes used to parse a request body
	// as multipart/form-data.
	MaxUploadSize int64

	// MaxMemory defines the maximum number of bytes used to parse a request body
	// as multipart/form-data in memory, with the remainder stored on disk in
	// temporary files.
	MaxMemory int64

	// Map of all headers that are added to graphql response. If not
	// set, only one header: Content-Type: application/json will be set.
	ResponseHeaders map[string][]string
}

type MultipartMixed struct {
	Boundary        string
	DeliveryTimeout time.Duration
}

type Options struct {
	// AllowedMethods is a list of allowed HTTP methods.
	AllowedMethods []string
}

type POST struct {
	// Map of all headers that are added to graphql response. If not
	// set, only one header: Content-Type: application/graphql-response+json will be set.
	ResponseHeaders map[string][]string

	// UseGrapQLResponseJsonByDefault determines whether to use 'application/graphql-response+json'
	// as the response content type
	// when the Accept header is empty or 'application/*' or '*/*'.
	UseGrapQLResponseJsonByDefault bool
}

type SSE struct {
	KeepAlivePingInterval time.Duration
	// MinEventInterval optionally paces SSE event frames for high-throughput streams.
	MinEventInterval time.Duration
}

type UrlEncodedForm struct {
	// Map of all headers that are added to graphql response. If not
	// set, only one header: Content-Type: application/json will be set.
	ResponseHeaders map[string][]string
}

type Websocket struct {
	// Implementation accepts HTTP requests as websocket connections. If nil,
	// gqlgen uses a CoderWebsocketImplementation with zero-valued accept
	// options.
	Implementation WebsocketImplementation

	InitFunc              WebsocketInitFunc
	InitTimeout           time.Duration
	ErrorFunc             WebsocketErrorFunc
	CloseFunc             WebsocketCloseFunc
	KeepAlivePingInterval time.Duration
	PongOnlyInterval      time.Duration
	PingPongInterval      time.Duration
	/* If PingPongInterval has a non-0 duration, then when the server sends a ping
	 * it sets a ReadDeadline of PingPongInterval*2 and if the client doesn't respond
	 * with pong before that deadline is reached then the connection will die with a
	 * 1006 error code.
	 *
	 * MissingPongOk if true, tells the server to not use a ReadDeadline such that a
	 * missing/slow pong response from the client doesn't kill the connection.
	 */
	MissingPongOk bool

	// PayloadReadLimit is the maximum size in bytes of a WebSocket message read from the client.
	// If nil, defaults to 1 MB. Set to a pointer of -1 to disable the limit entirely.
	// Custom websocket adapters must implement WebsocketReadLimiter to enforce this limit.
	PayloadReadLimit *int64
}

type WebsocketAcceptOptions struct {
	// ResponseHeader is passed back with the HTTP 101 response.
	ResponseHeader http.Header
	// Subprotocols are the GraphQL websocket subprotocols supported by gqlgen.
	// Implementations should merge these with their own implementation-specific
	// subprotocol configuration when negotiating the websocket connection.
	Subprotocols []string
}

type WebsocketCloseFunc func(ctx context.Context, closeCode int)

type WebsocketConn interface {
	io.Closer
	NextReader() (messageType int, r io.Reader, err error)
	WriteJSON(v any) error
	WriteClose(closeCode int, message string) error
	Subprotocol() string
}

type WebsocketError struct {
	Err error

	// IsReadError flags whether the error occurred on read or write to the websocket
	IsReadError bool
}

type WebsocketErrorFunc func(ctx context.Context, err error)

type WebsocketImplementation interface {
	Accept(
		w http.ResponseWriter,
		r *http.Request,
		options WebsocketAcceptOptions,
	) (WebsocketConn, error)
}

type WebsocketInitFunc func(ctx context.Context, initPayload InitPayload) (context.Context, *InitPayload, error)

type WebsocketReadDeadliner interface {
	SetReadDeadline(t time.Time) error
}

type WebsocketReadLimiter interface {
	SetReadLimit(limit int64)
}