api

Documentation

Index

• func DecodeSchema(r io.Reader) (*pilosaclient.Schema, map[string]bool, error)
• func IngestJSON(index *pilosaclient.Index, m idk.Main, in io.Reader) error
• type ErrDuplicateElement
  • func (err ErrDuplicateElement) Error() string
• type TypeError
  • func (t TypeError) Error() string

Functions

func DecodeSchema

func DecodeSchema(r io.Reader) (*pilosaclient.Schema, map[string]bool, error)

DecodeSchema takes JSON stream (io.Reader - mainly http request body) and tries to decode it into pilosa.Schema. The function returns also a map: index-name -> if-not-exists option, so we can swallow "conflict" error in case of creating an index with the name as existing one.

func IngestJSON

func IngestJSON(index *pilosaclient.Index, m idk.Main, in io.Reader) error

Types

type ErrDuplicateElement

type ErrDuplicateElement struct {
	// Elem is the duplicated element.
	Elem interface{}
}

ErrDuplicateElement is an error indicating that an element was included in a set multiple times.

func (ErrDuplicateElement) Error

func (err ErrDuplicateElement) Error() string

type TypeError

type TypeError struct {
	// Expected is a human-readable name of the expected type.
	Expected string

	// Value is the incorrectly-typed value.
	Value interface{}
}

TypeError is an error indicating that the type of a value was set incorrectly.

func (TypeError) Error

func (t TypeError) Error() string