druid

Documentation

Index

• func GetDSN(config map[string]string) (string, error)
• func Ingest(coordinatorURL, specJSON, datasourceName string, timeout time.Duration) error
• type NativeQuery
  • func NewNativeQuery(dsn string) NativeQuery
  • func (n *NativeQuery) Do(ctx context.Context, dr, res interface{}, queryID string) error
• type NativeSearchQuery
• type NativeSearchQueryRequest
  • func NewNativeSearchQueryRequest(source, search string, dimensions []string, start, end time.Time, ...) NativeSearchQueryRequest
• type NativeSearchQueryResponse
• type NativeSearchSort
• type QueryContext
• type QueryPlan

Functions

func GetDSN

func GetDSN(config map[string]string) (string, error)

func Ingest

func Ingest(coordinatorURL, specJSON, datasourceName string, timeout time.Duration) error

Ingest uses the Druid REST API to submit an ingestion spec. It returns once Druid has finished ingesting data. This function is for test and development usage and has not been tested for production use.

Types

type NativeQuery

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

func NewNativeQuery

func NewNativeQuery(dsn string) NativeQuery

func (*NativeQuery) Do

func (n *NativeQuery) Do(ctx context.Context, dr, res interface{}, queryID string) error

type NativeSearchQuery

type NativeSearchQuery struct {
	Type          string `json:"type"`
	CaseSensitive bool   `json:"case_sensitive"`
	Value         string `json:"value"`
}

type NativeSearchQueryRequest

type NativeSearchQueryRequest struct {
	Context          QueryContext           `json:"context"`
	QueryType        string                 `json:"queryType"`
	DataSource       string                 `json:"dataSource"`
	SearchDimensions []string               `json:"searchDimensions"`
	Limit            int                    `json:"limit"`
	Query            NativeSearchQuery      `json:"query"`
	Sort             NativeSearchSort       `json:"sort"`
	Intervals        []string               `json:"intervals"`
	Filter           map[string]interface{} `json:"filter"`
}

func NewNativeSearchQueryRequest

func NewNativeSearchQueryRequest(source, search string, dimensions []string, start, end time.Time, filter map[string]interface{}) NativeSearchQueryRequest

type NativeSearchQueryResponse

type NativeSearchQueryResponse []struct {
	Timestamp time.Time `json:"timestamp"`
	Result    []struct {
		Dimension string `json:"dimension"`
		Value     string `json:"value"`
	} `json:"result"`
}

type NativeSearchSort

type NativeSearchSort struct {
	Type string `json:"type"`
}

type QueryContext

type QueryContext struct {
	QueryID string `json:"queryId,omitempty"`
}

type QueryPlan

type QueryPlan struct {
	Query struct {
		Filter *map[string]interface{} `json:"filter"`
	} `json:"query"`
}