mongogateway

type ClusterCatalogVersionProvider func(context.Context) (uint64, error)

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

type Server struct {
	MaxMessageLength       int32
	MaxFindScanDocuments   int
	MaxCursorRetainedBytes int
	MaxOpenCursors         int
	CursorIdleTimeout      time.Duration
	// UpdateCoalescingMaxDelay waits for additional same-collection update
	// commands before publishing a batch. Zero means only coalesce already-queued
	// work; negative disables coalescing.
	UpdateCoalescingMaxDelay time.Duration
	// UpdateCoalescingMaxBatch caps one coalesced same-collection update publish.
	// Values above maxUpdateCoalescingBatch are clamped.
	UpdateCoalescingMaxBatch int
	// UpdateCoalescingIdleTTL removes an idle per-collection coalescer after this
	// duration. Zero uses the default; negative disables idle removal.
	UpdateCoalescingIdleTTL time.Duration
	// InsertCoalescingMaxDelay waits for additional same-collection single-document
	// BSON insert commands before publishing a batch. Zero means only coalesce
	// already-queued work; negative disables coalescing.
	InsertCoalescingMaxDelay time.Duration
	// InsertCoalescingMaxBatch caps one coalesced same-collection insert publish.
	// Values above maxInsertCoalescingBatch are clamped.
	InsertCoalescingMaxBatch int
	// InsertCoalescingIdleTTL removes an idle per-collection coalescer after this
	// duration. Zero uses the default; negative disables idle removal.
	InsertCoalescingIdleTTL   time.Duration
	Collections               *collections.CollectionManager
	DefaultCollectionOptions  collections.CollectionOptions
	DefaultIndexStoragePolicy collections.RootStoragePolicy
	ClusterSubmitter          treenativewire.ClusterSubmitter
	ClusterCatalogVersion     ClusterCatalogVersionProvider
	// ClusterIdempotencyNonce scopes generated cluster mutation idempotency
	// keys to one gateway process epoch. NewServer initializes a random nonce
	// so sequence-based keys are not reused after restart.
	ClusterIdempotencyNonce string
	// contains filtered or unexported fields
}

type StandaloneOptions struct {
	Dir     string
	Profile treedb.Profile

	DefaultCollectionOptions  collections.CollectionOptions
	DefaultIndexStoragePolicy collections.RootStoragePolicy

	MaxMessageLength         int32
	MaxFindScanDocuments     int
	MaxCursorRetainedBytes   int
	MaxOpenCursors           int
	CursorIdleTimeout        time.Duration
	UpdateCoalescingMaxDelay time.Duration
	// UpdateCoalescingMaxBatchSet distinguishes an unset zero value from an
	// explicit zero, which disables update coalescing.
	UpdateCoalescingMaxBatchSet bool
	UpdateCoalescingMaxBatch    int
	UpdateCoalescingIdleTTL     time.Duration
	InsertCoalescingMaxDelay    time.Duration
	// InsertCoalescingMaxBatchSet distinguishes an unset zero value from an
	// explicit zero, which disables insert coalescing.
	InsertCoalescingMaxBatchSet bool
	InsertCoalescingMaxBatch    int
	InsertCoalescingIdleTTL     time.Duration
	ClusterSubmitter            treenativewire.ClusterSubmitter
	ClusterCatalogVersion       ClusterCatalogVersionProvider
}

type StandaloneServer struct {
	Options     StandaloneOptions
	Backend     *backenddb.DB
	Collections *collections.CollectionManager
	Server      *Server
	// contains filtered or unexported fields
}