inlet_http

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

type Config struct {
	Address    string `json:"address"`
	Domain     string `json:"domain"`
	Timeout    int64  `json:"timeout"`
	EnableStat bool   `json:"enable_stat"`
}

type GraphProvider interface {
	SetGraph(name string, graph spirit.MessageGraph) GraphProvider
	GetGraph(r *http.Request, body []byte) (graphs map[string]spirit.MessageGraph, err error)
}

type GraphResponse struct {
	GraphName   string
	RespPayload spirit.Payload
	Error       error
}

type GraphStat struct {
	GraphName    string `json:"-"`
	RequestCount int64  `json:"request_count"`
	TimeoutCount int64  `json:"timeout_count"`
	ErrorCount   int64  `json:"error_count"`

	TotalTimeCost   time.Duration `json:"-"`
	MinTimeCost     time.Duration `json:"-"`
	MaxTimeCost     time.Duration `json:"-"`
	LastRequestTime string        `json:"last_request_time"`

	StrTotalTimeCost string `json:"total_time_cost"`
	StrMinTimeCost   string `json:"min_time_cost"`
	StrMaxTimeCost   string `json:"max_time_cost"`
	AvgTimeCost      string `json:"avg_time_cost"`

	ErrorRate   string `json:"error_rate"`
	TimeoutRate string `json:"timeout_rate"`
}

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

type InletHTTPErrorResponseHandler func(err error, w http.ResponseWriter, r *http.Request)

type InletHTTPRequestDecoder func(body []byte) (map[string]interface{}, error)

type InletHTTPRequestPayloadHook func(r *http.Request, graphName string, body []byte, payload *spirit.Payload) (err error)

type InletHTTPResponseHandler func(graphsResponse map[string]GraphResponse, w http.ResponseWriter, r *http.Request)

type NameValue struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type Requester interface {
	Request(graph spirit.MessageGraph, payload spirit.Payload, payloadRespChan chan spirit.Payload, errResp chan error) (msgId string, err error)
	OnMessageReceived(payload spirit.Payload)
	OnMessageError(payload spirit.Payload)
	OnMessageProcessed(messageId string)
	SetMessageSenderFactory(factory spirit.MessageSenderFactory)
	GetMessageSenderFactory() spirit.MessageSenderFactory
	SetTimeout(timeout time.Duration)
	GetTimeout() time.Duration
}