plugins

Documentation

Index

• Constants
• type KafkaMessageAttr
• type KafkaUpstream
  • func (p *KafkaUpstream) Filter(conf interface{}, w http.ResponseWriter, r pkgHTTP.Request)
  • func (p *KafkaUpstream) Name() string
  • func (p *KafkaUpstream) ParseConf(in []byte) (interface{}, error)
• type KafkaUpstreamConf
• type KafkaUpstreamResponse

Constants

const HeaderContentType string = "content-type"

const HeaderContentTypeApplicationJson = "application/json"

const HeaderKey string = "key"

const HeaderPartition string = "partition"

const HeaderPartitionAny int32 = -1

const HeaderTopic string = "topic"

Types

type KafkaMessageAttr

type KafkaMessageAttr struct {
	// contains filtered or unexported fields
}

type KafkaUpstream

type KafkaUpstream struct {
	// Embed the default plugin here,
	// so that we don't need to reimplement all the methods.
	plugin.Plugin
}

func (*KafkaUpstream) Filter

func (p *KafkaUpstream) Filter(conf interface{}, w http.ResponseWriter, r pkgHTTP.Request)

func (*KafkaUpstream) Name

func (p *KafkaUpstream) Name() string

func (*KafkaUpstream) ParseConf

func (p *KafkaUpstream) ParseConf(in []byte) (interface{}, error)

type KafkaUpstreamConf

type KafkaUpstreamConf struct {
	Conf         map[string]interface{} `json:"config"`
	JsonKey      string                 `json:"jsonkey"`
	Topic        string                 `json:"topic"`
	Partition    int32                  `json:"partition"`
	Key          string                 `json:"key"`
	HeaderPrefix string                 `json:"headerprefix"`
}

type KafkaUpstreamResponse

type KafkaUpstreamResponse struct {
	Message string `json:"message"`
	Code    int    `json:"code"`
}