socket

package

v1.19.0 Latest Latest Go to latest Published: Nov 11, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

View Source

const (

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

This section is empty.

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

Connect socket connect

func GetConnectFunc(moduleType string) broker.ConnectFunc

GetConnectFunc get connect func

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

Context is object for Context Socket

func InitSocketContext() *Context

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

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

AddModuleGroup add module group

func (s *Context) Cleanup(module string)

Cleanup cleanup

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

Receive receive

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

Send send

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

SendResp send the response that got by NewRespByMessage

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

SendSync send sync

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

SendToGroup send to group

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

SendToGroupSync send to group sync

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

ModuleExchange module exchange