Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var LOGGER = logging.MustGetLogger("handler")
Functions ¶
This section is empty.
Types ¶
type GatewayOperations ¶
type GatewayOperations struct {
Consumer map[string]*go_kafka.Consumer
StartingPartition map[string]*int32
// contains filtered or unexported fields
}
func InitGatewayOperation ¶
func InitGatewayOperation() (GatewayOperations, error)
func (GatewayOperations) GetMessage ¶
func (operation GatewayOperations) GetMessage(w http.ResponseWriter, request *http.Request)
func (GatewayOperations) InitializeConsumer ¶
func (operation GatewayOperations) InitializeConsumer(topic string) error
func (GatewayOperations) ServiceCheck ¶
func (operation GatewayOperations) ServiceCheck(w http.ResponseWriter, req *http.Request)
Source Files
Click to show internal directories.
Click to hide internal directories.