summaryrefslogtreecommitdiff
path: root/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/end_sessions.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/end_sessions.go')
-rw-r--r--src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/end_sessions.go139
1 files changed, 0 insertions, 139 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/end_sessions.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/end_sessions.go
deleted file mode 100644
index d3f7a5dfcf9..00000000000
--- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/end_sessions.go
+++ /dev/null
@@ -1,139 +0,0 @@
-// Copyright (C) MongoDB, Inc. 2019-present.
-//
-// Licensed under the Apache License, Version 2.0 (the "License"); you may
-// not use this file except in compliance with the License. You may obtain
-// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
-
-// Code generated by operationgen. DO NOT EDIT.
-
-package operation
-
-import (
- "context"
- "errors"
-
- "go.mongodb.org/mongo-driver/event"
- "go.mongodb.org/mongo-driver/x/bsonx/bsoncore"
- "go.mongodb.org/mongo-driver/x/mongo/driver"
- "go.mongodb.org/mongo-driver/x/mongo/driver/description"
- "go.mongodb.org/mongo-driver/x/mongo/driver/session"
-)
-
-// EndSessions performs an endSessions operation.
-type EndSessions struct {
- sessionIDs bsoncore.Document
- session *session.Client
- clock *session.ClusterClock
- monitor *event.CommandMonitor
- database string
- deployment driver.Deployment
- selector description.ServerSelector
-}
-
-// NewEndSessions constructs and returns a new EndSessions.
-func NewEndSessions(sessionIDs bsoncore.Document) *EndSessions {
- return &EndSessions{
- sessionIDs: sessionIDs,
- }
-}
-
-func (es *EndSessions) processResponse(response bsoncore.Document, srvr driver.Server, desc description.Server) error {
- var err error
- return err
-}
-
-// Execute runs this operations and returns an error if the operaiton did not execute successfully.
-func (es *EndSessions) Execute(ctx context.Context) error {
- if es.deployment == nil {
- return errors.New("the EndSessions operation must have a Deployment set before Execute can be called")
- }
-
- return driver.Operation{
- CommandFn: es.command,
- ProcessResponseFn: es.processResponse,
- Client: es.session,
- Clock: es.clock,
- CommandMonitor: es.monitor,
- Database: es.database,
- Deployment: es.deployment,
- Selector: es.selector,
- }.Execute(ctx, nil)
-
-}
-
-func (es *EndSessions) command(dst []byte, desc description.SelectedServer) ([]byte, error) {
- if es.sessionIDs != nil {
- dst = bsoncore.AppendArrayElement(dst, "endSessions", es.sessionIDs)
- }
- return dst, nil
-}
-
-// sessionIDs specify the sessions to be expired.
-func (es *EndSessions) SessionIDs(sessionIDs bsoncore.Document) *EndSessions {
- if es == nil {
- es = new(EndSessions)
- }
-
- es.sessionIDs = sessionIDs
- return es
-}
-
-// Session sets the session for this operation.
-func (es *EndSessions) Session(session *session.Client) *EndSessions {
- if es == nil {
- es = new(EndSessions)
- }
-
- es.session = session
- return es
-}
-
-// ClusterClock sets the cluster clock for this operation.
-func (es *EndSessions) ClusterClock(clock *session.ClusterClock) *EndSessions {
- if es == nil {
- es = new(EndSessions)
- }
-
- es.clock = clock
- return es
-}
-
-// CommandMonitor sets the monitor to use for APM events.
-func (es *EndSessions) CommandMonitor(monitor *event.CommandMonitor) *EndSessions {
- if es == nil {
- es = new(EndSessions)
- }
-
- es.monitor = monitor
- return es
-}
-
-// Database sets the database to run this operation against.
-func (es *EndSessions) Database(database string) *EndSessions {
- if es == nil {
- es = new(EndSessions)
- }
-
- es.database = database
- return es
-}
-
-// Deployment sets the deployment to use for this operation.
-func (es *EndSessions) Deployment(deployment driver.Deployment) *EndSessions {
- if es == nil {
- es = new(EndSessions)
- }
-
- es.deployment = deployment
- return es
-}
-
-// ServerSelector sets the selector used to retrieve a server.
-func (es *EndSessions) ServerSelector(selector description.ServerSelector) *EndSessions {
- if es == nil {
- es = new(EndSessions)
- }
-
- es.selector = selector
- return es
-}