Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

transport

package

Go to main page

Versions in this module

v0

v0.14.0

Feb 13, 2024

v0.13.9

Jun 19, 2023

v0.13.8

Jan 31, 2023

v0.13.7

Nov 17, 2022

v0.13.6

Nov 17, 2022

Changes in this version

type Request

+ OverrideRequestOptions []HttpRequestOption

v0.13.5

Aug 23, 2022

v0.13.4

Aug 23, 2022

v0.13.3

Jul 28, 2022

v0.13.2

Jun 20, 2022

v0.13.1

Jun 17, 2022

v0.13.0

Jun 17, 2022

v0.0.12

May 17, 2022

v0.0.11

May 5, 2022

Changes in this version

+ var ErrClosedConnection = fmt.Errorf("closed connection")

+ type ChanResponse struct

+ func NewChanResponse(onClose func() error) *ChanResponse

+ func (r *ChanResponse) Close()

+ func (r *ChanResponse) CloseCh()

+ func (r *ChanResponse) CloseWithError(err error)

+ func (r *ChanResponse) Done() <-chan struct{}

+ func (r *ChanResponse) Err() error

+ func (r *ChanResponse) Get() OperationResponse

+ func (r *ChanResponse) Next() bool

+ func (r *ChanResponse) Send(op OperationResponse)

+ type ConnOptions struct

+ Context context.Context

+ Timeout time.Duration

+ URL string

+ type Func func(Request) Response

+ func (f Func) Request(req Request) Response

+ type Http struct

+ Client *http.Client

+ RequestOptions []HttpRequestOption

+ URL string

+ UseFormMultipart bool

+ func (h *Http) Request(req Request) Response

+ type HttpRequestOption func(req *http.Request)

+ type Mock map[string]Func

+ func (m Mock) Request(req Request) Response

+ type Operation string

+ const Mutation

+ const Query

+ const Subscription

+ type OperationMessage struct

+ ID string

+ Payload json.RawMessage

+ Type OperationMessageType

+ func (msg OperationMessage) String() string

+ type OperationMessageType string

+ const GQL_COMPLETE

+ const GQL_CONNECTION_ACK

+ const GQL_CONNECTION_ERROR

+ const GQL_CONNECTION_INIT

+ const GQL_CONNECTION_KEEP_ALIVE

+ const GQL_CONNECTION_TERMINATE

+ const GQL_DATA

+ const GQL_ERROR

+ const GQL_INTERNAL

+ const GQL_START

+ const GQL_STOP

+ const GQL_UNKNOWN

+ type OperationRequest struct

+ Extensions map[string]interface{}

+ OperationName string

+ Query string

+ Variables map[string]interface{}

+ func NewOperationRequestFromRequest(req Request) OperationRequest

+ type OperationResponse struct

+ Data json.RawMessage

+ Errors gqlerror.List

+ Extensions RawExtensions

+ func NewMockOperationResponse(v interface{}, errs gqlerror.List) OperationResponse

+ func (r OperationResponse) UnmarshalData(t interface{}) error

+ type ProxyResponse struct

+ func NewProxyResponse() *ProxyResponse

+ func (p *ProxyResponse) Bind(res Response, onOpres func(response OperationResponse, send func()))

+ func (p *ProxyResponse) Bound(res Response) bool

+ func (p *ProxyResponse) Unbind(res Response)

+ type RawExtensions map[string]json.RawMessage

+ func (es RawExtensions) Unmarshal(name string, t interface{}) error

+ type Request struct

+ Context context.Context

+ Extensions map[string]interface{}

+ Operation Operation

+ OperationName string

+ Query string

+ Variables map[string]interface{}

+ type Response interface

+ Close func()

+ CloseWithError func(err error)

+ Done func() <-chan struct{}

+ Err func() error

+ Get func() OperationResponse

+ Next func() bool

+ func NewErrorResponse(err error) Response

+ type SendResponse interface

+ Send func(OperationResponse)

+ type SingleResponse struct

+ func NewSingleResponse(or OperationResponse) *SingleResponse

+ func (r *SingleResponse) Close()

+ func (r *SingleResponse) CloseWithError(err error)

+ func (r *SingleResponse) Done() <-chan struct{}

+ func (r *SingleResponse) Err() error

+ func (r *SingleResponse) Get() OperationResponse

+ func (r *SingleResponse) Next() bool

+ type Status int

+ const StatusConnected

+ const StatusDisconnected

+ const StatusReady

+ func (s Status) String() string

+ type Transport interface

+ Request func(req Request) Response

+ func Split(f func(Request) (Transport, error)) Transport

+ func SplitSubscription(subtr, othertr Transport) Transport

+ type Upload struct

+ File io.Reader

+ Name string

+ func NewUpload(f *os.File) Upload

+ func (u *Upload) UnmarshalJSON(data []byte) error

+ func (u Upload) MarshalJSON() ([]byte, error)

+ type WebsocketConn interface

+ Close func() error

+ ReadJSON func(v interface{}) error

+ SetReadLimit func(limit int64)

+ WriteJSON func(v interface{}) error

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

+ func DefaultWebsocketConnProvider(timeout time.Duration, optionfs ...WsDialOption) WebsocketConnProvider

+ type WebsocketHandler struct

+ func (wh *WebsocketHandler) Close() error

+ func (wh *WebsocketHandler) ReadJSON(v interface{}) error

+ func (wh *WebsocketHandler) WriteJSON(v interface{}) error

+ type Ws struct

+ ConnectionParams interface{}

+ URL string

+ WebsocketConnProvider WebsocketConnProvider

+ func (t *Ws) Close() error

+ func (t *Ws) GetConn() WebsocketConn

+ func (t *Ws) Request(req Request) Response

+ func (t *Ws) Reset()

+ func (t *Ws) ResetWithErr(err error)

+ func (t *Ws) Start(ctx context.Context) <-chan error

+ func (t *Ws) WaitFor(st Status, s time.Duration)

+ type WsDialOption func(o *websocket.DialOptions)