v1

Documentation

Index

• type ContentType
• type Datadog
  • func (dd *Datadog) QueryQuotaUsage(ctx context.Context, _ *api.QuotaUsageRequest) (*api.QuotaUsageResponse, error)
  • func (dd *Datadog) QueryTimeSeriesMetrics(ctx context.Context, req *api.QueryTimeSeriesMetricsRequest) (*api.QueryTimeSeriesMetricsResponse, error)
• type DefaultNamespaceMetadataProvider
  • func (a *DefaultNamespaceMetadataProvider) GetNamespaceMetadata(ctx context.Context, req *api.GetNamespaceMetadataRequest) (*api.GetNamespaceMetadataResponse, error)
  • func (a *DefaultNamespaceMetadataProvider) InsertNamespaceMetadata(ctx context.Context, req *api.InsertNamespaceMetadataRequest) (*api.InsertNamespaceMetadataResponse, error)
  • func (a *DefaultNamespaceMetadataProvider) UpdateNamespaceMetadata(ctx context.Context, req *api.UpdateNamespaceMetadataRequest) (*api.UpdateNamespaceMetadataResponse, error)
• type DefaultUserMetadataProvider
  • func (a *DefaultUserMetadataProvider) GetUserMetadata(ctx context.Context, req *api.GetUserMetadataRequest) (*api.GetUserMetadataResponse, error)
  • func (a *DefaultUserMetadataProvider) InsertUserMetadata(ctx context.Context, req *api.InsertUserMetadataRequest) (*api.InsertUserMetadataResponse, error)
  • func (a *DefaultUserMetadataProvider) UpdateUserMetadata(ctx context.Context, req *api.UpdateUserMetadataRequest) (*api.UpdateUserMetadataResponse, error)
• type NamespaceMetadataProvider
• type Service
  • func GetRegisteredServices(kvStore kv.KeyValueStore, searchStore search.Store, ...) []Service
  • func GetRegisteredServicesRealtime(kvStore kv.KeyValueStore, searchStore search.Store, ...) []Service
• type UserMetadataProvider

Types

type ContentType

type ContentType string

type Datadog

type Datadog struct {
	Tenants *metadata.TenantManager
	Datadog *metrics.Datadog
}

func (*Datadog) QueryQuotaUsage

func (dd *Datadog) QueryQuotaUsage(ctx context.Context, _ *api.QuotaUsageRequest) (*api.QuotaUsageResponse, error)

func (*Datadog) QueryTimeSeriesMetrics

func (dd *Datadog) QueryTimeSeriesMetrics(ctx context.Context, req *api.QueryTimeSeriesMetricsRequest) (*api.QueryTimeSeriesMetricsResponse, error)

type DefaultNamespaceMetadataProvider

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

func (*DefaultNamespaceMetadataProvider) GetNamespaceMetadata

func (a *DefaultNamespaceMetadataProvider) GetNamespaceMetadata(ctx context.Context, req *api.GetNamespaceMetadataRequest) (*api.GetNamespaceMetadataResponse, error)

func (*DefaultNamespaceMetadataProvider) InsertNamespaceMetadata

func (a *DefaultNamespaceMetadataProvider) InsertNamespaceMetadata(ctx context.Context, req *api.InsertNamespaceMetadataRequest) (*api.InsertNamespaceMetadataResponse, error)

func (*DefaultNamespaceMetadataProvider) UpdateNamespaceMetadata

func (a *DefaultNamespaceMetadataProvider) UpdateNamespaceMetadata(ctx context.Context, req *api.UpdateNamespaceMetadataRequest) (*api.UpdateNamespaceMetadataResponse, error)

type DefaultUserMetadataProvider

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

func (*DefaultUserMetadataProvider) GetUserMetadata

func (a *DefaultUserMetadataProvider) GetUserMetadata(ctx context.Context, req *api.GetUserMetadataRequest) (*api.GetUserMetadataResponse, error)

func (*DefaultUserMetadataProvider) InsertUserMetadata

func (a *DefaultUserMetadataProvider) InsertUserMetadata(ctx context.Context, req *api.InsertUserMetadataRequest) (*api.InsertUserMetadataResponse, error)

func (*DefaultUserMetadataProvider) UpdateUserMetadata

func (a *DefaultUserMetadataProvider) UpdateUserMetadata(ctx context.Context, req *api.UpdateUserMetadataRequest) (*api.UpdateUserMetadataResponse, error)

type NamespaceMetadataProvider

type NamespaceMetadataProvider interface {
	GetNamespaceMetadata(ctx context.Context, req *api.GetNamespaceMetadataRequest) (*api.GetNamespaceMetadataResponse, error)
	InsertNamespaceMetadata(ctx context.Context, req *api.InsertNamespaceMetadataRequest) (*api.InsertNamespaceMetadataResponse, error)
	UpdateNamespaceMetadata(ctx context.Context, req *api.UpdateNamespaceMetadataRequest) (*api.UpdateNamespaceMetadataResponse, error)
}

type Service

type Service interface {
	RegisterHTTP(router chi.Router, inproc *inprocgrpc.Channel) error
	RegisterGRPC(grpc *grpc.Server) error
}

func GetRegisteredServices

func GetRegisteredServices(kvStore kv.KeyValueStore, searchStore search.Store, tenantMgr *metadata.TenantManager, txMgr *transaction.Manager) []Service

func GetRegisteredServicesRealtime

func GetRegisteredServicesRealtime(kvStore kv.KeyValueStore, searchStore search.Store, tenantMgr *metadata.TenantManager, txMgr *transaction.Manager) []Service

type UserMetadataProvider

type UserMetadataProvider interface {
	GetUserMetadata(ctx context.Context, req *api.GetUserMetadataRequest) (*api.GetUserMetadataResponse, error)
	InsertUserMetadata(ctx context.Context, req *api.InsertUserMetadataRequest) (*api.InsertUserMetadataResponse, error)
	UpdateUserMetadata(ctx context.Context, req *api.UpdateUserMetadataRequest) (*api.UpdateUserMetadataResponse, error)
}