telegram_push_message_svc

Documentation

Index

• func EnqueueMessageWL(message tptypes.QueueMessage)
• func GetSilentPatternsByChatIdRL(chatID int64) map[string]time.Time
• func RemoveSilencePatternWL(chatID int64, pattern string) error
• func SetSilencePatternWL(chatID int64, pattern string, duration time.Duration) (update bool, err error)
• func ShouldSendMessageWL(_case PreventSpammingCase, identities []string, ...) (shouldSendToIdentities []string)
• func StartTelegramPusherService(appCtx config.AppContext)
• type PreventSpammingCase
• type ReceiverBasedQueue

Functions

func EnqueueMessageWL

func EnqueueMessageWL(message tptypes.QueueMessage)

func GetSilentPatternsByChatIdRL

func GetSilentPatternsByChatIdRL(chatID int64) map[string]time.Time

func RemoveSilencePatternWL

func RemoveSilencePatternWL(chatID int64, pattern string) error

func SetSilencePatternWL

func SetSilencePatternWL(chatID int64, pattern string, duration time.Duration) (update bool, err error)

func ShouldSendMessageWL

func ShouldSendMessageWL(_case PreventSpammingCase, identities []string, ignoreIfLastSentLessThan time.Duration) (shouldSendToIdentities []string)

func StartTelegramPusherService

func StartTelegramPusherService(appCtx config.AppContext)

Types

type PreventSpammingCase

type PreventSpammingCase int8

const (
	PreventSpammingCaseTomeStoned PreventSpammingCase = iota
	PreventSpammingCaseJailed
	PreventSpammingCaseLowUptime
	PreventSpammingCaseMissedBlocksOverDangerousThreshold
	PreventSpammingCaseDirectHealthCheckOptionalRPC
	PreventSpammingCaseHealthCheckManagedRPC
	PreventSpammingCaseNotVotedGovernance
)

type ReceiverBasedQueue

type ReceiverBasedQueue interface {
	EnqueueMessageWL(types.QueueMessage)
	AnyPendingMessageRL() bool
	GetQueueInfoRL() (receiver int64, isReceiverPriority bool, size int, lastEnqueueUTC time.Time)
	DequeueMessagesWL(size int) []types.QueueMessage
	GetReceiverId() int64
}