elasticsearch

Documentation

Index

• type Action
  • func NewDeleteAction(key []byte, routing *string) Action
  • func NewIndexAction(key []byte, source []byte, routing *string) Action
  • func NewScriptUpdateAction(id []byte, script Script, routing *string) Action
• type ActionType
• type ResponseHandler
• type ResponseHandlerContext
• type ResponseHandlerInitContext
• type Script

Types

type Action

type Action struct {
	Routing   *string
	IndexName string
	Type      ActionType
	Source    []byte
	ID        []byte
}

func NewDeleteAction

func NewDeleteAction(key []byte, routing *string) Action

func NewIndexAction

func NewIndexAction(key []byte, source []byte, routing *string) Action

func NewScriptUpdateAction

func NewScriptUpdateAction(id []byte, script Script, routing *string) Action

type ActionType

type ActionType string

const (
	Index        ActionType = "Index"
	Delete       ActionType = "Delete"
	ScriptUpdate ActionType = "ScriptUpdate"
)

type ResponseHandler

type ResponseHandler interface {
	OnSuccess(ctx *ResponseHandlerContext)
	OnError(ctx *ResponseHandlerContext)
	OnInit(ctx *ResponseHandlerInitContext)
}

type ResponseHandlerContext

type ResponseHandlerContext struct {
	Action *Action
	Err    error
}

type ResponseHandlerInitContext

type ResponseHandlerInitContext struct {
	Config              *config.Config
	ElasticsearchClient *es.Client
}

type Script

type Script struct {
	Params map[string]interface{} `json:"params,omitempty"`
	Source string                 `json:"source"`
}