app

package
v0.1.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 30, 2023 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const EmptyServiceName = "empty"
View Source 
const (
	HealthCheckName = "HEALTH"
)

Variables

View Source 
var (
	Config models.Config
)

Functions

func InitConfig 

func InitConfig(configFile string, envFile string)

func InitDB 

func InitDB()

InitDB creates a new database wrapper

func InitLogger 

func InitLogger()

Types

type Database 

type Database interface {
	Connect() error
	Disconnect() error

	InsertOne(collection string, data interface{}) error
	FindOne(collection string, filter interface{}, result interface{}) error
	FindMany(collection string, filter interface{}, result interface{}) error
	UpdateOne(collection string, filter interface{}, update interface{}) error
	UpsertOne(collection string, filter interface{}, update interface{}) error

	XLock(resourceId string) (string, error)
	SLock(resourceId string) (string, error)
	Unlock(lockId string) error
}
var (
	DB Database
)

type EmptyService 

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

func (*EmptyService) Health 

func (e *EmptyService) Health() models.ServiceHealth

func (*EmptyService) Start 

func (e *EmptyService) Start()

func (*EmptyService) Stop 

func (e *EmptyService) Stop()

type HealthCheckRunner 

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

func NewHealthCheck 

func NewHealthCheck() *HealthCheckRunner

func (*HealthCheckRunner) FindLastHealth 

func (x *HealthCheckRunner) FindLastHealth() (models.Health, error)

func (*HealthCheckRunner) PostHealth 

func (x *HealthCheckRunner) PostHealth() bool

func (*HealthCheckRunner) Run 

func (x *HealthCheckRunner) Run()

func (*HealthCheckRunner) ServiceHealths 

func (x *HealthCheckRunner) ServiceHealths() []models.ServiceHealth

func (*HealthCheckRunner) SetServices 

func (x *HealthCheckRunner) SetServices(services []Service)

func (*HealthCheckRunner) Status 

func (x *HealthCheckRunner) Status() models.RunnerStatus

type MockDatabase added in v0.1.9 

type MockDatabase struct {
	mock.Mock
}

MockDatabase is an autogenerated mock type for the Database type

func NewMockDatabase added in v0.1.9 

func NewMockDatabase(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDatabase

NewMockDatabase creates a new instance of MockDatabase. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDatabase) Connect added in v0.1.9 

func (_m *MockDatabase) Connect() error

Connect provides a mock function with given fields:

func (*MockDatabase) Disconnect added in v0.1.9 

func (_m *MockDatabase) Disconnect() error

Disconnect provides a mock function with given fields:

func (*MockDatabase) EXPECT added in v0.1.9 

func (_m *MockDatabase) EXPECT() *MockDatabase_Expecter

func (*MockDatabase) FindMany added in v0.1.9 

func (_m *MockDatabase) FindMany(collection string, filter interface{}, result interface{}) error

FindMany provides a mock function with given fields: collection, filter, result

func (*MockDatabase) FindOne added in v0.1.9 

func (_m *MockDatabase) FindOne(collection string, filter interface{}, result interface{}) error

FindOne provides a mock function with given fields: collection, filter, result

func (*MockDatabase) InsertOne added in v0.1.9 

func (_m *MockDatabase) InsertOne(collection string, data interface{}) error

InsertOne provides a mock function with given fields: collection, data

func (*MockDatabase) SLock added in v0.1.9 

func (_m *MockDatabase) SLock(resourceId string) (string, error)

SLock provides a mock function with given fields: resourceId

func (*MockDatabase) Unlock added in v0.1.9 

func (_m *MockDatabase) Unlock(lockId string) error

Unlock provides a mock function with given fields: lockId

func (*MockDatabase) UpdateOne added in v0.1.9 

func (_m *MockDatabase) UpdateOne(collection string, filter interface{}, update interface{}) error

UpdateOne provides a mock function with given fields: collection, filter, update

func (*MockDatabase) UpsertOne added in v0.1.9 

func (_m *MockDatabase) UpsertOne(collection string, filter interface{}, update interface{}) error

UpsertOne provides a mock function with given fields: collection, filter, update

func (*MockDatabase) XLock added in v0.1.9 

func (_m *MockDatabase) XLock(resourceId string) (string, error)

XLock provides a mock function with given fields: resourceId

type MockDatabase_Connect_Call added in v0.1.9 

