messageimpl

Documentation

Index

• func Exit()
• func Init(cfg *Config, log *logrus.Entry) error
• func Producer() *producer
• type Config
• type Topics

Functions

func Exit

func Exit()

func Init

func Init(cfg *Config, log *logrus.Entry) error

func Producer

func Producer() *producer

Types

type Config

type Config struct {
	kafka.Config

	Topics Topics `json:"topics"  required:"true"`
}

type Topics

type Topics struct {
	NewSoftwarePkg            string `json:"new_software_pkg"              required:"true"`
	ApprovedSoftwarePkg       string `json:"approved_software_pkg"         required:"true"`
	RejectedSoftwarePkg       string `json:"rejected_software_pkg"         required:"true"`
	AbandonedSoftwarePkg      string `json:"abandoned_software_pkg"        required:"true"`
	AlreadyExistedSoftwarePkg string `json:"already_existed_software_pkg"  required:"true"`
}