peergrouper

Documentation

Index

• Variables
• func InitiateMongoServer(p InitiateMongoParams, force bool) error
• func MaybeInitiateMongoServer(p InitiateMongoParams) error
• func New(st *state.State) (worker.Worker, error)
• type InitiateMongoParams

Variables

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.