type MockDatabase_Connect_Call struct {
	*mock.Call
}

MockDatabase_Connect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connect'

func (*MockDatabase_Connect_Call) Return added in v0.1.9 

func (_c *MockDatabase_Connect_Call) Return(_a0 error) *MockDatabase_Connect_Call

func (*MockDatabase_Connect_Call) Run added in v0.1.9 

func (_c *MockDatabase_Connect_Call) Run(run func()) *MockDatabase_Connect_Call

func (*MockDatabase_Connect_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_Connect_Call) RunAndReturn(run func() error) *MockDatabase_Connect_Call

type MockDatabase_Disconnect_Call added in v0.1.9 

type MockDatabase_Disconnect_Call struct {
	*mock.Call
}

MockDatabase_Disconnect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Disconnect'

func (*MockDatabase_Disconnect_Call) Return added in v0.1.9 

func (_c *MockDatabase_Disconnect_Call) Return(_a0 error) *MockDatabase_Disconnect_Call

func (*MockDatabase_Disconnect_Call) Run added in v0.1.9 

func (_c *MockDatabase_Disconnect_Call) Run(run func()) *MockDatabase_Disconnect_Call

func (*MockDatabase_Disconnect_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_Disconnect_Call) RunAndReturn(run func() error) *MockDatabase_Disconnect_Call

type MockDatabase_Expecter added in v0.1.9 

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

func (*MockDatabase_Expecter) Connect added in v0.1.9 

func (_e *MockDatabase_Expecter) Connect() *MockDatabase_Connect_Call

Connect is a helper method to define mock.On call

func (*MockDatabase_Expecter) Disconnect added in v0.1.9 

func (_e *MockDatabase_Expecter) Disconnect() *MockDatabase_Disconnect_Call

Disconnect is a helper method to define mock.On call

func (*MockDatabase_Expecter) FindMany added in v0.1.9 

func (_e *MockDatabase_Expecter) FindMany(collection interface{}, filter interface{}, result interface{}) *MockDatabase_FindMany_Call

FindMany is a helper method to define mock.On call

  • collection string
  • filter interface{}
  • result interface{}

func (*MockDatabase_Expecter) FindOne added in v0.1.9 

func (_e *MockDatabase_Expecter) FindOne(collection interface{}, filter interface{}, result interface{}) *MockDatabase_FindOne_Call

FindOne is a helper method to define mock.On call

  • collection string
  • filter interface{}
  • result interface{}

func (*MockDatabase_Expecter) InsertOne added in v0.1.9 

func (_e *MockDatabase_Expecter) InsertOne(collection interface{}, data interface{}) *MockDatabase_InsertOne_Call

InsertOne is a helper method to define mock.On call

  • collection string
  • data interface{}

func (*MockDatabase_Expecter) SLock added in v0.1.9 

func (_e *MockDatabase_Expecter) SLock(resourceId interface{}) *MockDatabase_SLock_Call

SLock is a helper method to define mock.On call

  • resourceId string

func (*MockDatabase_Expecter) Unlock added in v0.1.9 

func (_e *MockDatabase_Expecter) Unlock(lockId interface{}) *MockDatabase_Unlock_Call

Unlock is a helper method to define mock.On call

  • lockId string

func (*MockDatabase_Expecter) UpdateOne added in v0.1.9 

func (_e *MockDatabase_Expecter) UpdateOne(collection interface{}, filter interface{}, update interface{}) *MockDatabase_UpdateOne_Call

UpdateOne is a helper method to define mock.On call

  • collection string
  • filter interface{}
  • update interface{}

func (*MockDatabase_Expecter) UpsertOne added in v0.1.9 

func (_e *MockDatabase_Expecter) UpsertOne(collection interface{}, filter interface{}, update interface{}) *MockDatabase_UpsertOne_Call

UpsertOne is a helper method to define mock.On call

  • collection string
  • filter interface{}
  • update interface{}

func (*MockDatabase_Expecter) XLock added in v0.1.9 

func (_e *MockDatabase_Expecter) XLock(resourceId interface{}) *MockDatabase_XLock_Call

XLock is a helper method to define mock.On call

  • resourceId string

type MockDatabase_FindMany_Call added in v0.1.9 

type MockDatabase_FindMany_Call struct {
	*mock.Call
}

MockDatabase_FindMany_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindMany'

func (*MockDatabase_FindMany_Call) Return added in v0.1.9 

