http

package
v0.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 6, 2013 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const CHANNEL = "HTTP"

Variables

This section is empty.

Functions

This section is empty.

Types

type HttpEndpoint

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

func NewHttpEndpoint

func NewHttpEndpoint(address string, staticPath string) *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) *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 added in v0.6.0

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{})

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL