mongorpc

package
v0.0.0-...-8524f9a Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	IndexDirection_name = map[int32]string{
		0: "ASCENDING",
		1: "DESCENDING",
	}
	IndexDirection_value = map[string]int32{
		"ASCENDING":  0,
		"DESCENDING": 1,
	}
)

Enum value maps for IndexDirection.

View Source 
var (
	NullValue_name = map[int32]string{
		0: "NULL_VALUE",
	}
	NullValue_value = map[string]int32{
		"NULL_VALUE": 0,
	}
)

Enum value maps for NullValue.

View Source 
var File_mongorpc_admin_proto protoreflect.FileDescriptor
View Source 
var File_mongorpc_mongorpc_proto protoreflect.FileDescriptor
View Source 
var File_mongorpc_value_proto protoreflect.FileDescriptor
View Source 
var MongoRPCAdmin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mongorpc.MongoRPCAdmin",
	HandlerType: (*MongoRPCAdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDatabases",
			Handler:    _MongoRPCAdmin_ListDatabases_Handler,
		},
		{
			MethodName: "DropDatabase",
			Handler:    _MongoRPCAdmin_DropDatabase_Handler,
		},
		{
			MethodName: "CreateCollection",
			Handler:    _MongoRPCAdmin_CreateCollection_Handler,
		},
		{
			MethodName: "DropCollection",
			Handler:    _MongoRPCAdmin_DropCollection_Handler,
		},
		{
			MethodName: "ListCollections",
			Handler:    _MongoRPCAdmin_ListCollections_Handler,
		},
		{
			MethodName: "ListIndexes",
			Handler:    _MongoRPCAdmin_ListIndexes_Handler,
		},
		{
			MethodName: "CreateIndex",
			Handler:    _MongoRPCAdmin_CreateIndex_Handler,
		},
		{
			MethodName: "DropIndex",
			Handler:    _MongoRPCAdmin_DropIndex_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mongorpc/admin.proto",
}

MongoRPCAdmin_ServiceDesc is the grpc.ServiceDesc for MongoRPCAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var MongoRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mongorpc.MongoRPC",
	HandlerType: (*MongoRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDocument",
			Handler:    _MongoRPC_GetDocument_Handler,
		},
		{
			MethodName: "InsertDocument",
			Handler:    _MongoRPC_InsertDocument_Handler,
		},
		{
			MethodName: "UpdateDocument",
			Handler:    _MongoRPC_UpdateDocument_Handler,
		},
		{
			MethodName: "DeleteDocument",
			Handler:    _MongoRPC_DeleteDocument_Handler,
		},
		{
			MethodName: "BulkInsertDocuments",
			Handler:    _MongoRPC_BulkInsertDocuments_Handler,
		},
		{
			MethodName: "QueryDocuments",
			Handler:    _MongoRPC_QueryDocuments_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Listen",
			Handler:       _MongoRPC_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "mongorpc/mongorpc.proto",
}

MongoRPC_ServiceDesc is the grpc.ServiceDesc for MongoRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMongoRPCAdminServer 

func RegisterMongoRPCAdminServer(s grpc.ServiceRegistrar, srv MongoRPCAdminServer)

func RegisterMongoRPCServer 

func RegisterMongoRPCServer(s grpc.ServiceRegistrar, srv MongoRPCServer)

Types

type ArrayValue 

type ArrayValue struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Array is a special type that is used to represent an array value in a MongoDB

func (*ArrayValue) Descriptor deprecated 

func (*ArrayValue) Descriptor() ([]byte, []int)

Deprecated: Use ArrayValue.ProtoReflect.Descriptor instead.

func (*ArrayValue) GetValues 

func (x *ArrayValue) GetValues() []*Value

func (*ArrayValue) ProtoMessage 

func (*ArrayValue) ProtoMessage()

func (*ArrayValue) ProtoReflect 

func (x *ArrayValue) ProtoReflect() protoreflect.Message

func (*ArrayValue) Reset 

func (x *ArrayValue) Reset()

func (*ArrayValue) String 

func (x *ArrayValue) String() string

type BulkInsertDocumentsRequest 

