http

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2020 License: Apache-2.0 Imports: 28 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	QueryResultTypeRow uint32 = iota
	QueryResultTypePairs
	QueryResultTypeUint64
)

QueryResult types.

Variables

This section is empty.

Functions

func GetHTTPClient 

func GetHTTPClient(t *tls.Config) *http.Client

func NewTranslateStore 

func NewTranslateStore(node interface{}) pilosa.TranslateStore

NewTranslateStore returns a new instance of TranslateStore based on node. DEPRECATED: Providing a string url to this function is being deprecated. Instead, provide a *pilosa.Node. TODO (2.0) Refactor to avoid panic

func OptHandlerAPI 

func OptHandlerAPI(api *pilosa.API) handlerOption

func OptHandlerAllowedOrigins 

func OptHandlerAllowedOrigins(origins []string) handlerOption

func OptHandlerCloseTimeout added in v1.0.1 

func OptHandlerCloseTimeout(d time.Duration) handlerOption

OptHandlerCloseTimeout controls how long to wait for the http Server to shutdown cleanly before forcibly destroying it. Default is 30 seconds.

func OptHandlerListener 

func OptHandlerListener(ln net.Listener) handlerOption

func OptHandlerLogger 

func OptHandlerLogger(logger logger.Logger) handlerOption

Types

type Bits 

type Bits []pilosa.Bit

Bits is a slice of Bit.

func (Bits) ColumnIDs 

func (p Bits) ColumnIDs() []uint64

ColumnIDs returns a slice of all the column IDs.

func (Bits) ColumnKeys 

func (p Bits) ColumnKeys() []string

ColumnKeys returns a slice of all the column keys.

func (Bits) GroupByShard 

func (p Bits) GroupByShard() map[uint64][]pilosa.Bit

GroupByShard returns a map of bits by shard.

func (Bits) HasColumnKeys added in v1.1.0 

func (p Bits) HasColumnKeys() bool

HasColumnKeys returns true if any values use a column key.

func (Bits) HasRowKeys added in v1.1.0 

func (p Bits) HasRowKeys() bool

HasRowKeys returns true if any values use a row key.

func (Bits) Len 

func (p Bits) Len() int

func (Bits) Less 

func (p Bits) Less(i, j int) bool

func (Bits) RowIDs 

func (p Bits) RowIDs() []uint64

RowIDs returns a slice of all the row IDs.

func (Bits) RowKeys 

func (p Bits) RowKeys() []string

RowKeys returns a slice of all the row keys.

func (Bits) Swap 

func (p Bits) Swap(i, j int)

func (Bits) Timestamps 

func (p Bits) Timestamps() []int64

Timestamps returns a slice of all the timestamps.

type BitsByPos 

type BitsByPos []pilosa.Bit

BitsByPos is a slice of bits sorted row then column.

func (BitsByPos) Len 

func (p BitsByPos) Len() int

func (BitsByPos) Less 

func (p BitsByPos) Less(i, j int) bool

func (BitsByPos) Swap 

func (p BitsByPos) Swap(i, j int)

type Error 

type Error struct {
	// Human-readable message.
	Message string `json:"message"`
}

Error defines a standard application error.

func (*Error) Error 

func (e *Error) Error() string

Error returns the string representation of the error message.

type FieldValues 

type FieldValues []pilosa.FieldValue

FieldValues represents a slice of field values.

func (FieldValues) ColumnIDs 

func (p FieldValues) ColumnIDs() []uint64

ColumnIDs returns a slice of all the column IDs.

func (FieldValues) ColumnKeys added in v1.1.0 

func (p FieldValues) ColumnKeys() []string

ColumnKeys returns a slice of all the column keys.

func (FieldValues) GroupByShard 

func (p FieldValues) GroupByShard() map[uint64][]pilosa.FieldValue

GroupByShard returns a map of field values by shard.

func (FieldValues) HasColumnKeys added in v1.1.0 

func (p FieldValues) HasColumnKeys() bool

HasColumnKeys returns true if any values use a column key.

func (FieldValues) Len 

func (p FieldValues) Len() int

func (FieldValues) Less 

func (p FieldValues) Less(i, j int) bool

func (FieldValues) Swap 

func (p FieldValues) Swap(i, j int)

func (FieldValues) Values 

func (p FieldValues) Values() []int64

Values returns a slice of all the values.

type Handler 

type Handler struct {
	Handler http.Handler
	// contains filtered or unexported fields
}

Handler represents an HTTP handler.

func NewHandler 

func NewHandler(opts ...handlerOption) (*Handler, error)

NewHandler returns a new instance of Handler with a default logger.

func (*Handler) Close 

func (h *Handler) Close() error

Close tries to cleanly shutdown the HTTP server, and failing that, after a timeout, calls Server.Close.

func (*Handler) Serve 

func (h *Handler) Serve() error

func (*Handler) ServeHTTP 

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP handles an HTTP request.

type InternalClient 

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

InternalClient represents a client to the Pilosa cluster.

func NewInternalClient 

func NewInternalClient(host string, remoteClient *http.Client) (*InternalClient, error)

NewInternalClient returns a new instance of InternalClient to connect to host.

func NewInternalClientFromURI 

func NewInternalClientFromURI(defaultURI *pilosa.URI, remoteClient *http.Client) *InternalClient

func (*InternalClient) BlockData 

func (c *InternalClient) BlockData(ctx context.Context, uri *pilosa.URI, index, field, view string, shard uint64, block int) ([]uint64, []uint64, error)

BlockData returns row/column id pairs for a block.

func (*InternalClient) ColumnAttrDiff 

