http

Documentation

Index

• Constants
• type HttpEndpoint
  • func NewHttpEndpoint(address string, staticPath string, infoEnable bool) *HttpEndpoint
  • func (this *HttpEndpoint) SendQueriesTo(queryChannel network.QueryChannel)
  • func (this *HttpEndpoint) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type HttpQuery
  • func NewHttpQuery(w http.ResponseWriter, r *http.Request, info bool) *HttpQuery
  • func (this *HttpQuery) Duration() time.Duration
  • func (this *HttpQuery) Process()
  • func (this *HttpQuery) Request() network.QueryRequest
  • func (this *HttpQuery) Response() network.QueryResponse
  • func (this *HttpQuery) SetStopChannel(stop misc.StopChannel)
  • func (this *HttpQuery) StartTime() time.Time
  • func (this *HttpQuery) StopProcessing()
• type HttpResponse
  • func (this *HttpResponse) NoMoreResults()
  • func (this *HttpResponse) Process() error
  • func (this *HttpResponse) ProcessError() (int, error)
  • func (this *HttpResponse) ProcessResults() (int, error)
  • func (this *HttpResponse) ProcessWarningsAndInfo() (int, error)
  • func (this *HttpResponse) SendError(err query.Error)
  • func (this *HttpResponse) SendResult(val interface{})

Constants

const CHANNEL = "HTTP"

Types

type HttpEndpoint

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

func NewHttpEndpoint

func NewHttpEndpoint(address string, staticPath string, infoEnable bool) *HttpEndpoint

func (*HttpEndpoint) SendQueriesTo

func (this *HttpEndpoint) SendQueriesTo(queryChannel network.QueryChannel)

func (*HttpEndpoint) ServeHTTP

func (this *HttpEndpoint) ServeHTTP(w http.ResponseWriter, r *http.Request)

type HttpQuery

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

func NewHttpQuery

func NewHttpQuery(w http.ResponseWriter, r *http.Request, info bool) *HttpQuery

func (*HttpQuery) Duration

func (this *HttpQuery) Duration() time.Duration

func (*HttpQuery) Process

func (this *HttpQuery) Process()

func (*HttpQuery) Request

func (this *HttpQuery) Request() network.QueryRequest

func (*HttpQuery) Response

func (this *HttpQuery) Response() network.QueryResponse

func (*HttpQuery) SetStopChannel

func (this *HttpQuery) SetStopChannel(stop misc.StopChannel)

func (*HttpQuery) StartTime

func (this *HttpQuery) StartTime() time.Time

func (*HttpQuery) StopProcessing

func (this *HttpQuery) StopProcessing()

type HttpResponse

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

func (*HttpResponse) NoMoreResults

func (this *HttpResponse) NoMoreResults()

func (*HttpResponse) Process

func (this *HttpResponse) Process() error

func (*HttpResponse) ProcessError

func (this *HttpResponse) ProcessError() (int, error)

func (*HttpResponse) ProcessResults

func (this *HttpResponse) ProcessResults() (int, error)

func (*HttpResponse) ProcessWarningsAndInfo

func (this *HttpResponse) ProcessWarningsAndInfo() (int, error)

func (*HttpResponse) SendError

func (this *HttpResponse) SendError(err query.Error)

func (*HttpResponse) SendResult

func (this *HttpResponse) SendResult(val interface{})