func (_c *MockDatabase_FindMany_Call) Return(_a0 error) *MockDatabase_FindMany_Call

func (*MockDatabase_FindMany_Call) Run added in v0.1.9 

func (_c *MockDatabase_FindMany_Call) Run(run func(collection string, filter interface{}, result interface{})) *MockDatabase_FindMany_Call

func (*MockDatabase_FindMany_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_FindMany_Call) RunAndReturn(run func(string, interface{}, interface{}) error) *MockDatabase_FindMany_Call

type MockDatabase_FindOne_Call added in v0.1.9 

type MockDatabase_FindOne_Call struct {
	*mock.Call
}

MockDatabase_FindOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindOne'

func (*MockDatabase_FindOne_Call) Return added in v0.1.9 

func (_c *MockDatabase_FindOne_Call) Return(_a0 error) *MockDatabase_FindOne_Call

func (*MockDatabase_FindOne_Call) Run added in v0.1.9 

func (_c *MockDatabase_FindOne_Call) Run(run func(collection string, filter interface{}, result interface{})) *MockDatabase_FindOne_Call

func (*MockDatabase_FindOne_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_FindOne_Call) RunAndReturn(run func(string, interface{}, interface{}) error) *MockDatabase_FindOne_Call

type MockDatabase_InsertOne_Call added in v0.1.9 

type MockDatabase_InsertOne_Call struct {
	*mock.Call
}

MockDatabase_InsertOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertOne'

func (*MockDatabase_InsertOne_Call) Return added in v0.1.9 

func (_c *MockDatabase_InsertOne_Call) Return(_a0 error) *MockDatabase_InsertOne_Call

func (*MockDatabase_InsertOne_Call) Run added in v0.1.9 

func (_c *MockDatabase_InsertOne_Call) Run(run func(collection string, data interface{})) *MockDatabase_InsertOne_Call

func (*MockDatabase_InsertOne_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_InsertOne_Call) RunAndReturn(run func(string, interface{}) error) *MockDatabase_InsertOne_Call

type MockDatabase_SLock_Call added in v0.1.9 

type MockDatabase_SLock_Call struct {
	*mock.Call
}

MockDatabase_SLock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SLock'

func (*MockDatabase_SLock_Call) Return added in v0.1.9 

func (_c *MockDatabase_SLock_Call) Return(_a0 string, _a1 error) *MockDatabase_SLock_Call

func (*MockDatabase_SLock_Call) Run added in v0.1.9 

func (_c *MockDatabase_SLock_Call) Run(run func(resourceId string)) *MockDatabase_SLock_Call

func (*MockDatabase_SLock_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_SLock_Call) RunAndReturn(run func(string) (string, error)) *MockDatabase_SLock_Call

type MockDatabase_Unlock_Call added in v0.1.9 

type MockDatabase_Unlock_Call struct {
	*mock.Call
}

MockDatabase_Unlock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unlock'

func (*MockDatabase_Unlock_Call) Return added in v0.1.9 

func (_c *MockDatabase_Unlock_Call) Return(_a0 error) *MockDatabase_Unlock_Call

func (*MockDatabase_Unlock_Call) Run added in v0.1.9 

func (_c *MockDatabase_Unlock_Call) Run(run func(lockId string)) *MockDatabase_Unlock_Call

func (*MockDatabase_Unlock_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_Unlock_Call) RunAndReturn(run func(string) error) *MockDatabase_Unlock_Call

type MockDatabase_UpdateOne_Call added in v0.1.9 

type MockDatabase_UpdateOne_Call struct {
	*mock.Call
}

MockDatabase_UpdateOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateOne'

func (*MockDatabase_UpdateOne_Call) Return added in v0.1.9 

func (_c *MockDatabase_UpdateOne_Call) Return(_a0 error) *MockDatabase_UpdateOne_Call

func (*MockDatabase_UpdateOne_Call) Run added in v0.1.9 

func (_c *MockDatabase_UpdateOne_Call) Run(run func(collection string, filter interface{}, update interface{})) *MockDatabase_UpdateOne_Call

func (*MockDatabase_UpdateOne_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_UpdateOne_Call) RunAndReturn(run func(string, interface{}, interface{}) error) *MockDatabase_UpdateOne_Call

type MockDatabase_UpsertOne_Call added in v0.1.9 

type MockDatabase_UpsertOne_Call struct {
	*mock.Call
}

