elasticsearch

Documentation

Index

• Constants
• type Action
• type Connector
  • func (e *Connector) GetMetaInfo(resourceOptions map[string]interface{}) (common.MetaInfoResult, error)
  • func (e *Connector) Run(resourceOptions map[string]interface{}, actionOptions map[string]interface{}) (common.RuntimeResult, error)
  • func (e *Connector) TestConnection(resourceOptions map[string]interface{}) (common.ConnectionResult, error)
  • func (e *Connector) ValidateActionOptions(actionOptions map[string]interface{}) (common.ValidateResult, error)
  • func (e *Connector) ValidateResourceOptions(resourceOptions map[string]interface{}) (common.ValidateResult, error)
• type OperationRunner
• type Resource

Constants

const (
	SEARCH_OPERATION = "search"
	INSERT_OPERATION = "insert"
	GET_OPERATION    = "get"
	UPDATE_OPERATION = "update"
	DELETE_OPERATION = "delete"
)

Types

type Action

type Action struct {
	Operation string `validate:"required,oneof=search insert get update delete"`
	Index     string
	ID        string
	Body      string
	Query     string
}

type Connector

type Connector struct {
	ResourceOpts Resource
	ActionOpts   Action
}

func (*Connector) GetMetaInfo

func (e *Connector) GetMetaInfo(resourceOptions map[string]interface{}) (common.MetaInfoResult, error)

func (*Connector) Run

func (e *Connector) Run(resourceOptions map[string]interface{}, actionOptions map[string]interface{}) (common.RuntimeResult, error)

func (*Connector) TestConnection

func (e *Connector) TestConnection(resourceOptions map[string]interface{}) (common.ConnectionResult, error)

func (*Connector) ValidateActionOptions

func (e *Connector) ValidateActionOptions(actionOptions map[string]interface{}) (common.ValidateResult, error)

func (*Connector) ValidateResourceOptions

func (e *Connector) ValidateResourceOptions(resourceOptions map[string]interface{}) (common.ValidateResult, error)

type OperationRunner

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

type Resource

type Resource struct {
	Host     string `validate:"required,url"`
	Port     string `validate:"required"`
	Username string `validate:"required"`
	Password string `validate:"required"`
}