natsproto

Documentation

Index

• func NewClient(subject string, conn *nats.Conn) graphqlclientgen.ProtoClient
• type Client
  • func (client Client) Do(ctx context.Context, in graphqlclientgen.Body, out any) error
• type Server
  • func NewDefaultServer(es graphql.ExecutableSchema) *Server
  • func NewServer(es graphql.ExecutableSchema) *Server
  • func (server *Server) AddTransport(transport graphql.Transport)
  • func (server *Server) AroundFields(f graphql.FieldMiddleware)
  • func (server *Server) AroundOperations(f graphql.OperationMiddleware)
  • func (server *Server) AroundResponses(f graphql.ResponseMiddleware)
  • func (server *Server) AroundRootFields(f graphql.RootFieldMiddleware)
  • func (server *Server) HandleFunc(msg *nats.Msg)
  • func (server *Server) SetErrorPresenter(f graphql.ErrorPresenterFunc)
  • func (server *Server) SetParserTokenLimit(limit int)
  • func (server *Server) SetQueryCache(cache graphql.Cache[*ast.QueryDocument])
  • func (server *Server) SetRecoverFunc(f graphql.RecoverFunc)
  • func (server *Server) Use(extension graphql.HandlerExtension)

Functions

func NewClient

func NewClient(subject string, conn *nats.Conn) graphqlclientgen.ProtoClient

NewClient creates a new Client for graphqlclientgen clients

Types

type Client

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

func (Client) Do

func (client Client) Do(ctx context.Context, in graphqlclientgen.Body, out any) error

Do performs nats request towards a GraphQL api

type Server

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

func NewDefaultServer

func NewDefaultServer(es graphql.ExecutableSchema) *Server

NewDefaultServer creates a new Server with sensible defaults for nats subscription

func NewServer

func NewServer(es graphql.ExecutableSchema) *Server

NewServer creates a new Server for nats subscription

func (*Server) AddTransport

func (server *Server) AddTransport(transport graphql.Transport)

func (*Server) AroundFields

func (server *Server) AroundFields(f graphql.FieldMiddleware)

AroundFields is a convenience method for creating an extension that only implements field middleware

func (*Server) AroundOperations

func (server *Server) AroundOperations(f graphql.OperationMiddleware)

AroundOperations is a convenience method for creating an extension that only implements operation middleware

func (*Server) AroundResponses

func (server *Server) AroundResponses(f graphql.ResponseMiddleware)

AroundResponses is a convenience method for creating an extension that only implements response middleware

func (*Server) AroundRootFields

func (server *Server) AroundRootFields(f graphql.RootFieldMiddleware)

AroundRootFields is a convenience method for creating an extension that only implements field middleware

func (*Server) HandleFunc

func (server *Server) HandleFunc(msg *nats.Msg)

HandleFunc handler for nats.Subscribe

func (*Server) SetErrorPresenter

func (server *Server) SetErrorPresenter(f graphql.ErrorPresenterFunc)

func (*Server) SetParserTokenLimit

func (server *Server) SetParserTokenLimit(limit int)

func (*Server) SetQueryCache

func (server *Server) SetQueryCache(cache graphql.Cache[*ast.QueryDocument])

func (*Server) SetRecoverFunc

func (server *Server) SetRecoverFunc(f graphql.RecoverFunc)

func (*Server) Use

func (server *Server) Use(extension graphql.HandlerExtension)