store

Documentation

Index

• type Store
  • func New(config *config.Config) (*Store, error)
  • func (s *Store) Close() error
  • func (s *Store) CreateFile(file model.File) (*int, error)
  • func (s *Store) CreateMessage(message model.CreateMessageParams) (*int, error)
  • func (s *Store) CreateSession(session model.Session) (*int, error)
  • func (s *Store) CreateThread(thread model.Thread) (*int, error)
  • func (s *Store) CreateUser(user model.CreateUser) (*int, error)
  • func (s *Store) DeleteExpiredMessages() error
  • func (s *Store) DeleteExpiredSessions() error
  • func (s *Store) DeleteFile(id int) error
  • func (s *Store) DeleteMessage(messageID int) error
  • func (s *Store) DeleteSession(id int) error
  • func (s *Store) DeleteSessionByUserID(userID int) error
  • func (s *Store) DeleteStaleThread() error
  • func (s *Store) DeleteThread(id int) error
  • func (s *Store) GetExpiredMessages() ([]model.Message, error)
  • func (s *Store) GetExpiredSessions() ([]model.Session, error)
  • func (s *Store) GetExpiredThreads() ([]model.Thread, error)
  • func (s *Store) GetFile(id int) (*model.File, error)
  • func (s *Store) GetFileByPath(path string) (*model.File, error)
  • func (s *Store) GetFilesByThread(threadID int) ([]model.File, error)
  • func (s *Store) GetMessage(messageID int) (*model.Message, error)
  • func (s *Store) GetMessagesByThread(threadId int, lastId *int) ([]model.Message, error)
  • func (s *Store) GetSession(id int) (*model.Session, error)
  • func (s *Store) GetSessionByUserID(userID int) (*model.Session, error)
  • func (s *Store) GetThread(id int) (*model.Thread, error)
  • func (s *Store) GetUser(id int) (*model.User, error)
  • func (s *Store) GetUserBySlackID(slackID string) (*model.User, error)
  • func (s *Store) Migrate() error
  • func (s *Store) Ping() error
  • func (s *Store) SetMessageExpiresAt(messageID int, expireAt time.Time) error
  • func (s *Store) SetMessageFileID(messageID int, fileID int) error
  • func (s *Store) SetThreadSlackTimestamp(threadID int, slackTimestamp string) error
  • func (s *Store) UpdateMessage(message model.UpdateMessageParams) error
  • func (s *Store) UpdateSessionExpiresAt(id int, expiresAt time.Time) error
  • func (s *Store) UpdateUser(user model.CreateUser) error

Types

type Store

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

func New

func New(config *config.Config) (*Store, error)

func (*Store) Close

func (s *Store) Close() error

func (*Store) CreateFile

func (s *Store) CreateFile(file model.File) (*int, error)

func (*Store) CreateMessage

func (s *Store) CreateMessage(message model.CreateMessageParams) (*int, error)

func (*Store) CreateSession

func (s *Store) CreateSession(session model.Session) (*int, error)

func (*Store) CreateThread

func (s *Store) CreateThread(thread model.Thread) (*int, error)

func (*Store) CreateUser

func (s *Store) CreateUser(user model.CreateUser) (*int, error)

func (*Store) DeleteExpiredMessages

func (s *Store) DeleteExpiredMessages() error

func (*Store) DeleteExpiredSessions

func (s *Store) DeleteExpiredSessions() error

func (*Store) DeleteFile

func (s *Store) DeleteFile(id int) error

func (*Store) DeleteMessage

func (s *Store) DeleteMessage(messageID int) error

func (*Store) DeleteSession

func (s *Store) DeleteSession(id int) error

func (*Store) DeleteSessionByUserID

func (s *Store) DeleteSessionByUserID(userID int) error

func (*Store) DeleteStaleThread

func (s *Store) DeleteStaleThread() error

func (*Store) DeleteThread

func (s *Store) DeleteThread(id int) error

func (*Store) GetExpiredMessages

func (s *Store) GetExpiredMessages() ([]model.Message, error)

func (*Store) GetExpiredSessions

func (s *Store) GetExpiredSessions() ([]model.Session, error)

func (*Store) GetExpiredThreads

func (s *Store) GetExpiredThreads() ([]model.Thread, error)

func (*Store) GetFile

func (s *Store) GetFile(id int) (*model.File, error)

func (*Store) GetFileByPath

func (s *Store) GetFileByPath(path string) (*model.File, error)

func (*Store) GetFilesByThread

func (s *Store) GetFilesByThread(threadID int) ([]model.File, error)

func (*Store) GetMessage

func (s *Store) GetMessage(messageID int) (*model.Message, error)

func (*Store) GetMessagesByThread

func (s *Store) GetMessagesByThread(threadId int, lastId *int) ([]model.Message, error)

func (*Store) GetSession

func (s *Store) GetSession(id int) (*model.Session, error)

func (*Store) GetSessionByUserID

func (s *Store) GetSessionByUserID(userID int) (*model.Session, error)

func (*Store) GetThread

func (s *Store) GetThread(id int) (*model.Thread, error)

func (*Store) GetUser

func (s *Store) GetUser(id int) (*model.User, error)

func (*Store) GetUserBySlackID

func (s *Store) GetUserBySlackID(slackID string) (*model.User, error)

func (*Store) Migrate

func (s *Store) Migrate() error

func (*Store) Ping

func (s *Store) Ping() error

func (*Store) SetMessageExpiresAt

func (s *Store) SetMessageExpiresAt(messageID int, expireAt time.Time) error

func (*Store) SetMessageFileID

func (s *Store) SetMessageFileID(messageID int, fileID int) error

func (*Store) SetThreadSlackTimestamp

func (s *Store) SetThreadSlackTimestamp(threadID int, slackTimestamp string) error

func (*Store) UpdateMessage

func (s *Store) UpdateMessage(message model.UpdateMessageParams) error

func (*Store) UpdateSessionExpiresAt

func (s *Store) UpdateSessionExpiresAt(id int, expiresAt time.Time) error

func (*Store) UpdateUser

func (s *Store) UpdateUser(user model.CreateUser) error