Versions in this module Expand all Collapse all v0 v0.6.0 Jun 30, 2023 Changes in this version + type APIServer struct + func NewAPIServer(logger log.Logger, namespaceService NamespaceService, ...) *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) CreateNamespace(ctx context.Context, req *compassv1beta1.CreateNamespaceRequest) (*compassv1beta1.CreateNamespaceResponse, 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) GetNamespace(ctx context.Context, req *compassv1beta1.GetNamespaceRequest) (*compassv1beta1.GetNamespaceResponse, 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) ListNamespaces(ctx context.Context, req *compassv1beta1.ListNamespacesRequest) (*compassv1beta1.ListNamespacesResponse, 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) UpdateNamespace(ctx context.Context, req *compassv1beta1.UpdateNamespaceRequest) (*compassv1beta1.UpdateNamespaceResponse, 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, 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) + 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 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(*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, *namespace.Namespace, 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, 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