graphify

package module
v0.4.32 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2025 License: Unlicense Imports: 44 Imported by: 1

README

graphify

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AdminFromContext added in v0.0.11 

func AdminFromContext(ctx context.Context) (value *accountv1.Admin, found bool)

AdminFromContext ...

func ContextWithAdmin added in v0.0.11 

func ContextWithAdmin(parent context.Context, admin *accountv1.Admin) context.Context

ContextWithAdmin ...

func Convert added in v0.4.6 

func Convert[T any](size int, fn func(int) T) (result []T)

Convert converts a slice of values to a slice of values using a function

func DevelopmentContext added in v0.0.12 

func DevelopmentContext(parent context.Context) context.Context

DevelopmentContext ...

func ExposeNodes added in v0.4.3 

func ExposeNodes(nodes ...any) exposedNodes

ExposeNodes ...

func Filter added in v0.4.6 

func Filter(keyValues ...interface{}) *bindVars

Filter ...

func GenerateRandomPassword added in v0.4.6 

func GenerateRandomPassword() string

generateRandomPassword generates a random password with the following requirements: Password Length: 16 Include Alpha Upper (A-Z): true Include Alpha Lower (a-z): true Include Number (0-9): true

func IsDevelopmentContext added in v0.0.12 

func IsDevelopmentContext(ctx context.Context) (value bool)

IsDevelopmentContext ...

func Mutation added in v0.1.0 

func Mutation[Arg interfaces.GraphqlArgument, Out interfaces.GraphqlOutput](fn func(context.Context, Arg) (Out, error)) mutation

Mutation ...

func NewConnection 

func NewConnection(ctx context.Context, conf ConnectionConfig) *connection

NewConnection ...

func NewFilesystemStorage added in v0.0.6 

func NewFilesystemStorage(params FilesystemStorageConfig) *filesystemStorage

NewFilesystemStorage ...

func Pure added in v0.4.6 

func Pure[T any](v T) (result T)

Pure converts a value to a pure JSON value

func Query added in v0.1.0 

func Query[Arg interfaces.GraphqlArgument, Out interfaces.GraphqlOutput](fn func(context.Context, Arg) (Out, error)) query

Query ...

func ToMap added in v0.4.6 

func ToMap(v any) (result map[string]any)

ToMap converts a value to a map[string]any

Types

type AdminHandler added in v0.4.3 

type AdminHandler struct {
	dashboardv1.UnimplementedAuthenticationServiceServer
	dashboardv1.UnimplementedResourceServiceServer
	dashboardv1.UnimplementedSchemaServiceServer
	// contains filtered or unexported fields
}

AdminHandler ...

func NewAdminHandler added in v0.4.3 

func NewAdminHandler(ctx context.Context, config AdminHandlerConfig, params AdminHandlerParams) *AdminHandler

NewAdminHandler ...

func (*AdminHandler) CreateAccount added in v0.4.6 

func (h *AdminHandler) CreateAccount(ctx context.Context, req *dashboardv1.CreateAccountRequest) (*emptypb.Empty, error)

func (*AdminHandler) CreateResource added in v0.4.6 

func (h *AdminHandler) CreateResource(ctx context.Context, req *dashboardv1.CreateResourceRequest) (*dashboardv1.CreateResourceResponse, error)

func (*AdminHandler) DeleteResource added in v0.4.6 

func (h *AdminHandler) DeleteResource(ctx context.Context, req *dashboardv1.DeleteResourceRequest) (*emptypb.Empty, error)

func (*AdminHandler) FilesDownloadHandler added in v0.4.6 

func (h *AdminHandler) FilesDownloadHandler(w http.ResponseWriter, r *http.Request, pathParams map[string]string)

func (*AdminHandler) FilesUploadHandler added in v0.4.6 

func (h *AdminHandler) FilesUploadHandler(w http.ResponseWriter, r *http.Request, _ map[string]string)

func (*AdminHandler) GetAccount added in v0.4.6 

