test

Documentation

Index

• func Run(qc network.QueryChannel, q string) ([]interface{}, []query.Error, query.Error)
• func Start(site, pool string) network.QueryChannel
• type MockQuery
  • func (this *MockQuery) Request() network.QueryRequest
  • func (this *MockQuery) Response() network.QueryResponse
  • func (this *MockQuery) SetStopChannel(stopChannel misc.StopChannel)
  • func (this *MockQuery) StartTime() time.Time
• type MockResponse
  • func (this *MockResponse) NoMoreResults()
  • func (this *MockResponse) SendError(err query.Error)
  • func (this *MockResponse) SendResult(val interface{})

Functions

func Run

func Run(qc network.QueryChannel, q string) ([]interface{}, []query.Error, query.Error)

func Start

func Start(site, pool string) network.QueryChannel

Types

type MockQuery

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

func (*MockQuery) Request

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

func (*MockQuery) Response

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

func (*MockQuery) SetStopChannel

func (this *MockQuery) SetStopChannel(stopChannel misc.StopChannel)

func (*MockQuery) StartTime

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

type MockResponse

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

func (*MockResponse) NoMoreResults

func (this *MockResponse) NoMoreResults()

func (*MockResponse) SendError

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

func (*MockResponse) SendResult

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