Documentation
¶
Index ¶
- Constants
- type Handler
- type Response
- func (r *Response) SetCode(code pb.Code) *Response
- func (r *Response) SetDataMap(data map[string]string) *Response
- func (r *Response) SetReason(reason string) *Response
- func (r *Response) SetSentTime(sentTime int64) *Response
- func (r *Response) SetStatus(status pb.Status) *Response
- func (r *Response) Write(w io.Writer, s serialization.SerializeFunc) (int, error)
- type Service
Constants ¶
View Source
const ( ContentJSON = "application/json" ContentProto = "application/proto" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(collector collection.Collector) *Handler
func (*Handler) Ack ¶
func (h *Handler) Ack(rw http.ResponseWriter, resChannel chan struct{}, s serialization.SerializeFunc, reqGuid string, connGroup string) collection.AckFunc
func (*Handler) RESTAPIHandler ¶
func (h *Handler) RESTAPIHandler(rw http.ResponseWriter, r *http.Request)
type Response ¶
type Response struct {
*pb.SendEventResponse
}
func (*Response) SetSentTime ¶
func (*Response) Write ¶
func (r *Response) Write(w io.Writer, s serialization.SerializeFunc) (int, error)
type Service ¶
type Service struct {
Collector collection.Collector
// contains filtered or unexported fields
}
func NewRestService ¶
func NewRestService(c collection.Collector) *Service
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.