csv

Documentation

Index

• func NewHandlerI[T any](inj *do.Injector) (database.DBHandler[T], error)
• type CSVHandler
  • func NewHandler[T any](cfg *config.CSVConfig) *CSVHandler[T]
  • func (c *CSVHandler[T]) Close()
  • func (c *CSVHandler[T]) Create(input *T) (err error)
  • func (c *CSVHandler[T]) Delete(input *T) (err error)
  • func (c *CSVHandler[T]) Get(id string) (*T, error)
  • func (c *CSVHandler[T]) GetAll() ([]T, error)
  • func (c *CSVHandler[T]) Save(input *T) (err error)
  • func (c *CSVHandler[T]) ScheduleJob(s *gocron.Scheduler)
  • func (c *CSVHandler[T]) Shutdown() error
  • func (c *CSVHandler[T]) Update(dbObject T, input T) (err error)
• type SyncMap
  • func NewSyncMap[K comparable, V any]() *SyncMap[K, V]
  • func (rm *SyncMap[K, V]) Delete(key K)
  • func (rm *SyncMap[K, V]) Load(key K) (value V, ok bool)
  • func (rm *SyncMap[K, V]) LoadAll() (value []V)
  • func (rm *SyncMap[K, V]) Store(key K, value V)

Functions

func NewHandlerI

func NewHandlerI[T any](inj *do.Injector) (database.DBHandler[T], error)

Types

type CSVHandler

type CSVHandler[T any] struct {
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler[T any](cfg *config.CSVConfig) *CSVHandler[T]

func (*CSVHandler[T]) Close

func (c *CSVHandler[T]) Close()

func (*CSVHandler[T]) Create

func (c *CSVHandler[T]) Create(input *T) (err error)

func (*CSVHandler[T]) Delete

func (c *CSVHandler[T]) Delete(input *T) (err error)

func (*CSVHandler[T]) Get

func (c *CSVHandler[T]) Get(id string) (*T, error)

func (*CSVHandler[T]) GetAll

func (c *CSVHandler[T]) GetAll() ([]T, error)

func (*CSVHandler[T]) Save

func (c *CSVHandler[T]) Save(input *T) (err error)

func (*CSVHandler[T]) ScheduleJob

func (c *CSVHandler[T]) ScheduleJob(s *gocron.Scheduler)

func (*CSVHandler[T]) Shutdown

func (c *CSVHandler[T]) Shutdown() error

func (*CSVHandler[T]) Update

func (c *CSVHandler[T]) Update(dbObject T, input T) (err error)

type SyncMap

type SyncMap[K comparable, V any] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSyncMap

func NewSyncMap[K comparable, V any]() *SyncMap[K, V]

func (*SyncMap[K, V]) Delete

func (rm *SyncMap[K, V]) Delete(key K)

func (*SyncMap[K, V]) Load

func (rm *SyncMap[K, V]) Load(key K) (value V, ok bool)

func (*SyncMap[K, V]) LoadAll

func (rm *SyncMap[K, V]) LoadAll() (value []V)

func (*SyncMap[K, V]) Store

func (rm *SyncMap[K, V]) Store(key K, value V)