api

Documentation

Index

• Constants
• func GetElasticLogFileContent(ctx context.Context, instance *model.Instance, body interface{}) (interface{}, error)
• func GetElasticLogFiles(ctx context.Context, instance *model.Instance, logsPath string) (interface{}, error)
• func GetElasticsearchNodesViaAgent(ctx context.Context, endpoint string) (*elastic.DiscoveryResult, error)
• func GetEnrolledNodesByAgent(instanceID string) (map[string]BindingItem, error)
• func Init()
• func NewClusterSettings(clusterID string) *model.Setting
• func NewIndexSettings(clusterID, nodeID, agentID, indexName, indexID string) *model.Setting
• func NewNodeAgentSettings(instanceID string, item *BindingItem) *model.Setting
• type APIHandler
  • func (h *APIHandler) GetHostAgentInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)
  • func (h *APIHandler) GetHostElasticProcess(w http.ResponseWriter, req *http.Request, ps httprouter.Params)
• type BindingItem
• type ClusterInfo
• type RemoteConfig

Constants

const Cluster = "cluster_settings"

const Index = "index_settings"

const LastAgentHash = "last_agent_hash"

const Node = "node_settings"

Functions

func GetElasticLogFileContent

func GetElasticLogFileContent(ctx context.Context, instance *model.Instance, body interface{}) (interface{}, error)

func GetElasticLogFiles

func GetElasticLogFiles(ctx context.Context, instance *model.Instance, logsPath string) (interface{}, error)

func GetElasticsearchNodesViaAgent

func GetElasticsearchNodesViaAgent(ctx context.Context, endpoint string) (*elastic.DiscoveryResult, error)

get nodes info via agent

func GetEnrolledNodesByAgent

func GetEnrolledNodesByAgent(instanceID string) (map[string]BindingItem, error)

node -> binding item

func Init

func Init()

func NewClusterSettings

func NewClusterSettings(clusterID string) *model.Setting

func NewIndexSettings

func NewIndexSettings(clusterID, nodeID, agentID, indexName, indexID string) *model.Setting

func NewNodeAgentSettings

func NewNodeAgentSettings(instanceID string, item *BindingItem) *model.Setting

Types

type APIHandler

type APIHandler struct {
	core.Handler
}

func (*APIHandler) GetHostAgentInfo

func (h *APIHandler) GetHostAgentInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetHostElasticProcess

func (h *APIHandler) GetHostElasticProcess(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

type BindingItem

type BindingItem struct {
	//infini system assigned id
	ClusterID string `json:"cluster_id"`

	ClusterUUID string `json:"cluster_uuid"`
	NodeUUID    string `json:"node_uuid"`

	Updated int64 `json:"updated"`
}

type ClusterInfo

type ClusterInfo struct {
	ClusterIDs []string `json:"cluster_id"`
}

type RemoteConfig

type RemoteConfig struct {
	orm.ORMObjectBase
	Metadata model.Metadata    `json:"metadata" elastic_mapping:"metadata: { type: object }"`
	Payload  common.ConfigFile `json:"payload" elastic_mapping:"payload: { type: object}"`
}