graphql

package
v1.18.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 13, 2026 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Dispatch

func Dispatch(path string, msg hermod.Message) error

Dispatch sends a message to the source that holds the given path.

func Register

func Register(path string) chan hermod.Message

Register creates the channel a GraphQL source reads its path from. It holds the path if nothing else does, and otherwise waits to take it over.

func Unregister

func Unregister(path string, ch chan hermod.Message)

Unregister releases a channel's claim on a path. Only the channel that holds the path removes it, so an outgoing engine's teardown cannot remove the source that took over from it.

Types

type GraphQLSource

type GraphQLSource struct {
	Path string
	// contains filtered or unexported fields
}

GraphQLSource implements the hermod.Source interface for receiving GraphQL requests.

func NewGraphQLSource

func NewGraphQLSource(path string) *GraphQLSource

NewGraphQLSource creates a new GraphQLSource.

func (*GraphQLSource) Ack

func (s *GraphQLSource) Ack(ctx context.Context, msg hermod.Message) error

func (*GraphQLSource) Close

func (s *GraphQLSource) Close() error

func (*GraphQLSource) Ping

func (s *GraphQLSource) Ping(ctx context.Context) error

func (*GraphQLSource) Read

func (s *GraphQLSource) Read(ctx context.Context) (hermod.Message, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL