Versions in this module Expand all Collapse all v0 v0.1.0 Mar 13, 2022 Changes in this version + func NewPostgresConnPool() (*sql.DB, error) + type ChannelMessageModel struct + ChannelID string + ID string + type MemoryChannelRepository struct + func NewMemoryChannelRepository() *MemoryChannelRepository + func (m *MemoryChannelRepository) GetChannelsByHashtags(ctx context.Context, hashtags []string) ([]domain.Channel, error) + func (m *MemoryChannelRepository) Save(ctx context.Context, channel domain.Channel) error + type PostgresChannelRepository struct + func NewPostgresChannelRepository(conn *sql.DB) *PostgresChannelRepository + func (r *PostgresChannelRepository) DeleteAll(ctx context.Context) error + func (r *PostgresChannelRepository) GetChannelsByHashtags(ctx context.Context, hashtags []string) ([]domain.Channel, error) + func (r *PostgresChannelRepository) Save(ctx context.Context, channel domain.Channel) error + type PostgresMessageRepository struct + func NewPostgresMessageRepository(conn *sql.DB) *PostgresMessageRepository + func (p *PostgresMessageRepository) GetByID(ctx context.Context, messageID string) (domain.Message, error) + func (p *PostgresMessageRepository) Save(ctx context.Context, msg domain.Message) error + type TgMessageSender struct + func NewMessageSender(tgBot *tgbotapi.BotAPI) *TgMessageSender + func (t *TgMessageSender) SendMessageToTgChan(tgChanId string, text string, username string, originMessageId string, ...) (domain.ChannelMessage, error)
Go to main page