func (h *AdminHandler) GetAccount(ctx context.Context, req *emptypb.Empty) (*dashboardv1.GetAccountResponse, error)

func (*AdminHandler) GetResource added in v0.4.6 

func (h *AdminHandler) GetResource(ctx context.Context, req *dashboardv1.GetResourceRequest) (*dashboardv1.GetResourceResponse, error)

func (*AdminHandler) GetResourceRelation added in v0.4.6 

func (h *AdminHandler) GetResourceRelation(ctx context.Context, req *dashboardv1.GetResourceRelationRequest) (*dashboardv1.GetResourceRelationResponse, error)

func (*AdminHandler) GetSchema added in v0.4.6 

func (h *AdminHandler) GetSchema(ctx context.Context, req *emptypb.Empty) (*dashboardv1.GetSchemaResponse, error)

func (*AdminHandler) Handler added in v0.4.3 

func (h *AdminHandler) Handler(ctx context.Context) http.Handler

func (*AdminHandler) ListResources added in v0.4.6 

func (h *AdminHandler) ListResources(ctx context.Context, req *dashboardv1.ListResourcesRequest) (*dashboardv1.ListResourcesResponse, error)

func (*AdminHandler) Login added in v0.4.6 

func (h *AdminHandler) Login(ctx context.Context, req *dashboardv1.LoginRequest) (*dashboardv1.LoginResponse, error)

func (*AdminHandler) UpdateResource added in v0.4.6 

func (h *AdminHandler) UpdateResource(ctx context.Context, req *dashboardv1.UpdateResourceRequest) (*dashboardv1.UpdateResourceResponse, error)

type AdminHandlerConfig added in v0.4.3 

type AdminHandlerConfig struct {
	Secret []byte
}

AdminHandlerConfig ...

type AdminHandlerParams added in v0.4.3 

type AdminHandlerParams struct {
	fx.In

	Access   IAccess
	Graph    IGraph
	Storage  IFileStorage
	Observer IObserver[Topic]
}

AdminHandlerParams ...

type ApplicationConfig added in v0.0.9 

type ApplicationConfig struct {
	// Name ...
	Name string `json:"name"`
	// Domain ...
	Domain string `json:"domain"`
	Logo string `json:"logo"`
}

ApplicationConfig ...

type ArangoAccess added in v0.4.3 

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

func NewArangoAccess added in v0.4.3 

func NewArangoAccess(conn IConnection, observer IObserver[Topic]) *ArangoAccess

func (*ArangoAccess) AutoMigrate added in v0.4.3 

func (e *ArangoAccess) AutoMigrate(ctx context.Context, graph IGraph) error

AutoMigrate ...

func (*ArangoAccess) Collection added in v0.4.3 

func (e *ArangoAccess) Collection(ctx context.Context, elem any, callbacks ...CollectionCallback) (err error)

Collection ...

func (*ArangoAccess) Create added in v0.4.3 

func (e *ArangoAccess) Create(ctx context.Context, val any) ([]string, error)

Create ...

func (*ArangoAccess) Delete added in v0.4.3 

func (e *ArangoAccess) Delete(ctx context.Context, item any) error

Delete ...

func (*ArangoAccess) Find added in v0.4.3 

func (e *ArangoAccess) Find(ctx context.Context, bindVars IVars, out any) error

Find ...

func (*ArangoAccess) List added in v0.4.3 

func (e *ArangoAccess) List(ctx context.Context, bindVars IVars, out any) (int64, error)

List ...

func (*ArangoAccess) ListKeys added in v0.4.3 

func (e *ArangoAccess) ListKeys(ctx context.Context, keys []string, out any) error

ListKeys ...

func (*ArangoAccess) Read added in v0.4.3 

func (e *ArangoAccess) Read(ctx context.Context, key string, out any) error

Read ...

func (*ArangoAccess) Relations added in v0.4.3 

func (e *ArangoAccess) Relations(ctx context.Context, id string, bindVars IVars, direction Direction, out any) (int64, error)

