Documentation
¶
Index ¶
- Variables
- type DefaultLogsAdaptor
- func (a *DefaultLogsAdaptor) GetComponentApplicationLogs(ctx context.Context, params observability.ComponentApplicationLogsParams) (*observability.ComponentApplicationLogsResult, error)
- func (a *DefaultLogsAdaptor) GetWorkflowLogs(ctx context.Context, params observability.WorkflowLogsParams) (*observability.WorkflowLogsResult, error)
- type DefaultTracesAdaptor
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrSpanNotFound = errors.New("span not found")
)
Functions ¶
This section is empty.
Types ¶
type DefaultLogsAdaptor ¶
type DefaultLogsAdaptor struct {
// contains filtered or unexported fields
}
DefaultLogsAdaptor queries logs from OpenSearch when the external logs adapter is not enabled. It creates and manages its own OpenSearch client internally.
func NewDefaultLogsAdaptor ¶
func NewDefaultLogsAdaptor(cfg *config.OpenSearchConfig, logger *slog.Logger) (*DefaultLogsAdaptor, error)
NewDefaultLogsAdaptor creates a new DefaultLogsAdaptor instance with its own OpenSearch client
func (*DefaultLogsAdaptor) GetComponentApplicationLogs ¶
func (a *DefaultLogsAdaptor) GetComponentApplicationLogs( ctx context.Context, params observability.ComponentApplicationLogsParams, ) (*observability.ComponentApplicationLogsResult, error)
GetComponentApplicationLogs retrieves component application logs from OpenSearch.
func (*DefaultLogsAdaptor) GetWorkflowLogs ¶
func (a *DefaultLogsAdaptor) GetWorkflowLogs( ctx context.Context, params observability.WorkflowLogsParams, ) (*observability.WorkflowLogsResult, error)
GetWorkflowLogs retrieves workflow logs from OpenSearch.
type DefaultTracesAdaptor ¶
type DefaultTracesAdaptor struct {
// contains filtered or unexported fields
}
func NewDefaultTracesAdaptor ¶
func NewDefaultTracesAdaptor(cfg *config.OpenSearchConfig, logger *slog.Logger) (*DefaultTracesAdaptor, error)
func (*DefaultTracesAdaptor) GetSpanDetails ¶
func (a *DefaultTracesAdaptor) GetSpanDetails(ctx context.Context, traceID string, spanID string) (*opensearch.Span, error)
GetSpanDetails retrieves details for a specific span
func (*DefaultTracesAdaptor) GetTraces ¶
func (a *DefaultTracesAdaptor) GetTraces(ctx context.Context, params observability.TracesQueryParams) (*observability.TracesQueryResult, error)
Source Files
Click to show internal directories.
Click to hide internal directories.