pkg

package

v0.0.0-...-4892902 Latest Latest Go to latest Published: Dec 20, 2022 License: Apache-2.0 Imports: 12 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/flant/negentropy

Links

Open Source Insights

Documentation ¶

Index ¶

func EmptyMemstore(kb *sharedkafka.MessageBroker, logger hclog.Logger) io.MemoryStore
func ParseRSAPrivateKey(privateKeyPEM string) (*rsa.PrivateKey, error)
func ParseRSAPubKey(publicKeyPEM string) (*rsa.PublicKey, error)
type DecryptedMessageProceeder
type KafkaSource
- func NewKafkaSource(kafkaCFG sharedkafka.BrokerConfig, topicName, groupID string, ...) *KafkaSource
- func (k *KafkaSource) Run()
- func (k *KafkaSource) Stop()

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)

func ParseRSAPubKey ¶

func ParseRSAPubKey(publicKeyPEM string) (*rsa.PublicKey, error)

Types ¶

type DecryptedMessageProceeder ¶

type DecryptedMessageProceeder interface {
	ProceedMessage(msgBody []byte, msgKey []byte) error
}

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()

Source Files ¶

View all Source files

consumer.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL