generated

Documentation

Index

• func NewExecutableSchema(cfg Config) graphql.ExecutableSchema
• type ComplexityRoot
• type Config
• type DirectiveRoot
• type MutationResolver
• type QueryResolver
• type ResolverRoot
• type SubscriptionResolver

Functions

func NewExecutableSchema

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

Types

type ComplexityRoot

type ComplexityRoot struct {
	Authorizer struct {
		Expression func(childComplexity int) int
		Name       func(childComplexity int) int
	}

	Authorizers struct {
		Authorizers func(childComplexity int) int
	}

	Connection struct {
		Attributes func(childComplexity int) int
		Directed   func(childComplexity int) int
		From       func(childComplexity int) int
		Ref        func(childComplexity int) int
		To         func(childComplexity int) int
	}

	Connections struct {
		Connections func(childComplexity int) int
		SeekNext    func(childComplexity int) int
	}

	Doc struct {
		Attributes func(childComplexity int) int
		Ref        func(childComplexity int) int
	}

	Docs struct {
		Docs     func(childComplexity int) int
		SeekNext func(childComplexity int) int
	}

	Index struct {
		Connections func(childComplexity int) int
		Docs        func(childComplexity int) int
		Expression  func(childComplexity int) int
		Gtype       func(childComplexity int) int
		Name        func(childComplexity int) int
	}

	Indexes struct {
		Indexes func(childComplexity int) int
	}

	Message struct {
		Channel   func(childComplexity int) int
		Data      func(childComplexity int) int
		Sender    func(childComplexity int) int
		Timestamp func(childComplexity int) int
	}

	Mutation struct {
		CreateConnection  func(childComplexity int, input model.ConnectionConstructor) int
		CreateConnections func(childComplexity int, input model.ConnectionConstructors) int
		CreateDoc         func(childComplexity int, input model.DocConstructor) int
		CreateDocs        func(childComplexity int, input model.DocConstructors) int
		DelConnection     func(childComplexity int, input model.RefInput) int
		DelConnections    func(childComplexity int, input model.Filter) int
		DelDoc            func(childComplexity int, input model.RefInput) int
		DelDocs           func(childComplexity int, input model.Filter) int
		EditConnection    func(childComplexity int, input model.Edit) int
		EditConnections   func(childComplexity int, input model.EFilter) int
		EditDoc           func(childComplexity int, input model.Edit) int
		EditDocs          func(childComplexity int, input model.EFilter) int
		Publish           func(childComplexity int, input model.OutboundMessage) int
		SearchAndConnect  func(childComplexity int, where model.SConnectFilter) int
		SetAuthorizers    func(childComplexity int, input model.AuthorizersInput) int
		SetIndexes        func(childComplexity int, input model.IndexesInput) int
		SetTypeValidators func(childComplexity int, input model.TypeValidatorsInput) int
	}

	Pong struct {
		Message func(childComplexity int) int
	}

	Query struct {
		AggregateConnections func(childComplexity int, where model.AggFilter) int
		AggregateDocs        func(childComplexity int, where model.AggFilter) int
		ConnectionsFrom      func(childComplexity int, where model.CFilter) int
		ConnectionsTo        func(childComplexity int, where model.CFilter) int
		ExistsConnection     func(childComplexity int, where model.ExistsFilter) int
		ExistsDoc            func(childComplexity int, where model.ExistsFilter) int
		GetConnection        func(childComplexity int, where model.RefInput) int
		GetDoc               func(childComplexity int, where model.RefInput) int
		GetSchema            func(childComplexity int, where *emptypb.Empty) int
		HasConnection        func(childComplexity int, where model.RefInput) int
		HasDoc               func(childComplexity int, where model.RefInput) int
		Me                   func(childComplexity int, where *emptypb.Empty) int
		Ping                 func(childComplexity int, where *emptypb.Empty) int
		SearchConnections    func(childComplexity int, where model.Filter) int
		SearchDocs           func(childComplexity int, where model.Filter) int
		Traverse             func(childComplexity int, where model.TraverseFilter) int
		TraverseMe           func(childComplexity int, where model.TraverseMeFilter) int
	}

	Ref struct {
		Gid   func(childComplexity int) int
		Gtype func(childComplexity int) int
	}

	Refs struct {
		Refs func(childComplexity int) int
	}

	Request struct {
		Method    func(childComplexity int) int
		Request   func(childComplexity int) int
		Timestamp func(childComplexity int) int
		User      func(childComplexity int) int
	}

	Schema struct {
		Authorizers     func(childComplexity int) int
		ConnectionTypes func(childComplexity int) int
		DocTypes        func(childComplexity int) int
		Indexes         func(childComplexity int) int
		Validators      func(childComplexity int) int
	}

	Subscription struct {
		Subscribe func(childComplexity int, where model.ChanFilter) int
	}

	Traversal struct {
		Depth         func(childComplexity int) int
		Doc           func(childComplexity int) int
		Hops          func(childComplexity int) int
		TraversalPath func(childComplexity int) int
	}

	Traversals struct {
		Traversals func(childComplexity int) int
	}

	TypeValidator struct {
		Connections func(childComplexity int) int
		Docs        func(childComplexity int) int
		Expression  func(childComplexity int) int
		Gtype       func(childComplexity int) int
		Name        func(childComplexity int) int
	}

	TypeValidators struct {
		Validators func(childComplexity int) int
	}
}

