test

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 21, 2018 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MustDo added in v0.9.0 

func MustDo(method, urlStr string, body string) *httpResponse

MustDo executes http.Do() with an http.NewRequest(). Panic on error.

func MustMarshalJSON added in v0.5.0 

func MustMarshalJSON(v interface{}) []byte

MustMarshalJSON marshals v to JSON. Panic on error.

func MustNewHTTPRequest added in v0.5.0 

func MustNewHTTPRequest(method, urlStr string, body io.Reader) *gohttp.Request

MustNewHTTPRequest creates a new HTTP request. Panic on error.

func NewBufferLogger added in v0.9.0 

func NewBufferLogger() *bufferLogger

NewBufferLogger returns a new instance of BufferLogger.

func OptAllowedOrigins added in v1.0.0 

func OptAllowedOrigins(origins []string) server.CommandOption

func TestField_SetCacheSize added in v1.0.0 

func TestField_SetCacheSize(t *testing.T)

Ensure field can set its cache

Types

type Cluster added in v1.0.0 

type Cluster []*Command

Cluster represents a Pilosa cluster (multiple Command instances)

func MustNewCluster added in v1.0.0 

func MustNewCluster(t *testing.T, size int, opts ...[]server.CommandOption) Cluster

MustNewCluster creates a new cluster

func MustRunCluster added in v1.0.0 

func MustRunCluster(t *testing.T, size int, opts ...[]server.CommandOption) Cluster

MustRunCluster creates and starts a new cluster

func (Cluster) Close added in v1.0.0 

func (c Cluster) Close() error

Stop stops a Cluster

func (Cluster) Start added in v1.0.0 

func (c Cluster) Start() error

Start runs a Cluster

type Command added in v1.0.0 

type Command struct {
	*server.Command
	// contains filtered or unexported fields
}

////////////////////////////////////////////////////////////////////////////////// Command represents a test wrapper for server.Command.

func MustRunCommand added in v1.0.0 

func MustRunCommand() *Command

MustRunCommand returns a new, running Main. Panic on error.

func NewCommandNode added in v1.0.0 

func NewCommandNode(isCoordinator bool, opts ...server.CommandOption) *Command

NewCommandNode returns a new instance of Command with clustering enabled.

func (*Command) Client added in v1.0.0 

func (m *Command) Client() *http.InternalClient

Client returns a client to connect to the program.

func (*Command) Close added in v1.0.0 

func (m *Command) Close() error

Close closes the program and removes the underlying data directory.

func (*Command) GossipAddress added in v1.0.0 

func (m *Command) GossipAddress() string

GossipAddress returns the address on which gossip is listening after a Main has been setup. Useful to pass as a seed to other nodes when creating and testing clusters.

func (*Command) MustCreateField added in v1.1.0 

func (m *Command) MustCreateField(t *testing.T, index, field string, opts ...pilosa.FieldOption) *pilosa.Field

MustCreateField uses this command's API to create the field. The index must already exist - it fails the test if there is an error.

func (*Command) MustCreateIndex added in v1.1.0 

func (m *Command) MustCreateIndex(t *testing.T, name string, opts pilosa.IndexOptions) *pilosa.Index

MustCreateIndex uses this command's API to create an index and fails the test if there is an error.

func (*Command) MustQuery added in v1.1.0 

func (m *Command) MustQuery(t *testing.T, req *pilosa.QueryRequest) pilosa.QueryResponse

MustQuery uses this command's API to execute the given query request, failing if Query returns a non-nil error, otherwise returning the QueryResponse.

func (*Command) MustRecalculateCaches added in v1.1.0 

func (m *Command) MustRecalculateCaches(t *testing.T)

MustRecalculateCaches calls RecalculateCaches on the command's API, and fails if there is an error.

func (*Command) Query added in v1.0.0 

func (m *Command) Query(index, rawQuery, query string) (string, error)

Query executes a query against the program through the HTTP API.

func (*Command) RecalculateCaches added in v1.0.0 

