mock

Documentation

Index

• type Environment
  • 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) GetSender(key evergreen.SenderKey) (send.Sender, error)
  • 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) SaveConfig() error
  • func (e *Environment) Session() *mgo.Session
  • func (e *Environment) Settings() *evergreen.Settings

Types

type Environment

type Environment struct {
	Remote            amboy.Queue
	Driver            queue.Driver
	Local             amboy.Queue
	Closers           map[string]func(context.Context) error
	DBSession         *anserMock.Session
	EvergreenSettings *evergreen.Settings

	InternalSender *send.InternalSender
	// contains filtered or unexported fields
}

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) GetSender

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

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) SaveConfig

func (e *Environment) SaveConfig() error

func (*Environment) Session

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

func (*Environment) Settings

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