socket

package

v1.9.3 Latest Latest Go to latest Published: Dec 12, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

View Source

const (

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

This section is empty.

func GetConnectFunc(moduleType string) broker.ConnectFunc

GetConnectFunc get connect func

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

SocketConnect socket connect

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

ModuleExchange module exchange

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

func InitSocketContext() *SocketContext

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

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

AddModuleGroup add module group

func (s *SocketContext) Cleanup(module string)

Cleanup cleanup

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

Receive receive

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

Send send

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

SendResp send the response that got by NewRespByMessage

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

SendSync send sync

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

SendToGroup send to group

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

SendToGroupSync send to group sync