Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FuncGetLogLevel ¶
func FuncGetLogLevel()
FuncGetLogLevel godoc (only for swagger doc) @Summary Get Log Level @Description Get current logging level @Tags Logs @Produce json @Success 200 "Status OK" @Failure 400 "Status Bad Request" @Router /log_level [get]
func FuncLogin ¶
func FuncLogin()
FuncLogin godoc (only for swagger doc) @Summary Login @Description Authenticate using basic auth @Description Example : @Description <pre>{"login":"myuser","password":"mypassword"}</pre> @Tags Security @Produce json @Param job body interface{} true "Credentials (json)" @Success 200 "Status OK" @Failure 400 "Status Bad Request" @Router /login [post]
func FuncSetLogLevel ¶
func FuncSetLogLevel()
FuncSetLogLevel godoc (only for swagger doc) @Summary Set Log Level @Description Set logging level @Description Example : @Description <pre>{"level":"info"}</pre> @Tags Logs @Consumme json @Produce json @Param level body interface{} true "Level (json)" @Success 200 "Status OK" @Failure 400 "Status Bad Request" @Router /log_level [put]
func IsAlive ¶
func IsAlive(w http.ResponseWriter, r *http.Request)
IsAlive godoc @Summary Check if alive @Description allows to check if the assistant is alive @Tags System @Success 200 "Status OK" @Router /isalive [get]
func NotImplemented ¶
func NotImplemented(w http.ResponseWriter, r *http.Request)
NotImplemented returns a basic message "Not Implemented" when called, and should be use a filler for future handler
Types ¶
type IngesterHandler ¶
type IngesterHandler struct {
// contains filtered or unexported fields
}
IngesterHandler is a basic struct allowing to setup a single bulkIngester intance for all handlers
func NewIngesterHandler ¶
func NewIngesterHandler() *IngesterHandler
NewIngesterHandler returns a pointer to an IngesterHandler instance
func (*IngesterHandler) ReceiveData ¶
func (handler *IngesterHandler) ReceiveData(w http.ResponseWriter, r *http.Request)
ReceiveData godoc @Title ReceiveData @Description Entrypoint for bulk data ingestion @tags Ingest @Resource /ingester @Router /ingester/data [post] @Accept json @Param data body ingester.BulkIngestRequest true "Bulk Ingest Request" @Success 200 "Status OK" @Failure 400 "Status Bad Request" @Failure 503 "Status Service Unavailable"
type IngesterServer ¶ added in v5.1.0
type IngesterServer struct {
pb.UnimplementedIngesterServer
// contains filtered or unexported fields
}
func NewIngesterServer ¶ added in v5.1.0
func NewIngesterServer() IngesterServer
NewIngesterServer returns a pointer to an IngesterHandler instance
func (IngesterServer) Ingest ¶ added in v5.1.0
func (s IngesterServer) Ingest(ctx context.Context, bir *pb.BulkIngestRequest) (*pb.BulkIngestResponse, error)
Source Files