rest

package

v0.3.0 Latest Latest Go to latest Published: Sep 23, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

View Source

const (
	ContentJSON  = "application/json"
	ContentProto = "application/proto"
)

This section is empty.

This section is empty.

type Handler struct {
	// contains filtered or unexported fields
}

func NewHandler(collector collector.Collector) *Handler

func (h *Handler) Ack(rw http.ResponseWriter, resChannel chan struct{}, s serde.SerializeFunc, reqGuid string, connGroup string) collector.AckFunc

func (h *Handler) RESTAPIHandler(rw http.ResponseWriter, r *http.Request)

type Response struct {
	*pb.SendEventResponse
}

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 serde.SerializeFunc) (int, error)

type Service struct {
	Collector collector.Collector
	// contains filtered or unexported fields
}

func NewRestService(c collector.Collector) *Service

func (s *Service) Init(context.Context) error

func (*Service) Name() string

func (s *Service) Shutdown(ctx context.Context) error

Path	Synopsis
websocket
connection