httptrace

Documentation

Index

• type NodeTraceFactory
  • func (s *NodeTraceFactory) Configure(jsonBuf []byte) (extension.Provider, error)
  • func (*NodeTraceFactory) ListIndex() string
• type Provider
  • func (provider *Provider) FetchForObject(ctx context.Context, object utilobject.VersionedKey, mainTags model.KeyValues, ...) (*extension.FetchResult, error)
  • func (provider *Provider) FetchForVersion(ctx context.Context, object utilobject.VersionedKey, resourceVersion string, ...) (*extension.FetchResult, error)
  • func (provider *Provider) Kind() string
  • func (provider *Provider) LoadCache(ctx context.Context, jsonBuf []byte) ([]*model.Span, error)
  • func (provider *Provider) MaxConcurrency() int
  • func (provider *Provider) RawConfig() []byte
  • func (provider *Provider) TotalTimeout() time.Duration
• type ProviderArgs
• type TraceBackend
• type TraceResponse

Types

type NodeTraceFactory

type NodeTraceFactory struct {
	manager.BaseComponent
	Logger logrus.FieldLogger
}

func (*NodeTraceFactory) Configure

func (s *NodeTraceFactory) Configure(jsonBuf []byte) (extension.Provider, error)

func (*NodeTraceFactory) ListIndex

func (*NodeTraceFactory) ListIndex() string

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func (*Provider) FetchForObject

func (provider *Provider) FetchForObject(
	ctx context.Context,
	object utilobject.VersionedKey,
	mainTags model.KeyValues,
	start, end time.Time,
) (*extension.FetchResult, error)

func (*Provider) FetchForVersion

func (provider *Provider) FetchForVersion(
	ctx context.Context,
	object utilobject.VersionedKey,
	resourceVersion string,
	mainTags model.KeyValues,
	start, end time.Time,
) (*extension.FetchResult, error)

func (*Provider) Kind

func (provider *Provider) Kind() string

func (*Provider) LoadCache

func (provider *Provider) LoadCache(ctx context.Context, jsonBuf []byte) ([]*model.Span, error)

func (*Provider) MaxConcurrency

func (provider *Provider) MaxConcurrency() int

func (*Provider) RawConfig

func (provider *Provider) RawConfig() []byte

func (*Provider) TotalTimeout

func (provider *Provider) TotalTimeout() time.Duration

type ProviderArgs

type ProviderArgs struct {
	Service   string `json:"service"`
	Operation string `json:"operation"`

	TraceBackends []TraceBackend `json:"traceBackends"`

	TotalTimeout   string `json:"totalTimeout"`
	MaxConcurrency int    `json:"maxConcurrency"`
}

type TraceBackend

type TraceBackend struct {
	TagFilters    filterutil.TagFilters `json:"tagFilters"`
	ArgsTemplates map[string]string     `json:"argsTemplates"`
	URLTemplate   string                `json:"urlTemplate"`

	ForObject     bool `json:"forObject"`
	ForAuditEvent bool `json:"forAuditEvent"`
	// contains filtered or unexported fields
}

type TraceResponse

type TraceResponse struct {
	Data []*model.Trace
}