Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ConsumerPluginPath = golenv.OverrideIfEnv("CONSUMER_PLUGIN_PATH", "./consumer.so")
)
View Source
var (
ConsumerType = golenv.OverrideIfEnv("CONSUMER_TYPE", "tcp-server")
)
Functions ¶
Types ¶
type Consumer ¶
type Consumer interface {
Consume()
}
func NewConsumerPlugin ¶
func NewConsumerPlugin() Consumer
func NewTCPServer ¶
func NewTCPServer() Consumer
type ConsumerPlugin ¶
func (*ConsumerPlugin) Consume ¶
func (plugin *ConsumerPlugin) Consume()
type NewConsumerFunc ¶
type NewConsumerFunc func() Consumer
Click to show internal directories.
Click to hide internal directories.