safebatcher

type Batch struct {
	Queries []interface{}
	Path    string
	// contains filtered or unexported fields
}

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

type Config struct {
	MaxBatchSize int
	MaxLatency   time.Duration
	IdleTimeout  time.Duration
}

type PredictionRequestBatcher struct {
	sync.Mutex

	MaxBatchSize int
	MaxLatency   time.Duration
	IdleTimeout  time.Duration
	// contains filtered or unexported fields
}

type PredictionResponse struct {
	Metrics     interface{}   `json:"metrics"`
	Predictions []interface{} `json:"predictions"`
}

type Request struct {
	Queries []interface{} `json:"queries"`
}

type Response struct {
	Message     string        `json:"message"`
	Metrics     interface{}   `json:"metrics"`
	Predictions []interface{} `json:"predictions"`
}