kafkake

type CacheState int

type Client struct {
	State         State
	Exchanger     *Exchanger
	Consumer      *kafka.Consumer
	ConsumerTopic string
	Producer      *kafka.Producer
	ProducerTopic string
}

type ClientConfig struct {
	BootstrapServers string
	SecurityProtocol string
	SaslMechanisms   string
	SaslUsername     string
	SaslPassword     string
}

type ClientHandler func([]byte) ([]byte, error)

type ClientOption func(client *Client)

type Error struct {
	Message error `json:"message"`
}

type Exchanger struct {
	Client         *Client
	Handler        ClientHandler
	RequestSchema  interface{}
	ResponseSchema interface{}
}

type Handler func([]byte) ([]byte, error)

type KafkakeConfig struct {
	BootstrapServers string
	SecurityProtocol string
	SaslMechanisms   string
	SaslUsername     string
	SaslPassword     string
}

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

type MessageStatus int

type Processor struct {
	ProcessorConfig
	State         State
	RequestTopic  string
	ResponseTopic string
	Consumer      *kafka.Consumer
	Producers     map[int32]*kafka.Producer
	Handler       Handler
	MessageStates map[string]*MessageState
}

type ProcessorConfig struct {
	BootstrapServers string
	SecurityProtocol string
	SaslMechanisms   string
	SaslUsername     string
	SaslPassword     string
}

type Requestor struct {
	KeyCache      *cache.Cache
	ValueCache    *cache.Cache
	Consumer      *kafka.Consumer
	ConsumerTopic string
	Producer      *kafka.Producer
	ProducerTopic string
}

type State int