extensionjaeger

Documentation

Index

• Constants
• 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 Storage
  • func (s *Storage) Configure(jsonBuf []byte) (extension.Provider, error)
  • func (*Storage) ListIndex() string

Constants

const DefaultNumTracesLimit = 5

Types

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 {
	StorageArgs map[string]string `json:"storageArgs"`

	Service        string            `json:"service"`
	Operation      string            `json:"operation"`
	TagTemplates   map[string]string `json:"tagTemplates"`
	NumTracesLimit int               `json:"numTracesLimit"`

	ForObject     bool `json:"forObject"`
	ForAuditEvent bool `json:"forAuditEvent"`

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

type Storage

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

func (*Storage) Configure

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

func (*Storage) ListIndex

func (*Storage) ListIndex() string