handlers

Documentation

Index

• Constants
• func Consumer(ctx *gofr.Context) (interface{}, error)
• func ConsumerWithCommit(ctx *gofr.Context) (interface{}, error)
• func Producer(ctx *gofr.Context) (interface{}, error)
• type Person

Constants

const (
	PublishEventHistogram = "time_taken_to_publish_event"
	ConsumeEventSummary   = "time_taken_to_consume_event"
)

Functions

func Consumer

func Consumer(ctx *gofr.Context) (interface{}, error)

func ConsumerWithCommit

func ConsumerWithCommit(ctx *gofr.Context) (interface{}, error)

func Producer

func Producer(ctx *gofr.Context) (interface{}, error)

Types

type Person

type Person struct {
	ID    string `avro:"Id"`
	Name  string `avro:"Name"`
	Email string `avro:"Email"`
}