mock

Documentation

Index

• type Environment
  • func (e *Environment) Client() *mongo.Client
  • func (e *Environment) ClientConfig() *evergreen.ClientConfig
  • func (e *Environment) Close(ctx context.Context) error
  • func (e *Environment) Configure(ctx context.Context, path string, db *evergreen.DBSettings) error
  • func (e *Environment) Context() (context.Context, context.CancelFunc)
  • func (e *Environment) DB() *mongo.Database
  • func (e *Environment) GetSender(key evergreen.SenderKey) (send.Sender, error)
  • func (e *Environment) JasperManager() jasper.Manager
  • func (e *Environment) LocalQueue() amboy.Queue
  • func (e *Environment) RegisterCloser(name string, closer func(context.Context) error)
  • func (e *Environment) RemoteQueue() amboy.Queue
  • func (e *Environment) RemoteQueueGroup() amboy.QueueGroup
  • func (e *Environment) SaveConfig() error
  • func (e *Environment) Session() db.Session
  • func (e *Environment) SetSender(key evergreen.SenderKey, s send.Sender) error
  • func (e *Environment) Settings() *evergreen.Settings

Types

type Environment

type Environment struct {
	Remote               amboy.Queue
	Driver               queue.Driver
	Local                amboy.Queue
	JasperProcessManager jasper.Manager
	RemoteGroup          amboy.QueueGroup
	Closers              map[string]func(context.Context) error
	DBSession            *anserMock.Session
	EvergreenSettings    *evergreen.Settings
	MongoClient          *mongo.Client

	DatabaseName   string
	EnvContext     context.Context
	InternalSender *send.InternalSender
	// contains filtered or unexported fields
}

func (*Environment) Client

func (e *Environment) Client() *mongo.Client

func (*Environment) ClientConfig

func (e *Environment) ClientConfig() *evergreen.ClientConfig

func (*Environment) Close

func (e *Environment) Close(ctx context.Context) error

func (*Environment) Configure

func (e *Environment) Configure(ctx context.Context, path string, db *evergreen.DBSettings) error

func (*Environment) Context

func (e *Environment) Context() (context.Context, context.CancelFunc)

func (*Environment) DB

func (e *Environment) DB() *mongo.Database

func (*Environment) GetSender

func (e *Environment) GetSender(key evergreen.SenderKey) (send.Sender, error)

func (*Environment) JasperManager

func (e *Environment) JasperManager() jasper.Manager

func (*Environment) LocalQueue

func (e *Environment) LocalQueue() amboy.Queue

func (*Environment) RegisterCloser

func (e *Environment) RegisterCloser(name string, closer func(context.Context) error)

func (*Environment) RemoteQueue

func (e *Environment) RemoteQueue() amboy.Queue

func (*Environment) RemoteQueueGroup

func (e *Environment) RemoteQueueGroup() amboy.QueueGroup

func (*Environment) SaveConfig

func (e *Environment) SaveConfig() error

func (*Environment) Session

func (e *Environment) Session() db.Session

func (*Environment) SetSender

func (e *Environment) SetSender(key evergreen.SenderKey, s send.Sender) error

func (*Environment) Settings

func (e *Environment) Settings() *evergreen.Settings