notifications

package
v0.0.0-...-5fc2af4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ProposalCreated           = "proposal-created"
	ProposalActivating        = "proposal-activating-soon"
	ProposalCanceled          = "proposal-canceled"
	ProposalVotingOpen        = "proposal-voting-open"
	ProposalVotingEnding      = "proposal-voting-ending-soon"
	ProposalOutcome           = "proposal-outcome"
	ProposalAccepted          = "proposal-accepted"
	ProposalFailedQuorum      = "proposal-failed-quorum"
	ProposalFailedVotes       = "proposal-failed-votes"
	ProposalQueued            = "proposal-queued"
	ProposalQueueEnding       = "proposal-queue-ending-soon"
	ProposalGracePeriod       = "proposal-grace"
	ProposalExecuted          = "proposal-executed"
	ProposalExpires           = "proposal-expires-soon"
	ProposalExpired           = "proposal-expired"
	AbrogationProposalCreated = "abrogation-proposal-created"
	ProposalAbrogated         = "proposal-abrogated"
)
View Source 
const (
	ProposalStateWarmUp      = "WARMUP"
	ProposalStateActive      = "ACTIVE"
	ProposalStateCanceled    = "CANCELED"
	ProposalStateAccepted    = "ACCEPTED"
	ProposalStateFailed      = "FAILED"
	ProposalStateQueued      = "QUEUED"
	ProposalStateGracePeriod = "GRACE"
	ProposalStateExecuted    = "EXECUTED"
	ProposalStateAbrogated   = "ABROGATED"
	ProposalStateExpired     = "EXPIRED"
)
View Source 
const (
	DelegateStart = "delegate-start"
)
View Source 
const (
	SmartYieldTokenBought = "smart-yield-token-bought"
)

Variables

This section is empty.

Functions

func DeleteJobsWithTx 

func DeleteJobsWithTx(ctx context.Context, tx pgx.Tx, jobs ...*Job) error

func ExecuteJobsWithTx 

func ExecuteJobsWithTx(ctx context.Context, tx pgx.Tx, jobs ...*Job) error

func ScheduleJobsWithTx 

func ScheduleJobsWithTx(ctx context.Context, tx pgx.Tx, jobs ...*Job) error

func SoftDeleteJobsWithTx 

func SoftDeleteJobsWithTx(ctx context.Context, tx pgx.Tx, jobs ...*Job) error

Types

type AbrogationProposalCreatedJobData 

type AbrogationProposalCreatedJobData AbrogationProposalJobData

func (*AbrogationProposalCreatedJobData) ExecuteWithTx 

func (jd *AbrogationProposalCreatedJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type AbrogationProposalJobData 

type AbrogationProposalJobData struct {
	Id                    int64  `json:"proposalId"`
	Proposer              string `json:"proposer"`
	CreateTime            int64  `json:"createTime"`
	IncludedInBlockNumber int64  `json:"includedInBlockNumber"`
}

type DelegateJobData 

type DelegateJobData struct {
	StartTime             int64           `json:"startTime"`
	From                  string          `json:"from"`
	To                    string          `json:"to"`
	Amount                decimal.Decimal `json:"amount"`
	IncludedInBlockNumber int64           `json:"includedInBlockNumber"`
}

func (*DelegateJobData) ExecuteWithTx 

func (jd *DelegateJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type Job 

type Job struct {
	Id              int64           `json:"id"`
	JobType         string          `json:"jobType"`
	ExecuteOn       int64           `json:"executeOn"`
	JobData         json.RawMessage `json:"jobData"`
	IncludedInBlock int64           `json:"includedInBlock"`
}

func NewAbrogationProposalCreatedJob 

func NewAbrogationProposalCreatedJob(data *AbrogationProposalCreatedJobData) (*Job, error)

new abrogation proposal

func NewDelegateStartJob 

func NewDelegateStartJob(data *DelegateJobData) (*Job, error)

func NewJob 

func NewJob(typ string, executeOn int64, block int64, data interface{}) (*Job, error)

func NewProposalAbrogatedJob 

func NewProposalAbrogatedJob(data *ProposalAbrogatedJobData) (*Job, error)

func NewProposalActivatingJob 

func NewProposalActivatingJob(data *ProposalActivatingJobData) (*Job, error)

proposal voting starting soon

func NewProposalCanceledJob 

func NewProposalCanceledJob(data *ProposalCanceledJobData) (*Job, error)

proposal canceled

func NewProposalCreatedJob 

func NewProposalCreatedJob(data *ProposalCreatedJobData) (*Job, error)

proposal created

func NewProposalExecutedJob 

func NewProposalExecutedJob(data *ProposalExecutedJobData) (*Job, error)

proposal executed

func NewProposalExpiredJob 

func NewProposalExpiredJob(data *ProposalExpiredJobData) (*Job, error)

func NewProposalExpiresJob 

func NewProposalExpiresJob(data *ProposalExpiresJobData) (*Job, error)

proposal expires soon

func NewProposalGracePeriodJob 

func NewProposalGracePeriodJob(data *ProposalGracePeriodJobData) (*Job, error)

proposal entering the grace period

func NewProposalOutcomeJob 

func NewProposalOutcomeJob(data *ProposalOutcomeJobData) (*Job, error)

outcome of proposal voting period

func NewProposalQueueEndingJob 

func NewProposalQueueEndingJob(data *ProposalQueueEndingJobData) (*Job, error)

func NewProposalQueuedJob 

func NewProposalQueuedJob(data *ProposalQueuedJobData) (*Job, error)

proposal queued

func NewProposalVotingEndingJob 

func NewProposalVotingEndingJob(data *ProposalVotingEndingJobData) (*Job, error)

voting ending soon

func NewProposalVotingOpenJob 

func NewProposalVotingOpenJob(data *ProposalVotingOpenJobData) (*Job, error)

proposal started - voting open

func NewSmartYieldTokenBoughtJob 

func NewSmartYieldTokenBoughtJob(data *SmartYieldJobData) (*Job, error)

type JobExecuter 

type JobExecuter interface {
	ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)
}

type Notification 

type Notification struct {
	Target           string
	NotificationType string
	StartsOn         int64
	ExpiresOn        int64
	Message          string
	Metadata         types.JSONObject
	IncludedInBlock  int64
}

func NewNotification 

func NewNotification(target string, typ string, starts int64, expires int64, msg string, metadata map[string]interface{}, block int64) Notification

func (*Notification) ToDBWithTx 

func (n *Notification) ToDBWithTx(ctx context.Context, tx pgx.Tx) error

type ProposalAbrogatedJobData 

type ProposalAbrogatedJobData ProposalJobData

func (*ProposalAbrogatedJobData) ExecuteWithTx 

func (jd *ProposalAbrogatedJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalActivatingJobData 

type ProposalActivatingJobData ProposalJobData

func (*ProposalActivatingJobData) ExecuteWithTx 

func (jd *ProposalActivatingJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalCanceledJobData 

type ProposalCanceledJobData ProposalEventsJobData

func (*ProposalCanceledJobData) ExecuteWithTx 

func (jd *ProposalCanceledJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalCreatedJobData 

type ProposalCreatedJobData ProposalJobData

new proposal

func (*ProposalCreatedJobData) ExecuteWithTx 

func (jd *ProposalCreatedJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalEventsJobData 

type ProposalEventsJobData struct {
	Id                    int64  `json:"proposalId"`
	CreateTime            int64  `json:"createTime"`
	Caller                string `json:"caller"`
	IncludedInBlockNumber int64  `json:"includedInBlockNumber"`
}

type ProposalExecutedJobData 

type ProposalExecutedJobData ProposalEventsJobData

func (*ProposalExecutedJobData) ExecuteWithTx 

func (jd *ProposalExecutedJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalExpiredJobData 

type ProposalExpiredJobData ProposalJobData

func (*ProposalExpiredJobData) ExecuteWithTx 

func (jd *ProposalExpiredJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalExpiresJobData 

type ProposalExpiresJobData ProposalJobData

func (*ProposalExpiresJobData) ExecuteWithTx 

func (jd *ProposalExpiresJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalGracePeriodJobData 

type ProposalGracePeriodJobData ProposalJobData

func (*ProposalGracePeriodJobData) ExecuteWithTx 

func (jd *ProposalGracePeriodJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalJobData 

type ProposalJobData struct {
	Id                    int64  `json:"proposalId"`
	Proposer              string `json:"proposer"`
	Title                 string `json:"title"`
	CreateTime            int64  `json:"createTime"`
	WarmUpDuration        int64  `json:"warmUpDuration"`
	ActiveDuration        int64  `json:"activeDuration"`
	QueueDuration         int64  `json:"queueDuration"`
	GraceDuration         int64  `json:"graceDuration"`
	IncludedInBlockNumber int64  `json:"includedInBlockNumber"`
	DisplayDuration       int64  `json:"displayDuration"`
}

type ProposalOutcomeJobData 

type ProposalOutcomeJobData ProposalJobData

func (*ProposalOutcomeJobData) ExecuteWithTx 

func (jd *ProposalOutcomeJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalQueueEndingJobData 

type ProposalQueueEndingJobData ProposalJobData

func (*ProposalQueueEndingJobData) ExecuteWithTx 

func (jd *ProposalQueueEndingJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalQueuedJobData 

type ProposalQueuedJobData ProposalEventsJobData

func (*ProposalQueuedJobData) ExecuteWithTx 

func (jd *ProposalQueuedJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalVotingEndingJobData 

type ProposalVotingEndingJobData ProposalJobData

func (*ProposalVotingEndingJobData) ExecuteWithTx 

func (jd *ProposalVotingEndingJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type ProposalVotingOpenJobData 

type ProposalVotingOpenJobData ProposalJobData

func (*ProposalVotingOpenJobData) ExecuteWithTx 

func (jd *ProposalVotingOpenJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type SmartYieldJobData 

type SmartYieldJobData struct {
	StartTime             int64           `json:"startTime"`
	Pool                  smartyield.Pool `json:"pool"`
	HasRewardPool         bool            `json:"hasRewardPool"`
	Buyer                 string          `json:"buyer"`
	Amount                decimal.Decimal `json:"amount"`
	IncludedInBlockNumber int64           `json:"includedInBlockNumber"`
}

func (*SmartYieldJobData) ExecuteWithTx 

func (jd *SmartYieldJobData) ExecuteWithTx(ctx context.Context, tx pgx.Tx) ([]*Job, error)

type Worker 

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

func NewWorker 

func NewWorker(db *pgxpool.Pool) (*Worker, error)

func (*Worker) Run 

func (w *Worker) Run(ctx context.Context)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.