db

package

v0.1.984 Latest Latest Go to latest Published: Mar 5, 2026 License: Apache-2.0 Imports: 7 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Client interface {
	contract.DBOperator
}

func NewClient(d Dependencies, opts ClientOptions) (Client, error)

type ClientOption = contract.Opt[ClientOptions]

func WithTimeout(x time.Duration) ClientOption

type ClientOptions struct {
	Timeout time.Duration
}

func ApplyClientOptions(opts *ClientOptions, modifiers ...ClientOption) ClientOptions

type DefaultTool struct {
	T *contract.Tool[Client]
}

func NewTool(c Client, opts contract.ToolOptions[Client]) *DefaultTool

func (d *DefaultTool) DeleteMany(ctx context.Context, opts contract.DeleteManyOptions) error

DeleteMany removes multiple documents that match the given filter.

func (d *DefaultTool) DeleteOne(ctx context.Context, opts contract.DeleteOneOptions) error

DeleteOne removes a single document that matches the provided filter.

func (d *DefaultTool) FindMany(ctx context.Context, opts contract.FindManyOptions) ([]any, error)

FindMany retrieves multiple documents that match the filter criteria.

func (d *DefaultTool) FindOne(ctx context.Context, opts contract.FindOneOptions) error

FindOne retrieves a single document from the collection based on the provided filter.

func (d *DefaultTool) InsertOne(ctx context.Context, opts contract.InsertOneOptions) error

InsertOne inserts a single document into the specified collection.

func (d *DefaultTool) ReplaceOne(ctx context.Context, opts contract.ReplaceOneOptions) error

ReplaceOne updates a document that matches the filter with the provided document.

type Dependencies struct {
	C contract.DBOperator
}

type Tool interface {
	Client
}