graphql

Jun 29, 2024

Changes in this version

+ const ErrGraphQLExtensionsDecode

type Client

+ func (c *Client) ExecRawWithExtensions(ctx context.Context, query string, variables map[string]any, options ...Option) ([]byte, []byte, error)

+ type NetworkError struct

+ func (e NetworkError) Body() string

+ func (e NetworkError) Error() string

+ func (e NetworkError) StatusCode() int

type Option

+ func BindExtensions(value any) Option

Mar 4, 2024

Changes in this version

type SubscriptionClient

+ func (sc *SubscriptionClient) GetSubscriptions() map[string]Subscription

Feb 26, 2024

Changes in this version

type Error

+ func (e Error) Unwrap() error

type Errors

+ func (e Errors) Unwrap() []error

type SubscriptionClient

+ func (sc *SubscriptionClient) GetSubscription(id string) *Subscription

Feb 3, 2024

Changes in this version

type Error

+ Path []interface{}

type WebsocketOptions

+ CompressionMode websocket.CompressionMode

+ CompressionThreshold int

+ HTTPHeader http.Header

+ Host string

Dec 3, 2023

Changes in this version

type SubscriptionClient

+ func (sc *SubscriptionClient) WithKeepAlive(interval time.Duration) *SubscriptionClient

+ func (sc *SubscriptionClient) WithRetryDelay(delay time.Duration) *SubscriptionClient

+ func (sc *SubscriptionClient) WithSyncMode(value bool) *SubscriptionClient

type WebsocketConn

+ Ping func() error

type WebsocketHandler

+ func (wh *WebsocketHandler) Ping() error

Apr 20, 2023

Changes in this version

+ const SubscriptionUnsubscribed

+ var ErrSubscriptionNotExists = errors.New("subscription does not exist")

Mar 16, 2023

Changes in this version

+ const SubscriptionRunning

+ const SubscriptionUnsubcribed

+ const SubscriptionWaiting

type Subscription

+ func (s *Subscription) SetStatus(status SubscriptionStatus)

+ func (s Subscription) GetID() string

+ func (s Subscription) GetKey() string

+ func (s Subscription) GetStatus() SubscriptionStatus

type SubscriptionClient

+ func (sc *SubscriptionClient) OnConnectionAlive(fn func()) *SubscriptionClient

+ func (sc *SubscriptionClient) OnSubscriptionComplete(fn func(sub Subscription)) *SubscriptionClient

+ func (sc *SubscriptionClient) WithExitWhenNoSubscription(value bool) *SubscriptionClient

+ func (sc *SubscriptionClient) WithRetryStatusCodes(codes ...string) *SubscriptionClient

type SubscriptionContext

+ OnConnectionAlive func()

+ OnDisconnected func()

+ OnSubscriptionComplete func(sub Subscription)

+ type SubscriptionStatus int32

type WebsocketConn

+ GetCloseStatus func(error) int32

type WebsocketHandler

+ func (wh *WebsocketHandler) GetCloseStatus(err error) int32

Feb 28, 2023

Changes in this version

type SubscriptionContext

+ func (sc *SubscriptionContext) Cancel()

+ func (sc *SubscriptionContext) GetContext() context.Context

+ func (sc *SubscriptionContext) GetSubscriptionsLength() int

+ func (sc *SubscriptionContext) NewContext()

Feb 13, 2023

Changes in this version

+ const GQLConnectionError

+ const GQLConnectionKeepAlive

+ const GQLConnectionTerminate

+ const GQLData

+ const GQLInternal

+ const GQLStart

+ const GQLStop

+ const GQLUnknown

+ const GraphQLWS

+ const StatusConnectionInitialisationTimeout

+ const StatusInvalidMessage

+ const StatusSubscriberAlreadyExists

+ const StatusTooManyInitialisationRequests

+ const StatusUnauthorized

+ const SubscriptionsTransportWS

+ type Doer interface

+ Do func(*http.Request) (*http.Response, error)

+ type GraphQLRequestPayload struct

+ OperationName string

+ Query string

+ Variables map[string]interface{}

type OperationMessageType

+ const GQLComplete

+ const GQLConnectionAck

+ const GQLConnectionInit

+ const GQLError

+ const GQLNext

+ const GQLPing

