Documentation ¶
Overview ¶
Package msgsync propagates protobuf messages to a particular topic.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cfg ¶
type Cfg struct {
Topic string
}
Cfg groups configurations fields. It can be extended with other fields (such as sync/async, partition...).
type Deps ¶
type Deps struct { local.PluginInfraDeps // inject Messaging messaging.Mux // inject Cfg }
Deps groups dependencies injected into the plugin so that they are logically separated from other plugin fields.
type PubPlugin ¶
type PubPlugin struct { Deps // inject // contains filtered or unexported fields }
PubPlugin implements KeyProtoValWriter that propagates protobuf messages to a particular topic (unless the messaging.Mux is not disabled).
func (*PubPlugin) AfterInit ¶
AfterInit uses provided MUX connection to build new publisher.
func (*PubPlugin) Put ¶
Put propagates this call to a particular messaging Publisher.
This method is supposed to be called in PubPlugin.AfterInit() or later (even from different go routine).