Versions in this module Expand all Collapse all v0 v0.7.1 Mar 28, 2026 v0.7.0 Mar 28, 2026 Changes in this version + type AssetService interface + AddProbe func(ctx context.Context, ns *namespace.Namespace, assetURN string, ...) error + DeleteAsset func(ctx context.Context, ns *namespace.Namespace, 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) + GroupAssets func(ctx context.Context, cfg asset.GroupConfig) ([]asset.GroupResult, 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, ns *namespace.Namespace, ast *asset.Asset, ...) (string, error) + UpsertAssetWithoutLineage func(ctx context.Context, ns *namespace.Namespace, ast *asset.Asset) (string, error) + type DiscussionService interface + CreateComment func(ctx context.Context, ns *namespace.Namespace, cmt *discussion.Comment) (string, error) + CreateDiscussion func(ctx context.Context, ns *namespace.Namespace, ...) (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 Handler struct + func New(namespaceService NamespaceService, assetService AssetService, ...) *Handler + func (server *Handler) CreateAssetProbe(ctx context.Context, ...) (*connect.Response[compassv1beta1.CreateAssetProbeResponse], error) + func (server *Handler) CreateComment(ctx context.Context, req *connect.Request[compassv1beta1.CreateCommentRequest]) (*connect.Response[compassv1beta1.CreateCommentResponse], error) + func (server *Handler) CreateDiscussion(ctx context.Context, ...) (*connect.Response[compassv1beta1.CreateDiscussionResponse], error) + func (server *Handler) CreateNamespace(ctx context.Context, ...) (*connect.Response[compassv1beta1.CreateNamespaceResponse], error) + func (server *Handler) CreateTagAsset(ctx context.Context, ...) (*connect.Response[compassv1beta1.CreateTagAssetResponse], error) + func (server *Handler) CreateTagTemplate(ctx context.Context, ...) (*connect.Response[compassv1beta1.CreateTagTemplateResponse], error) + func (server *Handler) DeleteAsset(ctx context.Context, req *connect.Request[compassv1beta1.DeleteAssetRequest]) (*connect.Response[compassv1beta1.DeleteAssetResponse], error) + func (server *Handler) DeleteComment(ctx context.Context, req *connect.Request[compassv1beta1.DeleteCommentRequest]) (*connect.Response[compassv1beta1.DeleteCommentResponse], error) + func (server *Handler) DeleteTagAsset(ctx context.Context, ...) (*connect.Response[compassv1beta1.DeleteTagAssetResponse], error) + func (server *Handler) DeleteTagTemplate(ctx context.Context, ...) (*connect.Response[compassv1beta1.DeleteTagTemplateResponse], error) + func (server *Handler) GetAllAssets(ctx context.Context, req *connect.Request[compassv1beta1.GetAllAssetsRequest]) (*connect.Response[compassv1beta1.GetAllAssetsResponse], error) + func (server *Handler) GetAllComments(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetAllCommentsResponse], error) + func (server *Handler) GetAllDiscussions(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetAllDiscussionsResponse], error) + func (server *Handler) GetAllTagTemplates(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetAllTagTemplatesResponse], error) + func (server *Handler) GetAllTagsByAsset(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetAllTagsByAssetResponse], error) + func (server *Handler) GetAllTypes(ctx context.Context, req *connect.Request[compassv1beta1.GetAllTypesRequest]) (*connect.Response[compassv1beta1.GetAllTypesResponse], error) + func (server *Handler) GetAssetByID(ctx context.Context, req *connect.Request[compassv1beta1.GetAssetByIDRequest]) (*connect.Response[compassv1beta1.GetAssetByIDResponse], error) + func (server *Handler) GetAssetByVersion(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetAssetByVersionResponse], error) + func (server *Handler) GetAssetStargazers(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetAssetStargazersResponse], error) + func (server *Handler) GetAssetVersionHistory(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetAssetVersionHistoryResponse], error) + func (server *Handler) GetComment(ctx context.Context, req *connect.Request[compassv1beta1.GetCommentRequest]) (*connect.Response[compassv1beta1.GetCommentResponse], error) + func (server *Handler) GetDiscussion(ctx context.Context, req *connect.Request[compassv1beta1.GetDiscussionRequest]) (*connect.Response[compassv1beta1.GetDiscussionResponse], error) + func (server *Handler) GetGraph(ctx context.Context, req *connect.Request[compassv1beta1.GetGraphRequest]) (*connect.Response[compassv1beta1.GetGraphResponse], error) + func (server *Handler) GetMyDiscussions(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetMyDiscussionsResponse], error) + func (server *Handler) GetMyStarredAsset(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetMyStarredAssetResponse], error) + func (server *Handler) GetMyStarredAssets(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetMyStarredAssetsResponse], error) + func (server *Handler) GetNamespace(ctx context.Context, req *connect.Request[compassv1beta1.GetNamespaceRequest]) (*connect.Response[compassv1beta1.GetNamespaceResponse], error) + func (server *Handler) GetTagByAssetAndTemplate(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetTagByAssetAndTemplateResponse], error) + func (server *Handler) GetTagTemplate(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetTagTemplateResponse], error) + func (server *Handler) GetUserStarredAssets(ctx context.Context, ...) (*connect.Response[compassv1beta1.GetUserStarredAssetsResponse], error) + func (server *Handler) GroupAssets(ctx context.Context, req *connect.Request[compassv1beta1.GroupAssetsRequest]) (*connect.Response[compassv1beta1.GroupAssetsResponse], error) + func (server *Handler) ListNamespaces(ctx context.Context, ...) (*connect.Response[compassv1beta1.ListNamespacesResponse], error) + func (server *Handler) PatchDiscussion(ctx context.Context, ...) (*connect.Response[compassv1beta1.PatchDiscussionResponse], error) + func (server *Handler) SearchAssets(ctx context.Context, req *connect.Request[compassv1beta1.SearchAssetsRequest]) (*connect.Response[compassv1beta1.SearchAssetsResponse], error) + func (server *Handler) StarAsset(ctx context.Context, req *connect.Request[compassv1beta1.StarAssetRequest]) (*connect.Response[compassv1beta1.StarAssetResponse], error) + func (server *Handler) SuggestAssets(ctx context.Context, req *connect.Request[compassv1beta1.SuggestAssetsRequest]) (*connect.Response[compassv1beta1.SuggestAssetsResponse], error) + func (server *Handler) UnstarAsset(ctx context.Context, req *connect.Request[compassv1beta1.UnstarAssetRequest]) (*connect.Response[compassv1beta1.UnstarAssetResponse], error) + func (server *Handler) UpdateComment(ctx context.Context, req *connect.Request[compassv1beta1.UpdateCommentRequest]) (*connect.Response[compassv1beta1.UpdateCommentResponse], error) + func (server *Handler) UpdateNamespace(ctx context.Context, ...) (*connect.Response[compassv1beta1.UpdateNamespaceResponse], error) + func (server *Handler) UpdateTagAsset(ctx context.Context, ...) (*connect.Response[compassv1beta1.UpdateTagAssetResponse], error) + func (server *Handler) UpdateTagTemplate(ctx context.Context, ...) (*connect.Response[compassv1beta1.UpdateTagTemplateResponse], error) + func (server *Handler) UpsertAsset(ctx context.Context, req *connect.Request[compassv1beta1.UpsertAssetRequest]) (*connect.Response[compassv1beta1.UpsertAssetResponse], error) + func (server *Handler) UpsertPatchAsset(ctx context.Context, ...) (*connect.Response[compassv1beta1.UpsertPatchAssetResponse], error) + type NamespaceService interface + Create func(ctx context.Context, ns *namespace.Namespace) (string, error) + GetByID func(ctx context.Context, id uuid.UUID) (*namespace.Namespace, error) + GetByName func(ctx context.Context, name string) (*namespace.Namespace, error) + List func(ctx context.Context) ([]*namespace.Namespace, error) + Update func(ctx context.Context, ns *namespace.Namespace) error + type Option func(*Handler) + 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, *namespace.Namespace, string, string) (string, error) + Unstars func(context.Context, string, string) error + type TagService interface + CreateTag func(ctx context.Context, ns *namespace.Namespace, 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, ns *namespace.Namespace, 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, ns *namespace.Namespace, templateURN string, ...) error + Validate func(template tag.Template) error + type UserService interface + ValidateUser func(ctx context.Context, ns *namespace.Namespace, uuid, email string) (string, error)
Go to main page