persist

Documentation

Index

• type EntityActions
  • func (ea EntityActions) ApplyActions(m *definition.Mock)
• type EntityPersister
• type FilePersister
  • func NewFilePersister(persistPath string) *FilePersister
  • func (fp FilePersister) Delete(name string) error
  • func (fp FilePersister) DeleteCollection(name string) error
  • func (fp FilePersister) GetName() string
  • func (fp FilePersister) GetSequence(name string, increase int) (int, error)
  • func (fp FilePersister) GetValue(key string) (string, error)
  • func (fp FilePersister) Read(name string) (string, error)
  • func (fp FilePersister) ReadCollection(name string) (string, error)
  • func (fp FilePersister) SetValue(key string, value string) error
  • func (fp FilePersister) Write(name, content string) error
• type MongoPersister
  • func NewMongoPersister(connectionString string) *MongoPersister
  • func (mp MongoPersister) Delete(name string) error
  • func (mp MongoPersister) DeleteCollection(name string) error
  • func (mp MongoPersister) GetName() string
  • func (mp MongoPersister) GetSequence(name string, increase int) (int, error)
  • func (mp MongoPersister) GetValue(key string) (string, error)
  • func (mp MongoPersister) Read(name string) (string, error)
  • func (mp MongoPersister) ReadCollection(name string) (string, error)
  • func (mp MongoPersister) SetValue(key string, value string) error
  • func (mp MongoPersister) Write(name, content string) error
• type MongoRepository
  • func NewMongoRepository(connectionString string) *MongoRepository
  • func (mr MongoRepository) ConnectMongo() (session *mgo.Session, err error)
  • func (mr MongoRepository) DeleteItem(collectionName string, id string) error
  • func (mr MongoRepository) GetAllItems(collectionName string) (map[string]string, error)
  • func (mr MongoRepository) GetItem(collectionName string, id string) (value string, err error)
  • func (mr MongoRepository) UpsertItem(collectionName string, id string, body string) error
• type PersistEngineBag
  • func GetNewPersistEngineBag(def EntityPersister) *PersistEngineBag
  • func (peb *PersistEngineBag) Add(engine EntityPersister)
  • func (peb *PersistEngineBag) Get(name string) EntityPersister
  • func (peb *PersistEngineBag) SetDefault(def EntityPersister)

Types

type EntityActions

type EntityActions struct {
	Engines *PersistEngineBag
}

FilePersister persists body in file

func (EntityActions) ApplyActions

func (ea EntityActions) ApplyActions(m *definition.Mock)

type EntityPersister

type EntityPersister interface {
	Read(name string) (string, error)
	ReadCollection(name string) (string, error)
	Write(name, content string) error
	Delete(name string) error
	DeleteCollection(name string) error
	GetName() string
	GetSequence(name string, increase int) (int, error)
	GetValue(key string) (string, error)
	SetValue(key string, value string) error
}

type FilePersister

type FilePersister struct {
	PersistPath string
}

FilePersister persists body in file

func NewFilePersister

func NewFilePersister(persistPath string) *FilePersister

NewFilePersister creates a new FilePersister

func (FilePersister) Delete

func (fp FilePersister) Delete(name string) error

func (FilePersister) DeleteCollection

func (fp FilePersister) DeleteCollection(name string) error

func (FilePersister) GetName

func (fp FilePersister) GetName() string

func (FilePersister) GetSequence

func (fp FilePersister) GetSequence(name string, increase int) (int, error)

func (FilePersister) GetValue

func (fp FilePersister) GetValue(key string) (string, error)

func (FilePersister) Read

func (fp FilePersister) Read(name string) (string, error)

func (FilePersister) ReadCollection

func (fp FilePersister) ReadCollection(name string) (string, error)

func (FilePersister) SetValue

func (fp FilePersister) SetValue(key string, value string) error

func (FilePersister) Write

func (fp FilePersister) Write(name, content string) error

type MongoPersister

type MongoPersister struct {
	Repository MongoRepository
}

MongoPersister persists body in mongo

func NewMongoPersister

func NewMongoPersister(connectionString string) *MongoPersister

NewMongoPersister creates a new MongoPersister

func (MongoPersister) Delete

func (mp MongoPersister) Delete(name string) error

func (MongoPersister) DeleteCollection

func (mp MongoPersister) DeleteCollection(name string) error

func (MongoPersister) GetName

func (mp MongoPersister) GetName() string

func (MongoPersister) GetSequence

func (mp MongoPersister) GetSequence(name string, increase int) (int, error)

func (MongoPersister) GetValue

func (mp MongoPersister) GetValue(key string) (string, error)

func (MongoPersister) Read

func (mp MongoPersister) Read(name string) (string, error)

func (MongoPersister) ReadCollection

func (mp MongoPersister) ReadCollection(name string) (string, error)

func (MongoPersister) SetValue

func (mp MongoPersister) SetValue(key string, value string) error

func (MongoPersister) Write

func (mp MongoPersister) Write(name, content string) error

type MongoRepository

type MongoRepository struct {
	ConnectionInfo mgo.DialInfo
}

MongoRepository saves and loads items from mongo

func NewMongoRepository

func NewMongoRepository(connectionString string) *MongoRepository

NewMongoRepository creates a new MongoRepository

func (MongoRepository) ConnectMongo

func (mr MongoRepository) ConnectMongo() (session *mgo.Session, err error)

func (MongoRepository) DeleteItem

func (mr MongoRepository) DeleteItem(collectionName string, id string) error

DeleteItem deletes an item from a collection

func (MongoRepository) GetAllItems

func (mr MongoRepository) GetAllItems(collectionName string) (map[string]string, error)

GetAllItems gets all the items from a given collection

func (MongoRepository) GetItem

func (mr MongoRepository) GetItem(collectionName string, id string) (value string, err error)

GetItem gets the result string rom interface

func (MongoRepository) UpsertItem

func (mr MongoRepository) UpsertItem(collectionName string, id string, body string) error

UpsertItem inserts or updates item with a given id in a given collection

type PersistEngineBag

type PersistEngineBag struct {
	// contains filtered or unexported fields
}

func GetNewPersistEngineBag

func GetNewPersistEngineBag(def EntityPersister) *PersistEngineBag

func (*PersistEngineBag) Add

func (peb *PersistEngineBag) Add(engine EntityPersister)

func (*PersistEngineBag) Get

func (peb *PersistEngineBag) Get(name string) EntityPersister

func (*PersistEngineBag) SetDefault

func (peb *PersistEngineBag) SetDefault(def EntityPersister)