mysql

Documentation

Index

• type ArchiveRepository
  • func NewArchiveRepository(db boil.ContextExecutor, fileTransfer transfer.IFileTransfer) *ArchiveRepository
  • func (i *ArchiveRepository) GetArchive(ctx context.Context, archiveID primitive.ID) (entity.Archive, error)
  • func (i *ArchiveRepository) GetArchiveByArchiveEventID(ctx context.Context, archiveEventID primitive.ID) (entity.Archive, error)
  • func (i *ArchiveRepository) Save(ctx context.Context, archive entity.Archive) error
• type ClientRepository
  • func NewClientRepository(db boil.ContextExecutor) *ClientRepository
  • func (i *ClientRepository) GetClient(ctx context.Context, clientID primitive.ID) (entity.Client, error)
• type DeviceRepository
  • func NewDeviceRepository(db boil.ContextExecutor) *DeviceRepository
  • func (d *DeviceRepository) GetDevice(ctx context.Context, deviceID primitive.ID) (entity.Device, error)
• type EventRepository
  • func NewEventRepository(db boil.ContextExecutor) *EventRepository
  • func (r *EventRepository) GetArchiveEvent(ctx context.Context, archiveEventID primitive.ID) (entity.ArchiveEvent, error)
  • func (r *EventRepository) SaveArchiveEvent(ctx context.Context, archiveEvent entity.ArchiveEvent) error
• type TxManager
  • func NewTxManger(db *sql.DB) *TxManager
  • func (t *TxManager) DoInTx(ctx context.Context, operation usecase.Operation) (context.Context, error)

Types

type ArchiveRepository

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

func NewArchiveRepository

func NewArchiveRepository(db boil.ContextExecutor, fileTransfer transfer.IFileTransfer) *ArchiveRepository

func (*ArchiveRepository) GetArchive

func (i *ArchiveRepository) GetArchive(
	ctx context.Context,
	archiveID primitive.ID,
) (entity.Archive, error)

func (*ArchiveRepository) GetArchiveByArchiveEventID

func (i *ArchiveRepository) GetArchiveByArchiveEventID(
	ctx context.Context,
	archiveEventID primitive.ID,
) (entity.Archive, error)

func (*ArchiveRepository) Save

func (i *ArchiveRepository) Save(
	ctx context.Context,
	archive entity.Archive,
) error

type ClientRepository

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

func NewClientRepository

func NewClientRepository(db boil.ContextExecutor) *ClientRepository

func (*ClientRepository) GetClient

func (i *ClientRepository) GetClient(ctx context.Context, clientID primitive.ID) (entity.Client, error)

type DeviceRepository

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

func NewDeviceRepository

func NewDeviceRepository(db boil.ContextExecutor) *DeviceRepository

func (*DeviceRepository) GetDevice

func (d *DeviceRepository) GetDevice(ctx context.Context, deviceID primitive.ID) (entity.Device, error)

type EventRepository

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

func NewEventRepository

func NewEventRepository(db boil.ContextExecutor) *EventRepository

func (*EventRepository) GetArchiveEvent

func (r *EventRepository) GetArchiveEvent(ctx context.Context, archiveEventID primitive.ID) (entity.ArchiveEvent, error)

func (*EventRepository) SaveArchiveEvent

func (r *EventRepository) SaveArchiveEvent(ctx context.Context, archiveEvent entity.ArchiveEvent) error

type TxManager

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

func NewTxManger

func NewTxManger(db *sql.DB) *TxManager

func (*TxManager) DoInTx

func (t *TxManager) DoInTx(ctx context.Context, operation usecase.Operation) (context.Context, error)