Documentation
¶
Index ¶
- Constants
- func ListProjectMembers(db *sqlx.DB) func(msg activity.Message)
- func Main()
- func MarkJobUuid(db *sqlx.DB) func(msg activity.Message)
- func MarkProjectUuid(db *sqlx.DB) func(msg activity.Message)
- type ActivityStore
- type ActivityWorker
- type BelongsToJob
- type BelongsToProject
- type DbActivityStore
- type MemoryActivityStore
Constants ¶
View Source
const ProgramName = "activity-worker"
Variables ¶
This section is empty.
Functions ¶
func ListProjectMembers ¶
ListProjectMembers fetches all project members and uses them as the activity's audience if the payload satisfies the BelongsToProject interface.
Types ¶
type ActivityStore ¶
type ActivityWorker ¶
type ActivityWorker struct {
// contains filtered or unexported fields
}
func NewActivityWorker ¶
func NewActivityWorker(source activity.Source, store ActivityStore) *ActivityWorker
func (*ActivityWorker) AddMessageHandler ¶
func (self *ActivityWorker) AddMessageHandler(handler func(activity.Message)) *ActivityWorker
func (*ActivityWorker) Log ¶
func (self *ActivityWorker) Log() logger.Logger
func (*ActivityWorker) SetLogger ¶
func (self *ActivityWorker) SetLogger(l logger.Logger)
func (*ActivityWorker) Start ¶
func (self *ActivityWorker) Start() error
func (*ActivityWorker) Stop ¶
func (self *ActivityWorker) Stop()
type BelongsToJob ¶
type BelongsToProject ¶
type BelongsToProject interface {
FindProject(store domain.ProjectStore) (*domain.Project, error)
}
type DbActivityStore ¶
type DbActivityStore struct {
// contains filtered or unexported fields
}
func NewDbActivityStore ¶
func NewDbActivityStore(db *sqlx.DB) *DbActivityStore
type MemoryActivityStore ¶
type MemoryActivityStore struct {
All []*domain.Activity
// contains filtered or unexported fields
}
func NewMemoryActivityStore ¶
func NewMemoryActivityStore() *MemoryActivityStore
func (*MemoryActivityStore) FailWith ¶
func (self *MemoryActivityStore) FailWith(err error) *MemoryActivityStore
Source Files
Click to show internal directories.
Click to hide internal directories.