iprocbusmem

Documentation

Index

• func Provide(groups []ChannelGroup) (bus iprocbus.IProcBus)
• type ChannelGroup

Functions

func Provide

func Provide(groups []ChannelGroup) (bus iprocbus.IProcBus)

Usage:

• Create IProcBus
• CommandProcessorsGroup: group0:{NumChannels:10, ChannelBufferSize: 10}
• One command processor - one channel
• QueryProcessorsGroup: group1:{NumChannels:1, ChannelBufferSize: 0}
• Wire IProcBus.ServiceChannel(...) to services
• Use Submit() to deliver messages to services

Types

type ChannelGroup

type ChannelGroup struct {
	NumChannels       int
	ChannelBufferSize int
}