type Config

type Config struct {
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type DirectiveRoot

type DirectiveRoot struct {
}

type MutationResolver

type MutationResolver interface {
	CreateDoc(ctx context.Context, input model.DocConstructor) (*model.Doc, error)
	CreateDocs(ctx context.Context, input model.DocConstructors) (*model.Docs, error)
	EditDoc(ctx context.Context, input model.Edit) (*model.Doc, error)
	EditDocs(ctx context.Context, input model.EFilter) (*model.Docs, error)
	DelDoc(ctx context.Context, input model.RefInput) (*emptypb.Empty, error)
	DelDocs(ctx context.Context, input model.Filter) (*emptypb.Empty, error)
	CreateConnection(ctx context.Context, input model.ConnectionConstructor) (*model.Connection, error)
	CreateConnections(ctx context.Context, input model.ConnectionConstructors) (*model.Connections, error)
	EditConnection(ctx context.Context, input model.Edit) (*model.Connection, error)
	EditConnections(ctx context.Context, input model.EFilter) (*model.Connections, error)
	DelConnection(ctx context.Context, input model.RefInput) (*emptypb.Empty, error)
	DelConnections(ctx context.Context, input model.Filter) (*emptypb.Empty, error)
	Publish(ctx context.Context, input model.OutboundMessage) (*emptypb.Empty, error)
	SetIndexes(ctx context.Context, input model.IndexesInput) (*emptypb.Empty, error)
	SetAuthorizers(ctx context.Context, input model.AuthorizersInput) (*emptypb.Empty, error)
	SetTypeValidators(ctx context.Context, input model.TypeValidatorsInput) (*emptypb.Empty, error)
	SearchAndConnect(ctx context.Context, where model.SConnectFilter) (*model.Connections, error)
}

type QueryResolver

type QueryResolver interface {
	Ping(ctx context.Context, where *emptypb.Empty) (*model.Pong, error)
	GetSchema(ctx context.Context, where *emptypb.Empty) (*model.Schema, error)
	Me(ctx context.Context, where *emptypb.Empty) (*model.Doc, error)
	GetDoc(ctx context.Context, where model.RefInput) (*model.Doc, error)
	SearchDocs(ctx context.Context, where model.Filter) (*model.Docs, error)
	Traverse(ctx context.Context, where model.TraverseFilter) (*model.Traversals, error)
	TraverseMe(ctx context.Context, where model.TraverseMeFilter) (*model.Traversals, error)
	GetConnection(ctx context.Context, where model.RefInput) (*model.Connection, error)
	ExistsDoc(ctx context.Context, where model.ExistsFilter) (bool, error)
	ExistsConnection(ctx context.Context, where model.ExistsFilter) (bool, error)
	HasDoc(ctx context.Context, where model.RefInput) (bool, error)
	HasConnection(ctx context.Context, where model.RefInput) (bool, error)
	SearchConnections(ctx context.Context, where model.Filter) (*model.Connections, error)
	ConnectionsFrom(ctx context.Context, where model.CFilter) (*model.Connections, error)
	ConnectionsTo(ctx context.Context, where model.CFilter) (*model.Connections, error)
	AggregateDocs(ctx context.Context, where model.AggFilter) (float64, error)
	AggregateConnections(ctx context.Context, where model.AggFilter) (float64, error)
}

type ResolverRoot

type ResolverRoot interface {
	Mutation() MutationResolver
	Query() QueryResolver
	Subscription() SubscriptionResolver
}

type SubscriptionResolver

type SubscriptionResolver interface {
	Subscribe(ctx context.Context, where model.ChanFilter) (<-chan *model.Message, error)
}