obrpcservice

Documentation

Index

• type ActionCmd
• type RPCAction
  • func NewRPCAction(objName, funcName string, needRet bool, params ...interface{}) *RPCAction
  • func (me *RPCAction) SetObjectIndex(index int) *RPCAction
• type RPCServiceExt
  • func InstanceExt() *RPCServiceExt
  • func (me *RPCServiceExt) AddServiceObjects(name string, objects []interface{}) bool
  • func (me *RPCServiceExt) PushRPCAction(action *RPCAction) bool
  • func (me *RPCServiceExt) StartRPCServiceExt()
  • func (me *RPCServiceExt) StopRPCServiceExt()
• type RoutinePool
  • func NewRoutinePool(cap int) *RoutinePool
  • func (me *RoutinePool) Close()
  • func (me *RoutinePool) Run()
• type Task

Types

type ActionCmd

type ActionCmd int

const (
	Action_RemoteCall ActionCmd = iota
	Action_RemoteExit
)

type RPCAction

type RPCAction struct {
	Ret      []interface{}
	RetError error

	RetChannel chan ActionCmd
	// contains filtered or unexported fields
}

RPCAction !

func NewRPCAction

func NewRPCAction(objName, funcName string, needRet bool, params ...interface{}) *RPCAction

func (*RPCAction) SetObjectIndex

func (me *RPCAction) SetObjectIndex(index int) *RPCAction

type RPCServiceExt

type RPCServiceExt struct {
	ConnectPoint chan ActionCmd
	// contains filtered or unexported fields
}

func InstanceExt

func InstanceExt() *RPCServiceExt

func (*RPCServiceExt) AddServiceObjects

func (me *RPCServiceExt) AddServiceObjects(name string, objects []interface{}) bool

AddServiceObjects !

func (*RPCServiceExt) PushRPCAction

func (me *RPCServiceExt) PushRPCAction(action *RPCAction) bool

PushRPCAction !

func (*RPCServiceExt) StartRPCServiceExt

func (me *RPCServiceExt) StartRPCServiceExt()

func (*RPCServiceExt) StopRPCServiceExt

func (me *RPCServiceExt) StopRPCServiceExt()

type RoutinePool

type RoutinePool struct {
	JobsChannel chan Task
	// contains filtered or unexported fields
}

func NewRoutinePool

func NewRoutinePool(cap int) *RoutinePool

func (*RoutinePool) Close

func (me *RoutinePool) Close()

func (*RoutinePool) Run

func (me *RoutinePool) Run()

type Task

type Task interface {
	Do()
}