handler

Documentation

Index

• Variables
• type GatewayOperations
  • func InitGatewayOperation() (GatewayOperations, error)
  • func (operation GatewayOperations) GetMessage(w http.ResponseWriter, request *http.Request)
  • func (operation GatewayOperations) InitializeConsumer(topic string) error
  • func (operation GatewayOperations) ServiceCheck(w http.ResponseWriter, req *http.Request)

Variables

var LOGGER = logging.MustGetLogger("handler")

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)