mongorpc

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jan 5, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package mongorpc provides the gRPC service implementations.

Package mongorpc provides the gRPC service implementations.

Package mongorpc provides the gRPC service implementations.

Package mongorpc provides streaming RPC implementations.

Package mongorpc provides transaction RPC implementations.

Package mongorpc provides additional RPC method implementations.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server 

type Server struct {
	mongorpcv1.UnimplementedMongoRPCServer
	// contains filtered or unexported fields
}

Server implements the MongoRPC gRPC service.

func NewServer 

func NewServer(db *mongodb.Client, rules *rules.Engine, adminKey, adminSecret string) *Server

NewServer creates a new MongoRPC server.

func (*Server) AbortTransaction 

func (s *Server) AbortTransaction(ctx context.Context, req *mongorpcv1.AbortTransactionRequest) (*mongorpcv1.AbortTransactionResponse, error)

AbortTransaction aborts an active transaction.

func (*Server) Aggregate 

func (s *Server) Aggregate(req *mongorpcv1.AggregateRequest, stream mongorpcv1.MongoRPC_AggregateServer) error

Aggregate runs an aggregation pipeline with streaming results.

func (*Server) BatchGetDocuments 

func (s *Server) BatchGetDocuments(req *mongorpcv1.BatchGetDocumentsRequest, stream mongorpcv1.MongoRPC_BatchGetDocumentsServer) error

BatchGetDocuments gets multiple documents by ID with streaming.

func (*Server) BeginTransaction 

func (s *Server) BeginTransaction(ctx context.Context, req *mongorpcv1.BeginTransactionRequest) (*mongorpcv1.BeginTransactionResponse, error)

BeginTransaction starts a new transaction.

func (*Server) CommitTransaction 

func (s *Server) CommitTransaction(ctx context.Context, req *mongorpcv1.CommitTransactionRequest) (*mongorpcv1.CommitTransactionResponse, error)

CommitTransaction commits an active transaction.

func (*Server) CountDocuments 

func (s *Server) CountDocuments(ctx context.Context, req *mongorpcv1.CountDocumentsRequest) (*mongorpcv1.CountDocumentsResponse, error)

CountDocuments counts documents matching a filter.

func (*Server) CreateCollection 

func (s *Server) CreateCollection(ctx context.Context, req *mongorpcv1.CreateCollectionRequest) (*emptypb.Empty, error)

CreateCollection creates a new collection.

func (*Server) CreateDocument 

func (s *Server) CreateDocument(ctx context.Context, req *mongorpcv1.CreateDocumentRequest) (*mongorpcv1.CreateDocumentResponse, error)

CreateDocument creates a new document.

func (*Server) CreateIndex 

func (s *Server) CreateIndex(ctx context.Context, req *mongorpcv1.CreateIndexRequest) (*mongorpcv1.CreateIndexResponse, error)

CreateIndex creates an index on a collection.

func (*Server) DeleteDocument 

func (s *Server) DeleteDocument(ctx context.Context, req *mongorpcv1.DeleteDocumentRequest) (*mongorpcv1.DeleteDocumentResponse, error)

DeleteDocument deletes a document by ID.

func (*Server) DeleteMany 

func (s *Server) DeleteMany(ctx context.Context, req *mongorpcv1.DeleteManyRequest) (*mongorpcv1.DeleteManyResponse, error)

DeleteMany deletes multiple documents.

func (*Server) DropCollection 

func (s *Server) DropCollection(ctx context.Context, req *mongorpcv1.DropCollectionRequest) (*emptypb.Empty, error)

DropCollection drops a collection.

func (*Server) DropIndex 

func (s *Server) DropIndex(ctx context.Context, req *mongorpcv1.DropIndexRequest) (*emptypb.Empty, error)

DropIndex removes an index from a collection.

func (*Server) GetDocument 

func (s *Server) GetDocument(ctx context.Context, req *mongorpcv1.GetDocumentRequest) (*mongorpcv1.GetDocumentResponse, error)

GetDocument retrieves a single document by ID.

func (*Server) GetSession 

func (s *Server) GetSession(txnID string) (*mongo.Session, bool)

GetSession returns the session for a transaction (for use in other RPC methods).

func (*Server) InsertMany 

func (s *Server) InsertMany(ctx context.Context, req *mongorpcv1.InsertManyRequest) (*mongorpcv1.InsertManyResponse, error)

InsertMany inserts multiple documents.

func (*Server) ListCollections 

func (s *Server) ListCollections(ctx context.Context, req *mongorpcv1.ListCollectionsRequest) (*mongorpcv1.ListCollectionsResponse, error)

ListCollections lists all collections in a database.

func (*Server) ListDocuments 

func (s *Server) ListDocuments(ctx context.Context, req *mongorpcv1.ListDocumentsRequest) (*mongorpcv1.ListDocumentsResponse, error)

ListDocuments lists documents in a collection.

func (*Server) ListIndexes 

func (s *Server) ListIndexes(ctx context.Context, req *mongorpcv1.ListIndexesRequest) (*mongorpcv1.ListIndexesResponse, error)

ListIndexes lists all indexes on a collection.

func (*Server) RenameCollection 

func (s *Server) RenameCollection(ctx context.Context, req *mongorpcv1.RenameCollectionRequest) (*emptypb.Empty, error)

RenameCollection renames a collection.

func (*Server) RunQuery 

func (s *Server) RunQuery(req *mongorpcv1.RunQueryRequest, stream mongorpcv1.MongoRPC_RunQueryServer) error

RunQuery runs a query with streaming results.

func (*Server) UpdateDocument 

func (s *Server) UpdateDocument(ctx context.Context, req *mongorpcv1.UpdateDocumentRequest) (*mongorpcv1.UpdateDocumentResponse, error)

UpdateDocument updates an existing document.

func (*Server) UpdateMany 

func (s *Server) UpdateMany(ctx context.Context, req *mongorpcv1.UpdateManyRequest) (*mongorpcv1.UpdateManyResponse, error)

UpdateMany updates multiple documents.

func (*Server) Watch 

func (s *Server) Watch(req *mongorpcv1.WatchRequest, stream mongorpcv1.MongoRPC_WatchServer) error

Watch watches a collection for changes (change streams).

type TransactionManager 

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

TransactionManager manages active transactions.

func NewTransactionManager 

func NewTransactionManager() *TransactionManager

NewTransactionManager creates a new transaction manager.

Source Files

View all Source files

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.