elasticsearchio

Documentation

Index

• func Read(scope beam.Scope, cfg ReadConfig, elemType reflect.Type) beam.PCollection
• func Write(scope beam.Scope, cfg WriteConfig, col beam.PCollection)
• type Hit
• type Hits
• type OpenPITResponse
• type PointInTime
• type ReadConfig
• type SearchRequest
• type SearchResponse
• type Total
• type WriteConfig

Functions

func Read

func Read(
	scope beam.Scope,
	cfg ReadConfig,
	elemType reflect.Type,
) beam.PCollection

func Write

func Write(
	scope beam.Scope,
	cfg WriteConfig,
	col beam.PCollection,
)

Types

type Hit

type Hit struct {
	Source json.RawMessage `json:"_source"`
	Sort   []any           `json:"sort"`
}

type Hits

type Hits struct {
	Hits  []*Hit `json:"hits"`
	Total Total  `json:"total"`
}

type OpenPITResponse

type OpenPITResponse struct {
	ID string `json:"id"`
}

type PointInTime

type PointInTime struct {
	ID        string `json:"id"`
	KeepAlive string `json:"keep_alive"`
}

type ReadConfig

type ReadConfig struct {
	Addresses []string
	CloudID   string
	APIKey    string
	Index     string
	Query     string
	BatchSize int
	KeepAlive string
}

type SearchRequest

type SearchRequest struct {
	Query       json.RawMessage `json:"query"`
	Pit         *PointInTime    `json:"pit,omitempty"`
	SearchAfter []any           `json:"search_after,omitempty"`
}

type SearchResponse

type SearchResponse struct {
	PitID string `json:"pit_id"`
	Hits  *Hits  `json:"hits"`
}

type Total

type Total struct {
	Value int `json:"value"`
}

type WriteConfig

type WriteConfig struct {
	Addresses  []string
	CloudID    string
	APIKey     string
	Index      string
	FlushBytes int
}