storagepostgres

Documentation

Index

• type StorageMsgTasksDB
  • func NewStorageMsgTasksDB(ctx context.Context, login string, password string, host string, port string, ...) (StorageMsgTasksDB, error)
  • func (s *StorageMsgTasksDB) AddElement(ctx context.Context, msgId string, taskId string) error
  • func (s *StorageMsgTasksDB) Finish()
  • func (s *StorageMsgTasksDB) GetIdMessageByTask(ctx context.Context, taskId string) (string, error)
  • func (s *StorageMsgTasksDB) GetIdTaskByMessage(ctx context.Context, msgId string) (string, error)

Types

type StorageMsgTasksDB

type StorageMsgTasksDB struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

func NewStorageMsgTasksDB

func NewStorageMsgTasksDB(ctx context.Context, login string, password string, host string, port string, name string, table string, sqlOpen func(string, string) (*sql.DB, error)) (StorageMsgTasksDB, error)

func (*StorageMsgTasksDB) AddElement

func (s *StorageMsgTasksDB) AddElement(ctx context.Context, msgId string, taskId string) error

func (*StorageMsgTasksDB) Finish

func (s *StorageMsgTasksDB) Finish()

func (*StorageMsgTasksDB) GetIdMessageByTask

func (s *StorageMsgTasksDB) GetIdMessageByTask(ctx context.Context, taskId string) (string, error)

func (*StorageMsgTasksDB) GetIdTaskByMessage

func (s *StorageMsgTasksDB) GetIdTaskByMessage(ctx context.Context, msgId string) (string, error)