kafka

Documentation

Index

• Variables
• type AdvertiseMode
• type Broker
• type Config
• type Output

Variables

var Module = module.Descriptor{
	Kind: "kafka",
	Actions: []module.ActionDesc{
		{
			Name: module.CreateAction,
		},
		{
			Name: module.UpdateAction,
		},
	},
	DriverFactory: func(confJSON json.RawMessage) (module.Driver, error) {
		conf := defaultDriverConf
		if err := json.Unmarshal(confJSON, &conf); err != nil {
			return nil, err
		}

		return &kafkaDriver{
			conf: conf,
		}, nil
	},
}

Types

type AdvertiseMode

type AdvertiseMode struct {
	Host    string `json:"host"`
	Address string `json:"address"`
}

type Broker

type Broker struct {
	Name    string `json:"name"`
	Host    string `json:"host"`
	Address string `json:"address"`
}

type Config

type Config struct {
	Entity        string        `json:"entity,omitempty"`
	Environment   string        `json:"environment,omitempty"`
	Landscape     string        `json:"landscape,omitempty"`
	Organization  string        `json:"organization,omitempty"`
	AdvertiseMode AdvertiseMode `json:"advertise_mode"`
	Brokers       []Broker      `json:"brokers,omitempty"`
	Type          string        `json:"type"`
}

type Output

type Output struct {
	URL string `json:"url"`
}