diff options
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.go | 139 |
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 -} |