service

Documentation

Overview

Package telegram is telegram server.

Index

• func Initialize(ctx context.Context)
• type Type
  • func New(ctx context.Context, dao *dao.Type, token, api string) (*Type, error)
  • func (s *Type) LoadAlertTypes(cfg *dto.QueryCfg) (alerts []*model.AlertTypes, err error)
  • func (s *Type) LoadAlertTypesByUser(u *model.Users) (alerts []*model.AlertTypes, err error)
  • func (s *Type) LoadUsers(cfg *dto.QueryCfg) (users []*model.Users, err error)
  • func (s *Type) LoadUsersByAlertType(a *model.AlertTypes) (users []*model.Users, err error)
  • func (s *Type) PleaseRetry(sender *tb.User, msg string)
  • func (s *Type) SendMsgToUser(uid int, msg string) (err error)
  • func (s *Type) Stop()
  • func (s *Type) ValidateTokenForAlertType(token, alertType string) (alert *model.AlertTypes, err error)

Functions

func Initialize

func Initialize(ctx context.Context)

Types

type Type

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

Type client

var Instance *Type

func New

func New(ctx context.Context, dao *dao.Type, token, api string) (*Type, error)

New create new telegram client

func (*Type) LoadAlertTypes

func (s *Type) LoadAlertTypes(cfg *dto.QueryCfg) (alerts []*model.AlertTypes, err error)

func (*Type) LoadAlertTypesByUser

func (s *Type) LoadAlertTypesByUser(u *model.Users) (alerts []*model.AlertTypes, err error)

func (*Type) LoadUsers

func (s *Type) LoadUsers(cfg *dto.QueryCfg) (users []*model.Users, err error)

func (*Type) LoadUsersByAlertType

func (s *Type) LoadUsersByAlertType(a *model.AlertTypes) (users []*model.Users, err error)

func (*Type) PleaseRetry

func (s *Type) PleaseRetry(sender *tb.User, msg string)

PleaseRetry echo retry

func (*Type) SendMsgToUser

func (s *Type) SendMsgToUser(uid int, msg string) (err error)

func (*Type) Stop

func (s *Type) Stop()

Stop stop telegram polling

func (*Type) ValidateTokenForAlertType

func (s *Type) ValidateTokenForAlertType(token, alertType string) (alert *model.AlertTypes, err error)