history

Documentation

Index

• Constants
• type Handlers
  • func NewHandlers(repository *HistoryRepository) *Handlers
  • func (h *Handlers) Post(c *fiber.Ctx) error
• type History
• type HistoryRepository
  • func NewHistoryRepository(conn string, database string) (*HistoryRepository, error)
  • func (r *HistoryRepository) Disconnect() error
  • func (r *HistoryRepository) Insert(path string) error
• type Rabbit
  • func NewRabbit(rabbitMQ string, repository *HistoryRepository) (*Rabbit, error)
  • func (r *Rabbit) Close()
  • func (r *Rabbit) Listen() error

Constants

const (
	MongoClientTimeout = 5
)

Types

type Handlers

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

func NewHandlers

func NewHandlers(repository *HistoryRepository) *Handlers

func (*Handlers) Post

func (h *Handlers) Post(c *fiber.Ctx) error

type History

type History struct {
	ID      primitive.ObjectID `bson:"_id"`
	Path    string             `bson:"videoPath"`
	Watched time.Time          `bson:"watched"`
}

type HistoryRepository

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

func NewHistoryRepository

func NewHistoryRepository(conn string, database string) (*HistoryRepository, error)

func (*HistoryRepository) Disconnect

func (r *HistoryRepository) Disconnect() error

func (*HistoryRepository) Insert

func (r *HistoryRepository) Insert(path string) error

type Rabbit

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

func NewRabbit

func NewRabbit(rabbitMQ string, repository *HistoryRepository) (*Rabbit, error)

func (*Rabbit) Close

func (r *Rabbit) Close()

func (*Rabbit) Listen

func (r *Rabbit) Listen() error