controller

Documentation

Index

• func NewCustomer(actID, bizID string, uniqueID uint64, talkID string, createTalkFlag bool, ...) defs.Customer
• func NewServicer(userID, uniqueID uint64, chSendMessage chan *talkpb.ServiceResponse, ...) defs.Servicer
• type CustomerController
  • func NewCustomerController(md defs.CustomerMD, m defs.ModelEx, logger l.Wrapper) *CustomerController
  • func NewCustomerControllerEx(maxCache, maxMessageCache int, md defs.CustomerMD, m defs.ModelEx, ...) *CustomerController
  • func (c *CustomerController) CustomerClose(customer defs.Customer) error
  • func (c *CustomerController) CustomerMessageIncoming(customer defs.Customer, seqID uint64, message *talkinters.TalkMessageW) error
  • func (c *CustomerController) InstallCustomer(customer defs.Customer) error
  • func (c *CustomerController) Post(f func())
  • func (c *CustomerController) UninstallCustomer(customer defs.Customer) error
• type ServicerController
  • func NewServicerController(md defs.ServicerMD, m defs.ModelEx, logger l.Wrapper) *ServicerController
  • func NewServicerControllerEx(maxCache, maxMessageCache int, md defs.ServicerMD, m defs.ModelEx, ...) *ServicerController
  • func (c *ServicerController) InstallServicer(servicer defs.Servicer) error
  • func (c *ServicerController) Post(f func())
  • func (c *ServicerController) ServicerAttachTalk(servicer defs.Servicer, talkID string) error
  • func (c *ServicerController) ServicerDetachTalk(servicer defs.Servicer, talkID string) error
  • func (c *ServicerController) ServicerMessageIncoming(servicer defs.Servicer, seqID uint64, talkID string, ...) error
  • func (c *ServicerController) ServicerQueryAttachedTalks(servicer defs.Servicer) error
  • func (c *ServicerController) ServicerQueryPendingTalks(servicer defs.Servicer) error
  • func (c *ServicerController) ServicerReloadTalk(servicer defs.Servicer, talkID string) error
  • func (c *ServicerController) UninstallServicer(servicer defs.Servicer) error

Functions

func NewCustomer

func NewCustomer(actID, bizID string, uniqueID uint64, talkID string, createTalkFlag bool, userID uint64, chSendMessage chan *talkpb.TalkResponse) defs.Customer

func NewServicer

func NewServicer(userID, uniqueID uint64, chSendMessage chan *talkpb.ServiceResponse, actIDs, bizIDs []string) defs.Servicer

Types

type CustomerController

type CustomerController struct {
	// contains filtered or unexported fields
}

func NewCustomerController

func NewCustomerController(md defs.CustomerMD, m defs.ModelEx, logger l.Wrapper) *CustomerController

func NewCustomerControllerEx

func NewCustomerControllerEx(maxCache, maxMessageCache int, md defs.CustomerMD, m defs.ModelEx, logger l.Wrapper) *CustomerController

func (*CustomerController) CustomerClose

func (c *CustomerController) CustomerClose(customer defs.Customer) error

func (*CustomerController) CustomerMessageIncoming

func (c *CustomerController) CustomerMessageIncoming(customer defs.Customer, seqID uint64,
	message *talkinters.TalkMessageW) error

func (*CustomerController) InstallCustomer

func (c *CustomerController) InstallCustomer(customer defs.Customer) error

func (*CustomerController) Post

func (c *CustomerController) Post(f func())

func (*CustomerController) UninstallCustomer

func (c *CustomerController) UninstallCustomer(customer defs.Customer) error

type ServicerController

type ServicerController struct {
	// contains filtered or unexported fields
}

func NewServicerController

func NewServicerController(md defs.ServicerMD, m defs.ModelEx, logger l.Wrapper) *ServicerController

func NewServicerControllerEx

func NewServicerControllerEx(maxCache, maxMessageCache int, md defs.ServicerMD, m defs.ModelEx, logger l.Wrapper) *ServicerController

func (*ServicerController) InstallServicer

func (c *ServicerController) InstallServicer(servicer defs.Servicer) error

func (*ServicerController) Post

func (c *ServicerController) Post(f func())

func (*ServicerController) ServicerAttachTalk

func (c *ServicerController) ServicerAttachTalk(servicer defs.Servicer, talkID string) error

func (*ServicerController) ServicerDetachTalk

func (c *ServicerController) ServicerDetachTalk(servicer defs.Servicer, talkID string) error

func (*ServicerController) ServicerMessageIncoming

func (c *ServicerController) ServicerMessageIncoming(servicer defs.Servicer, seqID uint64, talkID string,
	message *talkinters.TalkMessageW) error

func (*ServicerController) ServicerQueryAttachedTalks

func (c *ServicerController) ServicerQueryAttachedTalks(servicer defs.Servicer) error

func (*ServicerController) ServicerQueryPendingTalks

func (c *ServicerController) ServicerQueryPendingTalks(servicer defs.Servicer) error

func (*ServicerController) ServicerReloadTalk

func (c *ServicerController) ServicerReloadTalk(servicer defs.Servicer, talkID string) error

func (*ServicerController) UninstallServicer

func (c *ServicerController) UninstallServicer(servicer defs.Servicer) error