handlersv1beta1

package

Go to main page

Versions in this module

v0

v0.7.10

Sep 30, 2024

v0.7.9

Sep 3, 2024

v0.7.8

Aug 22, 2024

Changes in this version

type APIServer

+ func (server *APIServer) DeleteAssets(ctx context.Context, req *compassv1beta1.DeleteAssetsRequest) (*compassv1beta1.DeleteAssetsResponse, error)

type AssetService

+ DeleteAssets func(ctx context.Context, request asset.DeleteAssetsRequest) (uint32, error)

v0.7.7

Aug 22, 2024

v0.7.6

Jul 25, 2024

v0.7.5

Jun 20, 2024

v0.7.4

Apr 30, 2024

v0.7.3

Jan 5, 2024

v0.7.2

Jan 4, 2024

v0.7.1

Dec 12, 2023

v0.7.0

Dec 11, 2023

Changes in this version

type APIServer

+ func (server *APIServer) SyncAssets(ctx context.Context, req *compassv1beta1.SyncAssetsRequest) (*compassv1beta1.SyncAssetsResponse, error)

type AssetService

+ SyncAssets func(ctx context.Context, services []string) error

v0.6.5

Nov 8, 2023

v0.6.4

Oct 23, 2023

v0.6.3

Oct 9, 2023

v0.6.2

Oct 6, 2023

v0.6.1

Aug 21, 2023

Changes in this version

type AssetService

+ GetAssetByIDWithoutProbes func(ctx context.Context, id string) (asset.Asset, error)

v0.6.0

Aug 16, 2023

v0.5.7

Jul 6, 2023

v0.5.6

Jul 5, 2023

Changes in this version

type APIServer

+ func (server *APIServer) ValidateUserInCtx(ctx context.Context) (string, error)

+ type APIServerDeps struct

+ AssetSvc AssetService

+ DiscussionSvc DiscussionService

+ Logger log.Logger

+ StarSvc StarService

+ StatsD StatsDClient

+ TagSvc TagService

+ TagTemplateSvc TagTemplateService

+ UserSvc UserService

v0.5.5

May 26, 2023

v0.5.4

May 12, 2023

Changes in this version

type APIServer

+ func (server *APIServer) GroupAssets(ctx context.Context, req *compassv1beta1.GroupAssetsRequest) (*compassv1beta1.GroupAssetsResponse, error)

type AssetService

+ GroupAssets func(ctx context.Context, cfg asset.GroupConfig) (results []asset.GroupResult, err error)

v0.5.3

May 2, 2023

v0.5.2

Apr 12, 2023

v0.5.1

Mar 15, 2023

v0.5.0

Mar 14, 2023

Changes in this version

+ type APIServer struct

+ func NewAPIServer(logger log.Logger, assetService AssetService, starService StarService, ...) *APIServer

+ func (server *APIServer) CreateAssetProbe(ctx context.Context, req *compassv1beta1.CreateAssetProbeRequest) (*compassv1beta1.CreateAssetProbeResponse, error)

+ func (server *APIServer) CreateComment(ctx context.Context, req *compassv1beta1.CreateCommentRequest) (*compassv1beta1.CreateCommentResponse, error)

+ func (server *APIServer) CreateDiscussion(ctx context.Context, req *compassv1beta1.CreateDiscussionRequest) (*compassv1beta1.CreateDiscussionResponse, error)

+ func (server *APIServer) CreateTagAsset(ctx context.Context, req *compassv1beta1.CreateTagAssetRequest) (*compassv1beta1.CreateTagAssetResponse, error)

+ func (server *APIServer) CreateTagTemplate(ctx context.Context, req *compassv1beta1.CreateTagTemplateRequest) (*compassv1beta1.CreateTagTemplateResponse, error)

+ func (server *APIServer) DeleteAsset(ctx context.Context, req *compassv1beta1.DeleteAssetRequest) (*compassv1beta1.DeleteAssetResponse, error)

+ func (server *APIServer) DeleteComment(ctx context.Context, req *compassv1beta1.DeleteCommentRequest) (*compassv1beta1.DeleteCommentResponse, error)

+ func (server *APIServer) DeleteTagAsset(ctx context.Context, req *compassv1beta1.DeleteTagAssetRequest) (*compassv1beta1.DeleteTagAssetResponse, error)

+ func (server *APIServer) DeleteTagTemplate(ctx context.Context, req *compassv1beta1.DeleteTagTemplateRequest) (*compassv1beta1.DeleteTagTemplateResponse, error)

+ func (server *APIServer) GetAllAssets(ctx context.Context, req *compassv1beta1.GetAllAssetsRequest) (*compassv1beta1.GetAllAssetsResponse, error)

