estools

Jan 7, 2025

Changes in this version

+ func CreateServiceToken(ctx context.Context, client elastictransport.Interface, service string) (string, error)

+ func DeleteIndexTemplatesDataStreams(ctx context.Context, client elastictransport.Interface, name string) error

+ func DeletePipelines(ctx context.Context, client elastictransport.Interface, name string) error

+ func GetPipelines(ctx context.Context, client elastictransport.Interface, name string) (map[string]Pipeline, error)

+ type APIKeyRequest struct

+ Expiration string

+ Metadata mapstr.M

+ Name string

+ RoleDescriptors mapstr.M

+ type APIKeyResponse struct

+ APIKey string

+ Encoded string

+ Expiration int

+ ID string

+ Name string

+ func CreateAPIKey(ctx context.Context, client elastictransport.Interface, req APIKeyRequest) (APIKeyResponse, error)

+ type CatIntData int64

+ func (s *CatIntData) UnmarshalJSON(b []byte) error

+ type DataStream struct

+ Hidden bool

+ Indicies []map[string]string

+ Lifecycle Lifecycle

+ Name string

+ Status string

+ System bool

+ Template string

+ type DataStreams struct

+ DataStreams []DataStream

+ func GetDataStreamsForPattern(ctx context.Context, client elastictransport.Interface, namePattern string) (DataStreams, error)

+ type Documents struct

+ Hits Hits

+ TimedOut bool

+ Took int

+ func CheckForErrorsInLogs(ctx context.Context, client elastictransport.Interface, namespace string, ...) (Documents, error)

+ func CheckForErrorsInLogsWithContext(ctx context.Context, client elastictransport.Interface, namespace string, ...) (Documents, error)

+ func FindMatchingLogLines(ctx context.Context, client elastictransport.Interface, namespace, line string) (Documents, error)

+ func FindMatchingLogLinesForAgentWithContext(ctx context.Context, client elastictransport.Interface, agentID, line string) (Documents, error)

+ func FindMatchingLogLinesWithContext(ctx context.Context, client elastictransport.Interface, namespace, line string) (Documents, error)

+ func GetAllLogsForIndexWithContext(ctx context.Context, client elastictransport.Interface, index string) (Documents, error)

+ func GetLatestDocumentMatchingQuery(ctx context.Context, client elastictransport.Interface, ...) (Documents, error)

+ func GetLogsForAgentID(ctx context.Context, client elastictransport.Interface, id string) (Documents, error)

+ func GetLogsForDataset(ctx context.Context, client elastictransport.Interface, index string) (Documents, error)

+ func GetLogsForDatasetWithContext(ctx context.Context, client elastictransport.Interface, index string) (Documents, error)

+ func GetLogsForDatastream(ctx context.Context, client elastictransport.Interface, ...) (Documents, error)

+ func GetLogsForIndexWithContext(ctx context.Context, client elastictransport.Interface, index string, ...) (Documents, error)

+ func GetResultsForAgentAndDatastream(ctx context.Context, client elastictransport.Interface, dataset string, ...) (Documents, error)

+ func PerformQueryForRawQuery(ctx context.Context, queryRaw map[string]interface{}, index string, ...) (Documents, error)

+ type ESDoc struct

+ Index string

+ Score float64

+ Source map[string]interface{}

+ type Hits struct

+ Hits []ESDoc

+ Total TotalDocCount

+ type Index struct

+ DocsCount CatIntData

+ DocsDeleted CatIntData

+ Health string

+ Index string

+ Primary CatIntData

+ PrimaryStoreSizeBytes CatIntData

+ Replicated CatIntData

+ Status string

+ StoreSizeBytes CatIntData

+ UUID string

+ func GetAllindicies(ctx context.Context, client elastictransport.Interface) ([]Index, error)

+ func GetIndicesWithContext(ctx context.Context, client elastictransport.Interface, indicies []string) ([]Index, error)

+ type Lifecycle struct

+ DataRetention string

+ Enabled bool

+ type Ping struct

+ ClusterName string

+ ClusterUUID string

+ Name string

+ Version Version

+ func GetPing(ctx context.Context, client elastictransport.Interface) (Ping, error)

+ type Pipeline struct

+ Description string

+ Processors []map[string]interface{}

+ type Template struct

+ IndexTemplate map[string]interface{}

+ Name string

+ type TemplateResponse struct

+ IndexTemplates []Template

+ func GetIndexTemplatesForPattern(ctx context.Context, client elastictransport.Interface, name string) (TemplateResponse, error)

+ type TotalDocCount struct

+ Relation string

+ Value int

+ type Version struct

+ BuildFlavor string

+ Number string