repository

Documentation

Index

• Variables
• type MessageRepository
  • func CreateMessageRepository(id string) (MessageRepository, error)
  • func NewMysqlMessageRepository(id *global.ID, locker *global.Locker, db *mysql.Conn) MessageRepository
• type MysqlMessageRepository
  • func (r *MysqlMessageRepository) Create(ctx context.Context, message *pb.Message) (int64, error)
  • func (r *MysqlMessageRepository) Delete(ctx context.Context, id int64) error
  • func (r *MysqlMessageRepository) GetByID(ctx context.Context, id int64) (pb.Message, error)
  • func (r *MysqlMessageRepository) GetByUUID(ctx context.Context, uuid string) (pb.Message, error)
  • func (r *MysqlMessageRepository) List(ctx context.Context) ([]*pb.Message, error)
  • func (r *MysqlMessageRepository) ListByType(ctx context.Context, t string) ([]*pb.Message, error)

Variables

var ProviderSet = wire.NewSet(NewMysqlMessageRepository)

Types

type MessageRepository

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

func CreateMessageRepository

func CreateMessageRepository(id string) (MessageRepository, error)

func NewMysqlMessageRepository

func NewMysqlMessageRepository(id *global.ID, locker *global.Locker, db *mysql.Conn) MessageRepository

type MysqlMessageRepository

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

func (*MysqlMessageRepository) Create

func (r *MysqlMessageRepository) Create(ctx context.Context, message *pb.Message) (int64, error)

func (*MysqlMessageRepository) Delete

func (r *MysqlMessageRepository) Delete(ctx context.Context, id int64) error

func (*MysqlMessageRepository) GetByID

func (r *MysqlMessageRepository) GetByID(ctx context.Context, id int64) (pb.Message, error)

func (*MysqlMessageRepository) GetByUUID

func (r *MysqlMessageRepository) GetByUUID(ctx context.Context, uuid string) (pb.Message, error)

func (*MysqlMessageRepository) List

func (r *MysqlMessageRepository) List(ctx context.Context) ([]*pb.Message, error)

func (*MysqlMessageRepository) ListByType

func (r *MysqlMessageRepository) ListByType(ctx context.Context, t string) ([]*pb.Message, error)