sessionopt

package
v0.0.14 Latest Latest
Warning

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

Go to latest
Published: Sep 20, 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 added in v0.0.12

type OptDefaultReadConcern session.OptDefaultReadConcern

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

func DefaultReadConcern added in v0.0.12

func DefaultReadConcern(rc *readconcern.ReadConcern) OptDefaultReadConcern

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

func (OptDefaultReadConcern) ConvertSessionOption added in v0.0.12

func (opt OptDefaultReadConcern) ConvertSessionOption() session.ClientOptioner

ConvertSessionOption implements the Session interface.

type OptDefaultReadPreference added in v0.0.12

type OptDefaultReadPreference session.OptDefaultReadPreference

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

func DefaultReadPreference added in v0.0.12

func DefaultReadPreference(rp *readpref.ReadPref) OptDefaultReadPreference

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

func (OptDefaultReadPreference) ConvertSessionOption added in v0.0.12

func (opt OptDefaultReadPreference) ConvertSessionOption() session.ClientOptioner

ConvertSessionOption implements the Session interface.

type OptDefaultWriteConcern added in v0.0.12

type OptDefaultWriteConcern session.OptDefaultWriteConcern

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

func DefaultWriteConcern added in v0.0.12

func DefaultWriteConcern(wc *writeconcern.WriteConcern) OptDefaultWriteConcern

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

func (OptDefaultWriteConcern) ConvertSessionOption added in v0.0.12

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 added in v0.0.12

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

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

func (*SessionBundle) DefaultReadPreference added in v0.0.12

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

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

func (*SessionBundle) DefaultWriteConcern added in v0.0.12

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