repository

Documentation

Index

• type OperationRepository
  • func NewOperationRepository(logger hclog.Logger, redisClient rueidis.Client, config model.Configuration) (*OperationRepository, error)
  • func (s *OperationRepository) GetOperationsByService(context context.Context, service string) ([]*model.Operation, error)
  • func (s *OperationRepository) GetServices(context context.Context) ([]string, error)
  • func (s *OperationRepository) Write(context context.Context, jaegerSpan *jModel.Span) error
• type SpanRepository
  • func NewSpanRepository(logger hclog.Logger, redisClient rueidis.Client, config model.Configuration) (*SpanRepository, error)
  • func (s *SpanRepository) GetTracesById(context context.Context, ids []string) (map[string]*jModel.Trace, error)
  • func (s *SpanRepository) GetTracesId(context context.Context, queryParameters model.TraceQueryParameters) ([]string, error)
  • func (s *SpanRepository) Write(context context.Context, jSpan *jModel.Span) error

Types

type OperationRepository

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

func NewOperationRepository

func NewOperationRepository(logger hclog.Logger, redisClient rueidis.Client, config model.Configuration) (*OperationRepository, error)

func (*OperationRepository) GetOperationsByService

func (s *OperationRepository) GetOperationsByService(context context.Context, service string) ([]*model.Operation, error)

func (*OperationRepository) GetServices

func (s *OperationRepository) GetServices(context context.Context) ([]string, error)

func (*OperationRepository) Write

func (s *OperationRepository) Write(context context.Context, jaegerSpan *jModel.Span) error

type SpanRepository

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

func NewSpanRepository

func NewSpanRepository(logger hclog.Logger, redisClient rueidis.Client, config model.Configuration) (*SpanRepository, error)

func (*SpanRepository) GetTracesById

func (s *SpanRepository) GetTracesById(context context.Context, ids []string) (map[string]*jModel.Trace, error)

func (*SpanRepository) GetTracesId

func (s *SpanRepository) GetTracesId(context context.Context, queryParameters model.TraceQueryParameters) ([]string, error)

func (*SpanRepository) Write

func (s *SpanRepository) Write(context context.Context, jSpan *jModel.Span) error