func (c *InternalClient) ColumnAttrDiff(ctx context.Context, uri *pilosa.URI, index string, blks []pilosa.AttrBlock) (map[uint64]map[string]interface{}, error)

ColumnAttrDiff returns data from differing blocks on a remote host.

func (*InternalClient) CreateField 

func (c *InternalClient) CreateField(ctx context.Context, index, field string) error

func (*InternalClient) CreateFieldWithOptions added in v1.2.0 

func (c *InternalClient) CreateFieldWithOptions(ctx context.Context, index, field string, opt pilosa.FieldOptions) error

CreateField creates a new field on the server.

func (*InternalClient) CreateIndex 

func (c *InternalClient) CreateIndex(ctx context.Context, index string, opt pilosa.IndexOptions) error

CreateIndex creates a new index on the server.

func (*InternalClient) EnsureField 

func (c *InternalClient) EnsureField(ctx context.Context, indexName string, fieldName string) error

func (*InternalClient) EnsureFieldWithOptions added in v1.2.0 

func (c *InternalClient) EnsureFieldWithOptions(ctx context.Context, indexName string, fieldName string, opt pilosa.FieldOptions) error

func (*InternalClient) EnsureIndex 

func (c *InternalClient) EnsureIndex(ctx context.Context, name string, options pilosa.IndexOptions) error

func (*InternalClient) ExportCSV 

func (c *InternalClient) ExportCSV(ctx context.Context, index, field string, shard uint64, w io.Writer) error

ExportCSV bulk exports data for a single shard from a host to CSV format.

func (*InternalClient) FragmentBlocks 

func (c *InternalClient) FragmentBlocks(ctx context.Context, uri *pilosa.URI, index, field, view string, shard uint64) ([]pilosa.FragmentBlock, error)

FragmentBlocks returns a list of block checksums for a fragment on a host. Only returns blocks which contain data.

func (*InternalClient) FragmentNodes 

func (c *InternalClient) FragmentNodes(ctx context.Context, index string, shard uint64) ([]*pilosa.Node, error)

FragmentNodes returns a list of nodes that own a shard.

func (*InternalClient) Import 

func (c *InternalClient) Import(ctx context.Context, index, field string, shard uint64, bits []pilosa.Bit, opts ...pilosa.ImportOption) error

Import bulk imports bits for a single shard to a host.

func (*InternalClient) ImportK 

func (c *InternalClient) ImportK(ctx context.Context, index, field string, bits []pilosa.Bit, opts ...pilosa.ImportOption) error

ImportK bulk imports bits specified by string keys to a host.

func (*InternalClient) ImportRoaring added in v1.2.0 

func (c *InternalClient) ImportRoaring(ctx context.Context, uri *pilosa.URI, index, field string, shard uint64, remote bool, req *pilosa.ImportRoaringRequest) error

ImportRoaring does fast import of raw bits in roaring format (pilosa or official format, see API.ImportRoaring).

func (*InternalClient) ImportValue 

func (c *InternalClient) ImportValue(ctx context.Context, index, field string, shard uint64, vals []pilosa.FieldValue, opts ...pilosa.ImportOption) error

ImportValue bulk imports field values for a single shard to a host.

func (*InternalClient) ImportValueK added in v1.1.0 

func (c *InternalClient) ImportValueK(ctx context.Context, index, field string, vals []pilosa.FieldValue, opts ...pilosa.ImportOption) error

ImportValueK bulk imports keyed field values to a host.

func (*InternalClient) MaxShardByIndex 

func (c *InternalClient) MaxShardByIndex(ctx context.Context) (map[string]uint64, error)

MaxShardByIndex returns the number of shards on a server by index.

func (*InternalClient) Nodes added in v1.1.0 

func (c *InternalClient) Nodes(ctx context.Context) ([]*pilosa.Node, error)

Nodes returns a list of all nodes.

func (*InternalClient) PostSchema added in v1.4.0 

func (c *InternalClient) PostSchema(ctx context.Context, uri *pilosa.URI, s *pilosa.Schema, remote bool) error

func (*InternalClient) Query 

func (c *InternalClient) Query(ctx context.Context, index string, queryRequest *pilosa.QueryRequest) (*pilosa.QueryResponse, error)

Query executes query against the index.

func (*InternalClient) QueryNode 

func (c *InternalClient) QueryNode(ctx context.Context, uri *pilosa.URI, index string, queryRequest *pilosa.QueryRequest) (*pilosa.QueryResponse, error)

QueryNode executes query against the index, sending the request to the node specified.

func (*InternalClient) RetrieveShardFromURI 

func (c *InternalClient) RetrieveShardFromURI(ctx context.Context, index, field, view string, shard uint64, uri pilosa.URI) (io.ReadCloser, error)

RetrieveShardFromURI returns a ReadCloser which contains the data of the specified shard from the specified node. Caller *must* close the returned ReadCloser or risk leaking goroutines/tcp connections.

func (*InternalClient) RowAttrDiff 

func (c *InternalClient) RowAttrDiff(ctx context.Context, uri *pilosa.URI, index, field string, blks []pilosa.AttrBlock) (map[uint64]map[string]interface{}, error)

RowAttrDiff returns data from differing blocks on a remote host.

func (*InternalClient) Schema 

func (c *InternalClient) Schema(ctx context.Context) ([]*pilosa.IndexInfo, error)

Schema returns all index and field schema information.

func (*InternalClient) SendMessage 

func (c *InternalClient) SendMessage(ctx context.Context, uri *pilosa.URI, msg []byte) error

SendMessage posts a message synchronously.

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.