MockDatabase_UpsertOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertOne'

func (*MockDatabase_UpsertOne_Call) Return added in v0.1.9 

func (_c *MockDatabase_UpsertOne_Call) Return(_a0 error) *MockDatabase_UpsertOne_Call

func (*MockDatabase_UpsertOne_Call) Run added in v0.1.9 

func (_c *MockDatabase_UpsertOne_Call) Run(run func(collection string, filter interface{}, update interface{})) *MockDatabase_UpsertOne_Call

func (*MockDatabase_UpsertOne_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_UpsertOne_Call) RunAndReturn(run func(string, interface{}, interface{}) error) *MockDatabase_UpsertOne_Call

type MockDatabase_XLock_Call added in v0.1.9 

type MockDatabase_XLock_Call struct {
	*mock.Call
}

MockDatabase_XLock_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'XLock'

func (*MockDatabase_XLock_Call) Return added in v0.1.9 

func (_c *MockDatabase_XLock_Call) Return(_a0 string, _a1 error) *MockDatabase_XLock_Call

func (*MockDatabase_XLock_Call) Run added in v0.1.9 

func (_c *MockDatabase_XLock_Call) Run(run func(resourceId string)) *MockDatabase_XLock_Call

func (*MockDatabase_XLock_Call) RunAndReturn added in v0.1.9 

func (_c *MockDatabase_XLock_Call) RunAndReturn(run func(string) (string, error)) *MockDatabase_XLock_Call

type MongoDatabase added in v0.1.9 

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

MongoDatabase is a wrapper around the mongo database

func (*MongoDatabase) Connect added in v0.1.9 

func (d *MongoDatabase) Connect() error

Connect connects to the database

func (*MongoDatabase) Disconnect added in v0.1.9 

func (d *MongoDatabase) Disconnect() error

Disconnect disconnects from the database

func (*MongoDatabase) FindMany added in v0.1.9 

func (d *MongoDatabase) FindMany(collection string, filter interface{}, result interface{}) error

method for find multiple values in a collection

func (*MongoDatabase) FindOne added in v0.1.9 

func (d *MongoDatabase) FindOne(collection string, filter interface{}, result interface{}) error

method for find single value in a collection

func (*MongoDatabase) InsertOne added in v0.1.9 

func (d *MongoDatabase) InsertOne(collection string, data interface{}) error

method for insert single value in a collection

func (*MongoDatabase) SLock added in v0.1.9 

func (d *MongoDatabase) SLock(resourceId string) (string, error)

SLock locks a resource for shared access

func (*MongoDatabase) SetupIndexes added in v0.1.9 

func (d *MongoDatabase) SetupIndexes() error

Setup Indexes

func (*MongoDatabase) SetupLocker added in v0.1.9 

func (d *MongoDatabase) SetupLocker() error

SetupLocker sets up the locker

func (*MongoDatabase) Unlock added in v0.1.9 

func (d *MongoDatabase) Unlock(lockId string) error

Unlock unlocks a resource

func (*MongoDatabase) UpdateOne added in v0.1.9 

func (d *MongoDatabase) UpdateOne(collection string, filter interface{}, update interface{}) error

method for update single value in a collection

func (*MongoDatabase) UpsertOne added in v0.1.9 

func (d *MongoDatabase) UpsertOne(collection string, filter interface{}, update interface{}) error

method for upsert single value in a collection

func (*MongoDatabase) XLock added in v0.1.9 

func (d *MongoDatabase) XLock(resourceId string) (string, error)

XLock locks a resource for exclusive access

type Runner 

type Runner interface {
	Run()
	Status() models.RunnerStatus
}

type RunnerService 

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

func (*RunnerService) Health 

func (x *RunnerService) Health() models.ServiceHealth

func (*RunnerService) Start 

func (x *RunnerService) Start()

func (*RunnerService) Stop 

func (x *RunnerService) Stop()

type Service 

type Service interface {
	Start()
	Health() models.ServiceHealth
	Stop()
}

func NewEmptyService 

func NewEmptyService(wg *sync.WaitGroup) Service

func NewHealthService 

func NewHealthService(x *HealthCheckRunner, wg *sync.WaitGroup) Service

func NewRunnerService 

func NewRunnerService(
	name string,
	runner Runner,
	wg *sync.WaitGroup,
	interval time.Duration,

) Service

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.