type BulkInsertDocumentsRequest struct {

	// The database to insert the documents into
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// The collection to insert the documents into
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// The documents to insert
	Documents []*Value `protobuf:"bytes,3,rep,name=documents,proto3" json:"documents,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkInsertDocumentsRequest) Descriptor deprecated 

func (*BulkInsertDocumentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use BulkInsertDocumentsRequest.ProtoReflect.Descriptor instead.

func (*BulkInsertDocumentsRequest) GetCollection 

func (x *BulkInsertDocumentsRequest) GetCollection() string

func (*BulkInsertDocumentsRequest) GetDatabase 

func (x *BulkInsertDocumentsRequest) GetDatabase() string

func (*BulkInsertDocumentsRequest) GetDocuments 

func (x *BulkInsertDocumentsRequest) GetDocuments() []*Value

func (*BulkInsertDocumentsRequest) ProtoMessage 

func (*BulkInsertDocumentsRequest) ProtoMessage()

func (*BulkInsertDocumentsRequest) ProtoReflect 

func (x *BulkInsertDocumentsRequest) ProtoReflect() protoreflect.Message

func (*BulkInsertDocumentsRequest) Reset 

func (x *BulkInsertDocumentsRequest) Reset()

func (*BulkInsertDocumentsRequest) String 

func (x *BulkInsertDocumentsRequest) String() string

type ChangeStreamOptions 

type ChangeStreamOptions struct {
	BatchSize            int32      `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	FullDocument         bool       `protobuf:"varint,3,opt,name=full_document,json=fullDocument,proto3" json:"full_document,omitempty"`
	StartAtOperationTime *Timestamp `protobuf:"bytes,4,opt,name=start_at_operation_time,json=startAtOperationTime,proto3" json:"start_at_operation_time,omitempty"`
	MaxAwaitTimeMs       *Timestamp `protobuf:"bytes,5,opt,name=max_await_time_ms,json=maxAwaitTimeMs,proto3" json:"max_await_time_ms,omitempty"`
	ResumeAfter          *Value     `protobuf:"bytes,6,opt,name=resume_after,json=resumeAfter,proto3" json:"resume_after,omitempty"`
	Collation            *Value     `protobuf:"bytes,7,opt,name=collation,proto3" json:"collation,omitempty"`
	StartAfter           *Value     `protobuf:"bytes,8,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	// contains filtered or unexported fields
}

ChangeStreamOptions represents options that can be used to configure a Watch operation.

func (*ChangeStreamOptions) Descriptor deprecated 

func (*ChangeStreamOptions) Descriptor() ([]byte, []int)

Deprecated: Use ChangeStreamOptions.ProtoReflect.Descriptor instead.

func (*ChangeStreamOptions) GetBatchSize 

func (x *ChangeStreamOptions) GetBatchSize() int32

func (*ChangeStreamOptions) GetCollation 

func (x *ChangeStreamOptions) GetCollation() *Value

func (*ChangeStreamOptions) GetFullDocument 

func (x *ChangeStreamOptions) GetFullDocument() bool

func (*ChangeStreamOptions) GetMaxAwaitTimeMs 

func (x *ChangeStreamOptions) GetMaxAwaitTimeMs() *Timestamp

func (*ChangeStreamOptions) GetResumeAfter 

func (x *ChangeStreamOptions) GetResumeAfter() *Value

func (*ChangeStreamOptions) GetStartAfter 

func (x *ChangeStreamOptions) GetStartAfter() *Value

func (*ChangeStreamOptions) GetStartAtOperationTime 

func (x *ChangeStreamOptions) GetStartAtOperationTime() *Timestamp

func (*ChangeStreamOptions) ProtoMessage 

func (*ChangeStreamOptions) ProtoMessage()

func (*ChangeStreamOptions) ProtoReflect 

func (x *ChangeStreamOptions) ProtoReflect() protoreflect.Message

func (*ChangeStreamOptions) Reset 

func (x *ChangeStreamOptions) Reset()

func (*ChangeStreamOptions) String 

func (x *ChangeStreamOptions) String() string

type CreateCollectionOptions 

type CreateCollectionOptions struct {
	Size             int64  `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Max              int64  `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	Validator        *Value `protobuf:"bytes,3,opt,name=validator,proto3" json:"validator,omitempty"`
	ValidationLevel  string `protobuf:"bytes,4,opt,name=validationLevel,proto3" json:"validationLevel,omitempty"`
	ValidationAction string `protobuf:"bytes,5,opt,name=validationAction,proto3" json:"validationAction,omitempty"`
	StorageEngine    *Value `protobuf:"bytes,6,opt,name=storageEngine,proto3" json:"storageEngine,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCollectionOptions) Descriptor deprecated 

func (*CreateCollectionOptions) Descriptor() ([]byte, []int)

Deprecated: Use CreateCollectionOptions.ProtoReflect.Descriptor instead.

func (*CreateCollectionOptions) GetMax 

func (x *CreateCollectionOptions) GetMax() int64

func (*CreateCollectionOptions) GetSize 

func (x *CreateCollectionOptions) GetSize() int64

func (*CreateCollectionOptions) GetStorageEngine 

func (x *CreateCollectionOptions) GetStorageEngine() *Value

func (*CreateCollectionOptions) GetValidationAction 

func (x *CreateCollectionOptions) GetValidationAction() string

func (*CreateCollectionOptions) GetValidationLevel 

func (x *CreateCollectionOptions) GetValidationLevel() string

func (*CreateCollectionOptions) GetValidator 

func (x *CreateCollectionOptions) GetValidator() *Value

func (*CreateCollectionOptions) ProtoMessage 

func (*CreateCollectionOptions) ProtoMessage()

func (*CreateCollectionOptions) ProtoReflect 

func (x *CreateCollectionOptions) ProtoReflect() protoreflect.Message

func (*CreateCollectionOptions) Reset 

func (x *CreateCollectionOptions) Reset()

func (*CreateCollectionOptions) String 

func (x *CreateCollectionOptions) String() string

type CreateCollectionRequest 

type CreateCollectionRequest struct {
	Database   string                   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Collection string                   `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Options    *CreateCollectionOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCollectionRequest) Descriptor deprecated 

func (*CreateCollectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateCollectionRequest.ProtoReflect.Descriptor instead.

func (*CreateCollectionRequest) GetCollection 

func (x *CreateCollectionRequest) GetCollection() string

func (*CreateCollectionRequest) GetDatabase 

func (x *CreateCollectionRequest) GetDatabase() string

func (*CreateCollectionRequest) GetOptions 

func (x *CreateCollectionRequest) GetOptions() *CreateCollectionOptions

func (*CreateCollectionRequest) ProtoMessage 

func (*CreateCollectionRequest) ProtoMessage()

func (*CreateCollectionRequest) ProtoReflect 

func (x *CreateCollectionRequest) ProtoReflect() protoreflect.Message

func (*CreateCollectionRequest) Reset 

func (x *CreateCollectionRequest) Reset()

func (*CreateCollectionRequest) String 

func (x *CreateCollectionRequest) String() string

type CreateIndexRequest 

type CreateIndexRequest struct {
	Database   string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Index      *Index `protobuf:"bytes,3,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateIndexRequest) Descriptor deprecated 

func (*CreateIndexRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead.

func (*CreateIndexRequest) GetCollection 

func (x *CreateIndexRequest) GetCollection() string

func (*CreateIndexRequest) GetDatabase 

func (x *CreateIndexRequest) GetDatabase() string

func (*CreateIndexRequest) GetIndex 

func (x *CreateIndexRequest) GetIndex() *Index

func (*CreateIndexRequest) ProtoMessage 

func (*CreateIndexRequest) ProtoMessage()

func (*CreateIndexRequest) ProtoReflect 

func (x *CreateIndexRequest) ProtoReflect() protoreflect.Message

func (*CreateIndexRequest) Reset 

func (x *CreateIndexRequest) Reset()

func (*CreateIndexRequest) String 

func (x *CreateIndexRequest) String() string

type DeleteDocumentRequest 

type DeleteDocumentRequest struct {

	// database name
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// collection name
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// document id
	DocumentId *ObjectId `protobuf:"bytes,3,opt,name=document_id,json=documentId,proto3" json:"document_id,omitempty"`
	// contains filtered or unexported fields
}

DeleteDocumentRequest is a special type that is used to represent a delete document request in a MongoDB

func (*DeleteDocumentRequest) Descriptor deprecated 

func (*DeleteDocumentRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDocumentRequest.ProtoReflect.Descriptor instead.

func (*DeleteDocumentRequest) GetCollection 

func (x *DeleteDocumentRequest) GetCollection() string

func (*DeleteDocumentRequest) GetDatabase 

func (x *DeleteDocumentRequest) GetDatabase() string

func (*DeleteDocumentRequest) GetDocumentId 

func (x *DeleteDocumentRequest) GetDocumentId() *ObjectId

func (*DeleteDocumentRequest) ProtoMessage 

func (*DeleteDocumentRequest) ProtoMessage()

func (*DeleteDocumentRequest) ProtoReflect 

func (x *DeleteDocumentRequest) ProtoReflect() protoreflect.Message

func (*DeleteDocumentRequest) Reset 

func (x *DeleteDocumentRequest) Reset()

func (*DeleteDocumentRequest) String 

func (x *DeleteDocumentRequest) String() string

type DropCollectionRequest 

type DropCollectionRequest struct {
	Database   string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*DropCollectionRequest) Descriptor deprecated 

func (*DropCollectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropCollectionRequest.ProtoReflect.Descriptor instead.

func (*DropCollectionRequest) GetCollection 

func (x *DropCollectionRequest) GetCollection() string

func (*DropCollectionRequest) GetDatabase 

func (x *DropCollectionRequest) GetDatabase() string

func (*DropCollectionRequest) ProtoMessage 

func (*DropCollectionRequest) ProtoMessage()

func (*DropCollectionRequest) ProtoReflect 

func (x *DropCollectionRequest) ProtoReflect() protoreflect.Message

func (*DropCollectionRequest) Reset 

func (x *DropCollectionRequest) Reset()

func (*DropCollectionRequest) String 

func (x *DropCollectionRequest) String() string

type DropDatabaseRequest 

type DropDatabaseRequest struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

func (*DropDatabaseRequest) Descriptor deprecated 

func (*DropDatabaseRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropDatabaseRequest.ProtoReflect.Descriptor instead.

func (*DropDatabaseRequest) GetDatabase 

func (x *DropDatabaseRequest) GetDatabase() string

func (*DropDatabaseRequest) ProtoMessage 

func (*DropDatabaseRequest) ProtoMessage()

func (*DropDatabaseRequest) ProtoReflect 

func (x *DropDatabaseRequest) ProtoReflect() protoreflect.Message

func (*DropDatabaseRequest) Reset 

func (x *DropDatabaseRequest) Reset()

func (*DropDatabaseRequest) String 

func (x *DropDatabaseRequest) String() string

type DropIndexRequest 

type DropIndexRequest struct {
	Database   string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Index      string `protobuf:"bytes,3,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*DropIndexRequest) Descriptor deprecated 

func (*DropIndexRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropIndexRequest.ProtoReflect.Descriptor instead.

func (*DropIndexRequest) GetCollection 

func (x *DropIndexRequest) GetCollection() string

func (*DropIndexRequest) GetDatabase 

func (x *DropIndexRequest) GetDatabase() string

func (*DropIndexRequest) GetIndex 

func (x *DropIndexRequest) GetIndex() string

func (*DropIndexRequest) ProtoMessage 

func (*DropIndexRequest) ProtoMessage()

func (*DropIndexRequest) ProtoReflect 

func (x *DropIndexRequest) ProtoReflect() protoreflect.Message

func (*DropIndexRequest) Reset 

func (x *DropIndexRequest) Reset()

func (*DropIndexRequest) String 

func (x *DropIndexRequest) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type GetDocumentRequest 

type GetDocumentRequest struct {

	// The database to query
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// The collection to query
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// The document to query
	DocumentId *ObjectId `protobuf:"bytes,3,opt,name=document_id,json=documentId,proto3" json:"document_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDocumentRequest) Descriptor deprecated 

func (*GetDocumentRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDocumentRequest.ProtoReflect.Descriptor instead.

func (*GetDocumentRequest) GetCollection 

func (x *GetDocumentRequest) GetCollection() string

func (*GetDocumentRequest) GetDatabase 

func (x *GetDocumentRequest) GetDatabase() string

func (*GetDocumentRequest) GetDocumentId 

func (x *GetDocumentRequest) GetDocumentId() *ObjectId

func (*GetDocumentRequest) ProtoMessage 

func (*GetDocumentRequest) ProtoMessage()

func (*GetDocumentRequest) ProtoReflect 

func (x *GetDocumentRequest) ProtoReflect() protoreflect.Message

func (*GetDocumentRequest) Reset 

func (x *GetDocumentRequest) Reset()

func (*GetDocumentRequest) String 

func (x *GetDocumentRequest) String() string

type Index 

type Index struct {

	// The name of the index
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The keys to index
	Keys []*IndexKey `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// The unique flag
	Unique bool `protobuf:"varint,3,opt,name=unique,proto3" json:"unique,omitempty"`
	// contains filtered or unexported fields
}

func (*Index) Descriptor deprecated 

func (*Index) Descriptor() ([]byte, []int)

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetKeys 

func (x *Index) GetKeys() []*IndexKey

func (*Index) GetName 

func (x *Index) GetName() string

func (*Index) GetUnique 

func (x *Index) GetUnique() bool

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) ProtoReflect 

func (x *Index) ProtoReflect() protoreflect.Message

func (*Index) Reset 

func (x *Index) Reset()

func (*Index) String 

func (x *Index) String() string

type IndexDirection 

type IndexDirection int32
const (
	IndexDirection_ASCENDING  IndexDirection = 0
	IndexDirection_DESCENDING IndexDirection = 1
)

func (IndexDirection) Descriptor 

func (IndexDirection) Descriptor() protoreflect.EnumDescriptor

func (IndexDirection) Enum 

func (x IndexDirection) Enum() *IndexDirection

func (IndexDirection) EnumDescriptor deprecated 

func (IndexDirection) EnumDescriptor() ([]byte, []int)

Deprecated: Use IndexDirection.Descriptor instead.

func (IndexDirection) Number 

func (x IndexDirection) Number() protoreflect.EnumNumber

func (IndexDirection) String 

func (x IndexDirection) String() string

func (IndexDirection) Type 

func (IndexDirection) Type() protoreflect.EnumType

type IndexKey 

type IndexKey struct {

	// The field to index
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// The direction to index
	Direction IndexDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=mongorpc.IndexDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexKey) Descriptor deprecated 

func (*IndexKey) Descriptor() ([]byte, []int)

Deprecated: Use IndexKey.ProtoReflect.Descriptor instead.

func (*IndexKey) GetDirection 

func (x *IndexKey) GetDirection() IndexDirection

func (*IndexKey) GetField 

func (x *IndexKey) GetField() string

func (*IndexKey) ProtoMessage 

func (*IndexKey) ProtoMessage()

func (*IndexKey) ProtoReflect 

func (x *IndexKey) ProtoReflect() protoreflect.Message

func (*IndexKey) Reset 

func (x *IndexKey) Reset()

func (*IndexKey) String 

func (x *IndexKey) String() string

type InsertDocumentRequest 

type InsertDocumentRequest struct {

	// The database to insert the document into
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// The collection to insert the document into
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// The document to insert
	Document *Value `protobuf:"bytes,3,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

InsertDocumentRequest is a special type that is used to represent a insert document request in a MongoDB

func (*InsertDocumentRequest) Descriptor deprecated 

func (*InsertDocumentRequest) Descriptor() ([]byte, []int)

Deprecated: Use InsertDocumentRequest.ProtoReflect.Descriptor instead.

func (*InsertDocumentRequest) GetCollection 

func (x *InsertDocumentRequest) GetCollection() string

func (*InsertDocumentRequest) GetDatabase 

func (x *InsertDocumentRequest) GetDatabase() string

func (*InsertDocumentRequest) GetDocument 

func (x *InsertDocumentRequest) GetDocument() *Value

func (*InsertDocumentRequest) ProtoMessage 

func (*InsertDocumentRequest) ProtoMessage()

func (*InsertDocumentRequest) ProtoReflect 

func (x *InsertDocumentRequest) ProtoReflect() protoreflect.Message

func (*InsertDocumentRequest) Reset 

func (x *InsertDocumentRequest) Reset()

func (*InsertDocumentRequest) String 

func (x *InsertDocumentRequest) String() string

type ListCollectionsRequest 

type ListCollectionsRequest struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCollectionsRequest) Descriptor deprecated 

func (*ListCollectionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListCollectionsRequest.ProtoReflect.Descriptor instead.

func (*ListCollectionsRequest) GetDatabase 

func (x *ListCollectionsRequest) GetDatabase() string

func (*ListCollectionsRequest) ProtoMessage 

func (*ListCollectionsRequest) ProtoMessage()

func (*ListCollectionsRequest) ProtoReflect 

func (x *ListCollectionsRequest) ProtoReflect() protoreflect.Message

func (*ListCollectionsRequest) Reset 

func (x *ListCollectionsRequest) Reset()

func (*ListCollectionsRequest) String 

func (x *ListCollectionsRequest) String() string

type ListIndexesRequest 

type ListIndexesRequest struct {
	Database   string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*ListIndexesRequest) Descriptor deprecated 

func (*ListIndexesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListIndexesRequest.ProtoReflect.Descriptor instead.

func (*ListIndexesRequest) GetCollection 

func (x *ListIndexesRequest) GetCollection() string

func (*ListIndexesRequest) GetDatabase 

func (x *ListIndexesRequest) GetDatabase() string

func (*ListIndexesRequest) ProtoMessage 

func (*ListIndexesRequest) ProtoMessage()

func (*ListIndexesRequest) ProtoReflect 

func (x *ListIndexesRequest) ProtoReflect() protoreflect.Message

func (*ListIndexesRequest) Reset 

func (x *ListIndexesRequest) Reset()

func (*ListIndexesRequest) String 

func (x *ListIndexesRequest) String() string

type ListenRequest 

type ListenRequest struct {

	// The database to listen on
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// The collection to listen on
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// pipeline
	Pipeline []*Value `protobuf:"bytes,3,rep,name=pipeline,proto3" json:"pipeline,omitempty"`
	// ChangeStreamOptions represents options that can be used to configure a Watch operation.
	Options *ChangeStreamOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenRequest) Descriptor deprecated 

func (*ListenRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) GetCollection 

func (x *ListenRequest) GetCollection() string

func (*ListenRequest) GetDatabase 

func (x *ListenRequest) GetDatabase() string

func (*ListenRequest) GetOptions 

func (x *ListenRequest) GetOptions() *ChangeStreamOptions

func (*ListenRequest) GetPipeline 

func (x *ListenRequest) GetPipeline() []*Value

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect 

func (x *ListenRequest) ProtoReflect() protoreflect.Message

func (*ListenRequest) Reset 

func (x *ListenRequest) Reset()

func (*ListenRequest) String 

func (x *ListenRequest) String() string

type ListenResponse 

type ListenResponse struct {
	Changes *Value `protobuf:"bytes,1,opt,name=changes,proto3" json:"changes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenResponse) Descriptor deprecated 

func (*ListenResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListenResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse) GetChanges 

func (x *ListenResponse) GetChanges() *Value

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) ProtoReflect 

func (x *ListenResponse) ProtoReflect() protoreflect.Message

func (*ListenResponse) Reset 

func (x *ListenResponse) Reset()

func (*ListenResponse) String 

func (x *ListenResponse) String() string

type MapValue 

type MapValue struct {
	Fields map[string]*Value `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Map is a special type that is used to represent a map value in a MongoDB

func (*MapValue) Descriptor deprecated 

func (*MapValue) Descriptor() ([]byte, []int)

Deprecated: Use MapValue.ProtoReflect.Descriptor instead.

func (*MapValue) GetFields 

func (x *MapValue) GetFields() map[string]*Value

func (*MapValue) ProtoMessage 

func (*MapValue) ProtoMessage()

func (*MapValue) ProtoReflect 

func (x *MapValue) ProtoReflect() protoreflect.Message

func (*MapValue) Reset 

func (x *MapValue) Reset()

func (*MapValue) String 

func (x *MapValue) String() string

type MongoRPCAdminClient 

type MongoRPCAdminClient interface {
	ListDatabases(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Value, error)
	DropDatabase(ctx context.Context, in *DropDatabaseRequest, opts ...grpc.CallOption) (*Empty, error)
	CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*Empty, error)
	DropCollection(ctx context.Context, in *DropCollectionRequest, opts ...grpc.CallOption) (*Empty, error)
	ListCollections(ctx context.Context, in *ListCollectionsRequest, opts ...grpc.CallOption) (*Value, error)
	ListIndexes(ctx context.Context, in *ListIndexesRequest, opts ...grpc.CallOption) (*Value, error)
	CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*Value, error)
	DropIndex(ctx context.Context, in *DropIndexRequest, opts ...grpc.CallOption) (*Empty, error)
}

MongoRPCAdminClient is the client API for MongoRPCAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMongoRPCAdminClient 

func NewMongoRPCAdminClient(cc grpc.ClientConnInterface) MongoRPCAdminClient

type MongoRPCAdminServer 

type MongoRPCAdminServer interface {
	ListDatabases(context.Context, *Empty) (*Value, error)
	DropDatabase(context.Context, *DropDatabaseRequest) (*Empty, error)
	CreateCollection(context.Context, *CreateCollectionRequest) (*Empty, error)
	DropCollection(context.Context, *DropCollectionRequest) (*Empty, error)
	ListCollections(context.Context, *ListCollectionsRequest) (*Value, error)
	ListIndexes(context.Context, *ListIndexesRequest) (*Value, error)
	CreateIndex(context.Context, *CreateIndexRequest) (*Value, error)
	DropIndex(context.Context, *DropIndexRequest) (*Empty, error)
	// contains filtered or unexported methods
}

MongoRPCAdminServer is the server API for MongoRPCAdmin service. All implementations must embed UnimplementedMongoRPCAdminServer for forward compatibility

type MongoRPCClient 

type MongoRPCClient interface {
	GetDocument(ctx context.Context, in *GetDocumentRequest, opts ...grpc.CallOption) (*Value, error)
	InsertDocument(ctx context.Context, in *InsertDocumentRequest, opts ...grpc.CallOption) (*ObjectId, error)
	UpdateDocument(ctx context.Context, in *UpdateDocumentRequest, opts ...grpc.CallOption) (*Value, error)
	DeleteDocument(ctx context.Context, in *DeleteDocumentRequest, opts ...grpc.CallOption) (*Value, error)
	BulkInsertDocuments(ctx context.Context, in *BulkInsertDocumentsRequest, opts ...grpc.CallOption) (*Value, error)
	QueryDocuments(ctx context.Context, in *QueryDocumentsRequest, opts ...grpc.CallOption) (*Value, error)
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (MongoRPC_ListenClient, error)
}

MongoRPCClient is the client API for MongoRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMongoRPCClient 

func NewMongoRPCClient(cc grpc.ClientConnInterface) MongoRPCClient

type MongoRPCServer 

type MongoRPCServer interface {
	GetDocument(context.Context, *GetDocumentRequest) (*Value, error)
	InsertDocument(context.Context, *InsertDocumentRequest) (*ObjectId, error)
	UpdateDocument(context.Context, *UpdateDocumentRequest) (*Value, error)
	DeleteDocument(context.Context, *DeleteDocumentRequest) (*Value, error)
	BulkInsertDocuments(context.Context, *BulkInsertDocumentsRequest) (*Value, error)
	QueryDocuments(context.Context, *QueryDocumentsRequest) (*Value, error)
	Listen(*ListenRequest, MongoRPC_ListenServer) error
	// contains filtered or unexported methods
}

MongoRPCServer is the server API for MongoRPC service. All implementations must embed UnimplementedMongoRPCServer for forward compatibility

type MongoRPC_ListenClient 

type MongoRPC_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type MongoRPC_ListenServer 

type MongoRPC_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

type NullValue 

type NullValue int32

Null is a special type that is used to represent a null value in a MongoDB 

const (
	NullValue_NULL_VALUE NullValue = 0
)

func (NullValue) Descriptor 

func (NullValue) Descriptor() protoreflect.EnumDescriptor

func (NullValue) Enum 

func (x NullValue) Enum() *NullValue

func (NullValue) EnumDescriptor deprecated 

func (NullValue) EnumDescriptor() ([]byte, []int)

Deprecated: Use NullValue.Descriptor instead.

func (NullValue) Number 

func (x NullValue) Number() protoreflect.EnumNumber

func (NullValue) String 

func (x NullValue) String() string

func (NullValue) Type 

func (NullValue) Type() protoreflect.EnumType

type ObjectId 

type ObjectId struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectId) Descriptor deprecated 

func (*ObjectId) Descriptor() ([]byte, []int)

Deprecated: Use ObjectId.ProtoReflect.Descriptor instead.

func (*ObjectId) GetId 

func (x *ObjectId) GetId() string

func (*ObjectId) ProtoMessage 

func (*ObjectId) ProtoMessage()

func (*ObjectId) ProtoReflect 

func (x *ObjectId) ProtoReflect() protoreflect.Message

func (*ObjectId) Reset 

func (x *ObjectId) Reset()

func (*ObjectId) String 

func (x *ObjectId) String() string

type QueryDocumentsRequest 

type QueryDocumentsRequest struct {

	// The database to query
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// The collection to query
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// The query to use
	Query *Value `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// The sort to use
	Sort *Value `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	// The projection to use
	Projection *Value `protobuf:"bytes,5,opt,name=projection,proto3" json:"projection,omitempty"`
	// The skip to use
	Skip int32 `protobuf:"varint,6,opt,name=skip,proto3" json:"skip,omitempty"`
	// The limit to use
	Limit int32 `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDocumentsRequest) Descriptor deprecated 

func (*QueryDocumentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryDocumentsRequest.ProtoReflect.Descriptor instead.

func (*QueryDocumentsRequest) GetCollection 

func (x *QueryDocumentsRequest) GetCollection() string

func (*QueryDocumentsRequest) GetDatabase 

func (x *QueryDocumentsRequest) GetDatabase() string

func (*QueryDocumentsRequest) GetLimit 

func (x *QueryDocumentsRequest) GetLimit() int32

func (*QueryDocumentsRequest) GetProjection 

func (x *QueryDocumentsRequest) GetProjection() *Value

func (*QueryDocumentsRequest) GetQuery 

func (x *QueryDocumentsRequest) GetQuery() *Value

func (*QueryDocumentsRequest) GetSkip 

func (x *QueryDocumentsRequest) GetSkip() int32

func (*QueryDocumentsRequest) GetSort 

func (x *QueryDocumentsRequest) GetSort() *Value

func (*QueryDocumentsRequest) ProtoMessage 

func (*QueryDocumentsRequest) ProtoMessage()

func (*QueryDocumentsRequest) ProtoReflect 

func (x *QueryDocumentsRequest) ProtoReflect() protoreflect.Message

func (*QueryDocumentsRequest) Reset 

func (x *QueryDocumentsRequest) Reset()

func (*QueryDocumentsRequest) String 

func (x *QueryDocumentsRequest) String() string

type Timestamp 

type Timestamp struct {
	Seconds int64 `protobuf:"varint,1,opt,name=seconds,proto3" json:"seconds,omitempty"`
	Nanos   int32 `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"`
	// contains filtered or unexported fields
}

Timestamp is a special type that is used to represent a timestamp value in a MongoDB

func (*Timestamp) Descriptor deprecated 

func (*Timestamp) Descriptor() ([]byte, []int)

Deprecated: Use Timestamp.ProtoReflect.Descriptor instead.

func (*Timestamp) GetNanos 

func (x *Timestamp) GetNanos() int32

func (*Timestamp) GetSeconds 

func (x *Timestamp) GetSeconds() int64

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) ProtoReflect 

func (x *Timestamp) ProtoReflect() protoreflect.Message

func (*Timestamp) Reset 

func (x *Timestamp) Reset()

func (*Timestamp) String 

func (x *Timestamp) String() string

type UnimplementedMongoRPCAdminServer 

type UnimplementedMongoRPCAdminServer struct {
}

UnimplementedMongoRPCAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedMongoRPCAdminServer) CreateCollection 

func (UnimplementedMongoRPCAdminServer) CreateCollection(context.Context, *CreateCollectionRequest) (*Empty, error)

func (UnimplementedMongoRPCAdminServer) CreateIndex 

func (UnimplementedMongoRPCAdminServer) CreateIndex(context.Context, *CreateIndexRequest) (*Value, error)

func (UnimplementedMongoRPCAdminServer) DropCollection 

func (UnimplementedMongoRPCAdminServer) DropCollection(context.Context, *DropCollectionRequest) (*Empty, error)

func (UnimplementedMongoRPCAdminServer) DropDatabase 

func (UnimplementedMongoRPCAdminServer) DropDatabase(context.Context, *DropDatabaseRequest) (*Empty, error)

func (UnimplementedMongoRPCAdminServer) DropIndex 

func (UnimplementedMongoRPCAdminServer) DropIndex(context.Context, *DropIndexRequest) (*Empty, error)

func (UnimplementedMongoRPCAdminServer) ListCollections 

func (UnimplementedMongoRPCAdminServer) ListCollections(context.Context, *ListCollectionsRequest) (*Value, error)

func (UnimplementedMongoRPCAdminServer) ListDatabases 

func (UnimplementedMongoRPCAdminServer) ListDatabases(context.Context, *Empty) (*Value, error)

func (UnimplementedMongoRPCAdminServer) ListIndexes 

func (UnimplementedMongoRPCAdminServer) ListIndexes(context.Context, *ListIndexesRequest) (*Value, error)

type UnimplementedMongoRPCServer 

type UnimplementedMongoRPCServer struct {
}

UnimplementedMongoRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedMongoRPCServer) BulkInsertDocuments 

func (UnimplementedMongoRPCServer) BulkInsertDocuments(context.Context, *BulkInsertDocumentsRequest) (*Value, error)

func (UnimplementedMongoRPCServer) DeleteDocument 

func (UnimplementedMongoRPCServer) DeleteDocument(context.Context, *DeleteDocumentRequest) (*Value, error)

func (UnimplementedMongoRPCServer) GetDocument 

func (UnimplementedMongoRPCServer) GetDocument(context.Context, *GetDocumentRequest) (*Value, error)

func (UnimplementedMongoRPCServer) InsertDocument 

func (UnimplementedMongoRPCServer) InsertDocument(context.Context, *InsertDocumentRequest) (*ObjectId, error)

func (UnimplementedMongoRPCServer) Listen 

func (UnimplementedMongoRPCServer) Listen(*ListenRequest, MongoRPC_ListenServer) error

func (UnimplementedMongoRPCServer) QueryDocuments 

func (UnimplementedMongoRPCServer) QueryDocuments(context.Context, *QueryDocumentsRequest) (*Value, error)

func (UnimplementedMongoRPCServer) UpdateDocument 

func (UnimplementedMongoRPCServer) UpdateDocument(context.Context, *UpdateDocumentRequest) (*Value, error)

type UnsafeMongoRPCAdminServer 

type UnsafeMongoRPCAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeMongoRPCAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MongoRPCAdminServer will result in compilation errors.

type UnsafeMongoRPCServer 

type UnsafeMongoRPCServer interface {
	// contains filtered or unexported methods
}

UnsafeMongoRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MongoRPCServer will result in compilation errors.

type UpdateDocumentRequest 

type UpdateDocumentRequest struct {

	// The database to use
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// The collection to use
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// The document to update
	DocumentId *ObjectId `protobuf:"bytes,3,opt,name=document_id,json=documentId,proto3" json:"document_id,omitempty"`
	// Document Values
	Document *Value `protobuf:"bytes,4,opt,name=document,proto3" json:"document,omitempty"`
	// Replace the document
	Replace bool `protobuf:"varint,5,opt,name=replace,proto3" json:"replace,omitempty"`
	// contains filtered or unexported fields
}

UpdateDocumentRequest is a special type that is used to represent a update document request in a MongoDB

func (*UpdateDocumentRequest) Descriptor deprecated 

func (*UpdateDocumentRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDocumentRequest.ProtoReflect.Descriptor instead.

func (*UpdateDocumentRequest) GetCollection 

func (x *UpdateDocumentRequest) GetCollection() string

func (*UpdateDocumentRequest) GetDatabase 

func (x *UpdateDocumentRequest) GetDatabase() string

func (*UpdateDocumentRequest) GetDocument 

func (x *UpdateDocumentRequest) GetDocument() *Value

func (*UpdateDocumentRequest) GetDocumentId 

func (x *UpdateDocumentRequest) GetDocumentId() *ObjectId

func (*UpdateDocumentRequest) GetReplace 

func (x *UpdateDocumentRequest) GetReplace() bool

func (*UpdateDocumentRequest) ProtoMessage 

func (*UpdateDocumentRequest) ProtoMessage()

func (*UpdateDocumentRequest) ProtoReflect 

func (x *UpdateDocumentRequest) ProtoReflect() protoreflect.Message

func (*UpdateDocumentRequest) Reset 

func (x *UpdateDocumentRequest) Reset()

func (*UpdateDocumentRequest) String 

func (x *UpdateDocumentRequest) String() string

type Value 

type Value struct {

	// Types that are assignable to Type:
	//	*Value_Integer32Value
	//	*Value_Integer64Value
	//	*Value_BooleanValue
	//	*Value_StringValue
	//	*Value_DoubleValue
	//	*Value_NullValue
	//	*Value_ArrayValue
	//	*Value_MapValue
	//	*Value_ObjectIdValue
	//	*Value_TimestampValue
	Type isValue_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

Value is a special type that is used to represent a value in a MongoDB

func (*Value) Descriptor deprecated 

func (*Value) Descriptor() ([]byte, []int)

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetArrayValue 

func (x *Value) GetArrayValue() *ArrayValue

func (*Value) GetBooleanValue 

func (x *Value) GetBooleanValue() bool

func (*Value) GetDoubleValue 

func (x *Value) GetDoubleValue() float64

func (*Value) GetInteger32Value 

func (x *Value) GetInteger32Value() int32

func (*Value) GetInteger64Value 

func (x *Value) GetInteger64Value() int64

func (*Value) GetMapValue 

func (x *Value) GetMapValue() *MapValue

func (*Value) GetNullValue 

func (x *Value) GetNullValue() NullValue

func (*Value) GetObjectIdValue 

func (x *Value) GetObjectIdValue() *ObjectId

func (*Value) GetStringValue 

func (x *Value) GetStringValue() string

func (*Value) GetTimestampValue 

func (x *Value) GetTimestampValue() *Timestamp

func (*Value) GetType 

func (m *Value) GetType() isValue_Type

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Value_ArrayValue 

type Value_ArrayValue struct {
	ArrayValue *ArrayValue `protobuf:"bytes,7,opt,name=array_value,json=arrayValue,proto3,oneof"`
}

type Value_BooleanValue 

type Value_BooleanValue struct {
	BooleanValue bool `protobuf:"varint,3,opt,name=boolean_value,json=booleanValue,proto3,oneof"`
}

type Value_DoubleValue 

type Value_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,5,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Value_Integer32Value 

type Value_Integer32Value struct {
	Integer32Value int32 `protobuf:"varint,1,opt,name=integer32_value,json=integer32Value,proto3,oneof"`
}

type Value_Integer64Value 

type Value_Integer64Value struct {
	Integer64Value int64 `protobuf:"varint,2,opt,name=integer64_value,json=integer64Value,proto3,oneof"`
}

type Value_MapValue 

type Value_MapValue struct {
	MapValue *MapValue `protobuf:"bytes,8,opt,name=map_value,json=mapValue,proto3,oneof"`
}

type Value_NullValue 

type Value_NullValue struct {
	NullValue NullValue `protobuf:"varint,6,opt,name=null_value,json=nullValue,proto3,enum=mongorpc.NullValue,oneof"`
}

type Value_ObjectIdValue 

type Value_ObjectIdValue struct {
	ObjectIdValue *ObjectId `protobuf:"bytes,9,opt,name=object_id_value,json=objectIdValue,proto3,oneof"`
}

type Value_StringValue 

type Value_StringValue struct {
	StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Value_TimestampValue 

type Value_TimestampValue struct {
	TimestampValue *Timestamp `protobuf:"bytes,10,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

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.