actions

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Nov 3, 2020 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IndexAction  = "indices:data/write/index"
	GetAction    = "indices:data/read/get"
	DeleteAction = "indices:data/write/delete"
)
View Source 
const (
	NodesInfoAction  = "cluster:monitor/nodes/info"
	NodesStatsAction = "cluster:monitor/nodes/stats"
)
View Source 
const (
	ClusterStatsAction = "cluster:monitor/stats"
)
View Source 
const (
	IndicesStatsAction = "indices:monitor/stats"
)
View Source 
const (
	SearchAction = "search"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type MethodHandlers 

type MethodHandlers map[RestMethod]RestHandler

type ResponseListener 

type ResponseListener func(response RestResponse)

type RestCatIndices 

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

func NewRestCatIndices 

func NewRestCatIndices(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestCatIndices

func (*RestCatIndices) Handle 

func (h *RestCatIndices) Handle(r *RestRequest, reply ResponseListener)

type RestCatNodes 

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

func NewRestCatNodes 

func NewRestCatNodes(clusterService *cluster.Service, transportService *transport.Service) *RestCatNodes

func (*RestCatNodes) Handle 

func (h *RestCatNodes) Handle(r *RestRequest, reply ResponseListener)

type RestCatShards 

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

func NewRestCatShards 

func NewRestCatShards(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestCatShards

func (*RestCatShards) Handle 

func (h *RestCatShards) Handle(r *RestRequest, reply ResponseListener)

type RestCatTemplates 

type RestCatTemplates struct{}

func (*RestCatTemplates) Handle 

func (h *RestCatTemplates) Handle(r *RestRequest, reply ResponseListener)

type RestClusterHealth 

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

func NewRestClusterHealth 

func NewRestClusterHealth(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver) *RestClusterHealth

func (*RestClusterHealth) Handle 

func (h *RestClusterHealth) Handle(r *RestRequest, reply ResponseListener)

type RestClusterState 

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

func NewRestClusterState 

func NewRestClusterState(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver) *RestClusterState

func (*RestClusterState) Handle 

func (h *RestClusterState) Handle(r *RestRequest, reply ResponseListener)

type RestClusterStats 

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

func NewRestClusterStats 

func NewRestClusterStats(clusterService *cluster.Service, transportService *transport.Service, indicesService *indices.Service) *RestClusterStats

func (*RestClusterStats) Handle 

func (h *RestClusterStats) Handle(r *RestRequest, reply ResponseListener)

type RestDeleteDoc 

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

func NewRestDeleteDoc 

func NewRestDeleteDoc(clusterService *cluster.Service, indicesService *indices.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestDeleteDoc

func (*RestDeleteDoc) Handle 

func (h *RestDeleteDoc) Handle(r *RestRequest, reply ResponseListener)

type RestDeleteIndex 

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

func NewRestDeleteIndex 

func NewRestDeleteIndex(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver, deleteIndexService *cluster.MetadataDeleteIndexService) *RestDeleteIndex

func (*RestDeleteIndex) Handle 

func (h *RestDeleteIndex) Handle(r *RestRequest, reply ResponseListener)

type RestGetDoc 

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

func NewRestGetDoc 

func NewRestGetDoc(clusterService *cluster.Service, indicesService *indices.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestGetDoc

func (*RestGetDoc) Handle 

func (h *RestGetDoc) Handle(r *RestRequest, reply ResponseListener)

type RestGetIndex 

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

func NewRestGetIndex 

func NewRestGetIndex(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver) *RestGetIndex

func (*RestGetIndex) Handle 

func (h *RestGetIndex) Handle(r *RestRequest, reply ResponseListener)

type RestGetIndexAlias 

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

func NewRestGetIndexAlias 

func NewRestGetIndexAlias(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver) *RestGetIndexAlias

func (*RestGetIndexAlias) Handle 

func (h *RestGetIndexAlias) Handle(r *RestRequest, reply ResponseListener)

type RestGetMappings 

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

func NewRestGetMappings 

func NewRestGetMappings(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver) *RestGetMappings

func (*RestGetMappings) Handle 

func (h *RestGetMappings) Handle(r *RestRequest, reply ResponseListener)

type RestGetSource 

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

func NewRestGetSource 

func NewRestGetSource(clusterService *cluster.Service, indicesService *indices.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestGetSource

func (*RestGetSource) Handle 

func (h *RestGetSource) Handle(r *RestRequest, reply ResponseListener)

type RestHandler 

type RestHandler interface {
	Handle(r *RestRequest, reply ResponseListener)
}

type RestHeadIndex 

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

func NewRestHeadIndex 

func NewRestHeadIndex(clusterService *cluster.Service, indexNameExpressionResolver *indices.NameExpressionResolver) *RestHeadIndex

func (*RestHeadIndex) Handle 

func (h *RestHeadIndex) Handle(r *RestRequest, reply ResponseListener)

type RestIndexDoc 

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

func NewRestIndexDoc 

func NewRestIndexDoc(clusterService *cluster.Service, createIndexService *cluster.MetadataCreateIndexService, indicesService *indices.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestIndexDoc

func (*RestIndexDoc) Handle 

func (h *RestIndexDoc) Handle(r *RestRequest, reply ResponseListener)

type RestIndexDocId 

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

func NewRestIndexDocId 

func NewRestIndexDocId(clusterService *cluster.Service, createIndexService *cluster.MetadataCreateIndexService, indicesService *indices.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestIndexDocId

func (*RestIndexDocId) Handle 

func (h *RestIndexDocId) Handle(r *RestRequest, reply ResponseListener)

type RestIndicesStatsAction 

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

func NewRestIndicesStatsAction 

func NewRestIndicesStatsAction(clusterService *cluster.Service, indicesService *indices.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestIndicesStatsAction

func (*RestIndicesStatsAction) Handle 

func (h *RestIndicesStatsAction) Handle(r *RestRequest, reply ResponseListener)

type RestMain 

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

func NewRestMain 

func NewRestMain(clusterService *cluster.Service) *RestMain

func (*RestMain) Handle 

func (h *RestMain) Handle(r *RestRequest, reply ResponseListener)

type RestMethod 

type RestMethod int
const (
	GET RestMethod = iota
	POST
	PUT
	DELETE
	HEAD
)

type RestNodesInfo 

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

func NewRestNodesInfo 

func NewRestNodesInfo(clusterService *cluster.Service, transportService *transport.Service) *RestNodesInfo

func (*RestNodesInfo) Handle 

func (h *RestNodesInfo) Handle(r *RestRequest, reply ResponseListener)

type RestNodesStats 

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

func NewRestNodesStats 

func NewRestNodesStats(clusterService *cluster.Service, indicesService *indices.Service, transportService *transport.Service) *RestNodesStats

func (*RestNodesStats) Handle 

func (h *RestNodesStats) Handle(r *RestRequest, reply ResponseListener)

type RestPostIndexAlias 

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

func NewRestPostIndexAlias 

func NewRestPostIndexAlias(indexAliasesService *cluster.MetadataIndexAliasService) *RestPostIndexAlias

func (*RestPostIndexAlias) Handle 

func (h *RestPostIndexAlias) Handle(r *RestRequest, reply ResponseListener)

type RestPutIndex 

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

func NewRestPutIndex 

func NewRestPutIndex(clusterIndexService *cluster.MetadataCreateIndexService) *RestPutIndex

func (*RestPutIndex) Handle 

func (h *RestPutIndex) Handle(r *RestRequest, reply ResponseListener)

type RestRefresh 

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

func NewRestRefresh 

func NewRestRefresh(clusterService *cluster.Service) *RestRefresh

func (*RestRefresh) Handle 

func (h *RestRefresh) Handle(r *RestRequest, reply ResponseListener)

type RestRequest 

type RestRequest struct {
	ID          uint64
	Path        string
	Method      RestMethod
	PathParams  map[string]string
	QueryParams map[string][]byte
	Header      map[string][]byte
	Body        []byte
}

type RestResponse 

type RestResponse struct {
	StatusCode int
	Body       interface{}
}

type RestSearch 

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

func NewRestSearch 

func NewRestSearch(clusterService *cluster.Service, indicesService *indices.Service, indexNameExpressionResolver *indices.NameExpressionResolver, transportService *transport.Service) *RestSearch

func (*RestSearch) Handle 

func (h *RestSearch) Handle(r *RestRequest, reply ResponseListener)

type RestXpack 

type RestXpack struct{}

func (*RestXpack) Handle 

func (h *RestXpack) Handle(r *RestRequest, reply ResponseListener)

type SearchRequest 

type SearchRequest struct {
	SearchIndex string
	ShardId     state.ShardId
	SearchBody  map[string]interface{}
}

func SearchRequestFromBytes 

func SearchRequestFromBytes(b []byte) *SearchRequest

type SearchResponse 

type SearchResponse struct {
	SearchResult SearchResultData
}

func SearchResponseFromBytes 

func SearchResponseFromBytes(b []byte) *SearchResponse

func (*SearchResponse) ToBytes 

func (r *SearchResponse) ToBytes() []byte

type SearchResultData 

type SearchResultData struct {
	Results  *bleve.SearchResult
	DocList  []interface{}
	MaxScore float64
	Took     int64
}

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.