bx24sync

type BasicAuth struct {
	User     string `json:"user"`
	Password string `json:"password"`
}

type CheckInput func(r io.Reader) (bool, error)

type ConsumerConfig struct {
	Brokers           []Socket `json:"brokers"`
	Topic             string   `json:"topic"`
	GroupId           string   `json:"groupId"`
	Partition         int      `json:"Partition"`
	GeneratorEndpoint Endpoint `json:"generatorEndpoint"`
	TargetEndpoint    Endpoint `json:"targetEndpoint"`
}

type DataBaseConnection struct {
	Socket    `json:"socket"`
	BasicAuth `json:"auth"`
	Database  string `json:"database"`
}

type Endpoint struct {
	Socket
	Method string
	SSL    bool
}

type GeneratorConfig struct {
	DB              DataBaseConnection `json:"db"`
	Web             Socket             `json:"web"`
	StorageQueryTxt string             `json:"queryDir"`
	CheckInput      bool               `json:"checkInput"`
}

type HandlerFunc func(http.ResponseWriter, *http.Request) error

type HttpMethod struct {
	Path    string
	Handler HandlerFunc
	CheckInput
	AllowMethods []string
}

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

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

type Message struct {
	Topic     string
	Partition int
	Offset    int64
	Key       []byte
	Value     []byte
}

type ProducerConfig struct {
	Broker Socket `json:"broker"`
	Topic  string `json:"topic"`
}

type RegistrarConfig struct {
	Http Socket
	ProducerConfig
	CheckInput bool
}

type ReponseLogger struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

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

type Socket struct {
	Host string `json:"host"`
	Port int    `json:"port"`
}