+ func (server *APIServer) GetAllComments(ctx context.Context, req *compassv1beta1.GetAllCommentsRequest) (*compassv1beta1.GetAllCommentsResponse, error)

+ func (server *APIServer) GetAllDiscussions(ctx context.Context, req *compassv1beta1.GetAllDiscussionsRequest) (*compassv1beta1.GetAllDiscussionsResponse, error)

+ func (server *APIServer) GetAllTagTemplates(ctx context.Context, req *compassv1beta1.GetAllTagTemplatesRequest) (*compassv1beta1.GetAllTagTemplatesResponse, error)

+ func (server *APIServer) GetAllTagsByAsset(ctx context.Context, req *compassv1beta1.GetAllTagsByAssetRequest) (*compassv1beta1.GetAllTagsByAssetResponse, error)

+ func (server *APIServer) GetAllTypes(ctx context.Context, req *compassv1beta1.GetAllTypesRequest) (*compassv1beta1.GetAllTypesResponse, error)

+ func (server *APIServer) GetAssetByID(ctx context.Context, req *compassv1beta1.GetAssetByIDRequest) (*compassv1beta1.GetAssetByIDResponse, error)

+ func (server *APIServer) GetAssetByVersion(ctx context.Context, req *compassv1beta1.GetAssetByVersionRequest) (*compassv1beta1.GetAssetByVersionResponse, error)

+ func (server *APIServer) GetAssetStargazers(ctx context.Context, req *compassv1beta1.GetAssetStargazersRequest) (*compassv1beta1.GetAssetStargazersResponse, error)

+ func (server *APIServer) GetAssetVersionHistory(ctx context.Context, req *compassv1beta1.GetAssetVersionHistoryRequest) (*compassv1beta1.GetAssetVersionHistoryResponse, error)

+ func (server *APIServer) GetComment(ctx context.Context, req *compassv1beta1.GetCommentRequest) (*compassv1beta1.GetCommentResponse, error)

+ func (server *APIServer) GetDiscussion(ctx context.Context, req *compassv1beta1.GetDiscussionRequest) (*compassv1beta1.GetDiscussionResponse, error)

+ func (server *APIServer) GetGraph(ctx context.Context, req *compassv1beta1.GetGraphRequest) (*compassv1beta1.GetGraphResponse, error)

+ func (server *APIServer) GetMyDiscussions(ctx context.Context, req *compassv1beta1.GetMyDiscussionsRequest) (*compassv1beta1.GetMyDiscussionsResponse, error)

+ func (server *APIServer) GetMyStarredAsset(ctx context.Context, req *compassv1beta1.GetMyStarredAssetRequest) (*compassv1beta1.GetMyStarredAssetResponse, error)

+ func (server *APIServer) GetMyStarredAssets(ctx context.Context, req *compassv1beta1.GetMyStarredAssetsRequest) (*compassv1beta1.GetMyStarredAssetsResponse, error)

+ func (server *APIServer) GetTagByAssetAndTemplate(ctx context.Context, req *compassv1beta1.GetTagByAssetAndTemplateRequest) (*compassv1beta1.GetTagByAssetAndTemplateResponse, error)

+ func (server *APIServer) GetTagTemplate(ctx context.Context, req *compassv1beta1.GetTagTemplateRequest) (*compassv1beta1.GetTagTemplateResponse, error)

+ func (server *APIServer) GetUserStarredAssets(ctx context.Context, req *compassv1beta1.GetUserStarredAssetsRequest) (*compassv1beta1.GetUserStarredAssetsResponse, error)

+ func (server *APIServer) PatchDiscussion(ctx context.Context, req *compassv1beta1.PatchDiscussionRequest) (*compassv1beta1.PatchDiscussionResponse, error)

+ func (server *APIServer) SearchAssets(ctx context.Context, req *compassv1beta1.SearchAssetsRequest) (*compassv1beta1.SearchAssetsResponse, error)

+ func (server *APIServer) StarAsset(ctx context.Context, req *compassv1beta1.StarAssetRequest) (*compassv1beta1.StarAssetResponse, error)

+ func (server *APIServer) SuggestAssets(ctx context.Context, req *compassv1beta1.SuggestAssetsRequest) (*compassv1beta1.SuggestAssetsResponse, error)

+ func (server *APIServer) UnstarAsset(ctx context.Context, req *compassv1beta1.UnstarAssetRequest) (*compassv1beta1.UnstarAssetResponse, error)

+ func (server *APIServer) UpdateComment(ctx context.Context, req *compassv1beta1.UpdateCommentRequest) (*compassv1beta1.UpdateCommentResponse, error)

