service

package

v0.0.0-...-2f87fcc Latest Latest Go to latest Published: Jun 3, 2023 License: GPL-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/singerdmx/BulletJournal

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetUrl(uuid string, action string) string
type Cleaner
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 ¶

View Source

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

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL