mongo

Documentation

Index

• func GetSession(ctx context.Context, db, url string) (*mongo.Database, error)
• type MessageRepository
  • func NewMessageRepository(db *mongo.Database) MessageRepository

Functions

func GetSession

func GetSession(ctx context.Context, db, url string) (*mongo.Database, error)

Types

type MessageRepository

type MessageRepository interface {
	FindMessageById(ctx context.Context, id string) (entities.Messages, error)
	AddMessage(ctx context.Context, body entities.Messages) (entities.Messages, error)
	GetAllMessages(ctx context.Context, limit, offset int64) ([]entities.Messages, error)
	DeleteMessageById(ctx context.Context, id string) (int64, error)
}

func NewMessageRepository

func NewMessageRepository(db *mongo.Database) MessageRepository