sessionopt

package
v0.0.3-0...-630480d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 1, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type OptCausalConsistency

type OptCausalConsistency session.OptCausalConsistency

OptCausalConsistency specifies if a client session should be causally consistent.

func CausalConsistency

func CausalConsistency(b bool) OptCausalConsistency

CausalConsistency specifies if a client session should be causally consistent. Causally consistent reads are not causally consistent with unacknowledged writes.

func (OptCausalConsistency) ConvertSessionOption

func (opt OptCausalConsistency) ConvertSessionOption() session.ClientOptioner

ConvertSessionOption implements the Session interface.

type OptDefaultReadConcern

type OptDefaultReadConcern session.OptDefaultReadConcern

OptDefaultReadConcern specifies the default read concern for transactions started from this session.

func DefaultReadConcern

func DefaultReadConcern(rc *readconcern.ReadConcern) OptDefaultReadConcern

DefaultReadConcern specifies the default read concern for transactions started from this session.

func (OptDefaultReadConcern) ConvertSessionOption

func (opt OptDefaultReadConcern) ConvertSessionOption() session.ClientOptioner

ConvertSessionOption implements the Session interface.

type OptDefaultReadPreference

type OptDefaultReadPreference session.OptDefaultReadPreference

OptDefaultReadPreference specifies the default read preference for transactions started from this session.

func DefaultReadPreference

func DefaultReadPreference(rp *readpref.ReadPref) OptDefaultReadPreference

DefaultReadPreference specifies the default read preference for transactions started from this session.

func (OptDefaultReadPreference) ConvertSessionOption

func (opt OptDefaultReadPreference) ConvertSessionOption() session.ClientOptioner

ConvertSessionOption implements the Session interface.

type OptDefaultWriteConcern

type OptDefaultWriteConcern session.OptDefaultWriteConcern

OptDefaultWriteConcern specifies the default write concern for transactions started from this session.

func DefaultWriteConcern

func DefaultWriteConcern(wc *writeconcern.WriteConcern) OptDefaultWriteConcern

DefaultWriteConcern specifies the default write concern for transactions started from this session.

func (OptDefaultWriteConcern) ConvertSessionOption

func (opt OptDefaultWriteConcern) ConvertSessionOption() session.ClientOptioner

ConvertSessionOption implements the Session interface.

type Session

type Session interface {
	ConvertSessionOption() session.ClientOptioner
	// contains filtered or unexported methods
}

Session represents options for creating client sessions.

type SessionBundle

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

SessionBundle bundles session options

func BundleSession

func BundleSession(opts ...Session) *SessionBundle

BundleSession bundles session options

func (*SessionBundle) CausalConsistency

func (sb *SessionBundle) CausalConsistency(b bool) *SessionBundle

CausalConsistency specifies if a session should be causally consistent. Defaults to true. Causally consistent reads are not causally consistent with unacknowledged writes.

func (*SessionBundle) ConvertSessionOption

func (sb *SessionBundle) ConvertSessionOption() session.ClientOptioner

ConvertSessionOption implements the Session interface

func (*SessionBundle) DefaultReadConcern

func (sb *SessionBundle) DefaultReadConcern(rc *readconcern.ReadConcern) *SessionBundle

DefaultReadConcern specifies the default read concern for transactions started from this session.

func (*SessionBundle) DefaultReadPreference

func (sb *SessionBundle) DefaultReadPreference(rp *readpref.ReadPref) *SessionBundle

DefaultReadPreference specifies the default read preference for transactions started from this session.

func (*SessionBundle) DefaultWriteConcern

func (sb *SessionBundle) DefaultWriteConcern(wc *writeconcern.WriteConcern) *SessionBundle

DefaultWriteConcern specifies the default write concern for transactions started from this session.

func (*SessionBundle) Unbundle

func (sb *SessionBundle) Unbundle(deduplicate bool) ([]session.ClientOptioner, error)

Unbundle transforms a bundle into a slice of options, optionally deduplicating.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL