socket

Documentation

Index

• Constants
• func Connect(opts broker.ConnectOptions) (interface{}, error)
• func GetConnectFunc(moduleType string) broker.ConnectFunc
• type Context
  • func InitSocketContext() *Context
  • func (s *Context) AddModule(info *common.ModuleInfo)
  • func (s *Context) AddModuleGroup(module, group string)
  • func (s *Context) Cleanup(module string)
  • func (s *Context) Receive(module string) (model.Message, error)
  • func (s *Context) Send(module string, message model.Message)
  • func (s *Context) SendResp(message model.Message)
  • func (s *Context) SendSync(module string, message model.Message, timeout time.Duration) (model.Message, error)
  • func (s *Context) SendToGroup(group string, message model.Message)
  • func (s *Context) SendToGroupSync(module string, message model.Message, timeout time.Duration) error
• type ModuleExchange

Constants

const (

	// TODO: configurable
	HandshakeTimeout = 60 * time.Second
)

Functions

func Connect

func Connect(opts broker.ConnectOptions) (interface{}, error)

Connect socket connect

func GetConnectFunc

func GetConnectFunc(moduleType string) broker.ConnectFunc

GetConnectFunc get connect func

Types

type Context

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

Context is object for Context Socket

func InitSocketContext

func InitSocketContext() *Context

func (*Context) AddModule

func (s *Context) AddModule(info *common.ModuleInfo)

func (*Context) AddModuleGroup

func (s *Context) AddModuleGroup(module, group string)

AddModuleGroup add module group

func (*Context) Cleanup

func (s *Context) Cleanup(module string)

Cleanup cleanup

func (*Context) Receive

func (s *Context) Receive(module string) (model.Message, error)

Receive receive

func (*Context) Send

func (s *Context) Send(module string, message model.Message)

Send send

func (*Context) SendResp

func (s *Context) SendResp(message model.Message)

SendResp send the response that got by NewRespByMessage

func (*Context) SendSync

func (s *Context) SendSync(module string, message model.Message, timeout time.Duration) (model.Message, error)

SendSync send sync

func (*Context) SendToGroup

func (s *Context) SendToGroup(group string, message model.Message)

SendToGroup send to group

func (*Context) SendToGroupSync

func (s *Context) SendToGroupSync(module string, message model.Message, timeout time.Duration) error

SendToGroupSync send to group sync

type ModuleExchange

type ModuleExchange struct {
	Modules []string            `json:"modules"`
	Groups  map[string][]string `json:"groups"`
}

ModuleExchange module exchange