service

Documentation

Index

• type Config
• type Messages
  • func New(cfg Config) *Messages
  • func (s *Messages) Close()
  • func (s *Messages) ReadUserMessages(ctx context.Context, userId usermodel.UserId, limit int32, offset int32, ...) (*model.MessagesList, error)
  • func (s *Messages) SaveMessage(ctx context.Context, msg *model.Message) (*model.Message, error)

Types

type Config

type Config struct {
	RpcAddr string
}

type Messages

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

func New

func New(cfg Config) *Messages

func (*Messages) Close

func (s *Messages) Close()

func (*Messages) ReadUserMessages

func (s *Messages) ReadUserMessages(
	ctx context.Context,
	userId usermodel.UserId,
	limit int32,
	offset int32,
	ascending bool,
) (
	*model.MessagesList,
	error,
)

func (*Messages) SaveMessage

func (s *Messages) SaveMessage(ctx context.Context, msg *model.Message) (
	*model.Message,
	error,
)