gateway

Documentation

Index

• type BulkAction
  • func (bulkAction *BulkAction) ToStringArray() []string
• type ESGateway
  • func NewESGateway(cfg *config.Config) (*ESGateway, error)
  • func (gateway *ESGateway) Run()

Types

type BulkAction

type BulkAction struct {
	ActionType string
	Metadata   map[string]interface{}
	Document   map[string]interface{}
}

func (*BulkAction) ToStringArray

func (bulkAction *BulkAction) ToStringArray() []string

type ESGateway

type ESGateway struct {
	Engine   *gin.Engine
	Address  string
	User     string
	Password string

	SourceES es.ES
	TargetES es.ES

	MasterES es.ES
	SlaveES  es.ES
}

func NewESGateway

func NewESGateway(cfg *config.Config) (*ESGateway, error)

func (*ESGateway) Run

func (gateway *ESGateway) Run()