internal

type Dispatcher struct {
	// A pool of workers channels that are registered with the dispatcher
	WorkerPool chan chan Job
	// contains filtered or unexported fields
}

type Job struct {
	Payload Payload
}

type KafkaConsumer struct {
	Consumer *kafka.Consumer
	Topics   []string
	// contains filtered or unexported fields
}

type Payload struct {
	ID     string          `json:"id"`
	Type   ReqType         `json:"type"`
	Action ReqAction       `json:"action"`
	Data   json.RawMessage `json:"data"`
}

type ReqAction string

type ReqType string

type Response struct {
	ErrorCode    int32
	ErrorMessage *string
	Payload      *Payload
}

type Worker struct {
	WorkerPool chan chan Job
	JobChannel chan Job
	// contains filtered or unexported fields
}