IntenseWebs/grafana
3
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-02-25 18:55:37 -06:00
Code Issues Packages Projects Releases Wiki Activity

chore: add basic tracing to playlist service (#77165)

Browse Source
This commit is contained in:
Kristin Laemmert
2023-10-26 06:25:31 -07:00
committed by GitHub
parent 2c92e370dd
commit 15c1d5f636
1 changed files with 22 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
pkg/services/playlist/playlistimpl/playlist.go
View File

@@ -4,34 +4,47 @@ import (
"context"
"github.com/grafana/grafana/pkg/infra/db"
"github.com/grafana/grafana/pkg/infra/tracing"
"github.com/grafana/grafana/pkg/services/playlist"
)
type Service struct {
store store
store store
tracer tracing.Tracer
}
var _ playlist.Service = &Service{}
func ProvideService(db db.DB) playlist.Service {
return &Service{store: &sqlStore{
db: db,
}}
func ProvideService(db db.DB, tracer tracing.Tracer) playlist.Service {
return &Service{
tracer: tracer,
store: &sqlStore{
db: db,
},
}
}
func (s *Service) Create(ctx context.Context, cmd *playlist.CreatePlaylistCommand) (*playlist.Playlist, error) {
ctx, span := s.tracer.Start(ctx, "playlists.Create")
defer span.End()
return s.store.Insert(ctx, cmd)
}
func (s *Service) Update(ctx context.Context, cmd *playlist.UpdatePlaylistCommand) (*playlist.PlaylistDTO, error) {
ctx, span := s.tracer.Start(ctx, "playlists.Update")
defer span.End()
return s.store.Update(ctx, cmd)
}
func (s *Service) GetWithoutItems(ctx context.Context, q *playlist.GetPlaylistByUidQuery) (*playlist.Playlist, error) {
ctx, span := s.tracer.Start(ctx, "playlists.GetWithoutItems")
defer span.End()
return s.store.Get(ctx, q)
}
func (s *Service) Get(ctx context.Context, q *playlist.GetPlaylistByUidQuery) (*playlist.PlaylistDTO, error) {
ctx, span := s.tracer.Start(ctx, "playlists.Get")
defer span.End()
v, err := s.store.Get(ctx, q)
if err != nil {
return nil, err
@@ -66,9 +79,13 @@ func (s *Service) Get(ctx context.Context, q *playlist.GetPlaylistByUidQuery) (*
}
func (s *Service) Search(ctx context.Context, q *playlist.GetPlaylistsQuery) (playlist.Playlists, error) {
ctx, span := s.tracer.Start(ctx, "playlists.Search")
defer span.End()
return s.store.List(ctx, q)
}
func (s *Service) Delete(ctx context.Context, cmd *playlist.DeletePlaylistCommand) error {
ctx, span := s.tracer.Start(ctx, "playlists.Delete")
defer span.End()
return s.store.Delete(ctx, cmd)
}