service

Documentation

Index

• Constants
• func GetUrl(uuid string, action string) string
• type Cleaner
  • func (c *Cleaner) Clean(maxRetentionTimeInDays int)
  • func (c *Cleaner) CleanOutdatedTasks()
  • func (c *Cleaner) CountForTable(tableName string) *uint64
• type Investment
  • func NewInvestment(streamChannel chan<- *StreamingMessage, ctx context.Context, ...) *Investment
• type Job
  • func (r *Job) Run(params ...interface{})
• type MessageService
  • func NewMessageService(groupDao *persistence.GroupDao, ...) *MessageService
  • func (m *MessageService) SendJoinGroupEmail(username, email string, groupId, uid uint64)
• type Reminder
• type StreamingMessage

Constants

const (
	Accept  = "accept"
	Decline = "decline"
)

Functions

func GetUrl

func GetUrl(uuid string, action string) string

Types

type Cleaner

type Cleaner struct {
	Settings      postgresql.ConnectionURL
	StreamChannel chan<- *StreamingMessage
}

Cleaner ...

func (*Cleaner) Clean

func (c *Cleaner) Clean(maxRetentionTimeInDays int)

Clean ...Main method for executing cleaning jobs

func (*Cleaner) CleanOutdatedTasks

func (c *Cleaner) CleanOutdatedTasks()

Clean all outdated tasks for projects who have setting auto_delete is true

func (*Cleaner) CountForTable

func (c *Cleaner) CountForTable(tableName string) *uint64

CountForTable ...Helper method used for testing

type Investment

type Investment struct {
	StreamChannel chan<- *StreamingMessage
	// contains filtered or unexported fields
}

func NewInvestment

func NewInvestment(streamChannel chan<- *StreamingMessage, ctx context.Context, sampleTaskDao *persistence.SampleTaskDao, restClient *resty.Client) *Investment

type Job

type Job struct {
	Cleaner    *Cleaner
	Investment *Investment
	Reminder   *Reminder
}

func (*Job) Run

func (r *Job) Run(params ...interface{})

type MessageService

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

func NewMessageService

func NewMessageService(
	groupDao *persistence.GroupDao,
	joinGroupInvitationDao *persistence.JoinGroupInvitationDao,
	mailClient *mailjet.Client) *MessageService

func (*MessageService) SendJoinGroupEmail

func (m *MessageService) SendJoinGroupEmail(username, email string, groupId, uid uint64)

Send join group invitation email to users

type Reminder

type Reminder struct {
}

type StreamingMessage

type StreamingMessage struct {
	ServiceName string
	Message     uint64
	Err         error
}