Lines Matching defs:Aggregate

27 type Aggregate struct {  struct
28 	allowDiskUse             *bool
29 	batchSize                *int32
30 	bypassDocumentValidation *bool
31 	collation                bsoncore.Document
32 	comment                  *string
33 	hint                     bsoncore.Value
34 	maxTimeMS                *int64
35 	pipeline                 bsoncore.Document
36 	session                  *session.Client
37 	clock                    *session.ClusterClock
38 	collection               string
39 	monitor                  *event.CommandMonitor
40 	database                 string
41 	deployment               driver.Deployment
42 	readConcern              *readconcern.ReadConcern
43 	readPreference           *readpref.ReadPref
44 	retry                    *driver.RetryMode
45 	selector                 description.ServerSelector
46 	writeConcern             *writeconcern.WriteConcern
47 	crypt                    *driver.Crypt
49 	result driver.CursorResponse
60 func (a *Aggregate) Result(opts driver.CursorOptions) (*driver.BatchCursor, error) {
68 func (a *Aggregate) ResultCursorResponse() driver.CursorResponse {
72 …e) processResponse(response bsoncore.Document, srvr driver.Server, desc description.Server) error {
81 func (a *Aggregate) Execute(ctx context.Context) error {
107 func (a *Aggregate) command(dst []byte, desc description.SelectedServer) ([]byte, error) {
156 func (a *Aggregate) AllowDiskUse(allowDiskUse bool) *Aggregate {
166 func (a *Aggregate) BatchSize(batchSize int32) *Aggregate {
176 func (a *Aggregate) BypassDocumentValidation(bypassDocumentValidation bool) *Aggregate {
186 func (a *Aggregate) Collation(collation bsoncore.Document) *Aggregate {
196 func (a *Aggregate) Comment(comment string) *Aggregate {
206 func (a *Aggregate) Hint(hint bsoncore.Value) *Aggregate {
216 func (a *Aggregate) MaxTimeMS(maxTimeMS int64) *Aggregate {
226 func (a *Aggregate) Pipeline(pipeline bsoncore.Document) *Aggregate {
236 func (a *Aggregate) Session(session *session.Client) *Aggregate {
246 func (a *Aggregate) ClusterClock(clock *session.ClusterClock) *Aggregate {
256 func (a *Aggregate) Collection(collection string) *Aggregate {
266 func (a *Aggregate) CommandMonitor(monitor *event.CommandMonitor) *Aggregate {
276 func (a *Aggregate) Database(database string) *Aggregate {
286 func (a *Aggregate) Deployment(deployment driver.Deployment) *Aggregate {
296 func (a *Aggregate) ReadConcern(readConcern *readconcern.ReadConcern) *Aggregate {
306 func (a *Aggregate) ReadPreference(readPreference *readpref.ReadPref) *Aggregate {
316 func (a *Aggregate) ServerSelector(selector description.ServerSelector) *Aggregate {
326 func (a *Aggregate) WriteConcern(writeConcern *writeconcern.WriteConcern) *Aggregate {
338 func (a *Aggregate) Retry(retry driver.RetryMode) *Aggregate {
348 func (a *Aggregate) Crypt(crypt *driver.Crypt) *Aggregate {