graphify

Documentation

Index

• func CollectionFor(t reflect.Type) string
• func ContextWithDatabaseConfig(ctx context.Context, cnf DatabaseConfig) context.Context
• func Create(ctx context.Context, val interface{}, comm *Common) ([]string, error)
• func Delete(ctx context.Context, item interface{}, comm *Common) error
• func List(ctx context.Context, offset, count int, out interface{}, comm *Common) (int, error)
• func ListKeys(ctx context.Context, keys []string, out interface{}, comm *Common) error
• func NewConnection() *connection
• func NewGraph(comm *Common) *graph
• func Read(ctx context.Context, key string, out interface{}, comm *Common) error
• func Update(ctx context.Context, key string, item interface{}, comm *Common) error
• func WriteErrorResponse(w http.ResponseWriter, status int, err error)
• func WriteJSONResponse(w http.ResponseWriter, status int, data interface{})
• func WriteResponse(w http.ResponseWriter, status int, data []byte)
• func WriteSuccessResponse(w http.ResponseWriter, status int)
• type Common
• type DatabaseConfig
  • func DatabaseConfigFromContext(ctx context.Context) (*DatabaseConfig, error)
• type Event
• type IConnection
• type IObserver
• type Observer
  • func NewObserver[T comparable]() *Observer[T]
  • func (o *Observer[T]) Emit(e *Event[T]) error
  • func (o *Observer[T]) Subscribe(t T, p Processor[T]) SourceID
  • func (o *Observer[T]) Unsubscribe(s SourceID)
• type Processor
• type SourceID
• type Topic
  • func (t Topic) For(elem interface{}) Topic

Functions

func CollectionFor

func CollectionFor(t reflect.Type) string

CollectionFor ...

func ContextWithDatabaseConfig

func ContextWithDatabaseConfig(ctx context.Context, cnf DatabaseConfig) context.Context

ContextWithDatabaseConfig ...

func Create

func Create(ctx context.Context, val interface{}, comm *Common) ([]string, error)

Create ...

func Delete

func Delete(ctx context.Context, item interface{}, comm *Common) error

Delete ...

func List

func List(ctx context.Context, offset, count int, out interface{}, comm *Common) (int, error)

List ...

func ListKeys

func ListKeys(ctx context.Context, keys []string, out interface{}, comm *Common) error

ListKeys ...

func NewConnection

func NewConnection() *connection

NewConnection ...

func NewGraph

func NewGraph(comm *Common) *graph

func Read

func Read(ctx context.Context, key string, out interface{}, comm *Common) error

Read ...

func Update

func Update(ctx context.Context, key string, item interface{}, comm *Common) error

Update ...

func WriteErrorResponse

func WriteErrorResponse(w http.ResponseWriter, status int, err error)

func WriteJSONResponse

func WriteJSONResponse(w http.ResponseWriter, status int, data interface{})

func WriteResponse

func WriteResponse(w http.ResponseWriter, status int, data []byte)

func WriteSuccessResponse

func WriteSuccessResponse(w http.ResponseWriter, status int)

Types

type Common

type Common struct {
	Observer   IObserver[Topic]
	Connection IConnection
}

type DatabaseConfig

type DatabaseConfig struct {
	// Name ...
	Name string
}

DatabaseConfig ...

func DatabaseConfigFromContext

func DatabaseConfigFromContext(ctx context.Context) (*DatabaseConfig, error)

DatabaseConfigFromContext ...

type Event

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

Event ...

type IConnection

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

IConnection ...

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 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 SourceID

type SourceID int64

SourceID ...

type Topic

type Topic string

var (
	CreatedTopic Topic = "created"
	UpdatedTopic Topic = "updated"
	DeletedTopic Topic = "deleted"
)

func (Topic) For

func (t Topic) For(elem interface{}) Topic