repository

Documentation

Index

• Variables
• type MessageRepository
  • func CreateMessageRepository(id string) (MessageRepository, error)
  • func NewRqliteMessageRepository(db *rqlite.Conn) MessageRepository
• type RqliteMessageRepository
  • func (r *RqliteMessageRepository) Create(message pb.Message) (int64, error)
  • func (r *RqliteMessageRepository) Delete(id int64) error
  • func (r *RqliteMessageRepository) GetByID(id int64) (pb.Message, error)
  • func (r *RqliteMessageRepository) GetByUUID(uuid string) (pb.Message, error)
  • func (r *RqliteMessageRepository) List() ([]pb.Message, error)
  • func (r *RqliteMessageRepository) ListByType(t string) ([]pb.Message, error)

Variables

var ProviderSet = wire.NewSet(NewRqliteMessageRepository)

Types

type MessageRepository

type MessageRepository interface {
	GetByID(id int64) (pb.Message, error)
	GetByUUID(uuid string) (pb.Message, error)
	ListByType(t string) ([]pb.Message, error)
	List() ([]pb.Message, error)
	Create(message pb.Message) (int64, error)
	Delete(id int64) error
}

func CreateMessageRepository

func CreateMessageRepository(id string) (MessageRepository, error)

func NewRqliteMessageRepository

func NewRqliteMessageRepository(db *rqlite.Conn) MessageRepository

type RqliteMessageRepository

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

func (*RqliteMessageRepository) Create

func (r *RqliteMessageRepository) Create(message pb.Message) (int64, error)

func (*RqliteMessageRepository) Delete

func (r *RqliteMessageRepository) Delete(id int64) error

func (*RqliteMessageRepository) GetByID

func (r *RqliteMessageRepository) GetByID(id int64) (pb.Message, error)

func (*RqliteMessageRepository) GetByUUID

func (r *RqliteMessageRepository) GetByUUID(uuid string) (pb.Message, error)

func (*RqliteMessageRepository) List

func (r *RqliteMessageRepository) List() ([]pb.Message, error)

func (*RqliteMessageRepository) ListByType

func (r *RqliteMessageRepository) ListByType(t string) ([]pb.Message, error)