mongodb

Documentation

Index

• type MongodbConnection
  • func NewMongoConnection(ctx context.Context, url string) (*MongodbConnection, error)
  • func (c *MongodbConnection) Close(handler func(err error))
• type MongodbOperator
  • func NewMongoOperator[T any](connection *MongodbConnection) *MongodbOperator[T]
  • func (c *MongodbOperator[T]) Create(ctx context.Context, collection *clerk.Collection, data T) error
  • func (c *MongodbOperator[T]) Delete(ctx context.Context, collection *clerk.Collection, filter map[string]any) error
  • func (c *MongodbOperator[T]) Query(ctx context.Context, collection *clerk.Collection, filter map[string]any, ...) (<-chan T, error)
  • func (c *MongodbOperator[T]) Update(ctx context.Context, collection *clerk.Collection, filter map[string]any, ...) error
  • func (c *MongodbOperator[T]) Watch(ctx context.Context, collection *clerk.Collection, operation clerk.Operation) (<-chan T, error)

Types

type MongodbConnection

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

func NewMongoConnection

func NewMongoConnection(ctx context.Context, url string) (*MongodbConnection, error)

func (*MongodbConnection) Close

func (c *MongodbConnection) Close(handler func(err error))

type MongodbOperator

type MongodbOperator[T any] struct {
	// contains filtered or unexported fields
}

func NewMongoOperator

func NewMongoOperator[T any](connection *MongodbConnection) *MongodbOperator[T]

func (*MongodbOperator[T]) Create

func (c *MongodbOperator[T]) Create(
	ctx context.Context,
	collection *clerk.Collection,
	data T,
) error

func (*MongodbOperator[T]) Delete

func (c *MongodbOperator[T]) Delete(
	ctx context.Context,
	collection *clerk.Collection,
	filter map[string]any,
) error

func (*MongodbOperator[T]) Query

func (c *MongodbOperator[T]) Query(
	ctx context.Context,
	collection *clerk.Collection,
	filter map[string]any,
	skip int,
	take int,
) (<-chan T, error)

func (*MongodbOperator[T]) Update

func (c *MongodbOperator[T]) Update(
	ctx context.Context,
	collection *clerk.Collection,
	filter map[string]any,
	data T,
	upsert bool,
) error

func (*MongodbOperator[T]) Watch

func (c *MongodbOperator[T]) Watch(
	ctx context.Context,
	collection *clerk.Collection,
	operation clerk.Operation,
) (<-chan T, error)