telegram_push_message_svc

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: May 16, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EnqueueMessageWL added in v1.2.0 

func EnqueueMessageWL(message tptypes.QueueMessage)

func ShouldSendMessageWL 

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

func StartTelegramPusherService added in v1.2.0 

func StartTelegramPusherService(appCtx config.AppContext)

Types

type PreventSpammingCase 

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

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
}

Source Files

View all Source files

Directories

Path Synopsis

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.