+ func (server *APIServer) UpdateTagAsset(ctx context.Context, req *compassv1beta1.UpdateTagAssetRequest) (*compassv1beta1.UpdateTagAssetResponse, error)

+ func (server *APIServer) UpdateTagTemplate(ctx context.Context, req *compassv1beta1.UpdateTagTemplateRequest) (*compassv1beta1.UpdateTagTemplateResponse, error)

+ func (server *APIServer) UpsertAsset(ctx context.Context, req *compassv1beta1.UpsertAssetRequest) (*compassv1beta1.UpsertAssetResponse, error)

+ func (server *APIServer) UpsertPatchAsset(ctx context.Context, req *compassv1beta1.UpsertPatchAssetRequest) (*compassv1beta1.UpsertPatchAssetResponse, error)

+ type AssetService interface

+ AddProbe func(ctx context.Context, assetURN string, probe *asset.Probe) error

+ DeleteAsset func(ctx context.Context, id string) error

+ GetAllAssets func(ctx context.Context, flt asset.Filter, withTotal bool) ([]asset.Asset, uint32, error)

+ GetAssetByID func(ctx context.Context, id string) (asset.Asset, error)

+ GetAssetByVersion func(ctx context.Context, id string, version string) (asset.Asset, error)

+ GetAssetVersionHistory func(ctx context.Context, flt asset.Filter, id string) ([]asset.Asset, error)

+ GetLineage func(ctx context.Context, urn string, query asset.LineageQuery) (asset.Lineage, error)

+ GetTypes func(ctx context.Context, flt asset.Filter) (map[asset.Type]int, error)

+ SearchAssets func(ctx context.Context, cfg asset.SearchConfig) (results []asset.SearchResult, err error)

+ SuggestAssets func(ctx context.Context, cfg asset.SearchConfig) (suggestions []string, err error)

+ UpsertAsset func(ctx context.Context, ast *asset.Asset, upstreams, downstreams []string) (string, error)

+ UpsertAssetWithoutLineage func(ctx context.Context, ast *asset.Asset) (string, error)

+ type DiscussionService interface

+ CreateComment func(ctx context.Context, cmt *discussion.Comment) (string, error)

+ CreateDiscussion func(ctx context.Context, discussion *discussion.Discussion) (string, error)

+ DeleteComment func(ctx context.Context, commentID string, discussionID string) error

+ GetComment func(ctx context.Context, commentID string, discussionID string) (discussion.Comment, error)

+ GetComments func(ctx context.Context, discussionID string, filter discussion.Filter) ([]discussion.Comment, error)

+ GetDiscussion func(ctx context.Context, did string) (discussion.Discussion, error)

+ GetDiscussions func(ctx context.Context, filter discussion.Filter) ([]discussion.Discussion, error)

+ PatchDiscussion func(ctx context.Context, discussion *discussion.Discussion) error

+ UpdateComment func(ctx context.Context, cmt *discussion.Comment) error

+ type Option func(*APIServer)

+ func WithStatsD(st StatsDClient) Option

+ type StarService interface

+ GetStargazers func(context.Context, star.Filter, string) ([]user.User, error)

+ GetStarredAssetByUserID func(context.Context, string, string) (asset.Asset, error)

+ GetStarredAssetsByUserID func(context.Context, star.Filter, string) ([]asset.Asset, error)

+ Stars func(context.Context, string, string) (string, error)

+ Unstars func(context.Context, string, string) error

+ type StatsDClient interface

+ Incr func(name string) *statsd.Metric

+ type TagService interface

+ CreateTag func(ctx context.Context, tag *tag.Tag) error

+ DeleteTag func(ctx context.Context, assetID, templateURN string) error

+ FindTagByAssetIDAndTemplateURN func(ctx context.Context, assetID, templateURN string) (tag.Tag, error)

+ GetTagsByAssetID func(ctx context.Context, assetID string) ([]tag.Tag, error)

+ UpdateTag func(ctx context.Context, tag *tag.Tag) error

+ Validate func(tag *tag.Tag) error

+ type TagTemplateService interface

+ CreateTemplate func(ctx context.Context, template *tag.Template) error

+ DeleteTemplate func(ctx context.Context, urn string) error

+ GetTemplate func(ctx context.Context, urn string) (tag.Template, error)

+ GetTemplates func(ctx context.Context, templateURN string) ([]tag.Template, error)

+ UpdateTemplate func(ctx context.Context, templateURN string, template *tag.Template) error

+ Validate func(template tag.Template) error

+ type UserService interface

+ ValidateUser func(ctx context.Context, uuid, email string) (string, error)

v0.5.0-rc1

Mar 14, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL