sms

Documentation

Index

• Variables
• func AsyncPool() *goroutine.Pool
• func PersistenceSmsJournal()
• func Query(queryId int64) []any
• func SelectSession(phone string) *session.Session
• func Send(message string, phones ...string) (queryId int64)
• func StartCacheExpireTicker(asyncHandler func([]any))
• type ISP
  • func (i ISP) Int() int
• type SessionFactory
  • func CreateSessionFactory(isp string) *SessionFactory
  • func (f *SessionFactory) Len() int
  • func (f *SessionFactory) Less(i, j int) bool
  • func (f *SessionFactory) PeekSession() *session.Session
  • func (f *SessionFactory) Swap(i, j int)

Variables

var Conf yaml_config.YmlConfig

var ISPS = [3]string{session.CMPP, session.SGIP, session.SMGP}

Functions

func AsyncPool

func AsyncPool() *goroutine.Pool

func PersistenceSmsJournal

func PersistenceSmsJournal()

func Query

func Query(queryId int64) []any

func SelectSession

func SelectSession(phone string) *session.Session

SelectSession 根据手机号码选择一个会话

func Send

func Send(message string, phones ...string) (queryId int64)

Send sms to phones return query id

func StartCacheExpireTicker

func StartCacheExpireTicker(asyncHandler func([]any))

StartCacheExpireTicker 过期数据定期检查器

Types

type ISP

type ISP string

func (ISP) Int

func (i ISP) Int() int

type SessionFactory

type SessionFactory struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func CreateSessionFactory

func CreateSessionFactory(isp string) *SessionFactory

CreateSessionFactory 创建或获取由isp指定的factory，isp需与sms.yml配置文件对应，否则会引起程序崩溃

func (*SessionFactory) Len

func (f *SessionFactory) Len() int

func (*SessionFactory) Less

func (f *SessionFactory) Less(i, j int) bool

func (*SessionFactory) PeekSession

func (f *SessionFactory) PeekSession() *session.Session

PeekSession 获取排序后在头部的会话（最近最少使用的会话）

func (*SessionFactory) Swap

func (f *SessionFactory) Swap(i, j int)