Relations ...

func (*ArangoAccess) Replace added in v0.4.3 

func (e *ArangoAccess) Replace(ctx context.Context, key string, item any) error

Replace ...

func (*ArangoAccess) Update added in v0.4.3 

func (e *ArangoAccess) Update(ctx context.Context, key string, item any) error

Update ...

type CollectionCallback added in v0.4.3 

type CollectionCallback func(context.Context, driver.Collection)

CollectionCallback ...

type ConnectionConfig added in v0.4.3 

type ConnectionConfig struct {
	// DBName ...
	DBName string
	// UserName ...
	UserName string
	// Password ...
	Password string
	// Connection ...
	Connection http.ConnectionConfig
}

ConnectionConfig ...

type Direction added in v0.0.12 

type Direction string
const (
	DirectionInbound  Direction = "INBOUND"
	DirectionOutbound Direction = "OUTBOUND"
	DirectionAny      Direction = "ANY"
)

type Empty added in v0.4.3 

type Empty struct{}

Empty is ignored from graphql input

func (*Empty) Argument added in v0.4.3 

func (*Empty) Argument() graphql.FieldConfigArgument

type Event 

type Event[T comparable] struct {
	// Topic ...
	Topic T
	// Payload ...
	Payload protoreflect.ProtoMessage
	// Timestamp ...
	Timestamp time.Time
}

Event ...

type FilesystemStorageConfig added in v0.4.3 

type FilesystemStorageConfig struct {
	// BasePath ...
	BasePath string
	// MaxMemory ...
	MaxMemory int
}

FilesystemStorageConfig ...

type Graph added in v0.4.3 

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

Graph ...

func NewGraph 

func NewGraph() *Graph

NewGraph ...

func (*Graph) CollectionFor added in v0.4.3 

func (g *Graph) CollectionFor(t reflect.Type) string

CollectionFor ...

func (*Graph) Edge added in v0.4.3 

func (g *Graph) Edge(from, to, edge any)

Edge ...

func (*Graph) Edges added in v0.4.3 

func (g *Graph) Edges() []reflect.Type

Edges ...

func (*Graph) Node added in v0.4.3 

func (g *Graph) Node(node any)

Node ...

func (*Graph) Nodes added in v0.4.3 

func (g *Graph) Nodes() []reflect.Type

Nodes ...

func (*Graph) Relation added in v0.4.3 

func (g *Graph) Relation(edge reflect.Type) *Relation

Relation ...

func (*Graph) TypeOf added in v0.4.3 

func (g *Graph) TypeOf(collection string) reflect.Type

TypeOf ...

type GraphqlHandler added in v0.4.3 

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

GraphqlHandler ...

func NewGraphqlHandler added in v0.4.3 

func NewGraphqlHandler(access IAccess, graph IGraph) *GraphqlHandler

NewGraphqlHandler ...

func (*GraphqlHandler) Handle added in v0.4.8 

func (e *GraphqlHandler) Handle(ctx context.Context, handlers ...interface{}) *handler.Handler

Handle ...

type IAccess added in v0.4.3 

type IAccess interface {
	// AutoMigrate ...
	AutoMigrate(ctx context.Context, graph IGraph) error

	// Collection ...
	Collection(ctx context.Context, elem any, callbacks ...CollectionCallback) (err error)

	// List ...
	List(ctx context.Context, bindVars IVars, out any) (int64, error)

	// ListKeys ...
	ListKeys(ctx context.Context, keys []string, out any) error

	// Find ...
	Find(ctx context.Context, bindVars IVars, out any) error

	// Read ...
	Read(ctx context.Context, key string, out any) error

	// Create ...
	Create(ctx context.Context, val any) ([]string, error)

	// Update ...
	Update(ctx context.Context, key string, item any) error

	// Replace ...
	Replace(ctx context.Context, key string, item any) error

	// Delete ...
	Delete(ctx context.Context, item any) error

	// Relations ...
	Relations(ctx context.Context, id string, bindVars IVars, direction Direction, out any) (int64, error)
}

