messagerepo

Documentation

Index

• type Configuration
• type Logger
• type Repository
  • func NewMessageRepository(ctx context.Context, conf Configuration) (*Repository, error)
  • func (r *Repository) Close(ctx context.Context) error
  • func (r *Repository) GetMessages(ctx context.Context, input models.GetMessagesInput) ([]*models.Message, error)
  • func (r *Repository) SaveMessage(ctx context.Context, message *models.Message) error

Types

type Configuration

type Configuration struct {
	IsDebugMode bool
	Logger      Logger
	Host        string
	Port        string
	Password    string
	DBName      string
	User        string
	SSLMode     string
}

Configuration contains setting for connection to message's repository

type Logger

type Logger interface {
	Debug(msg ...interface{})
	Info(msg ...interface{})
	Warn(msg ...interface{})
	Error(msg ...interface{})
	Fatal(msg ...interface{})
}

Logger ...

type Repository

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

Repository represents message's repository

func NewMessageRepository

func NewMessageRepository(ctx context.Context, conf Configuration) (*Repository, error)

NewMessageRepository creates new instance of message's repository

func (*Repository) Close

func (r *Repository) Close(ctx context.Context) error

Close close connection to message's repository

func (*Repository) GetMessages

func (r *Repository) GetMessages(ctx context.Context, input models.GetMessagesInput) ([]*models.Message, error)

GetMessages returns message by given time range

func (*Repository) SaveMessage

func (r *Repository) SaveMessage(ctx context.Context, message *models.Message) error

SaveMessage save message in `messages` table