Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EmptyMemstore ¶
func EmptyMemstore(kb *sharedkafka.MessageBroker, logger hclog.Logger) io.MemoryStore
func ParseRSAPrivateKey ¶
func ParseRSAPrivateKey(privateKeyPEM string) (*rsa.PrivateKey, error)
Types ¶
type KafkaSource ¶
type KafkaSource struct { io.KafkaSourceImpl // need for using KafkaSourceImpl io.MemoryStore }
func NewKafkaSource ¶
func NewKafkaSource(kafkaCFG sharedkafka.BrokerConfig, topicName, groupID string, parentLogger hclog.Logger, proceeder DecryptedMessageProceeder) *KafkaSource
func (*KafkaSource) Run ¶
func (k *KafkaSource) Run()
func (*KafkaSource) Stop ¶
func (k *KafkaSource) Stop()
Click to show internal directories.
Click to hide internal directories.