+ const GQLPong

+ const GQLSubscribe

+ type Subscription struct

+ func (s *Subscription) SetStarted(value bool)

+ func (s Subscription) GetHandler() func(data []byte, err error)

+ func (s Subscription) GetPayload() GraphQLRequestPayload

+ func (s Subscription) GetStarted() bool

type SubscriptionClient

+ func (sc *SubscriptionClient) WithConnectionParamsFn(fn func() map[string]interface{}) *SubscriptionClient

+ func (sc *SubscriptionClient) WithProtocol(protocol SubscriptionProtocolType) *SubscriptionClient

+ type SubscriptionContext struct

+ OnConnected func()

+ func (sc *SubscriptionContext) Close() error

+ func (sc *SubscriptionContext) GetAcknowledge() bool

+ func (sc *SubscriptionContext) GetSubscription(id string) *Subscription

+ func (sc *SubscriptionContext) GetSubscriptions() map[string]*Subscription

+ func (sc *SubscriptionContext) GetWebsocketConn() WebsocketConn

+ func (sc *SubscriptionContext) Log(message interface{}, source string, opType OperationMessageType)

+ func (sc *SubscriptionContext) Send(message interface{}, opType OperationMessageType) error

+ func (sc *SubscriptionContext) SetAcknowledge(value bool)

+ func (sc *SubscriptionContext) SetSubscription(id string, sub *Subscription)

+ func (sc *SubscriptionContext) SetWebsocketConn(conn WebsocketConn)

+ type SubscriptionProtocol interface

+ Close func(ctx *SubscriptionContext) error

+ ConnectionInit func(ctx *SubscriptionContext, connectionParams map[string]interface{}) error

+ GetSubprotocols func() []string

+ OnMessage func(ctx *SubscriptionContext, subscription *Subscription, message OperationMessage)

+ Subscribe func(ctx *SubscriptionContext, id string, sub *Subscription) error

+ Unsubscribe func(ctx *SubscriptionContext, id string) error

+ type SubscriptionProtocolType String

Sep 29, 2022

Changes in this version

type ID

+ func ToID(v interface{}) ID

Aug 9, 2022

Changes in this version

type Client

+ func (c *Client) ExecRaw(ctx context.Context, query string, variables map[string]interface{}, ...) ([]byte, error)

Jul 5, 2022

Changes in this version

+ var ErrSubscriptionStopped = errors.New("subscription stopped")

Jun 10, 2022

Changes in this version

type SubscriptionClient

+ func (sc *SubscriptionClient) Exec(query string, variables map[string]interface{}, ...) (string, error)

May 6, 2022

Changes in this version

type Client

+ func (c *Client) Exec(ctx context.Context, query string, v interface{}, ...) error

+ type GraphQLType interface

+ GetGraphQLType func() string

Mar 14, 2022

Changes in this version

+ const ErrGraphQLDecode

+ const ErrGraphQLEncode

+ const ErrJsonDecode

+ const ErrJsonEncode

+ const ErrRequestError

+ func ConstructMutation(v interface{}, variables map[string]interface{}, options ...Option) (string, error)

+ func ConstructQuery(v interface{}, variables map[string]interface{}, options ...Option) (string, error)

+ func ConstructSubscription(v interface{}, variables map[string]interface{}, options ...Option) (string, error)

+ func UnmarshalGraphQL(data []byte, v interface{}) error

type Client

+ func (c *Client) WithDebug(debug bool) *Client

+ type Error struct

+ Extensions map[string]interface{}

+ Locations []struct{ ... }

+ Message string

+ func (e Error) Error() string

type SubscriptionClient

+ func (sc *SubscriptionClient) WithWebSocketOptions(options WebsocketOptions) *SubscriptionClient

+ type WebsocketOptions struct

+ HTTPClient *http.Client

Dec 18, 2021

Changes in this version

type Client

+ func (c *Client) WithRequestModifier(f RequestModifier) *Client

+ type RequestModifier func(*http.Request)

Dec 14, 2021

Changes in this version

+ type Errors []struct

+ func (e Errors) Error() string

Nov 14, 2021

Changes in this version

+ func ElemSafe(v reflect.Value) reflect.Value

+ func FieldSafe(valStruct reflect.Value, i int) reflect.Value

