handlers

package

v0.0.0-...-ece14be Latest Latest Go to latest Published: Nov 3, 2021 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func GetAllValues(kvstore *kvstore.KVStore) http.HandlerFunc

func GetValue(kvstore *kvstore.KVStore) http.HandlerFunc

func SetValue(kvstore *kvstore.KVStore, kafkaWriter *kafkaGo.Writer) http.HandlerFunc

func Subscribe(kvstore *kvstore.KVStore, kafkaReader *kafkaGo.Reader) http.HandlerFunc

type IncomingGETRequest struct {
	Key string `json:"Key"`
}

type IncomingPOSTRequest struct {
	Key   string `json:"Key"`
	Value string `json:"Value"`
}

type KafkaRecord struct {
	Topic     string
	Partition int
	Offset    int
	Key       string
	Value     string
}

type OutgoingPOSTRequest struct {
	Key   string `json:"Key"`
	Value string `json:"Value"`
}