package
0.0.0-20200625043019-ec8dcbf1eed9
Repository: https://github.com/kafkaesque-io/pubsub-function.git
Documentation: pkg.go.dev

# Functions

ConsumerConfigFromHTTPParts returns configuration parameters required to generate Pulsar Client and Consumer.
ConsumerParams returns a configuration parameters for Pulsar consumer.
DeleteFunctionHandler deletes a function.
ExtractEvalTenant is a customized function to evaluate subject against tenant.
GetEffectiveRoutes gets effective routes.
GetFunctionHandler gets a function.
GetTopicFnFromRoute builds a valida topic fullname from the http route.
GetTopicKey gets the topic key from the request body or url sub route.
Init initializes database.
Logger logs http traffic.
NewRouter - create new router for HTTP routing.
ReceiveHandler - the message receiver handler.
StatusPage replies with basic status code.
TokenSubjectHandler issues new token.
TriggerFunctionHandler deletes a function.
UpdateFunctionHandler creates or updates a function.
VerifySubject verifies the subject can meet the requirement.
VerifySubjectBasedOnTopic verifies the subject can meet the requirement.

# Variables

PrometheusRoute definition.
ReceiverRoutes definition.
RestRoutes definition.

# Structs

ResponseErr - Error struct for Http response.
Route - HTTP Route.
TokenServerResponse is the json object for token server response.

# Type aliases

Routes list of HTTP Routes.