telegram

Documentation

Index

• func EscapeMarkdownV2(v any) string
• func Ref(v any, url string) string
• func Spoiler(v any) string
• func UserIdRef(v any, id int64) string
• func UserRef(v any, user string) string
• type AlertBot
  • func NewAlertBot(token string, chatId string, version string) *AlertBot
  • func (o *AlertBot) Close()
  • func (o *AlertBot) Closing()
  • func (o *AlertBot) QueueSize() int
  • func (o *AlertBot) Send(message string)
  • func (o *AlertBot) SendLog(m ulog.Message)
  • func (o *AlertBot) Sendf(f string, v ...any)
  • func (o *AlertBot) SetLogMessageLimit(limit int)
  • func (o *AlertBot) SetQueue(queue QueueIf[string])
  • func (o *AlertBot) Shutdown(ts time.Duration)
  • func (o *AlertBot) Startup()
• type Limiter
  • func NewLimiter[T any](send func(T)) *Limiter[T]
  • func (o *Limiter[T]) Close()
  • func (o *Limiter[T]) Push(m T) bool
  • func (o *Limiter[T]) Queue() QueueIf[T]
  • func (o *Limiter[T]) SetInterval(interval time.Duration)
  • func (o *Limiter[T]) SetQueue(queue QueueIf[T])
• type LimiterIf
• type Queue
  • func NewQueue[T any]() *Queue[T]
  • func (o *Queue[T]) Capacity() int
  • func (o *Queue[T]) Pop() (v T, ok bool)
  • func (o *Queue[T]) Push(v T) bool
  • func (o *Queue[T]) Reset()
  • func (o *Queue[T]) SetCapacity(capacity int)
  • func (o *Queue[T]) Size() int
• type QueueIf

Functions

func EscapeMarkdownV2

func EscapeMarkdownV2(v any) string

func Ref

func Ref(v any, url string) string

func Spoiler

func Spoiler(v any) string

func UserIdRef

func UserIdRef(v any, id int64) string

func UserRef

func UserRef(v any, user string) string

Types

type AlertBot

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

func NewAlertBot

func NewAlertBot(token string, chatId string, version string) *AlertBot

func (*AlertBot) Close

func (o *AlertBot) Close()

func (*AlertBot) Closing

func (o *AlertBot) Closing()

func (*AlertBot) QueueSize

func (o *AlertBot) QueueSize() int

func (*AlertBot) Send

func (o *AlertBot) Send(message string)

func (*AlertBot) SendLog

func (o *AlertBot) SendLog(m ulog.Message)

func (*AlertBot) Sendf

func (o *AlertBot) Sendf(f string, v ...any)

func (*AlertBot) SetLogMessageLimit

func (o *AlertBot) SetLogMessageLimit(limit int)

func (*AlertBot) SetQueue

func (o *AlertBot) SetQueue(queue QueueIf[string])

func (*AlertBot) Shutdown

func (o *AlertBot) Shutdown(ts time.Duration)

func (*AlertBot) Startup

func (o *AlertBot) Startup()

type Limiter

type Limiter[T any] struct {
	// contains filtered or unexported fields
}

func NewLimiter

func NewLimiter[T any](send func(T)) *Limiter[T]

func (*Limiter[T]) Close

func (o *Limiter[T]) Close()

func (*Limiter[T]) Push

func (o *Limiter[T]) Push(m T) bool

func (*Limiter[T]) Queue

func (o *Limiter[T]) Queue() QueueIf[T]

func (*Limiter[T]) SetInterval

func (o *Limiter[T]) SetInterval(interval time.Duration)

func (*Limiter[T]) SetQueue

func (o *Limiter[T]) SetQueue(queue QueueIf[T])

type LimiterIf

type LimiterIf[T any] interface {
	SetInterval(time.Duration)
	SetQueue(QueueIf[T])
	Queue() QueueIf[T]
	Close()
	Push(T) bool
}

type Queue

type Queue[T any] struct {
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue[T any]() *Queue[T]

func (*Queue[T]) Capacity

func (o *Queue[T]) Capacity() int

func (*Queue[T]) Pop

func (o *Queue[T]) Pop() (v T, ok bool)

func (*Queue[T]) Push

func (o *Queue[T]) Push(v T) bool

func (*Queue[T]) Reset

func (o *Queue[T]) Reset()

func (*Queue[T]) SetCapacity

func (o *Queue[T]) SetCapacity(capacity int)

func (*Queue[T]) Size

func (o *Queue[T]) Size() int

type QueueIf

type QueueIf[T any] interface {
	SetCapacity(int)
	Capacity() int
	Size() int
	Reset()
	Push(T) bool
	Pop() (T, bool)
}