channels

Documentation

Index

• Variables
• func NewTelegramChat(apiURL string, botToken string, chatID string, opts map[string]string, ...) (*telegramChat, error)
• type MessageChannelInterface
  • func BuildChannel(chanURL *url.URL, logger *zerolog.Logger) (MessageChannelInterface, error)
  • func BuildChannelsFromURLS(urls []string, logger *zerolog.Logger) ([]MessageChannelInterface, error)
  • func NewTelegramChannel(chanURL *url.URL, logger *zerolog.Logger) (MessageChannelInterface, error)
• type TelegramMessage
  • func (m *TelegramMessage) Map() (map[string]interface{}, error)
  • func (m *TelegramMessage) String() string

Variables

var (
	ErrUnknownChannelType = eris.New("Unknown channel type")
	ErrCreateChannelErorr = eris.New("Error on create channel")
)

var (
	ErrChannelIsFull      = eris.New("The channel is full")
	ErrInvalidMessageType = eris.New("Invalid message type")
)

var (
	TelegramMessageQueueCap = 1000
	TelegramBotAPIURL       = "https://api.telegram.org"
)

var ErrTelegramInvalidTimeout = eris.New("Invalid telegram timeout")

Functions

func NewTelegramChat

func NewTelegramChat(apiURL string, botToken string, chatID string, opts map[string]string, logger *zerolog.Logger) (*telegramChat, error)

Types

type MessageChannelInterface

type MessageChannelInterface interface {
	fmt.Stringer
	Name() string
	MessageContainer() interface{}
	Enqueue(interface{}) error
	Provider() interface {
		HTTPClient() *http.Client
	}
	Stop() error
	Start() error
}

func BuildChannel

func BuildChannel(chanURL *url.URL, logger *zerolog.Logger) (MessageChannelInterface, error)

func BuildChannelsFromURLS

func BuildChannelsFromURLS(urls []string, logger *zerolog.Logger) ([]MessageChannelInterface, error)

func NewTelegramChannel

func NewTelegramChannel(chanURL *url.URL, logger *zerolog.Logger) (MessageChannelInterface, error)

type TelegramMessage

type TelegramMessage struct {
	Text                  string  `json:"text" mapstructure:"text"`
	ParseMode             *string `json:"parseMode,omitempty" mapstructure:"parse_mode,omitempty"`
	DisableWebPagePreview int     `json:"disableWebPagePreview" mapstructure:"disable_web_page_preview"`
	DisableNotifications  int     `json:"disableNotifications" mapstructure:"disable_notifications"`
	ReplyToMessageID      *int    `json:"replyToMessageId,omitempty" mapstructure:"reply_to_message_id,omitempty"`
}

func (*TelegramMessage) Map

func (m *TelegramMessage) Map() (map[string]interface{}, error)

func (*TelegramMessage) String

func (m *TelegramMessage) String() string