serve

Documentation

Index

• func New(n int) (chan<- Payload, <-chan struct{})
• func Run(c *config.Config, p chan<- Payload, sigint <-chan os.Signal, ...)
• type HandlerType
• type Payload
  • func (p *Payload) ID() string
• type SyncCommands
  • func NewSyncCommands(commands []string) *SyncCommands
  • func (s *SyncCommands) Decorate(command, chat string, f HandlerType) HandlerType

Functions

func New

func New(n int) (chan<- Payload, <-chan struct{})

New creates new channels for events queue and stopping any handling. A caller must close queue channel and waits stop one closing.

func Run

func Run(c *config.Config, p chan<- Payload, sigint <-chan os.Signal, logInfo, logError *log.Logger)

Run starts main service process.

Types

type HandlerType

type HandlerType func(context.Context, *cmd.Event) error

HandlerType is a type for command handler.

type Payload

type Payload struct {
	Cfg      *config.Config
	Event    *botgolang.Event
	LogInfo  *log.Logger
	LogError *log.Logger
}

Payload is a struct for events payload.

func (*Payload) ID

func (p *Payload) ID() string

ID returns message ID.

type SyncCommands

type SyncCommands struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SyncCommands is a global map of chats which should be locked during command execution.

func NewSyncCommands

func NewSyncCommands(commands []string) *SyncCommands

func (*SyncCommands) Decorate

func (s *SyncCommands) Decorate(command, chat string, f HandlerType) HandlerType

Decorate returns a decorated function for the chat.