peergrouper

package
v0.0.0-...-f19ae85 Latest Latest
Warning

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

Go to latest
Published: Mar 12, 2015 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrReplicaSetAlreadyInitiated = errors.New("replicaset is already initiated")

ErrReplicaSetAlreadyInitiated is returned with attemptInitiateMongoServer is called on a mongo with an existing relicaset, it helps to assert which of the two valid paths was taking when calling MaybeInitiateMongoServer/InitiateMongoServer which is useful for testing purposes and also when debugging cases of faulty replica sets

Functions

func InitiateMongoServer

func InitiateMongoServer(p InitiateMongoParams, force bool) error

InitiateMongoServer checks for an existing mongo configuration. If no existing configuration is found one is created using Initiate. If force flag is true, the configuration will be started anyway.

func MaybeInitiateMongoServer

func MaybeInitiateMongoServer(p InitiateMongoParams) error

MaybeInitiateMongoServer is a convenience function for initiating a mongo replicaset only if it is not already initiated.

func New

func New(st *state.State) (worker.Worker, error)

New returns a new worker that maintains the mongo replica set with respect to the given state.

Types

type InitiateMongoParams

type InitiateMongoParams struct {
	// DialInfo specifies how to connect to the mongo server.
	DialInfo *mgo.DialInfo

	// MemberHostPort provides the address to use for
	// the first replica set member.
	MemberHostPort string

	// User holds the user to log as in to the mongo server.
	// If it is empty, no login will take place.
	User     string
	Password string
}

InitiateMongoParams holds parameters for the MaybeInitiateMongo call.

Jump to

Keyboard shortcuts

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