model

Documentation

Index

• type ClientEvents
  • func NewClientEvents(ctx context.Context, chatID int64, botNotify chan<- Notification, ...) *ClientEvents
  • func (e *ClientEvents) ContinuousReadAndNotify()
  • func (e *ClientEvents) SendAction(a pkgmodel.ActionEvent) error
• type Event
• type Notification
  • func NewNotification(chatID int64, text string) Notification

Types

type ClientEvents

type ClientEvents struct {

	// Recv прием сообщений от клиентского приложения
	Recv chan *Event
	// Send отправка сообщений в клиентское приложение
	Send chan *Event
	// Err обработка ошибок, при появлении в канале объекта, клиентский стрим закрывается
	Err chan error

	// IsNotify флаг показывает отправлять ли пользователю сообщения
	IsNotify bool
	// contains filtered or unexported fields
}

ClientEvents обеспечивает связь между пользователем telegram и конкретным клиентским приложением структура содержит каналы, которые привязаны к стриму подключенного клиентского приложения

func NewClientEvents

func NewClientEvents(ctx context.Context, chatID int64, botNotify chan<- Notification, isNotify bool, logger zerolog.Logger) *ClientEvents

NewClientEvents создает настроенную структуру ClientEvents

func (*ClientEvents) ContinuousReadAndNotify

func (e *ClientEvents) ContinuousReadAndNotify()

ContinuousReadAndNotify ожидает событие от клиентского приложения и передает его непосредственно в чат пользователю

func (*ClientEvents) SendAction

func (e *ClientEvents) SendAction(a pkgmodel.ActionEvent) error

SendAction отправить событие клиентскому приложению

type Event

type Event struct {
	E   *proto.Event
	Err error
}

Event внутреннее описание события

type Notification

type Notification struct {
	ChatID int64
	Text   string
}

Notification внутреннее описание события уведомления

func NewNotification

func NewNotification(chatID int64, text string) Notification