func (m *Command) RecalculateCaches() error

RecalculateCaches is deprecated. Use MustRecalculateCaches.

func (*Command) Reopen added in v1.0.0 

func (m *Command) Reopen() error

Reopen closes the program and reopens it.

func (*Command) URL added in v1.0.0 

func (m *Command) URL() string

URL returns the base URL string for accessing the running program.

type Field added in v1.0.0 

type Field struct {
	*pilosa.Field
}

Field represents a test wrapper for pilosa.Field.

type Holder added in v0.5.0 

type Holder struct {
	*pilosa.Holder
}

Holder is a test wrapper for pilosa.Holder.

func MustOpenHolder added in v0.5.0 

func MustOpenHolder() *Holder

MustOpenHolder creates and opens a holder at a temporary path. Panic on error.

func NewHolder added in v0.5.0 

func NewHolder() *Holder

NewHolder returns a new instance of Holder with a temporary path.

func (*Holder) ClearBit added in v1.0.0 

func (h *Holder) ClearBit(index, field string, rowID, columnID uint64)

ClearBit clears a bit on the given field.

func (*Holder) Close added in v0.5.0 

func (h *Holder) Close() error

Close closes the holder and removes all underlying data.

func (*Holder) MustCreateIndexIfNotExists added in v0.5.0 

func (h *Holder) MustCreateIndexIfNotExists(index string, opt pilosa.IndexOptions) *Index

MustCreateIndexIfNotExists returns a given index. Panic on error.

func (*Holder) MustSetBits added in v1.0.0 

func (h *Holder) MustSetBits(index, field string, rowID uint64, columnIDs ...uint64)

MustSetBits sets columns on a row. Panic on error. This function does not accept a timestamp or quantum.

func (*Holder) Reopen added in v0.5.0 

func (h *Holder) Reopen() error

Reopen instantiates and opens a new holder. Note that the holder must be Closed first.

func (*Holder) Row added in v1.0.0 

func (h *Holder) Row(index, field string, rowID uint64) *pilosa.Row

Row returns a Row for a given field.

func (*Holder) RowAttrStore added in v1.0.0 

func (h *Holder) RowAttrStore(index, field string) pilosa.AttrStore

func (*Holder) RowTime added in v1.0.0 

func (h *Holder) RowTime(index, field string, rowID uint64, t time.Time, quantum string) *pilosa.Row

func (*Holder) SetBit added in v1.0.0 

func (h *Holder) SetBit(index, field string, rowID, columnID uint64)

SetBit sets a bit on the given field.

func (*Holder) SetBitTime added in v1.1.0 

func (h *Holder) SetBitTime(index, field string, rowID, columnID uint64, t *time.Time)

SetBitTime sets a bit with timestamp on the given field.

type Index added in v0.5.0 

type Index struct {
	*pilosa.Index
}

Index represents a test wrapper for pilosa.Index.

func MustOpenIndex added in v0.5.0 

func MustOpenIndex() *Index

MustOpenIndex returns a new, opened index at a temporary path. Panic on error.

func (*Index) Close added in v0.5.0 

func (i *Index) Close() error

Close closes the index and removes the underlying data.

func (*Index) CreateField added in v1.0.0 

func (i *Index) CreateField(name string, opts ...pilosa.FieldOption) (*Field, error)

CreateField creates a field with the given options.

func (*Index) CreateFieldIfNotExists added in v1.0.0 

func (i *Index) CreateFieldIfNotExists(name string, opts ...pilosa.FieldOption) (*Field, error)

CreateFieldIfNotExists creates a field with the given options if it doesn't exist.

func (*Index) Reopen added in v0.5.0 

func (i *Index) Reopen() error

Reopen closes the index and reopens it.

type ModHasher added in v0.5.0 

type ModHasher struct{}

modHasher represents a simple, mod-based hashing.

func (*ModHasher) Hash added in v0.5.0 

func (*ModHasher) Hash(key uint64, n int) int

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.