Lines Matching defs:Aggregate

26 type Aggregate struct {  struct
27 	NS           Namespace
28 	Pipeline     bsonx.Arr
29 	CursorOpts   []bsonx.Elem
30 	Opts         []bsonx.Elem
31 	ReadPref     *readpref.ReadPref
32 	WriteConcern *writeconcern.WriteConcern
33 	ReadConcern  *readconcern.ReadConcern
34 	Clock        *session.ClusterClock
35 	Session      *session.Client
37 	result bson.Raw
38 	err    error
42 func (a *Aggregate) Encode(desc description.SelectedServer) (wiremessage.WireMessage, error) {
51 func (a *Aggregate) encode(desc description.SelectedServer) (*Read, error) {
102 func (a *Aggregate) HasDollarOut() bool {
121 func (a *Aggregate) Decode(desc description.SelectedServer, wm wiremessage.WireMessage) *Aggregate {
131 func (a *Aggregate) decode(desc description.SelectedServer, rdr bson.Raw) *Aggregate {
142 func (a *Aggregate) Result() (bson.Raw, error) {
150 func (a *Aggregate) Err() error { return a.err }
153 …tx context.Context, desc description.SelectedServer, rw wiremessage.ReadWriter) (bson.Raw, error) {