contentdb

Documentation

Index

• type ContentDBService
  • func NewContentDBService(configs types.DBConfig, InstanceIDs []string) *ContentDBService
  • func (dbService *ContentDBService) AddLPPParticipant(instanceID string, lppParticipant types.LPPParticipant) (string, error)
  • func (dbService *ContentDBService) AddNewsItem(instanceID string, newsItem types.NewsItem) (string, error)
  • func (dbService *ContentDBService) AddTickBiteMapData(instanceID string, tickBiteMapData types.TickBiteMapData) (string, error)
  • func (dbService *ContentDBService) CreateIndexLPPInfos(instanceID string) error
  • func (dbService *ContentDBService) CreateIndexNewsItemInfos(instanceID string) error
  • func (dbService *ContentDBService) CreateIndexTickBiteMapInfos(instanceID string) error
  • func (dbService *ContentDBService) DeleteFileInfo(instanceID string, fileID string) (count int64, err error)
  • func (dbService *ContentDBService) FindFileInfo(instanceID string, fileID string) (types.FileInfo, error)
  • func (dbService *ContentDBService) FindTickBiteMapDataNewerThan(instanceID string, time int64) (tickBiteMapData []types.TickBiteMapData, err error)
  • func (dbService *ContentDBService) FindUninvitedLPPParticipants(instanceID string) ([]types.LPPParticipant, error)
  • func (dbService *ContentDBService) GetFileInfoList(instanceID string) (fileInfoList []types.FileInfo, err error)
  • func (dbService *ContentDBService) GetLPPParticipant(instanceID string, pid string) (lppParticipant types.LPPParticipant, err error)
  • func (dbService *ContentDBService) GetNewsItemsList(instanceID string) (newsItemList []types.NewsItem, err error)
  • func (dbService *ContentDBService) GetParticpantsToRemind(instanceID string) ([]types.LPPParticipant, error)
  • func (dbService *ContentDBService) ReplaceLPPParticipant(instanceID string, lppParticipant types.LPPParticipant) error
  • func (dbService *ContentDBService) SaveFileInfo(instanceID string, fileInfo types.FileInfo) (types.FileInfo, error)
  • func (dbService *ContentDBService) UpdateLPPParticipantInvitationSentAt(instanceID string, pid string, invitationSentAt time.Time) error
  • func (dbService *ContentDBService) UpdateLPPParticipantReminderSentAt(instanceID string, pid string, reminderSentAt time.Time) error
  • func (dbService *ContentDBService) UpdateLPPParticipantSubmissions(instanceID string, pid string, submissions map[string]time.Time, ...) error

Types

type ContentDBService

type ContentDBService struct {
	DBClient *mongo.Client

	DBNamePrefix string
	// contains filtered or unexported fields
}

func NewContentDBService

func NewContentDBService(configs types.DBConfig, InstanceIDs []string) *ContentDBService

func (*ContentDBService) AddLPPParticipant

func (dbService *ContentDBService) AddLPPParticipant(instanceID string, lppParticipant types.LPPParticipant) (string, error)

func (*ContentDBService) AddNewsItem

func (dbService *ContentDBService) AddNewsItem(instanceID string, newsItem types.NewsItem) (string, error)

func (*ContentDBService) AddTickBiteMapData

func (dbService *ContentDBService) AddTickBiteMapData(instanceID string, tickBiteMapData types.TickBiteMapData) (string, error)

func (*ContentDBService) CreateIndexLPPInfos

func (dbService *ContentDBService) CreateIndexLPPInfos(instanceID string) error

func (*ContentDBService) CreateIndexNewsItemInfos

func (dbService *ContentDBService) CreateIndexNewsItemInfos(instanceID string) error

func (*ContentDBService) CreateIndexTickBiteMapInfos

func (dbService *ContentDBService) CreateIndexTickBiteMapInfos(instanceID string) error

func (*ContentDBService) DeleteFileInfo

func (dbService *ContentDBService) DeleteFileInfo(instanceID string, fileID string) (count int64, err error)

func (*ContentDBService) FindFileInfo

func (dbService *ContentDBService) FindFileInfo(instanceID string, fileID string) (types.FileInfo, error)

func (*ContentDBService) FindTickBiteMapDataNewerThan

func (dbService *ContentDBService) FindTickBiteMapDataNewerThan(instanceID string, time int64) (tickBiteMapData []types.TickBiteMapData, err error)

func (*ContentDBService) FindUninvitedLPPParticipants

func (dbService *ContentDBService) FindUninvitedLPPParticipants(instanceID string) ([]types.LPPParticipant, error)

func (*ContentDBService) GetFileInfoList

func (dbService *ContentDBService) GetFileInfoList(instanceID string) (fileInfoList []types.FileInfo, err error)

func (*ContentDBService) GetLPPParticipant

func (dbService *ContentDBService) GetLPPParticipant(instanceID string, pid string) (lppParticipant types.LPPParticipant, err error)

func (*ContentDBService) GetNewsItemsList

func (dbService *ContentDBService) GetNewsItemsList(instanceID string) (newsItemList []types.NewsItem, err error)

func (*ContentDBService) GetParticpantsToRemind

func (dbService *ContentDBService) GetParticpantsToRemind(instanceID string) ([]types.LPPParticipant, error)

func (*ContentDBService) ReplaceLPPParticipant

func (dbService *ContentDBService) ReplaceLPPParticipant(instanceID string, lppParticipant types.LPPParticipant) error

func (*ContentDBService) SaveFileInfo

func (dbService *ContentDBService) SaveFileInfo(instanceID string, fileInfo types.FileInfo) (types.FileInfo, error)

func (*ContentDBService) UpdateLPPParticipantInvitationSentAt

func (dbService *ContentDBService) UpdateLPPParticipantInvitationSentAt(instanceID string, pid string, invitationSentAt time.Time) error

func (*ContentDBService) UpdateLPPParticipantReminderSentAt

func (dbService *ContentDBService) UpdateLPPParticipantReminderSentAt(instanceID string, pid string, reminderSentAt time.Time) error

func (*ContentDBService) UpdateLPPParticipantSubmissions

func (dbService *ContentDBService) UpdateLPPParticipantSubmissions(instanceID string, pid string, submissions map[string]time.Time, tempParticipantInfo *types.TempParticipantInfo) error