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 {
	AuthTarget struct {
		Headers func(childComplexity int) int
		Target  func(childComplexity int) int
		User    func(childComplexity int) int
	}

	Authorizer struct {
		Expression      func(childComplexity int) int
		Method          func(childComplexity int) int
		Name            func(childComplexity int) int
		TargetRequests  func(childComplexity int) int
		TargetResponses 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
	}

	Constraint struct {
		Expression        func(childComplexity int) int
		Gtype             func(childComplexity int) int
		Name              func(childComplexity int) int
		TargetConnections func(childComplexity int) int
		TargetDocs        func(childComplexity int) int
	}

	Constraints struct {
		Constraints 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 {
		Expression        func(childComplexity int) int
		Gtype             func(childComplexity int) int
		Name              func(childComplexity int) int
		TargetConnections func(childComplexity int) int
		TargetDocs        func(childComplexity int) int
	}

	Indexes struct {
		Indexes func(childComplexity int) int
	}

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

	Mutation struct {
		Broadcast          func(childComplexity int, input model.OutboundMessage) int
		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.EditFilter) int
		EditDoc            func(childComplexity int, input model.Edit) int
		EditDocs           func(childComplexity int, input model.EditFilter) int
		PutConnection      func(childComplexity int, input *model.PutConnection) int
		PutConnections     func(childComplexity int, input *model.PutConnections) int
		PutDoc             func(childComplexity int, input *model.PutDoc) int
		PutDocs            func(childComplexity int, input *model.PutDocs) int
		SearchAndConnect   func(childComplexity int, input model.SearchConnectFilter) int
		SearchAndConnectMe func(childComplexity int, input model.SearchConnectMeFilter) int
		SetAuthorizers     func(childComplexity int, input model.AuthorizersInput) int
		SetConstraints     func(childComplexity int, input model.ConstraintsInput) int
		SetIndexes         func(childComplexity int, input model.IndexesInput) int
		SetTriggers        func(childComplexity int, input model.TriggersInput) int
	}

	Peer struct {
		Addr   func(childComplexity int) int
		NodeID func(childComplexity int) int
	}

	Query struct {
		AggregateConnections func(childComplexity int, where model.AggFilter) int
		AggregateDocs        func(childComplexity int, where model.AggFilter) int
		ClusterState         func(childComplexity int, where *emptypb.Empty) int
		ConnectionsFrom      func(childComplexity int, where model.ConnectFilter) int
		ConnectionsTo        func(childComplexity int, where model.ConnectFilter) 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
		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
	}

	RaftState struct {
		Leader     func(childComplexity int) int
		Membership func(childComplexity int) int
		Peers      func(childComplexity int) int
		Stats      func(childComplexity int) int
	}

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

	Refs struct {
		Refs func(childComplexity int) int
	}

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

	Subscription struct {
		Stream func(childComplexity int, where model.StreamFilter) 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
	}

	Trigger struct {
		Gtype             func(childComplexity int) int
		Name              func(childComplexity int) int
		TargetConnections func(childComplexity int) int
		TargetDocs        func(childComplexity int) int
		Trigger           func(childComplexity int) int
	}

	Triggers struct {
		Triggers 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)
	PutDoc(ctx context.Context, input *model.PutDoc) (*model.Doc, error)
	PutDocs(ctx context.Context, input *model.PutDocs) (*model.Docs, error)
	EditDoc(ctx context.Context, input model.Edit) (*model.Doc, error)
	EditDocs(ctx context.Context, input model.EditFilter) (*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)
	PutConnection(ctx context.Context, input *model.PutConnection) (*model.Connection, error)
	PutConnections(ctx context.Context, input *model.PutConnections) (*model.Connections, error)
	EditConnection(ctx context.Context, input model.Edit) (*model.Connection, error)
	EditConnections(ctx context.Context, input model.EditFilter) (*model.Connections, error)
	DelConnection(ctx context.Context, input model.RefInput) (*emptypb.Empty, error)
	DelConnections(ctx context.Context, input model.Filter) (*emptypb.Empty, error)
	Broadcast(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)
	SetConstraints(ctx context.Context, input model.ConstraintsInput) (*emptypb.Empty, error)
	SetTriggers(ctx context.Context, input model.TriggersInput) (*emptypb.Empty, error)
	SearchAndConnect(ctx context.Context, input model.SearchConnectFilter) (*model.Connections, error)
	SearchAndConnectMe(ctx context.Context, input model.SearchConnectMeFilter) (*model.Connections, error)
}

type QueryResolver

type QueryResolver interface {
	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.ConnectFilter) (*model.Connections, error)
	ConnectionsTo(ctx context.Context, where model.ConnectFilter) (*model.Connections, error)
	AggregateDocs(ctx context.Context, where model.AggFilter) (float64, error)
	AggregateConnections(ctx context.Context, where model.AggFilter) (float64, error)
	ClusterState(ctx context.Context, where *emptypb.Empty) (*model.RaftState, error)
}

type ResolverRoot

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

type SubscriptionResolver

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