+ func IndexSafe(v reflect.Value, i int) reflect.Value

Oct 18, 2021

Changes in this version

+ type Option interface

+ String func() string

+ Type func() OptionType

+ func OperationName(name string) Option

+ type OptionType string

+ const OptionTypeOperationDirective

Sep 21, 2021

Changes in this version

type SubscriptionClient

+ func (sc *SubscriptionClient) SubscribeRaw(query string, variables map[string]interface{}, ...) (string, error)

+ type WebsocketHandler struct

+ func (wh *WebsocketHandler) Close() error

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

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

Nov 12, 2020

Changes in this version

type Client

+ func (c *Client) MutateRaw(ctx context.Context, m interface{}, variables map[string]interface{}) (*json.RawMessage, error)

+ func (c *Client) NamedMutateRaw(ctx context.Context, name string, m interface{}, ...) (*json.RawMessage, error)

+ func (c *Client) NamedQueryRaw(ctx context.Context, name string, q interface{}, ...) (*json.RawMessage, error)

+ func (c *Client) QueryRaw(ctx context.Context, q interface{}, variables map[string]interface{}) (*json.RawMessage, error)

Sep 1, 2020

Changes in this version

+ type Boolean bool

+ func NewBoolean(v Boolean) *Boolean

+ type Client struct

+ func NewClient(url string, httpClient *http.Client) *Client

+ func (c *Client) Mutate(ctx context.Context, m interface{}, variables map[string]interface{}) error

+ func (c *Client) NamedMutate(ctx context.Context, name string, m interface{}, ...) error

+ func (c *Client) NamedQuery(ctx context.Context, name string, q interface{}, ...) error

+ func (c *Client) Query(ctx context.Context, q interface{}, variables map[string]interface{}) error

+ type Float float64

+ func NewFloat(v Float) *Float

+ type ID interface

+ func NewID(v ID) *ID

+ type Int int32

+ func NewInt(v Int) *Int

+ type OperationMessage struct

+ ID string

+ Payload json.RawMessage

+ Type OperationMessageType

+ func (om 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 String string

+ func NewString(v String) *String

+ type SubscriptionClient struct

+ func NewSubscriptionClient(url string) *SubscriptionClient

+ func (sc *SubscriptionClient) Close() (err error)

+ func (sc *SubscriptionClient) GetContext() context.Context

+ func (sc *SubscriptionClient) GetTimeout() time.Duration

+ func (sc *SubscriptionClient) GetURL() string

+ func (sc *SubscriptionClient) NamedSubscribe(name string, v interface{}, variables map[string]interface{}, ...) (string, error)

+ func (sc *SubscriptionClient) OnConnected(fn func()) *SubscriptionClient

+ func (sc *SubscriptionClient) OnDisconnected(fn func()) *SubscriptionClient

+ func (sc *SubscriptionClient) OnError(onError func(sc *SubscriptionClient, err error) error) *SubscriptionClient

+ func (sc *SubscriptionClient) Reset() error

+ func (sc *SubscriptionClient) Run() error

+ func (sc *SubscriptionClient) Subscribe(v interface{}, variables map[string]interface{}, ...) (string, error)

+ func (sc *SubscriptionClient) Unsubscribe(id string) error

+ func (sc *SubscriptionClient) WithConnectionParams(params map[string]interface{}) *SubscriptionClient

+ func (sc *SubscriptionClient) WithLog(logger func(args ...interface{})) *SubscriptionClient

+ func (sc *SubscriptionClient) WithReadLimit(limit int64) *SubscriptionClient

+ func (sc *SubscriptionClient) WithRetryTimeout(timeout time.Duration) *SubscriptionClient

+ func (sc *SubscriptionClient) WithTimeout(timeout time.Duration) *SubscriptionClient

+ func (sc *SubscriptionClient) WithWebSocket(fn func(sc *SubscriptionClient) (WebsocketConn, error)) *SubscriptionClient

+ func (sc *SubscriptionClient) WithoutLogTypes(types ...OperationMessageType) *SubscriptionClient

+ type WebsocketConn interface

+ Close func() error

+ ReadJSON func(v interface{}) error

+ SetReadLimit func(limit int64)

+ WriteJSON func(v interface{}) error