pgx

Documentation

Index

• type ChatRepository
  • func NewChatRepository(pool *pgxpool.Pool, log *zap.Logger) *ChatRepository
  • func (c *ChatRepository) CreateChat(ctx context.Context, id int64, chatType model.ChatType) error
  • func (c *ChatRepository) DeleteChat(ctx context.Context, id int64) error
  • func (c *ChatRepository) GetChatsWithNoMessageInIt(ctx context.Context, date time.Time, msg string) ([]int64, error)
  • func (c *ChatRepository) GetConsumersIDs(ctx context.Context) ([]int64, error)
  • func (c *ChatRepository) SafeThatMessageHadBeenSend(ctx context.Context, id int64, date time.Time, msg string) error
• type Storage
  • func New(pool *pgxpool.Pool, log *zap.Logger) *Storage
  • func (s *Storage) Chat() storage.ChatRepository

Types

type ChatRepository

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

func NewChatRepository

func NewChatRepository(pool *pgxpool.Pool, log *zap.Logger) *ChatRepository

func (*ChatRepository) CreateChat

func (c *ChatRepository) CreateChat(ctx context.Context, id int64, chatType model.ChatType) error

func (*ChatRepository) DeleteChat

func (c *ChatRepository) DeleteChat(ctx context.Context, id int64) error

func (*ChatRepository) GetChatsWithNoMessageInIt

func (c *ChatRepository) GetChatsWithNoMessageInIt(ctx context.Context, date time.Time, msg string) ([]int64, error)

func (*ChatRepository) GetConsumersIDs

func (c *ChatRepository) GetConsumersIDs(ctx context.Context) ([]int64, error)

func (*ChatRepository) SafeThatMessageHadBeenSend

func (c *ChatRepository) SafeThatMessageHadBeenSend(ctx context.Context, id int64, date time.Time, msg string) error

type Storage

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

func New

func New(pool *pgxpool.Pool, log *zap.Logger) *Storage

func (*Storage) Chat

func (s *Storage) Chat() storage.ChatRepository