gql

Documentation

Index

• Variables
• func OnAuthorizate(authInfo AuthorizateInfo) (err definitionError.GQLError)
• func OnIntrospection() (err definitionError.GQLError)
• type Access
• type AuthorizateInfo
• type DefaultArguments
• type Directives
• type EventID
• type Gql
  • func Init(filesystem systemutils.FSInterface, folder string) *Gql
  • func (o *Gql) Directive(resolver string, object resolvers.Directive)
  • func (o *Gql) GQLRender(w http.ResponseWriter, r *http.Request, sessionID string) (isErr bool)
  • func (o *Gql) GQLRenderSubscription(mt int, message []byte, socketId, sessionID string)
  • func (o *Gql) GetScalars() Scalars
  • func (o *Gql) GetSchema() *ast.Schema
  • func (o *Gql) ObjectType(resolver string, object resolvers.ObjectTypeInterface)
  • func (o *Gql) Scalar(resolver string, object resolvers.Scalar)
  • func (o *Gql) WebsocketResponse(request HttpRequest, socketId string, requestID RequestID, mt int, ...)
  • func (o *Gql) WriteWebsocketMessage(mt int, socketId string, requestID RequestID, response *HttpResponse)
• type Grant
• type HttpRequest
• type HttpResponse
• type ObjectTypes
• type OperationID
• type RequestID
• type ResolverName
• type Response
• type Scalars
• type SocketID
• type SourceEvents
  • func (o *SourceEvents) Publish(operationID OperationID, value interface{})
• type Subscription
• type SubscriptionClose
• type TypeName
• type WebSocketRequest

Variables

var PubSub = &SourceEvents{
	subscriptionEvents: make(map[OperationID]chan interface{}, 0),
	operationEvents:    make(map[OperationID]map[EventID]*Subscription, 0),
}

Functions

func OnAuthorizate

func OnAuthorizate(authInfo AuthorizateInfo) (err definitionError.GQLError)

func OnIntrospection

func OnIntrospection() (err definitionError.GQLError)

Types

type Access

type Access []string

type AuthorizateInfo

type AuthorizateInfo struct {
	Operation string
	SrcType   TypeName
	DstType   TypeName
	Resolver  ResolverName
	SessionID string
}

type DefaultArguments

type DefaultArguments struct {
	Name    string
	IsArray bool
	Value   interface{}
	NonNull bool
	Kind    string
	Type    string
}

type Directives

type Directives map[string]resolvers.Directive

type EventID

type EventID string

type Gql

type Gql struct {
	OnIntrospection  func() (err definitionError.GQLError)
	OnAuthorizate    func(authInfo AuthorizateInfo) definitionError.GQLError
	OnScalarArgument func(scalarType string, value interface{}) (r interface{})
	// contains filtered or unexported fields
}

func Init

func Init(filesystem systemutils.FSInterface, folder string) *Gql

func (*Gql) Directive

func (o *Gql) Directive(resolver string, object resolvers.Directive)

func (*Gql) GQLRender

func (o *Gql) GQLRender(w http.ResponseWriter, r *http.Request, sessionID string) (isErr bool)

func (*Gql) GQLRenderSubscription

func (o *Gql) GQLRenderSubscription(mt int, message []byte, socketId, sessionID string)

func (*Gql) GetScalars

func (o *Gql) GetScalars() Scalars

func (*Gql) GetSchema

func (o *Gql) GetSchema() *ast.Schema

func (*Gql) ObjectType

func (o *Gql) ObjectType(resolver string, object resolvers.ObjectTypeInterface)

func (*Gql) Scalar

func (o *Gql) Scalar(resolver string, object resolvers.Scalar)

func (*Gql) WebsocketResponse

func (o *Gql) WebsocketResponse(request HttpRequest, socketId string, requestID RequestID, mt int, sessionID string)

func (*Gql) WriteWebsocketMessage

func (o *Gql) WriteWebsocketMessage(mt int, socketId string, requestID RequestID, response *HttpResponse)

type Grant

type Grant map[TypeName]map[TypeName]map[ResolverName]Access

type HttpRequest

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

type HttpResponse

type HttpResponse struct {
	Data   string `json:"data,omitempty"`
	Errors string `json:"errors,omitempty"`
}

type ObjectTypes

type ObjectTypes map[string]resolvers.ObjectTypeInterface

type OperationID

type OperationID string

type RequestID

type RequestID string

type ResolverName

type ResolverName string

type Response

type Response interface{}

type Scalars

type Scalars map[string]resolvers.Scalar

type SocketID

type SocketID string

type SourceEvents

type SourceEvents struct {
	// contains filtered or unexported fields
}

func (*SourceEvents) Publish

func (o *SourceEvents) Publish(operationID OperationID, value interface{})

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

type SubscriptionClose

type SubscriptionClose struct{}

type TypeName

type TypeName string

type WebSocketRequest

type WebSocketRequest struct {
	Id      string      `json:"id"`
	Type    string      `json:"type"`
	Payload HttpRequest `json:"payload"`
}