IAccess ...

type IConnection 

type IConnection interface {
	// Database ...
	Database(ctx context.Context) (driver.Database, error)
	// Collection ...
	Collection(ctx context.Context, elem any) (driver.Collection, error)
	// Reflect ...
	Reflect(ctx context.Context, elem reflect.Type) (driver.Collection, error)
}

IConnection ...

type IFileStorage added in v0.0.6 

type IFileStorage interface {
	// StoreFile ...
	StoreFile(name string, file []byte) (err error)

	// StoreByHash ...
	StoreByHash(file []byte) (hash string, err error)

	// ReadFile ...
	ReadFile(name string) (fileContent []byte, errr error)

	// MaxMemory ...
	MaxMemory() int
}

IFileStorage ...

type IGraph added in v0.4.3 

type IGraph interface {
	// Node ...
	Node(node any)
	// Edge ...
	Edge(from, to, edge any)

	// Nodes ...
	Nodes() []reflect.Type
	// Edges ...
	Edges() []reflect.Type
	// Relation ...
	Relation(edge reflect.Type) *Relation

	// CollectionFor ...
	CollectionFor(elem reflect.Type) string
	// TypeOf ...
	TypeOf(name string) reflect.Type
}

IGraph ...

type IObserver 

type IObserver[T comparable] interface {
	// Subscribe ...
	Subscribe(t T, p Processor[T]) SourceID
	// Unsubscribe ...
	Unsubscribe(s SourceID)
	// Emit ...
	Emit(e *Event[T]) error
}

IObserver ...

type IVars added in v0.4.6 

type IVars interface {
	// Limit ...
	Limit() string

	// Filters ...
	Filters() string

	// Values ...
	Values() map[string]interface{}
}

IVars ...

type Observer 

type Observer[T comparable] struct {
	// contains filtered or unexported fields
}

Observer ...

func NewObserver 

func NewObserver[T comparable]() *Observer[T]

NewObserver ...

func (*Observer[T]) Emit 

func (o *Observer[T]) Emit(e *Event[T]) error

Emit ...

func (*Observer[T]) Subscribe 

func (o *Observer[T]) Subscribe(t T, p Processor[T]) SourceID

Subscribe ...

func (*Observer[T]) Unsubscribe 

func (o *Observer[T]) Unsubscribe(s SourceID)

Unsubscribe ...

type Processor 

type Processor[T comparable] func(e *Event[T]) error

Processor ...

type Relation added in v0.4.3 

type Relation struct {
	From reflect.Type `json:"_from"`
	To   reflect.Type `json:"_to"`
}

Relation

type SourceID 

type SourceID int64

SourceID ...

type Topic 

type Topic string
var (
	CreatedTopic  Topic = "created"
	UpdatedTopic  Topic = "updated"
	ReplacedTopic Topic = "replaced"
	DeletedTopic  Topic = "deleted"
)
var (
	AdminCreatedTopic  Topic = "admin_created"
	AdminReplacedTopic Topic = "admin_replaced"
	AdminDeletedTopic  Topic = "admin_deleted"
)

func (Topic) For added in v0.0.2 

func (t Topic) For(elem any) Topic

Source Files

View all Source files

Directories

Path Synopsis
domain/common/v1
domain/library/v1
domain/relation/v1
cmd
pkg
dashboard/domain/account/v1
dashboard/domain/authentication/v1
Package authenticationv1 is a reverse proxy.
 Package authenticationv1 is a reverse proxy.
dashboard/domain/common/v1
dashboard/domain/dashboard/v1
Package dashboardv1 is a reverse proxy.
 Package dashboardv1 is a reverse proxy.
models/domain/argument/v1
models/domain/collections/v1
models/domain/graphify/argument/v1
models/domain/graphify/collections/v1
models/domain/graphify/observer/v1
models/domain/graphify/utils/v1
models/domain/observer/v1
models/domain/utils/v1

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.