Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rboot

package module

Go to main page

Versions in this module

v1

v1.3.8

Sep 13, 2021

v1.3.7

Sep 13, 2021

Changes in this version

+ func Insert(ss []string, s string) []string

v1.3.6

Sep 13, 2021

v1.3.5

Sep 13, 2021

v1.3.4

Sep 13, 2021

v1.3.3

Sep 13, 2021

v1.3.2

Sep 9, 2021

v1.3.1

Sep 9, 2021

Changes in this version

+ const DefaultBoltDBFile

+ const HOOK_AFTER_OUTGOING

+ const HOOK_BEFORE_INCOMING

+ var AllHookTypes = []int

+ var JobQueue chan Job

+ func DetectAdapter(name string) (adapterF, error)

+ func DetectBrain(name string) (func() Brain, error)

+ func GetMsgChannel(from, to string) string

+ func LoadEnv(filenames ...string) (err error)

+ func NewTicker(d time.Duration, name string, f func()) *ticker

+ func NewTimer(d time.Duration, name string, f func()) *timer

+ func RegisterAdapter(name string, adp adapterF)

+ func RegisterBrain(name string, m func() Brain)

+ func RegisterPlugin(name string, plugin Plugin)

+ func StrToDuration(t int, arc string) (time.Duration, error)

+ type Adapter interface

+ Incoming func() chan *Message

+ Outgoing func() chan *Message

+ type Brain interface

+ Close func() error

+ Get func(bucket, key string) ([]byte, error)

+ Remove func(bucket, key string) error

+ Set func(bucket, key string, value []byte) error

+ func Bolt() Brain

+ type Dispatcher struct

+ MaxWorkers int

+ Quit chan bool

+ WorkerPool chan chan Job

+ func NewDispatcher(maxWorkers int) *Dispatcher

+ func (d *Dispatcher) Dispatch()

+ func (d *Dispatcher) Run()

+ func (d *Dispatcher) Stop()

+ type Header map[string][]string

+ func (h Header) Add(key, value string)

+ func (h Header) Del(key string)

+ func (h Header) Get(key string) string

+ func (h Header) GetKey(key string) []string

+ func (h Header) Set(key, value string)

+ type Hook interface

+ Fire func(*Message) error

+ Types func() []int

+ type Hooks map[int][]Hook

+ func (hooks Hooks) Add(hook Hook)

+ func (hooks Hooks) Fire(typ int, bot *Robot, msg *Message) error

+ type Job interface

+ Do func()

+ type Message struct

+ Channel string

+ Content string

+ From string

+ Header Header

+ KeepHeader bool

+ Sender string

+ Time time.Time

+ To string

+ func NewMessage(content string, to ...string) *Message

+ func NewMessages(content string, to ...string) []*Message

+ func (m *Message) Cc() []string

+ func (m *Message) SetCc(to ...string)

+ func (m *Message) String() string

+ type Plugin struct

+ Action PluginFunc

+ Description string

+ Ruleset map[string]string

+ Usage map[string]string

+ type PluginFunc func(bot *Robot, incoming *Message) []*Message

+ func DirectivePlugin(name string) (PluginFunc, error)

+ type Regex struct

+ func (reg *Regex) Match(pattern, msg string) ([]string, bool)

+ type Robot struct

+ Brain Brain

+ CachePath string

+ Debug bool

+ Hooks Hooks

+ Router *Router

+ func New() *Robot

+ func (bot *Robot) AddHook(hook Hook)

+ func (bot *Robot) Find(bucket, key string) ([]byte, error)

+ func (bot *Robot) Go()

+ func (bot *Robot) Incoming() chan *Message

+ func (bot *Robot) Outgoing(msg *Message)

+ func (bot *Robot) Remove(bucket, key string) error

+ func (bot *Robot) SendText(text string, to string)

+ func (bot *Robot) SetBrain(brain Brain)

+ func (bot *Robot) Stop()

+ func (bot *Robot) Store(bucket, key string, value []byte) error

+ func (bot *Robot) VerifySign(sign, secret, content, datetime string) error

+ type Router struct

+ func (r *Router) Handle(path string, handler http.Handler) *route

+ func (r *Router) HandleFunc(path string, f func(http.ResponseWriter, *http.Request)) *route

+ func (r *Router) Use(mwf ...func(http.Handler) http.Handler)

+ type Rule interface

+ Match func(pattern, msg string) ([]string, bool)

+ type Worker struct

+ JobChannel chan Job

+ Quit chan bool

+ WorkerPool chan chan Job

+ func NewWorker(workPool chan chan Job) Worker

+ func (w Worker) Start()

+ func (w Worker) Stop()