druid

Documentation

Index

• type NativeClient
  • func NewNativeClient(olap drivers.OLAPStore) (*NativeClient, error)
  • func (n *NativeClient) Search(ctx context.Context, dr *NativeSearchQueryRequest) (NativeSearchQueryResponse, error)
• type NativeSearchQuery
• type NativeSearchQueryRequest
  • func NewNativeSearchQueryRequest(source, search string, dims []string, virtualCols []NativeVirtualColumns, ...) NativeSearchQueryRequest
• type NativeSearchQueryResponse
• type NativeSearchSort
• type NativeVirtualColumns
• type QueryContext
• type QueryPlan

Types

type NativeClient

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

func NewNativeClient

func NewNativeClient(olap drivers.OLAPStore) (*NativeClient, error)

func (*NativeClient) Search

func (n *NativeClient) Search(ctx context.Context, dr *NativeSearchQueryRequest) (NativeSearchQueryResponse, 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"`
	VirtualColumns   []NativeVirtualColumns `json:"virtualColumns"`
	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, dims []string, virtualCols []NativeVirtualColumns, limit int, 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 NativeVirtualColumns

type NativeVirtualColumns struct {
	Type       string `json:"type"`
	Name       string `json:"name"`
	Expression string `json:"expression"`
}

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"`
}