Versions in this module Expand all Collapse all v2 v2.0.0 Sep 11, 2023 Changes in this version + func GetMiddlewareFunc(config MiddlewareConfig) func(http.ResponseWriter, *http.Request) + func InstallStd(config MiddlewareConfig, handler http.Handler) func(http.ResponseWriter, *http.Request) + type KafkaConfig struct + Hosts []string + Topic string + type MiddlewareConfig struct + CreateMessage func(*http.Request) []byte + Fail func(error) + Publisher Publish + SendCondition func(*http.Request) bool + Topic string + type Publish interface + Close func() error + Run func() error + Send func(data []byte) error + func NewFakePublisher() Publish + func NewKafkaPublisher(ctx context.Context, config KafkaConfig) Publish Other modules containing this package github.com/istomyang/wsevent
Go to main page