kafka

Documentation

Index

• Variables
• func Init(cfg *Config, log mq.Logger, redis kfklib.Redis) error
• func OperateLogPublisherAdapter(topic string, publisher publisherAdapter) operatePublisherAdapter
• func PublisherAdapter() publisherAdapter
• func SubscriberAdapter() subscriberAdapter
• type Config
  • func (cfg *Config) SetDefault()

Variables

var Exit = kfklib.Exit

Functions

func Init

func Init(cfg *Config, log mq.Logger, redis kfklib.Redis) error

func OperateLogPublisherAdapter

func OperateLogPublisherAdapter(topic string, publisher publisherAdapter) operatePublisherAdapter

func PublisherAdapter

func PublisherAdapter() publisherAdapter

func SubscriberAdapter

func SubscriberAdapter() subscriberAdapter

Types

type Config

type Config struct {
	kfklib.Config
}

func (*Config) SetDefault

func (cfg *Config) SetDefault()