peergrouper

Documentation

Index

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

Functions

func MaybeInitiateMongoServer

func MaybeInitiateMongoServer(p InitiateMongoParams) error

MaybeInitiateMongoServer checks for an existing mongo configuration. If no existing configuration is found one is created using Initiate.

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.