service

Documentation

Index

• Variables
• func FetchEnv(ctx context.Context, w http.ResponseWriter, r *http.Request) (params map[string]string, query jsonutils.JSONObject, body []sub.Point)
• func FetchRequest(req *http.Request) ([]sub.Point, error)
• func InitHandlers(app *appsrv.Application)
• func InitInfluxDBSubscriptionHandlers(app *appsrv.Application, options *common_options.BaseOptions)
• func StartService()

Variables

var (
	SubscriptionWorkerManager *appsrv.SWorkerManager
)

Functions

func FetchEnv

func FetchEnv(ctx context.Context, w http.ResponseWriter, r *http.Request) (params map[string]string,
	query jsonutils.JSONObject, body []sub.Point)

func FetchRequest

func FetchRequest(req *http.Request) ([]sub.Point, error)

func InitHandlers

func InitHandlers(app *appsrv.Application)

func InitInfluxDBSubscriptionHandlers

func InitInfluxDBSubscriptionHandlers(app *appsrv.Application, options *common_options.BaseOptions)

func StartService

func StartService()