repository

Documentation

Index

• func GetType[T any](db *gorm.DB, sourceID string, name string) (*T, error)
• func GetTypes[T any](db *gorm.DB) ([]T, error)
• func GetTypesBySourceID[T any](db *gorm.DB, sourceID string) ([]T, error)
• func RegisterType[T any](db *gorm.DB, t T) (*T, error)
• type DatabaseRepository
  • func (r *DatabaseRepository) Close()
  • func (r *DatabaseRepository) GetActionType(sourceID string, name string) (*model.ActionType, error)
  • func (r *DatabaseRepository) GetActionTypes() ([]model.ActionType, error)
  • func (r *DatabaseRepository) GetActionTypesBySourceID(sourceID string) ([]model.ActionType, error)
  • func (r *DatabaseRepository) GetEventType(sourceID string, name string) (*model.EventType, error)
  • func (r *DatabaseRepository) GetEventTypes() ([]model.EventType, error)
  • func (r *DatabaseRepository) GetEventTypesBySourceID(sourceID string) ([]model.EventType, error)
  • func (r *DatabaseRepository) RegisterActionType(actionType model.ActionType) (*model.ActionType, error)
  • func (r *DatabaseRepository) RegisterEventType(eventType model.EventType) (*model.EventType, error)
• type Repository
  • func NewDatabaseRepository(databaseFilePath string) (Repository, error)
  • func NewDatabaseRepositoryInMemory() (Repository, error)

Functions

func GetType

func GetType[T any](db *gorm.DB, sourceID string, name string) (*T, error)

func GetTypes

func GetTypes[T any](db *gorm.DB) ([]T, error)

func GetTypesBySourceID

func GetTypesBySourceID[T any](db *gorm.DB, sourceID string) ([]T, error)

func RegisterType

func RegisterType[T any](db *gorm.DB, t T) (*T, error)

Types

type DatabaseRepository

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

func (*DatabaseRepository) Close

func (r *DatabaseRepository) Close()

func (*DatabaseRepository) GetActionType

func (r *DatabaseRepository) GetActionType(sourceID string, name string) (*model.ActionType, error)

func (*DatabaseRepository) GetActionTypes

func (r *DatabaseRepository) GetActionTypes() ([]model.ActionType, error)

func (*DatabaseRepository) GetActionTypesBySourceID

func (r *DatabaseRepository) GetActionTypesBySourceID(sourceID string) ([]model.ActionType, error)

func (*DatabaseRepository) GetEventType

func (r *DatabaseRepository) GetEventType(sourceID string, name string) (*model.EventType, error)

func (*DatabaseRepository) GetEventTypes

func (r *DatabaseRepository) GetEventTypes() ([]model.EventType, error)

func (*DatabaseRepository) GetEventTypesBySourceID

func (r *DatabaseRepository) GetEventTypesBySourceID(sourceID string) ([]model.EventType, error)

func (*DatabaseRepository) RegisterActionType

func (r *DatabaseRepository) RegisterActionType(actionType model.ActionType) (*model.ActionType, error)

func (*DatabaseRepository) RegisterEventType

func (r *DatabaseRepository) RegisterEventType(eventType model.EventType) (*model.EventType, error)

type Repository

type Repository interface {
	GetEventTypes() ([]model.EventType, error)
	RegisterEventType(eventType model.EventType) (*model.EventType, error)
	GetEventTypesBySourceID(sourceID string) ([]model.EventType, error)
	GetEventType(sourceID string, name string) (*model.EventType, error)

	GetActionTypes() ([]model.ActionType, error)
	RegisterActionType(actionType model.ActionType) (*model.ActionType, error)
	GetActionTypesBySourceID(sourceID string) ([]model.ActionType, error)
	GetActionType(sourceID string, name string) (*model.ActionType, error)

	Close()
}

func NewDatabaseRepository

func NewDatabaseRepository(databaseFilePath string) (Repository, error)

func NewDatabaseRepositoryInMemory

func NewDatabaseRepositoryInMemory() (Repository, error)