repository

Documentation

Index

• Constants
• type FileMessageRepository
  • func NewFileMessageRepository() *FileMessageRepository[model.Message]
  • func (r *FileMessageRepository[T]) FindByTopic(topic string) ([]model.Message, error)
  • func (r *FileMessageRepository[T]) Insert(message model.Message) error
• type MongoMessageRepository
  • func NewMongoMessageRepository(client *mongo.Client) *MongoMessageRepository[model.Message]
  • func (r *MongoMessageRepository[T]) FindByTopic(topic string) ([]model.Message, error)
  • func (r *MongoMessageRepository[T]) Insert(message model.Message) error
• type Repository

Constants

const (
	DefaultStoragePath = "../db-data/filestore"
)

Types

type FileMessageRepository

type FileMessageRepository[T model.Message] struct {
	// contains filtered or unexported fields
}

func NewFileMessageRepository

func NewFileMessageRepository() *FileMessageRepository[model.Message]

func (*FileMessageRepository[T]) FindByTopic

func (r *FileMessageRepository[T]) FindByTopic(topic string) ([]model.Message, error)

func (*FileMessageRepository[T]) Insert

func (r *FileMessageRepository[T]) Insert(message model.Message) error

type MongoMessageRepository

type MongoMessageRepository[T model.Message] struct {
	// contains filtered or unexported fields
}

func NewMongoMessageRepository

func NewMongoMessageRepository(client *mongo.Client) *MongoMessageRepository[model.Message]

func (*MongoMessageRepository[T]) FindByTopic

func (r *MongoMessageRepository[T]) FindByTopic(topic string) ([]model.Message, error)

func (*MongoMessageRepository[T]) Insert

func (r *MongoMessageRepository[T]) Insert(message model.Message) error

type Repository

type Repository[T any] interface {
	Insert(t T) error
	FindByTopic(topic string) ([]T, error)
}