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.0.12

Dec 8, 2022

v0.0.11

Dec 8, 2022

v0.0.10

Dec 8, 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)