observability

package

v1.5.0 Latest Latest Go to latest Published: Jun 2, 2026 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func EscapeHTML(text string) string

func SplitMessage(text string, limit int) []string

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

func Init(proxyURL, secretKey, groupID, topicID, from string, handler slog.Handler) (*Manager, slog.Handler)

func NewManager(client *TelegramClient) *Manager

func (m *Manager) Drain()

func (m *Manager) Handler(next slog.Handler) slog.Handler

func (m *Manager) Start()

func (m *Manager) TriggerSystemEvent(event, details string)

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

func NewClient(cfg TelegramConfig) *TelegramClient

func (c *TelegramClient) IsCoolingDown() bool

func (c *TelegramClient) Send(ctx context.Context, message string) error

type TelegramConfig struct {
	ProxyURL  string
	SecretKey string
	GroupID   string
	TopicID   string
	From      string
}

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

func NewHandler(next slog.Handler, client *TelegramClient, queue chan string) *TelegramHandler

func (h *TelegramHandler) Enabled(ctx context.Context, level slog.Level) bool

func (h *TelegramHandler) Handle(ctx context.Context, r slog.Record) error

func (h *TelegramHandler) WithAttrs(attrs []slog.Attr) slog.Handler

func (h *TelegramHandler) WithGroup(name string) slog.Handler