Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Repository ¶
type Repository struct {
*kafka.Writer
*kafka.Reader
// contains filtered or unexported fields
}
Repository that produces request stats to Kafka
func NewRepository ¶
func NewRepository(brokers, topic string) *Repository
NewRepository returns a new instance the repository to store stats in memory
func (*Repository) Increment ¶
func (r *Repository) Increment(path string, parameters map[string]interface{}) error
Increment number of hits in Kafka
func (*Repository) Listen ¶
func (r *Repository) Listen()
Source Files
Click to show internal directories.
Click to hide internal directories.