storage

Documentation

Index

• type AddMonitoringFlowStorage
• type MonitoringStorage
• type RuntimeAddMonitoringFlowStorage
  • func NewRuntimeAddMonitoringFlowStorage() *RuntimeAddMonitoringFlowStorage
  • func (s *RuntimeAddMonitoringFlowStorage) Get(_ context.Context, chatID int64) (*dto.AddMonitoringStep, error)
  • func (s *RuntimeAddMonitoringFlowStorage) Remove(_ context.Context, chatID int64) error
  • func (s *RuntimeAddMonitoringFlowStorage) Set(_ context.Context, data dto.AddMonitoringStep) error
• type RuntimeMonitoringStorage
  • func NewRuntimeMonitoringStorage() *RuntimeMonitoringStorage
  • func (s *RuntimeMonitoringStorage) GetAll(_ context.Context) ([]dto.MonitoringData, error)
  • func (s *RuntimeMonitoringStorage) GetAllByVehicleAndCountGte(_ context.Context, vehicleName string, count int) ([]dto.MonitoringData, error)
  • func (s *RuntimeMonitoringStorage) Remove(_ context.Context, chatID int64, vehicleName string) error
  • func (s *RuntimeMonitoringStorage) Save(_ context.Context, data dto.MonitoringData) error
• type SQLiteMonitoringStorage
  • func NewSQLiteMonitoringStorage(dbPath string) (*SQLiteMonitoringStorage, error)
  • func (s *SQLiteMonitoringStorage) GetAll(ctx context.Context) ([]dto.MonitoringData, error)
  • func (s *SQLiteMonitoringStorage) GetAllByVehicleAndCountGte(ctx context.Context, vehicleName string, count int) ([]dto.MonitoringData, error)
  • func (s *SQLiteMonitoringStorage) Remove(ctx context.Context, chatID int64, vehicleName string) error
  • func (s *SQLiteMonitoringStorage) Save(ctx context.Context, data dto.MonitoringData) error

Types

type AddMonitoringFlowStorage

type AddMonitoringFlowStorage interface {
	Set(ctx context.Context, data dto.AddMonitoringStep) error
	Get(ctx context.Context, chatID int64) (*dto.AddMonitoringStep, error)
	Remove(ctx context.Context, chatID int64) error
}

type MonitoringStorage

type MonitoringStorage interface {
	Save(ctx context.Context, data dto.MonitoringData) error
	Remove(ctx context.Context, chatID int64, vehicleName string) error
	GetAll(ctx context.Context) ([]dto.MonitoringData, error)
	GetAllByVehicleAndCountGte(ctx context.Context, vehicleName string, count int) ([]dto.MonitoringData, error)
}

type RuntimeAddMonitoringFlowStorage

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

func NewRuntimeAddMonitoringFlowStorage

func NewRuntimeAddMonitoringFlowStorage() *RuntimeAddMonitoringFlowStorage

func (*RuntimeAddMonitoringFlowStorage) Get

func (s *RuntimeAddMonitoringFlowStorage) Get(_ context.Context, chatID int64) (*dto.AddMonitoringStep, error)

func (*RuntimeAddMonitoringFlowStorage) Remove

func (s *RuntimeAddMonitoringFlowStorage) Remove(_ context.Context, chatID int64) error

func (*RuntimeAddMonitoringFlowStorage) Set

func (s *RuntimeAddMonitoringFlowStorage) Set(_ context.Context, data dto.AddMonitoringStep) error

type RuntimeMonitoringStorage

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

func NewRuntimeMonitoringStorage

func NewRuntimeMonitoringStorage() *RuntimeMonitoringStorage

func (*RuntimeMonitoringStorage) GetAll

func (s *RuntimeMonitoringStorage) GetAll(_ context.Context) ([]dto.MonitoringData, error)

func (*RuntimeMonitoringStorage) GetAllByVehicleAndCountGte

func (s *RuntimeMonitoringStorage) GetAllByVehicleAndCountGte(_ context.Context, vehicleName string, count int) ([]dto.MonitoringData, error)

func (*RuntimeMonitoringStorage) Remove

func (s *RuntimeMonitoringStorage) Remove(_ context.Context, chatID int64, vehicleName string) error

func (*RuntimeMonitoringStorage) Save

func (s *RuntimeMonitoringStorage) Save(_ context.Context, data dto.MonitoringData) error

type SQLiteMonitoringStorage

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

func NewSQLiteMonitoringStorage

func NewSQLiteMonitoringStorage(dbPath string) (*SQLiteMonitoringStorage, error)

func (*SQLiteMonitoringStorage) GetAll

func (s *SQLiteMonitoringStorage) GetAll(ctx context.Context) ([]dto.MonitoringData, error)

func (*SQLiteMonitoringStorage) GetAllByVehicleAndCountGte

func (s *SQLiteMonitoringStorage) GetAllByVehicleAndCountGte(ctx context.Context, vehicleName string, count int) ([]dto.MonitoringData, error)

func (*SQLiteMonitoringStorage) Remove

func (s *SQLiteMonitoringStorage) Remove(ctx context.Context, chatID int64, vehicleName string) error

func (*SQLiteMonitoringStorage) Save

func (s *SQLiteMonitoringStorage) Save(ctx context.Context, data dto.MonitoringData) error