kumiho

import "github.com/KumihoIO/kumiho-SDKs/go"

Package kumiho is the Go client for Kumiho Cloud — a graph-native creative & AI asset-management system. Kumiho tracks revisions, relationships, and lineage without uploading your files (“BYO storage”); it stores paths, metadata, and the dependency graph.

It mirrors the Python gold-standard SDK: a low-level Client wrapping every gRPC method, plus fluent domain types (Project, Space, Item, Revision, Artifact, Edge, Bundle).

Quick start

ctx := context.Background()
client, err := kumiho.Connect(ctx, "https://us-central.kumiho.cloud")
if err != nil { log.Fatal(err) }
defer client.Close()

project, _ := client.CreateProject(ctx, "my-vfx-project", "VFX assets")
space, _   := project.CreateSpace(ctx, "characters", "")
item, _    := space.CreateItem(ctx, "hero", "model")
rev, _     := item.CreateRevision(ctx, nil, 0)
rev.CreateArtifact(ctx, "mesh", "/assets/hero.fbx", nil)
rev.Tag(ctx, "approved")

A Kref is a URI identifying any object: kref://project/space/item.kind?r=REVISION&a=ARTIFACT.

Index

Constants

Standard tags.

const (
    // LatestTag points at the newest revision of an item.
    LatestTag = "latest"
    // PublishedTag marks a published / released revision.
    PublishedTag = "published"
)

Standard, semantically-meaningful edge types (UPPERCASE, as required by the Neo4j-backed graph).

const (
    EdgeBelongsTo   = "BELONGS_TO"
    EdgeCreatedFrom = "CREATED_FROM"
    EdgeReferenced  = "REFERENCED"
    EdgeDependsOn   = "DEPENDS_ON"
    EdgeDerivedFrom = "DERIVED_FROM"
    EdgeContains    = "CONTAINS"
    EdgeSupersedes  = "SUPERSEDES"
)

Version is the SDK version.

const Version = "0.10.0"

Variables

ReservedKinds are item kinds that cannot be created via CreateItem.

var ReservedKinds = []string{"bundle"}

func IsNotFound

func IsNotFound(err error) bool

IsNotFound reports whether err is a gRPC NOT_FOUND status.

func IsValidEdgeType

func IsValidEdgeType(edgeType string) bool

IsValidEdgeType reports whether edgeType is valid.

func IsValidKref

func IsValidKref(uri string) bool

IsValidKref reports whether uri is a valid kref.

func TenantSlug

func TenantSlug(tenantHint string) string

TenantSlug returns a URL-safe tenant slug (or a shortened tenant id) for the given tenant hint, or “” if no cached tenant info exists. Mirrors Python get_tenant_slug.

func ValidateEdgeType

func ValidateEdgeType(edgeType string) error

ValidateEdgeType checks an edge type (uppercase, [A-Z0-9_], 1-50 chars).

func ValidateKref

func ValidateKref(uri string) error

ValidateKref checks a kref URI for security and correctness. It rejects path traversal (“..”), control characters, and anything not matching the grammar.

type Artifact

Artifact is a file reference (path/URI) within a revision. Kumiho tracks the location, never the bytes (“BYO storage”).

type Artifact struct {
    Kref         Kref
    Location     string
    RevisionKref Kref
    ItemKref     Kref // empty if not provided by the server
    CreatedAt    string
    Author       string
    Metadata     map[string]string
    Deprecated   bool
    Username     string
    // contains filtered or unexported fields
}

func (*Artifact) Delete

func (a *Artifact) Delete(ctx context.Context, force bool) error

Delete deletes this artifact.

func (*Artifact) DeleteAttribute

func (a *Artifact) DeleteAttribute(ctx context.Context, key string) (bool, error)

DeleteAttribute deletes a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Artifact) GetAttribute

func (a *Artifact) GetAttribute(ctx context.Context, key string) (string, bool, error)

GetAttribute gets a single metadata attribute (ok=false if unset).

func (*Artifact) GetItem

func (a *Artifact) GetItem(ctx context.Context) (*Item, error)

GetItem returns the owning item.

func (*Artifact) GetProject

func (a *Artifact) GetProject(ctx context.Context) (*Project, error)

GetProject returns the containing project.

func (*Artifact) GetRevision

func (a *Artifact) GetRevision(ctx context.Context) (*Revision, error)

GetRevision returns the parent revision.

func (*Artifact) GetSpace

func (a *Artifact) GetSpace(ctx context.Context) (*Space, error)

GetSpace returns the containing space.

func (*Artifact) Name

func (a *Artifact) Name() string

Name returns the artifact name (from the kref’s &a=).

func (*Artifact) SetAttribute

func (a *Artifact) SetAttribute(ctx context.Context, key, value string) (bool, error)

SetAttribute sets a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Artifact) SetDefault

func (a *Artifact) SetDefault(ctx context.Context) error

SetDefault makes this artifact the default for its revision.

func (*Artifact) SetDeprecated

func (a *Artifact) SetDeprecated(ctx context.Context, status bool) error

SetDeprecated deprecates/restores this artifact (updates the in-memory flag).

func (*Artifact) SetMetadata

func (a *Artifact) SetMetadata(ctx context.Context, metadata map[string]string) (*Artifact, error)

SetMetadata merges metadata into this artifact.

type Bundle

Bundle is a reserved-kind item that aggregates other items with a full, immutable audit trail. It embeds *Item, so Item fields/methods are available.

type Bundle struct {
    *Item
}

func (*Bundle) AddMember

func (b *Bundle) AddMember(ctx context.Context, member *Item, metadata map[string]string) (success bool, message string, newRev *Revision, err error)

AddMember adds an item to this bundle.

func (*Bundle) History

func (b *Bundle) History(ctx context.Context) ([]BundleRevisionHistory, error)

History returns the bundle’s immutable membership-change history.

func (*Bundle) Members

func (b *Bundle) Members(ctx context.Context, revisionNumber *int32) ([]BundleMember, error)

Members returns current members (or those at revisionNumber when non-nil).

func (*Bundle) RemoveMember

func (b *Bundle) RemoveMember(ctx context.Context, member *Item, metadata map[string]string) (success bool, message string, newRev *Revision, err error)

RemoveMember removes an item from this bundle.

type BundleMember

BundleMember is an item that belongs to a bundle.

type BundleMember struct {
    ItemKref        Kref
    AddedAt         string
    AddedBy         string
    AddedByUsername string
    AddedInRevision int32
}

type BundleRevisionHistory

BundleRevisionHistory is one immutable membership-change record.

type BundleRevisionHistory struct {
    RevisionNumber int32
    Action         string // "CREATED", "ADDED", or "REMOVED"
    MemberItemKref Kref
    Author         string
    Username       string
    CreatedAt      string
    Metadata       map[string]string
}

type CacheControl

CacheControl is the cache window emitted by the control plane.

type CacheControl struct {
    IssuedAt            string `json:"issued_at"`
    RefreshAt           string `json:"refresh_at"`
    ExpiresAt           string `json:"expires_at"`
    ExpiresInSeconds    int64  `json:"expires_in_seconds"`
    RefreshAfterSeconds int64  `json:"refresh_after_seconds"`
}

type Client

Client is the low-level gRPC client for Kumiho. It is safe for concurrent use.

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

func Auto

func Auto(ctx context.Context) (*Client, error)

Auto builds a Client following the standard Kumiho bootstrap chain:

  1. Load a bearer token (KUMIHO_AUTH_TOKEN, else ~/.kumiho/kumiho_authentication.json).

  2. Token present -> control-plane discovery resolves the tenant’s regional cloud kumiho-server (errors propagate).

  3. No token -> probe the loopback self-hosted CE server and use it.

  4. Neither available -> returns an error.

For an explicit endpoint or a localhost dev fallback, use Connect or Builder.

func AutoWithTenant

func AutoWithTenant(ctx context.Context, tenantHint string) (*Client, error)

AutoWithTenant is like Auto but pins discovery to a tenant slug/id.

func Connect

func Connect(ctx context.Context, endpoint string) (*Client, error)

Connect builds a Client for an explicit endpoint (token auto-loaded).

func FromLocalCE

func FromLocalCE(ctx context.Context) (*Client, error)

FromLocalCE builds a tokenless client pointed at a locally-detected self-hosted CE server, or returns (nil, nil) if none is detected. Mirrors Python client_from_local_ce.

func (*Client) AddBundleMember

func (c *Client) AddBundleMember(ctx context.Context, bundleKref, memberItemKref Kref, metadata map[string]string) (success bool, message string, newRev *Revision, err error)

AddBundleMember adds an item to a bundle.

func (*Client) AnalyzeImpact

func (c *Client) AnalyzeImpact(ctx context.Context, revisionKref Kref, edgeTypeFilter []string, maxDepth, limit int32) ([]ImpactedRevision, error)

AnalyzeImpact analyzes which revisions are impacted by changes to a revision.

func (*Client) BatchGetRevisions

func (c *Client) BatchGetRevisions(ctx context.Context, revisionKrefs, itemKrefs []string, tag string, allowPartial bool) ([]*Revision, []string, error)

BatchGetRevisions fetches revisions by revision krefs and/or item krefs + tag.

func (*Client) Close

func (c *Client) Close() error

Close releases the underlying connection.

func (*Client) CreateArtifact

func (c *Client) CreateArtifact(ctx context.Context, revisionKref Kref, name, location string, metadata map[string]string) (*Artifact, error)

CreateArtifact creates a file-reference artifact on a revision.

func (*Client) CreateBundle

func (c *Client) CreateBundle(ctx context.Context, parentPath, bundleName string, metadata map[string]string) (*Bundle, error)

CreateBundle creates a bundle (the reserved “bundle” kind).

func (*Client) CreateEdge

func (c *Client) CreateEdge(ctx context.Context, source, target *Revision, edgeType string, metadata map[string]string) (*Edge, error)

CreateEdge creates a typed edge between two revisions.

func (*Client) CreateItem

func (c *Client) CreateItem(ctx context.Context, parentPath, itemName, kind string, metadata map[string]string) (*Item, error)

CreateItem creates an item. The reserved “bundle” kind is rejected.

func (*Client) CreateProject

func (c *Client) CreateProject(ctx context.Context, name, description string) (*Project, error)

CreateProject creates a new project.

func (*Client) CreateRevision

func (c *Client) CreateRevision(ctx context.Context, itemKref Kref, metadata map[string]string, number int32, embeddingText string) (*Revision, error)

CreateRevision creates a revision for an item (number=0 auto-increments).

func (*Client) CreateSpace

func (c *Client) CreateSpace(ctx context.Context, parentPath, spaceName string) (*Space, error)

CreateSpace creates a space under parentPath.

func (*Client) DeleteArtifact

func (c *Client) DeleteArtifact(ctx context.Context, kref Kref, force bool) error

DeleteArtifact deletes an artifact.

func (*Client) DeleteAttribute

func (c *Client) DeleteAttribute(ctx context.Context, kref Kref, key string) (bool, error)

DeleteAttribute deletes a single metadata attribute.

func (*Client) DeleteEdge

func (c *Client) DeleteEdge(ctx context.Context, sourceKref, targetKref Kref, edgeType string) error

DeleteEdge deletes an edge.

func (*Client) DeleteItem

func (c *Client) DeleteItem(ctx context.Context, kref Kref, force bool) error

DeleteItem deletes an item (force=true to delete with revisions).

func (*Client) DeleteProject

func (c *Client) DeleteProject(ctx context.Context, projectID string, force bool) error

DeleteProject deletes (force=true) or deprecates a project.

func (*Client) DeleteRevision

func (c *Client) DeleteRevision(ctx context.Context, kref Kref, force bool) error

DeleteRevision deletes a revision.

func (*Client) DeleteSpace

func (c *Client) DeleteSpace(ctx context.Context, path string, force bool) error

DeleteSpace deletes a space by path (force=true for a non-empty space).

func (*Client) EventStream

func (c *Client) EventStream(ctx context.Context, routingKeyFilter, krefFilter, cursor, consumerGroup string, fromBeginning bool) (*EventStream, error)

EventStream subscribes to the server event stream.

cursor and consumerGroup may be “”; fromBeginning replays available history (Creator tier+). Filters support wildcards.

func (*Client) FindShortestPath

func (c *Client) FindShortestPath(ctx context.Context, sourceKref, targetKref Kref, edgeTypeFilter []string, maxDepth int32, allShortest bool) (*ShortestPathResult, error)

FindShortestPath finds the shortest path between two revisions.

func (*Client) GetArtifact

func (c *Client) GetArtifact(ctx context.Context, revisionKref Kref, name string) (*Artifact, error)

GetArtifact gets an artifact by revision kref + name.

func (*Client) GetArtifactByKref

func (c *Client) GetArtifactByKref(ctx context.Context, krefURI string) (*Artifact, error)

GetArtifactByKref gets an artifact by kref URI, falling back to the revision’s default artifact when no &a= is present.

func (*Client) GetArtifacts

func (c *Client) GetArtifacts(ctx context.Context, revisionKref Kref) ([]*Artifact, error)

GetArtifacts gets all artifacts on a revision.

func (*Client) GetArtifactsByLocation

func (c *Client) GetArtifactsByLocation(ctx context.Context, location string) ([]*Artifact, error)

GetArtifactsByLocation reverse-looks-up artifacts referencing a file location.

func (*Client) GetAttribute

func (c *Client) GetAttribute(ctx context.Context, kref Kref, key string) (value string, ok bool, err error)

GetAttribute gets a single metadata attribute (ok=false if unset).

func (*Client) GetBundleByKref

func (c *Client) GetBundleByKref(ctx context.Context, krefURI string) (*Bundle, error)

GetBundleByKref gets a bundle by kref URI (verifies kind == bundle).

func (*Client) GetBundleHistory

func (c *Client) GetBundleHistory(ctx context.Context, bundleKref Kref) ([]BundleRevisionHistory, error)

GetBundleHistory returns a bundle’s immutable membership-change history.

func (*Client) GetBundleMembers

func (c *Client) GetBundleMembers(ctx context.Context, bundleKref Kref, revisionNumber *int32) (members []BundleMember, revNumber, totalCount int32, err error)

GetBundleMembers returns a bundle’s members (optionally at a revision).

func (*Client) GetChildSpaces

func (c *Client) GetChildSpaces(ctx context.Context, parentPath string, recursive bool, pageSize int, cursor string) (*Page[*Space], error)

GetChildSpaces lists child spaces under parentPath.

func (*Client) GetEdges

func (c *Client) GetEdges(ctx context.Context, kref Kref, edgeTypeFilter string, direction EdgeDirection) ([]*Edge, error)

GetEdges gets edges for a revision, filtered by type and direction.

func (*Client) GetEventCapabilities

func (c *Client) GetEventCapabilities(ctx context.Context) (*EventCapabilities, error)

GetEventCapabilities returns this tenant tier’s event-streaming capabilities.

func (*Client) GetItem

func (c *Client) GetItem(ctx context.Context, parentPath, itemName, kind string) (*Item, error)

GetItem gets an item by parent path, name and kind.

func (*Client) GetItemByKref

func (c *Client) GetItemByKref(ctx context.Context, krefURI string) (*Item, error)

GetItemByKref gets an item by its kref URI.

func (*Client) GetItemFromRevision

func (c *Client) GetItemFromRevision(ctx context.Context, revisionKref string) (*Item, error)

GetItemFromRevision returns the item that owns the given revision kref.

func (*Client) GetItems

func (c *Client) GetItems(ctx context.Context, parentPath, nameFilter, kindFilter string, pageSize int, cursor string, includeDeprecated bool) (*Page[*Item], error)

GetItems lists items in a space.

func (*Client) GetLatestRevision

func (c *Client) GetLatestRevision(ctx context.Context, itemKref Kref) (*Revision, error)

GetLatestRevision resolves the latest revision, or (nil, nil) if none.

func (*Client) GetProject

func (c *Client) GetProject(ctx context.Context, name string) (*Project, error)

GetProject returns the project with the given name, or (nil, nil) if absent.

func (*Client) GetProjects

func (c *Client) GetProjects(ctx context.Context) ([]*Project, error)

GetProjects lists all accessible projects.

func (*Client) GetRevision

func (c *Client) GetRevision(ctx context.Context, krefURI string) (*Revision, error)

GetRevision gets a revision by kref URI (supports ?t=tag / ?time=YYYYMMDDHHMM).

func (*Client) GetRevisions

func (c *Client) GetRevisions(ctx context.Context, itemKref Kref) ([]*Revision, error)

GetRevisions lists all revisions of an item.

func (*Client) GetSpace

func (c *Client) GetSpace(ctx context.Context, path string) (*Space, error)

GetSpace gets a space by path or kref.

func (*Client) GetTenantUsage

func (c *Client) GetTenantUsage(ctx context.Context) (*TenantUsage, error)

GetTenantUsage returns the current tenant’s node usage and limit.

func (*Client) HasTag

func (c *Client) HasTag(ctx context.Context, kref Kref, tag string) (bool, error)

HasTag reports whether a revision currently has a tag.

func (*Client) ItemSearch

func (c *Client) ItemSearch(ctx context.Context, contextFilter, nameFilter, kindFilter string, pageSize int, cursor string, includeDeprecated bool) (*Page[*Item], error)

ItemSearch searches items across the system by filters.

func (*Client) PeekNextRevision

func (c *Client) PeekNextRevision(ctx context.Context, itemKref Kref) (int32, error)

PeekNextRevision returns the next revision number for an item.

func (*Client) RemoveBundleMember

func (c *Client) RemoveBundleMember(ctx context.Context, bundleKref, memberItemKref Kref, metadata map[string]string) (success bool, message string, newRev *Revision, err error)

RemoveBundleMember removes an item from a bundle.

func (*Client) Resolve

func (c *Client) Resolve(ctx context.Context, kref string) (string, error)

Resolve resolves a kref to a file location.

func (*Client) ResolveKref

func (c *Client) ResolveKref(ctx context.Context, kref string, tag, t *string) (*Revision, error)

ResolveKref resolves an item kref to a revision by tag and/or time.

func (*Client) ScoreRevisions

func (c *Client) ScoreRevisions(ctx context.Context, query string, revisionKrefs, scoreFields []string) ([]ScoredRevision, error)

ScoreRevisions scores specific revisions against a query (server-side).

func (*Client) SetAttribute

func (c *Client) SetAttribute(ctx context.Context, kref Kref, key, value string) (bool, error)

SetAttribute sets a single metadata attribute on any entity.

func (*Client) SetDefaultArtifact

func (c *Client) SetDefaultArtifact(ctx context.Context, revisionKref Kref, artifactName string) error

SetDefaultArtifact sets a revision’s default artifact.

func (*Client) SetDeprecated

func (c *Client) SetDeprecated(ctx context.Context, kref Kref, deprecated bool) error

SetDeprecated deprecates/restores any node (item, revision, artifact).

func (*Client) TagRevision

func (c *Client) TagRevision(ctx context.Context, kref Kref, tag string) error

TagRevision applies a tag to a revision.

func (*Client) TraverseEdges

func (c *Client) TraverseEdges(ctx context.Context, originKref Kref, direction EdgeDirection, edgeTypeFilter []string, maxDepth, limit int32, includePath bool) (*TraversalResult, error)

TraverseEdges transitively traverses edges from an origin revision.

func (*Client) UntagRevision

func (c *Client) UntagRevision(ctx context.Context, kref Kref, tag string) error

UntagRevision removes a tag from a revision.

func (*Client) UpdateArtifactMetadata

func (c *Client) UpdateArtifactMetadata(ctx context.Context, kref Kref, metadata map[string]string) (*Artifact, error)

UpdateArtifactMetadata merges metadata into an artifact.

func (*Client) UpdateItemMetadata

func (c *Client) UpdateItemMetadata(ctx context.Context, kref Kref, metadata map[string]string) (*Item, error)

UpdateItemMetadata merges metadata into an item.

func (*Client) UpdateProject

func (c *Client) UpdateProject(ctx context.Context, projectID string, allowPublic *bool, description *string) (*Project, error)

UpdateProject updates a project’s description and/or public flag.

func (*Client) UpdateRevisionMetadata

func (c *Client) UpdateRevisionMetadata(ctx context.Context, kref Kref, metadata map[string]string) (*Revision, error)

UpdateRevisionMetadata merges metadata into a revision.

func (*Client) UpdateSpaceMetadata

func (c *Client) UpdateSpaceMetadata(ctx context.Context, kref Kref, metadata map[string]string) (*Space, error)

UpdateSpaceMetadata replaces/merges a space’s metadata.

func (*Client) WasTagged

func (c *Client) WasTagged(ctx context.Context, kref Kref, tag string) (bool, error)

WasTagged reports whether a revision was ever tagged with a tag.

type ClientBuilder

ClientBuilder configures a Client. Obtain one via Builder().

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

func Builder

func Builder() *ClientBuilder

Builder starts a new ClientBuilder.

func (*ClientBuilder) Build

func (b *ClientBuilder) Build(ctx context.Context) (*Client, error)

Build resolves routing/auth and dials the server (lazily).

func (*ClientBuilder) CachePath

func (b *ClientBuilder) CachePath(path string) *ClientBuilder

CachePath overrides the discovery cache file path (otherwise KUMIHO_DISCOVERY_CACHE_FILE, else the default). Mirrors Python’s cache_path.

func (*ClientBuilder) ControlPlaneURL

func (b *ClientBuilder) ControlPlaneURL(url string) *ClientBuilder

ControlPlaneURL overrides the control-plane discovery URL (otherwise KUMIHO_CONTROL_PLANE_URL, else the default). Mirrors Python’s control_plane_url.

func (*ClientBuilder) Endpoint

func (b *ClientBuilder) Endpoint(ep string) *ClientBuilder

Endpoint sets an explicit gRPC endpoint (host:port, https://host, grpcs://host:port).

func (*ClientBuilder) ForceDiscoveryRefresh

func (b *ClientBuilder) ForceDiscoveryRefresh(yes bool) *ClientBuilder

ForceDiscoveryRefresh bypasses the discovery cache.

func (*ClientBuilder) Metadata

func (b *ClientBuilder) Metadata(key, value string) *ClientBuilder

Metadata adds a static header sent on every RPC.

func (*ClientBuilder) TenantHint

func (b *ClientBuilder) TenantHint(h string) *ClientBuilder

TenantHint sets a tenant slug/id for discovery or the x-tenant-id header.

func (*ClientBuilder) Token

func (b *ClientBuilder) Token(t string) *ClientBuilder

Token sets an explicit bearer token (otherwise loaded from env / ~/.kumiho).

func (*ClientBuilder) UseDiscovery

func (b *ClientBuilder) UseDiscovery(yes bool) *ClientBuilder

UseDiscovery forces control-plane discovery on/off.

type DiscoveryError

DiscoveryError indicates a control-plane discovery / bootstrap failure.

type DiscoveryError struct{ Msg string }

func (*DiscoveryError) Error

func (e *DiscoveryError) Error() string

type DiscoveryRecord

DiscoveryRecord is a resolved tenant routing record.

type DiscoveryRecord struct {
    TenantID     string          `json:"tenant_id"`
    TenantName   string          `json:"tenant_name,omitempty"`
    Roles        []string        `json:"roles,omitempty"`
    Guardrails   json.RawMessage `json:"guardrails,omitempty"`
    Region       RegionRouting   `json:"region"`
    CacheControl CacheControl    `json:"cache_control"`
}

func TenantInfo

func TenantInfo(tenantHint string) *DiscoveryRecord

TenantInfo returns the cached discovery record for the given tenant hint (or the default tenant), or nil if no cache entry exists. Mirrors Python get_tenant_info (tenant id, name, roles, region, guardrails).

func (*DiscoveryRecord) Target

func (r *DiscoveryRecord) Target() string

Target is the gRPC endpoint to dial (authority preferred over server URL).

type Edge

Edge is a directed, typed relationship between two revisions.

type Edge struct {
    SourceKref Kref
    TargetKref Kref
    EdgeType   string
    Metadata   map[string]string
    CreatedAt  string
    Author     string
    Username   string
    // contains filtered or unexported fields
}

func (*Edge) Delete

func (e *Edge) Delete(ctx context.Context) error

Delete removes this edge.

type EdgeDirection

EdgeDirection selects which edges a query traverses.

type EdgeDirection int32


const (
    // Outgoing: edges where the queried revision is the source.
    Outgoing EdgeDirection = 0
    // Incoming: edges where the queried revision is the target.
    Incoming EdgeDirection = 1
    // Both directions.
    Both EdgeDirection = 2
)

type EdgeTypeValidationError

EdgeTypeValidationError is returned when an edge type is malformed.

type EdgeTypeValidationError struct{ Msg string }

func (*EdgeTypeValidationError) Error

func (e *EdgeTypeValidationError) Error() string

type Event

Event is a real-time notification from the server.

type Event struct {
    RoutingKey string
    Kref       Kref
    Timestamp  string
    Author     string
    Details    map[string]string
    Cursor     string
}

type EventCapabilities

EventCapabilities reports event-streaming capabilities for the tenant tier.

type EventCapabilities struct {
    SupportsReplay         bool
    SupportsCursor         bool
    SupportsConsumerGroups bool
    MaxRetentionHours      int64
    MaxBufferSize          int64
    Tier                   string
}

type EventStream

EventStream is a live subscription to server events. Call Recv repeatedly; it returns io.EOF when the server closes the stream.

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

func (*EventStream) Recv

func (s *EventStream) Recv() (*Event, error)

Recv blocks for the next event.

type ImpactedRevision

ImpactedRevision is a revision impacted by changes to another revision.

type ImpactedRevision struct {
    RevisionKref    Kref
    ItemKref        Kref
    ImpactDepth     int32
    ImpactPathTypes []string
}

type InvalidArgumentError

InvalidArgumentError is returned for malformed client-side arguments (e.g. a kref that is structurally not an item kref).

type InvalidArgumentError struct{ Msg string }

func (*InvalidArgumentError) Error

func (e *InvalidArgumentError) Error() string

type Item

Item is a versioned asset identified by a Kref.

type Item struct {
    Kref       Kref
    Name       string
    ItemName   string
    Kind       string
    CreatedAt  string
    Author     string
    Metadata   map[string]string
    Deprecated bool
    Username   string
    // contains filtered or unexported fields
}

func (*Item) CreateRevision

func (i *Item) CreateRevision(ctx context.Context, metadata map[string]string, number int32) (*Revision, error)

CreateRevision creates a revision (number=0 auto-increments).

func (*Item) Delete

func (i *Item) Delete(ctx context.Context, force bool) error

Delete deletes this item (force=true to delete with revisions).

func (*Item) DeleteAttribute

func (i *Item) DeleteAttribute(ctx context.Context, key string) (bool, error)

DeleteAttribute deletes a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Item) GetAttribute

func (i *Item) GetAttribute(ctx context.Context, key string) (string, bool, error)

GetAttribute gets a single metadata attribute (ok=false if unset).

func (*Item) GetLatestRevision

func (i *Item) GetLatestRevision(ctx context.Context) (*Revision, error)

GetLatestRevision returns the latest revision, or (nil, nil) if none.

Mirrors the Python Item.get_latest_revision: prefer the revision flagged “latest”, otherwise fall back to the highest-numbered revision.

func (*Item) GetProject

func (i *Item) GetProject(ctx context.Context) (*Project, error)

GetProject returns the containing project.

func (*Item) GetRevision

func (i *Item) GetRevision(ctx context.Context, number int32) (*Revision, error)

GetRevision gets a revision by number.

func (*Item) GetRevisionByTag

func (i *Item) GetRevisionByTag(ctx context.Context, tag string) (*Revision, error)

GetRevisionByTag returns the revision currently carrying tag, or (nil, nil).

func (*Item) GetRevisionByTime

func (i *Item) GetRevisionByTime(ctx context.Context, time string, tag string) (*Revision, error)

GetRevisionByTime returns the revision that held tag (or latest) at time. time may be “YYYYMMDDHHMM” or an RFC3339 timestamp; tag “” means latest.

func (*Item) GetRevisions

func (i *Item) GetRevisions(ctx context.Context) ([]*Revision, error)

GetRevisions lists all revisions.

func (*Item) GetSpace

func (i *Item) GetSpace(ctx context.Context) (*Space, error)

GetSpace returns the containing space.

func (*Item) PeekNextRevision

func (i *Item) PeekNextRevision(ctx context.Context) (int32, error)

PeekNextRevision returns the next revision number.

func (*Item) Project

func (i *Item) Project() string

Project returns the project name this item belongs to.

func (*Item) SetAttribute

func (i *Item) SetAttribute(ctx context.Context, key, value string) (bool, error)

SetAttribute sets a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Item) SetDeprecated

func (i *Item) SetDeprecated(ctx context.Context, status bool) error

SetDeprecated deprecates/restores this item (updates the in-memory flag).

func (*Item) SetMetadata

func (i *Item) SetMetadata(ctx context.Context, metadata map[string]string) (*Item, error)

SetMetadata merges metadata into this item.

func (*Item) Space

func (i *Item) Space() string

Space returns the space path this item belongs to.

type Kref

Kref is a Kumiho Reference: a URI uniquely identifying any object, kref://project/space/item.kind?r=REVISION&a=ARTIFACT.

It is a string type, so it can be used anywhere a string is expected.

type Kref string

func NewKref

func NewKref(uri string) (Kref, error)

NewKref parses and validates a kref URI.

func (Kref) ArtifactName

func (k Kref) ArtifactName() string

ArtifactName returns the artifact name from “&a=”, or “” if absent.

func (Kref) ItemName

func (k Kref) ItemName() string

ItemName returns the last path segment (e.g. “hero.model”), or “”.

func (Kref) Kind

func (k Kref) Kind() string

Kind returns the item kind (after the first “.” in the item name), or “”.

func (Kref) Path

func (k Kref) Path() string

Path returns the path component (after “kref://”, before any “?”).

func (Kref) Project

func (k Kref) Project() string

Project returns the first path segment.

func (Kref) Revision

func (k Kref) Revision() int

Revision returns the revision number from “?r=”, defaulting to 1.

func (Kref) Space

func (k Kref) Space() string

Space returns the segments between project and item, or “” if none.

func (Kref) String

func (k Kref) String() string

String implements fmt.Stringer.

func (Kref) URI

func (k Kref) URI() string

URI returns the underlying URI string.

type KrefValidationError

KrefValidationError is returned when a kref URI fails validation.

type KrefValidationError struct{ Msg string }

func (*KrefValidationError) Error

func (e *KrefValidationError) Error() string

type KumihoError

KumihoError is the common interface implemented by every error this SDK returns, so callers can match them all with a single errors.As. Mirrors Python’s KumihoError base exception.

var ke kumiho.KumihoError
if errors.As(err, &ke) { /* any kumiho error */ }

type KumihoError interface {
    // contains filtered or unexported methods
}

type Page

Page is a slice of list results plus an optional pagination cursor.

type Page[T any] struct {
    Items      []T
    NextCursor string
    TotalCount int32
}

type PathStep

PathStep is a single hop in a traversal path.

type PathStep struct {
    RevisionKref Kref
    EdgeType     string
    Depth        int32
}

type Project

Project is the top-level container for assets.

type Project struct {
    ProjectID   string
    Name        string
    Description string
    CreatedAt   string
    UpdatedAt   string
    Deprecated  bool
    AllowPublic bool
    // contains filtered or unexported fields
}

func (*Project) CreateBundle

func (p *Project) CreateBundle(ctx context.Context, bundleName, parentPath string, metadata map[string]string) (*Bundle, error)

CreateBundle creates a bundle (parentPath “” defaults to the project root).

func (*Project) CreateItem

func (p *Project) CreateItem(ctx context.Context, itemName, kind, parentPath string, metadata map[string]string) (*Item, error)

CreateItem creates an item (parentPath “” defaults to the project root).

func (*Project) CreateSpace

func (p *Project) CreateSpace(ctx context.Context, name, parentPath string) (*Space, error)

CreateSpace creates a space (parentPath “” defaults to the project root).

func (*Project) Delete

func (p *Project) Delete(ctx context.Context, force bool) error

Delete deletes (force=true) or deprecates this project.

func (*Project) GetBundle

func (p *Project) GetBundle(ctx context.Context, bundleName, parentPath string) (*Bundle, error)

GetBundle gets a bundle by name (parentPath “” = project root).

func (*Project) GetItem

func (p *Project) GetItem(ctx context.Context, itemName, kind, parentPath string) (*Item, error)

GetItem gets an item by name + kind (parentPath “” = project root).

func (*Project) GetItems

func (p *Project) GetItems(ctx context.Context, nameFilter, kindFilter string, pageSize int, cursor string) (*Page[*Item], error)

GetItems searches items within this project.

func (*Project) GetSpace

func (p *Project) GetSpace(ctx context.Context, name, parentPath string) (*Space, error)

GetSpace gets a space by relative name or absolute “/path”.

func (*Project) GetSpaces

func (p *Project) GetSpaces(ctx context.Context, parentPath string, recursive bool, pageSize int, cursor string) (*Page[*Space], error)

GetSpaces lists spaces in this project.

func (*Project) SetAllowPublic

func (p *Project) SetAllowPublic(ctx context.Context, allowPublic bool) (*Project, error)

SetAllowPublic is an alias for SetPublic (matching Python). The AllowPublic field is read-only — assigning it does not persist; call this instead.

func (*Project) SetPublic

func (p *Project) SetPublic(ctx context.Context, public bool) (*Project, error)

SetPublic enables/disables anonymous read access.

func (*Project) Update

func (p *Project) Update(ctx context.Context, description *string, allowPublic *bool) (*Project, error)

Update updates description and/or public flag (nil = leave unchanged).

type ProjectLimitError

ProjectLimitError is returned when guardrails block project creation (e.g. the tenant’s project limit was reached).

type ProjectLimitError struct{ Msg string }

func (*ProjectLimitError) Error

func (e *ProjectLimitError) Error() string

type RegionRouting

RegionRouting is the regional gRPC routing returned by the control plane.

type RegionRouting struct {
    RegionCode    string `json:"region_code"`
    ServerURL     string `json:"server_url"`
    GRPCAuthority string `json:"grpc_authority,omitempty"`
}

type ReservedKindError

ReservedKindError is returned when CreateItem is called with a reserved item kind (e.g. “bundle”); use CreateBundle instead. Mirrors Python’s ReservedKindError so callers can discriminate this case.

type ReservedKindError struct {
    Kind string
    Msg  string
}

func (*ReservedKindError) Error

func (e *ReservedKindError) Error() string

type Revision

Revision is a specific, immutable iteration of an item.

Tags is a snapshot from when the revision was fetched; call Refresh to re-read server-managed tags (e.g. “latest”).

type Revision struct {
    Kref            Kref
    ItemKref        Kref
    Number          int32
    Latest          bool
    Tags            []string
    Metadata        map[string]string
    CreatedAt       string
    Author          string
    Deprecated      bool
    Published       bool
    Username        string
    DefaultArtifact string
    // contains filtered or unexported fields
}

func (*Revision) AnalyzeImpact

func (r *Revision) AnalyzeImpact(ctx context.Context, edgeTypeFilter []string, maxDepth, limit int32) ([]ImpactedRevision, error)

AnalyzeImpact returns revisions impacted by changes to this revision. maxDepth<=0 defaults to 10 and limit<=0 to 100, matching Python.

func (*Revision) CreateArtifact

func (r *Revision) CreateArtifact(ctx context.Context, name, location string, metadata map[string]string) (*Artifact, error)

CreateArtifact creates a file-reference artifact on this revision.

func (*Revision) CreateEdge

func (r *Revision) CreateEdge(ctx context.Context, target *Revision, edgeType string, metadata map[string]string) (*Edge, error)

CreateEdge creates an edge from this revision to target.

func (*Revision) Delete

func (r *Revision) Delete(ctx context.Context, force bool) error

Delete deletes this revision.

func (*Revision) DeleteAttribute

func (r *Revision) DeleteAttribute(ctx context.Context, key string) (bool, error)

DeleteAttribute deletes a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Revision) DeleteEdge

func (r *Revision) DeleteEdge(ctx context.Context, target *Revision, edgeType string) error

DeleteEdge deletes an edge from this revision to target.

func (*Revision) FindAllPathsTo

func (r *Revision) FindAllPathsTo(ctx context.Context, target *Revision, edgeTypeFilter []string, maxDepth int32) (*ShortestPathResult, error)

FindAllPathsTo returns every shortest path to target (the Python find_path_to(all_paths=True) capability). maxDepth<=0 defaults to 10.

func (*Revision) FindPathTo

func (r *Revision) FindPathTo(ctx context.Context, target *Revision, edgeTypeFilter []string, maxDepth int32) (*RevisionPath, error)

FindPathTo returns the shortest path to target, or (nil, nil) if none. maxDepth<=0 defaults to 10, matching Python.

func (*Revision) GetAllDependencies

func (r *Revision) GetAllDependencies(ctx context.Context, edgeTypeFilter []string, maxDepth, limit int32) (*TraversalResult, error)

GetAllDependencies returns all transitive dependencies (outgoing). maxDepth<=0 defaults to 10 and limit<=0 to 100, matching Python.

func (*Revision) GetAllDependents

func (r *Revision) GetAllDependents(ctx context.Context, edgeTypeFilter []string, maxDepth, limit int32) (*TraversalResult, error)

GetAllDependents returns all transitive dependents (incoming). maxDepth<=0 defaults to 10 and limit<=0 to 100, matching Python.

func (*Revision) GetArtifact

func (r *Revision) GetArtifact(ctx context.Context, name string) (*Artifact, error)

GetArtifact gets an artifact by name.

func (*Revision) GetArtifacts

func (r *Revision) GetArtifacts(ctx context.Context) ([]*Artifact, error)

GetArtifacts gets all artifacts.

func (*Revision) GetAttribute

func (r *Revision) GetAttribute(ctx context.Context, key string) (string, bool, error)

GetAttribute gets a single metadata attribute (ok=false if unset).

func (*Revision) GetEdges

func (r *Revision) GetEdges(ctx context.Context, edgeTypeFilter string, direction EdgeDirection) ([]*Edge, error)

GetEdges gets edges for this revision (edgeTypeFilter “” = all).

func (*Revision) GetItem

func (r *Revision) GetItem(ctx context.Context) (*Item, error)

GetItem returns the parent item.

func (*Revision) GetLocations

func (r *Revision) GetLocations(ctx context.Context) ([]string, error)

GetLocations returns the file locations of all artifacts.

func (*Revision) GetProject

func (r *Revision) GetProject(ctx context.Context) (*Project, error)

GetProject returns the containing project.

func (*Revision) GetSpace

func (r *Revision) GetSpace(ctx context.Context) (*Space, error)

GetSpace returns the containing space.

func (*Revision) HasTag

func (r *Revision) HasTag(ctx context.Context, tag string) (bool, error)

HasTag reports whether this revision currently has a tag (server call).

func (*Revision) Refresh

func (r *Revision) Refresh(ctx context.Context) (*Revision, error)

Refresh re-reads this revision from the server (returns a fresh copy).

func (*Revision) SetAttribute

func (r *Revision) SetAttribute(ctx context.Context, key, value string) (bool, error)

SetAttribute sets a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Revision) SetDefaultArtifact

func (r *Revision) SetDefaultArtifact(ctx context.Context, artifactName string) error

SetDefaultArtifact sets the default artifact (used when resolving without &a=). Updates the in-memory DefaultArtifact on success.

func (*Revision) SetDeprecated

func (r *Revision) SetDeprecated(ctx context.Context, status bool) error

SetDeprecated deprecates/restores this revision (updates the in-memory flag).

func (*Revision) SetMetadata

func (r *Revision) SetMetadata(ctx context.Context, metadata map[string]string) (*Revision, error)

SetMetadata merges metadata into this revision.

func (*Revision) Tag

func (r *Revision) Tag(ctx context.Context, tag string) error

Tag applies a tag (updates the in-memory Tags snapshot on success).

func (*Revision) Untag

func (r *Revision) Untag(ctx context.Context, tag string) error

Untag removes a tag (updates the in-memory Tags snapshot on success).

func (*Revision) WasTagged

func (r *Revision) WasTagged(ctx context.Context, tag string) (bool, error)

WasTagged reports whether this revision was ever tagged with tag.

type RevisionPath

RevisionPath is a complete path between two revisions.

type RevisionPath struct {
    Steps      []PathStep
    TotalDepth int32
}

type ScoredRevision

ScoredRevision is a revision scored against a query by the server.

type ScoredRevision struct {
    Kref        string
    Score       float32
    ScoreMethod string
}

type SearchOptions

SearchOptions configures a full-text Search.

type SearchOptions struct {
    ContextFilter           string
    KindFilter              string
    IncludeDeprecated       bool
    IncludeRevisionMetadata bool
    IncludeArtifactMetadata bool
    MinScore                float32
    PageSize                int
    Cursor                  string
}

type SearchResult

SearchResult is a full-text search hit.

type SearchResult struct {
    Item      *Item
    Score     float32
    MatchedIn []string
}

type ShortestPathResult

ShortestPathResult is the outcome of a shortest-path query.

type ShortestPathResult struct {
    Paths      []RevisionPath
    PathExists bool
    PathLength int32
}

func (*ShortestPathResult) FirstPath

func (s *ShortestPathResult) FirstPath() *RevisionPath

FirstPath returns the first shortest path, or nil if none.

type Space

Space is a hierarchical folder within a project.

type Space struct {
    Path      string
    Name      string
    Type      string // "root" or "sub"
    CreatedAt string
    Author    string
    Metadata  map[string]string
    Username  string
    // contains filtered or unexported fields
}

func (*Space) CreateBundle

func (s *Space) CreateBundle(ctx context.Context, bundleName string, metadata map[string]string) (*Bundle, error)

CreateBundle creates a bundle in this space.

func (*Space) CreateItem

func (s *Space) CreateItem(ctx context.Context, itemName, kind string) (*Item, error)

CreateItem creates an item in this space.

func (*Space) CreateSpace

func (s *Space) CreateSpace(ctx context.Context, name string) (*Space, error)

CreateSpace creates a subspace.

func (*Space) Delete

func (s *Space) Delete(ctx context.Context, force bool) error

Delete deletes this space (force=true for a non-empty space).

func (*Space) DeleteAttribute

func (s *Space) DeleteAttribute(ctx context.Context, key string) (bool, error)

DeleteAttribute deletes a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Space) GetAttribute

func (s *Space) GetAttribute(ctx context.Context, key string) (string, bool, error)

GetAttribute gets a single metadata attribute (ok=false if unset).

func (*Space) GetBundle

func (s *Space) GetBundle(ctx context.Context, bundleName string) (*Bundle, error)

GetBundle gets a bundle by name.

func (*Space) GetChildSpaces

func (s *Space) GetChildSpaces(ctx context.Context) (*Page[*Space], error)

GetChildSpaces lists the immediate child spaces (Python get_child_spaces).

func (*Space) GetItem

func (s *Space) GetItem(ctx context.Context, itemName, kind string) (*Item, error)

GetItem gets an item by name + kind.

func (*Space) GetItems

func (s *Space) GetItems(ctx context.Context, nameFilter, kindFilter string, pageSize int, cursor string) (*Page[*Item], error)

GetItems lists items in this space.

func (*Space) GetSpace

func (s *Space) GetSpace(ctx context.Context, name string) (*Space, error)

GetSpace gets a subspace by name.

func (*Space) GetSpaces

func (s *Space) GetSpaces(ctx context.Context, recursive bool, pageSize int, cursor string) (*Page[*Space], error)

GetSpaces lists child spaces.

func (*Space) ParentSpace

func (s *Space) ParentSpace(ctx context.Context) (*Space, error)

ParentSpace returns the parent space, or (nil, nil) for a project root.

func (*Space) Project

func (s *Space) Project(ctx context.Context) (*Project, error)

Project returns the owning project.

func (*Space) SetAttribute

func (s *Space) SetAttribute(ctx context.Context, key, value string) (bool, error)

SetAttribute sets a single metadata attribute (updates the in-memory cache on success, matching Python).

func (*Space) SetMetadata

func (s *Space) SetMetadata(ctx context.Context, metadata map[string]string) (*Space, error)

SetMetadata replaces/merges this space’s metadata. Spaces are addressed by raw path (not a kref:// URI), so kref validation is bypassed.

type TenantUsage

TenantUsage reports the current tenant’s node usage and limit.

type TenantUsage struct {
    NodeCount int64
    NodeLimit int64
    TenantID  string
}

type TraversalResult

TraversalResult is the outcome of a transitive edge traversal.

type TraversalResult struct {
    RevisionKrefs []Kref
    Paths         []RevisionPath
    Edges         []*Edge
    TotalCount    int32
    Truncated     bool
    // contains filtered or unexported fields
}

func (*TraversalResult) GetRevisions

func (t *TraversalResult) GetRevisions(ctx context.Context) ([]*Revision, error)

GetRevisions fetches full Revision objects for every discovered revision.

kumihopb

import "github.com/KumihoIO/kumiho-SDKs/go/kumihopb"

Index

Constants

const (
    KumihoService_CreateProject_FullMethodName          = "/kumiho.KumihoService/CreateProject"
    KumihoService_GetProjects_FullMethodName            = "/kumiho.KumihoService/GetProjects"
    KumihoService_UpdateProject_FullMethodName          = "/kumiho.KumihoService/UpdateProject"
    KumihoService_DeleteProject_FullMethodName          = "/kumiho.KumihoService/DeleteProject"
    KumihoService_CreateSpace_FullMethodName            = "/kumiho.KumihoService/CreateSpace"
    KumihoService_GetSpace_FullMethodName               = "/kumiho.KumihoService/GetSpace"
    KumihoService_GetChildSpaces_FullMethodName         = "/kumiho.KumihoService/GetChildSpaces"
    KumihoService_DeleteSpace_FullMethodName            = "/kumiho.KumihoService/DeleteSpace"
    KumihoService_UpdateSpaceMetadata_FullMethodName    = "/kumiho.KumihoService/UpdateSpaceMetadata"
    KumihoService_CreateItem_FullMethodName             = "/kumiho.KumihoService/CreateItem"
    KumihoService_GetItem_FullMethodName                = "/kumiho.KumihoService/GetItem"
    KumihoService_GetItems_FullMethodName               = "/kumiho.KumihoService/GetItems"
    KumihoService_ItemSearch_FullMethodName             = "/kumiho.KumihoService/ItemSearch"
    KumihoService_DeleteItem_FullMethodName             = "/kumiho.KumihoService/DeleteItem"
    KumihoService_UpdateItemMetadata_FullMethodName     = "/kumiho.KumihoService/UpdateItemMetadata"
    KumihoService_Search_FullMethodName                 = "/kumiho.KumihoService/Search"
    KumihoService_ScoreRevisions_FullMethodName         = "/kumiho.KumihoService/ScoreRevisions"
    KumihoService_ResolveKref_FullMethodName            = "/kumiho.KumihoService/ResolveKref"
    KumihoService_ResolveLocation_FullMethodName        = "/kumiho.KumihoService/ResolveLocation"
    KumihoService_CreateRevision_FullMethodName         = "/kumiho.KumihoService/CreateRevision"
    KumihoService_GetRevision_FullMethodName            = "/kumiho.KumihoService/GetRevision"
    KumihoService_GetRevisions_FullMethodName           = "/kumiho.KumihoService/GetRevisions"
    KumihoService_BatchGetRevisions_FullMethodName      = "/kumiho.KumihoService/BatchGetRevisions"
    KumihoService_DeleteRevision_FullMethodName         = "/kumiho.KumihoService/DeleteRevision"
    KumihoService_PeekNextRevision_FullMethodName       = "/kumiho.KumihoService/PeekNextRevision"
    KumihoService_UpdateRevisionMetadata_FullMethodName = "/kumiho.KumihoService/UpdateRevisionMetadata"
    KumihoService_TagRevision_FullMethodName            = "/kumiho.KumihoService/TagRevision"
    KumihoService_UnTagRevision_FullMethodName          = "/kumiho.KumihoService/UnTagRevision"
    KumihoService_HasTag_FullMethodName                 = "/kumiho.KumihoService/HasTag"
    KumihoService_WasTagged_FullMethodName              = "/kumiho.KumihoService/WasTagged"
    KumihoService_SetDefaultArtifact_FullMethodName     = "/kumiho.KumihoService/SetDefaultArtifact"
    KumihoService_CreateArtifact_FullMethodName         = "/kumiho.KumihoService/CreateArtifact"
    KumihoService_GetArtifact_FullMethodName            = "/kumiho.KumihoService/GetArtifact"
    KumihoService_GetArtifacts_FullMethodName           = "/kumiho.KumihoService/GetArtifacts"
    KumihoService_GetArtifactsByLocation_FullMethodName = "/kumiho.KumihoService/GetArtifactsByLocation"
    KumihoService_DeleteArtifact_FullMethodName         = "/kumiho.KumihoService/DeleteArtifact"
    KumihoService_UpdateArtifactMetadata_FullMethodName = "/kumiho.KumihoService/UpdateArtifactMetadata"
    KumihoService_SetAttribute_FullMethodName           = "/kumiho.KumihoService/SetAttribute"
    KumihoService_GetAttribute_FullMethodName           = "/kumiho.KumihoService/GetAttribute"
    KumihoService_DeleteAttribute_FullMethodName        = "/kumiho.KumihoService/DeleteAttribute"
    KumihoService_CreateEdge_FullMethodName             = "/kumiho.KumihoService/CreateEdge"
    KumihoService_GetEdges_FullMethodName               = "/kumiho.KumihoService/GetEdges"
    KumihoService_DeleteEdge_FullMethodName             = "/kumiho.KumihoService/DeleteEdge"
    KumihoService_TraverseEdges_FullMethodName          = "/kumiho.KumihoService/TraverseEdges"
    KumihoService_FindShortestPath_FullMethodName       = "/kumiho.KumihoService/FindShortestPath"
    KumihoService_AnalyzeImpact_FullMethodName          = "/kumiho.KumihoService/AnalyzeImpact"
    KumihoService_CreateBundle_FullMethodName           = "/kumiho.KumihoService/CreateBundle"
    KumihoService_AddBundleMember_FullMethodName        = "/kumiho.KumihoService/AddBundleMember"
    KumihoService_RemoveBundleMember_FullMethodName     = "/kumiho.KumihoService/RemoveBundleMember"
    KumihoService_GetBundleMembers_FullMethodName       = "/kumiho.KumihoService/GetBundleMembers"
    KumihoService_GetBundleHistory_FullMethodName       = "/kumiho.KumihoService/GetBundleHistory"
    KumihoService_GetTenantUsage_FullMethodName         = "/kumiho.KumihoService/GetTenantUsage"
    KumihoService_EventStream_FullMethodName            = "/kumiho.KumihoService/EventStream"
    KumihoService_GetEventCapabilities_FullMethodName   = "/kumiho.KumihoService/GetEventCapabilities"
    KumihoService_SetDeprecated_FullMethodName          = "/kumiho.KumihoService/SetDeprecated"
)

Variables

Enum value maps for EdgeDirection.

var (
    EdgeDirection_name = map[int32]string{
        0:  "OUTGOING",
        1:  "INCOMING",
        2:  "BOTH",
    }
    EdgeDirection_value = map[string]int32{
        "OUTGOING": 0,
        "INCOMING": 1,
        "BOTH":     2,
    }
)


var File_kumiho_proto protoreflect.FileDescriptor

KumihoService_ServiceDesc is the grpc.ServiceDesc for KumihoService service. It’s only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var KumihoService_ServiceDesc = grpc.ServiceDesc{
    ServiceName: "kumiho.KumihoService",
    HandlerType: (*KumihoServiceServer)(nil),
    Methods: []grpc.MethodDesc{
        {
            MethodName: "CreateProject",
            Handler:    _KumihoService_CreateProject_Handler,
        },
        {
            MethodName: "GetProjects",
            Handler:    _KumihoService_GetProjects_Handler,
        },
        {
            MethodName: "UpdateProject",
            Handler:    _KumihoService_UpdateProject_Handler,
        },
        {
            MethodName: "DeleteProject",
            Handler:    _KumihoService_DeleteProject_Handler,
        },
        {
            MethodName: "CreateSpace",
            Handler:    _KumihoService_CreateSpace_Handler,
        },
        {
            MethodName: "GetSpace",
            Handler:    _KumihoService_GetSpace_Handler,
        },
        {
            MethodName: "GetChildSpaces",
            Handler:    _KumihoService_GetChildSpaces_Handler,
        },
        {
            MethodName: "DeleteSpace",
            Handler:    _KumihoService_DeleteSpace_Handler,
        },
        {
            MethodName: "UpdateSpaceMetadata",
            Handler:    _KumihoService_UpdateSpaceMetadata_Handler,
        },
        {
            MethodName: "CreateItem",
            Handler:    _KumihoService_CreateItem_Handler,
        },
        {
            MethodName: "GetItem",
            Handler:    _KumihoService_GetItem_Handler,
        },
        {
            MethodName: "GetItems",
            Handler:    _KumihoService_GetItems_Handler,
        },
        {
            MethodName: "ItemSearch",
            Handler:    _KumihoService_ItemSearch_Handler,
        },
        {
            MethodName: "DeleteItem",
            Handler:    _KumihoService_DeleteItem_Handler,
        },
        {
            MethodName: "UpdateItemMetadata",
            Handler:    _KumihoService_UpdateItemMetadata_Handler,
        },
        {
            MethodName: "Search",
            Handler:    _KumihoService_Search_Handler,
        },
        {
            MethodName: "ScoreRevisions",
            Handler:    _KumihoService_ScoreRevisions_Handler,
        },
        {
            MethodName: "ResolveKref",
            Handler:    _KumihoService_ResolveKref_Handler,
        },
        {
            MethodName: "ResolveLocation",
            Handler:    _KumihoService_ResolveLocation_Handler,
        },
        {
            MethodName: "CreateRevision",
            Handler:    _KumihoService_CreateRevision_Handler,
        },
        {
            MethodName: "GetRevision",
            Handler:    _KumihoService_GetRevision_Handler,
        },
        {
            MethodName: "GetRevisions",
            Handler:    _KumihoService_GetRevisions_Handler,
        },
        {
            MethodName: "BatchGetRevisions",
            Handler:    _KumihoService_BatchGetRevisions_Handler,
        },
        {
            MethodName: "DeleteRevision",
            Handler:    _KumihoService_DeleteRevision_Handler,
        },
        {
            MethodName: "PeekNextRevision",
            Handler:    _KumihoService_PeekNextRevision_Handler,
        },
        {
            MethodName: "UpdateRevisionMetadata",
            Handler:    _KumihoService_UpdateRevisionMetadata_Handler,
        },
        {
            MethodName: "TagRevision",
            Handler:    _KumihoService_TagRevision_Handler,
        },
        {
            MethodName: "UnTagRevision",
            Handler:    _KumihoService_UnTagRevision_Handler,
        },
        {
            MethodName: "HasTag",
            Handler:    _KumihoService_HasTag_Handler,
        },
        {
            MethodName: "WasTagged",
            Handler:    _KumihoService_WasTagged_Handler,
        },
        {
            MethodName: "SetDefaultArtifact",
            Handler:    _KumihoService_SetDefaultArtifact_Handler,
        },
        {
            MethodName: "CreateArtifact",
            Handler:    _KumihoService_CreateArtifact_Handler,
        },
        {
            MethodName: "GetArtifact",
            Handler:    _KumihoService_GetArtifact_Handler,
        },
        {
            MethodName: "GetArtifacts",
            Handler:    _KumihoService_GetArtifacts_Handler,
        },
        {
            MethodName: "GetArtifactsByLocation",
            Handler:    _KumihoService_GetArtifactsByLocation_Handler,
        },
        {
            MethodName: "DeleteArtifact",
            Handler:    _KumihoService_DeleteArtifact_Handler,
        },
        {
            MethodName: "UpdateArtifactMetadata",
            Handler:    _KumihoService_UpdateArtifactMetadata_Handler,
        },
        {
            MethodName: "SetAttribute",
            Handler:    _KumihoService_SetAttribute_Handler,
        },
        {
            MethodName: "GetAttribute",
            Handler:    _KumihoService_GetAttribute_Handler,
        },
        {
            MethodName: "DeleteAttribute",
            Handler:    _KumihoService_DeleteAttribute_Handler,
        },
        {
            MethodName: "CreateEdge",
            Handler:    _KumihoService_CreateEdge_Handler,
        },
        {
            MethodName: "GetEdges",
            Handler:    _KumihoService_GetEdges_Handler,
        },
        {
            MethodName: "DeleteEdge",
            Handler:    _KumihoService_DeleteEdge_Handler,
        },
        {
            MethodName: "TraverseEdges",
            Handler:    _KumihoService_TraverseEdges_Handler,
        },
        {
            MethodName: "FindShortestPath",
            Handler:    _KumihoService_FindShortestPath_Handler,
        },
        {
            MethodName: "AnalyzeImpact",
            Handler:    _KumihoService_AnalyzeImpact_Handler,
        },
        {
            MethodName: "CreateBundle",
            Handler:    _KumihoService_CreateBundle_Handler,
        },
        {
            MethodName: "AddBundleMember",
            Handler:    _KumihoService_AddBundleMember_Handler,
        },
        {
            MethodName: "RemoveBundleMember",
            Handler:    _KumihoService_RemoveBundleMember_Handler,
        },
        {
            MethodName: "GetBundleMembers",
            Handler:    _KumihoService_GetBundleMembers_Handler,
        },
        {
            MethodName: "GetBundleHistory",
            Handler:    _KumihoService_GetBundleHistory_Handler,
        },
        {
            MethodName: "GetTenantUsage",
            Handler:    _KumihoService_GetTenantUsage_Handler,
        },
        {
            MethodName: "GetEventCapabilities",
            Handler:    _KumihoService_GetEventCapabilities_Handler,
        },
        {
            MethodName: "SetDeprecated",
            Handler:    _KumihoService_SetDeprecated_Handler,
        },
    },
    Streams: []grpc.StreamDesc{
        {
            StreamName:    "EventStream",
            Handler:       _KumihoService_EventStream_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "kumiho.proto",
}

func RegisterKumihoServiceServer

func RegisterKumihoServiceServer(s grpc.ServiceRegistrar, srv KumihoServiceServer)

type AddBundleMemberRequest

type AddBundleMemberRequest struct {
    BundleKref     *Kref             `protobuf:"bytes,1,opt,name=bundle_kref,json=bundleKref,proto3" json:"bundle_kref,omitempty"`                                                     // The bundle item kref
    MemberItemKref *Kref             `protobuf:"bytes,2,opt,name=member_item_kref,json=memberItemKref,proto3" json:"member_item_kref,omitempty"`                                       // The item to add as member
    Metadata       map[string]string `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // Optional metadata for revision tracking
    // contains filtered or unexported fields
}

func (*AddBundleMemberRequest) Descriptor

func (*AddBundleMemberRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddBundleMemberRequest.ProtoReflect.Descriptor instead.

func (*AddBundleMemberRequest) GetBundleKref

func (x *AddBundleMemberRequest) GetBundleKref() *Kref

func (*AddBundleMemberRequest) GetMemberItemKref

func (x *AddBundleMemberRequest) GetMemberItemKref() *Kref

func (*AddBundleMemberRequest) GetMetadata

func (x *AddBundleMemberRequest) GetMetadata() map[string]string

func (*AddBundleMemberRequest) ProtoMessage

func (*AddBundleMemberRequest) ProtoMessage()

func (*AddBundleMemberRequest) ProtoReflect

func (x *AddBundleMemberRequest) ProtoReflect() protoreflect.Message

func (*AddBundleMemberRequest) Reset

func (x *AddBundleMemberRequest) Reset()

func (*AddBundleMemberRequest) String

func (x *AddBundleMemberRequest) String() string

type AddBundleMemberResponse

type AddBundleMemberResponse struct {
    Success     bool              `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
    Message     string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    NewRevision *RevisionResponse `protobuf:"bytes,3,opt,name=new_revision,json=newRevision,proto3" json:"new_revision,omitempty"` // The new revision created for this change
    // contains filtered or unexported fields
}

func (*AddBundleMemberResponse) Descriptor

func (*AddBundleMemberResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddBundleMemberResponse.ProtoReflect.Descriptor instead.

func (*AddBundleMemberResponse) GetMessage

func (x *AddBundleMemberResponse) GetMessage() string

func (*AddBundleMemberResponse) GetNewRevision

func (x *AddBundleMemberResponse) GetNewRevision() *RevisionResponse

func (*AddBundleMemberResponse) GetSuccess

func (x *AddBundleMemberResponse) GetSuccess() bool

func (*AddBundleMemberResponse) ProtoMessage

func (*AddBundleMemberResponse) ProtoMessage()

func (*AddBundleMemberResponse) ProtoReflect

func (x *AddBundleMemberResponse) ProtoReflect() protoreflect.Message

func (*AddBundleMemberResponse) Reset

func (x *AddBundleMemberResponse) Reset()

func (*AddBundleMemberResponse) String

func (x *AddBundleMemberResponse) String() string

type ArtifactResponse

type ArtifactResponse struct {
    Kref         *Kref             `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Location     string            `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
    RevisionKref *Kref             `protobuf:"bytes,3,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    ItemKref     *Kref             `protobuf:"bytes,4,opt,name=item_kref,json=itemKref,proto3" json:"item_kref,omitempty"`
    CreatedAt    string            `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
    ModifiedAt   string            `protobuf:"bytes,6,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
    Author       string            `protobuf:"bytes,7,opt,name=author,proto3" json:"author,omitempty"`
    Metadata     map[string]string `protobuf:"bytes,8,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    Deprecated   bool              `protobuf:"varint,9,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
    Username     string            `protobuf:"bytes,10,opt,name=username,proto3" json:"username,omitempty"`
    Name         string            `protobuf:"bytes,11,opt,name=name,proto3" json:"name,omitempty"`
    // contains filtered or unexported fields
}

func (*ArtifactResponse) Descriptor

func (*ArtifactResponse) Descriptor() ([]byte, []int)

Deprecated: Use ArtifactResponse.ProtoReflect.Descriptor instead.

func (*ArtifactResponse) GetAuthor

func (x *ArtifactResponse) GetAuthor() string

func (*ArtifactResponse) GetCreatedAt

func (x *ArtifactResponse) GetCreatedAt() string

func (*ArtifactResponse) GetDeprecated

func (x *ArtifactResponse) GetDeprecated() bool

func (*ArtifactResponse) GetItemKref

func (x *ArtifactResponse) GetItemKref() *Kref

func (*ArtifactResponse) GetKref

func (x *ArtifactResponse) GetKref() *Kref

func (*ArtifactResponse) GetLocation

func (x *ArtifactResponse) GetLocation() string

func (*ArtifactResponse) GetMetadata

func (x *ArtifactResponse) GetMetadata() map[string]string

func (*ArtifactResponse) GetModifiedAt

func (x *ArtifactResponse) GetModifiedAt() string

func (*ArtifactResponse) GetName

func (x *ArtifactResponse) GetName() string

func (*ArtifactResponse) GetRevisionKref

func (x *ArtifactResponse) GetRevisionKref() *Kref

func (*ArtifactResponse) GetUsername

func (x *ArtifactResponse) GetUsername() string

func (*ArtifactResponse) ProtoMessage

func (*ArtifactResponse) ProtoMessage()

func (*ArtifactResponse) ProtoReflect

func (x *ArtifactResponse) ProtoReflect() protoreflect.Message

func (*ArtifactResponse) Reset

func (x *ArtifactResponse) Reset()

func (*ArtifactResponse) String

func (x *ArtifactResponse) String() string

type BatchGetRevisionsRequest

Batch revision fetching - fetch multiple revisions in a single call

type BatchGetRevisionsRequest struct {

    // List of revision krefs to fetch (e.g., kref://project/space/item.kind?r=1)
    RevisionKrefs []*Kref `protobuf:"bytes,1,rep,name=revision_krefs,json=revisionKrefs,proto3" json:"revision_krefs,omitempty"`
    // Or fetch by item krefs with optional tag (defaults to "latest")
    ItemKrefs []*Kref `protobuf:"bytes,2,rep,name=item_krefs,json=itemKrefs,proto3" json:"item_krefs,omitempty"`
    // Tag to resolve when using item_krefs (default: "latest")
    Tag string `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
    // If true, continue on not-found errors and return partial results
    AllowPartial bool `protobuf:"varint,4,opt,name=allow_partial,json=allowPartial,proto3" json:"allow_partial,omitempty"`
    // contains filtered or unexported fields
}

func (*BatchGetRevisionsRequest) Descriptor

func (*BatchGetRevisionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use BatchGetRevisionsRequest.ProtoReflect.Descriptor instead.

func (*BatchGetRevisionsRequest) GetAllowPartial

func (x *BatchGetRevisionsRequest) GetAllowPartial() bool

func (*BatchGetRevisionsRequest) GetItemKrefs

func (x *BatchGetRevisionsRequest) GetItemKrefs() []*Kref

func (*BatchGetRevisionsRequest) GetRevisionKrefs

func (x *BatchGetRevisionsRequest) GetRevisionKrefs() []*Kref

func (*BatchGetRevisionsRequest) GetTag

func (x *BatchGetRevisionsRequest) GetTag() string

func (*BatchGetRevisionsRequest) ProtoMessage

func (*BatchGetRevisionsRequest) ProtoMessage()

func (*BatchGetRevisionsRequest) ProtoReflect

func (x *BatchGetRevisionsRequest) ProtoReflect() protoreflect.Message

func (*BatchGetRevisionsRequest) Reset

func (x *BatchGetRevisionsRequest) Reset()

func (*BatchGetRevisionsRequest) String

func (x *BatchGetRevisionsRequest) String() string

type BatchGetRevisionsResponse

type BatchGetRevisionsResponse struct {

    // Successfully fetched revisions (in same order as request when possible)
    Revisions []*RevisionResponse `protobuf:"bytes,1,rep,name=revisions,proto3" json:"revisions,omitempty"`
    // Krefs that were not found (only populated if allow_partial=true)
    NotFound []string `protobuf:"bytes,2,rep,name=not_found,json=notFound,proto3" json:"not_found,omitempty"`
    // Total requested vs returned counts
    RequestedCount int32 `protobuf:"varint,3,opt,name=requested_count,json=requestedCount,proto3" json:"requested_count,omitempty"`
    FoundCount     int32 `protobuf:"varint,4,opt,name=found_count,json=foundCount,proto3" json:"found_count,omitempty"`
    // contains filtered or unexported fields
}

func (*BatchGetRevisionsResponse) Descriptor

func (*BatchGetRevisionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use BatchGetRevisionsResponse.ProtoReflect.Descriptor instead.

func (*BatchGetRevisionsResponse) GetFoundCount

func (x *BatchGetRevisionsResponse) GetFoundCount() int32

func (*BatchGetRevisionsResponse) GetNotFound

func (x *BatchGetRevisionsResponse) GetNotFound() []string

func (*BatchGetRevisionsResponse) GetRequestedCount

func (x *BatchGetRevisionsResponse) GetRequestedCount() int32

func (*BatchGetRevisionsResponse) GetRevisions

func (x *BatchGetRevisionsResponse) GetRevisions() []*RevisionResponse

func (*BatchGetRevisionsResponse) ProtoMessage

func (*BatchGetRevisionsResponse) ProtoMessage()

func (*BatchGetRevisionsResponse) ProtoReflect

func (x *BatchGetRevisionsResponse) ProtoReflect() protoreflect.Message

func (*BatchGetRevisionsResponse) Reset

func (x *BatchGetRevisionsResponse) Reset()

func (*BatchGetRevisionsResponse) String

func (x *BatchGetRevisionsResponse) String() string

type BundleMember

type BundleMember struct {
    ItemKref        *Kref  `protobuf:"bytes,1,opt,name=item_kref,json=itemKref,proto3" json:"item_kref,omitempty"`                         // The item that is a member
    AddedAt         string `protobuf:"bytes,2,opt,name=added_at,json=addedAt,proto3" json:"added_at,omitempty"`                            // When the item was added to bundle
    AddedBy         string `protobuf:"bytes,3,opt,name=added_by,json=addedBy,proto3" json:"added_by,omitempty"`                            // Who added the item (author uuid)
    AddedByUsername string `protobuf:"bytes,4,opt,name=added_by_username,json=addedByUsername,proto3" json:"added_by_username,omitempty"`  // Username who added the item
    AddedInRevision int32  `protobuf:"varint,5,opt,name=added_in_revision,json=addedInRevision,proto3" json:"added_in_revision,omitempty"` // Which bundle revision this was added
    // contains filtered or unexported fields
}

func (*BundleMember) Descriptor

func (*BundleMember) Descriptor() ([]byte, []int)

Deprecated: Use BundleMember.ProtoReflect.Descriptor instead.

func (*BundleMember) GetAddedAt

func (x *BundleMember) GetAddedAt() string

func (*BundleMember) GetAddedBy

func (x *BundleMember) GetAddedBy() string

func (*BundleMember) GetAddedByUsername

func (x *BundleMember) GetAddedByUsername() string

func (*BundleMember) GetAddedInRevision

func (x *BundleMember) GetAddedInRevision() int32

func (*BundleMember) GetItemKref

func (x *BundleMember) GetItemKref() *Kref

func (*BundleMember) ProtoMessage

func (*BundleMember) ProtoMessage()

func (*BundleMember) ProtoReflect

func (x *BundleMember) ProtoReflect() protoreflect.Message

func (*BundleMember) Reset

func (x *BundleMember) Reset()

func (*BundleMember) String

func (x *BundleMember) String() string

type BundleRevisionHistory

type BundleRevisionHistory struct {
    RevisionNumber int32             `protobuf:"varint,1,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
    Action         string            `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`                                         // "ADDED" or "REMOVED"
    MemberItemKref *Kref             `protobuf:"bytes,3,opt,name=member_item_kref,json=memberItemKref,proto3" json:"member_item_kref,omitempty"` // The item that was added/removed
    Author         string            `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
    Username       string            `protobuf:"bytes,5,opt,name=username,proto3" json:"username,omitempty"`
    CreatedAt      string            `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
    Metadata       map[string]string `protobuf:"bytes,7,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // Immutable audit metadata
    // contains filtered or unexported fields
}

func (*BundleRevisionHistory) Descriptor

func (*BundleRevisionHistory) Descriptor() ([]byte, []int)

Deprecated: Use BundleRevisionHistory.ProtoReflect.Descriptor instead.

func (*BundleRevisionHistory) GetAction

func (x *BundleRevisionHistory) GetAction() string

func (*BundleRevisionHistory) GetAuthor

func (x *BundleRevisionHistory) GetAuthor() string

func (*BundleRevisionHistory) GetCreatedAt

func (x *BundleRevisionHistory) GetCreatedAt() string

func (*BundleRevisionHistory) GetMemberItemKref

func (x *BundleRevisionHistory) GetMemberItemKref() *Kref

func (*BundleRevisionHistory) GetMetadata

func (x *BundleRevisionHistory) GetMetadata() map[string]string

func (*BundleRevisionHistory) GetRevisionNumber

func (x *BundleRevisionHistory) GetRevisionNumber() int32

func (*BundleRevisionHistory) GetUsername

func (x *BundleRevisionHistory) GetUsername() string

func (*BundleRevisionHistory) ProtoMessage

func (*BundleRevisionHistory) ProtoMessage()

func (*BundleRevisionHistory) ProtoReflect

func (x *BundleRevisionHistory) ProtoReflect() protoreflect.Message

func (*BundleRevisionHistory) Reset

func (x *BundleRevisionHistory) Reset()

func (*BundleRevisionHistory) String

func (x *BundleRevisionHistory) String() string

type CreateArtifactRequest

type CreateArtifactRequest struct {
    RevisionKref *Kref             `protobuf:"bytes,1,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    Name         string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
    Location     string            `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
    ExistsError  bool              `protobuf:"varint,4,opt,name=exists_error,json=existsError,proto3" json:"exists_error,omitempty"`
    Metadata     map[string]string `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    // contains filtered or unexported fields
}

func (*CreateArtifactRequest) Descriptor

func (*CreateArtifactRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateArtifactRequest.ProtoReflect.Descriptor instead.

func (*CreateArtifactRequest) GetExistsError

func (x *CreateArtifactRequest) GetExistsError() bool

func (*CreateArtifactRequest) GetLocation

func (x *CreateArtifactRequest) GetLocation() string

func (*CreateArtifactRequest) GetMetadata

func (x *CreateArtifactRequest) GetMetadata() map[string]string

func (*CreateArtifactRequest) GetName

func (x *CreateArtifactRequest) GetName() string

func (*CreateArtifactRequest) GetRevisionKref

func (x *CreateArtifactRequest) GetRevisionKref() *Kref

func (*CreateArtifactRequest) ProtoMessage

func (*CreateArtifactRequest) ProtoMessage()

func (*CreateArtifactRequest) ProtoReflect

func (x *CreateArtifactRequest) ProtoReflect() protoreflect.Message

func (*CreateArtifactRequest) Reset

func (x *CreateArtifactRequest) Reset()

func (*CreateArtifactRequest) String

func (x *CreateArtifactRequest) String() string

type CreateBundleRequest

type CreateBundleRequest struct {
    ParentPath string            `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`                                                     // Space path where bundle will be created
    BundleName string            `protobuf:"bytes,2,opt,name=bundle_name,json=bundleName,proto3" json:"bundle_name,omitempty"`                                                     // Name of the bundle
    Metadata   map[string]string `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // Initial metadata
    // contains filtered or unexported fields
}

func (*CreateBundleRequest) Descriptor

func (*CreateBundleRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateBundleRequest.ProtoReflect.Descriptor instead.

func (*CreateBundleRequest) GetBundleName

func (x *CreateBundleRequest) GetBundleName() string

func (*CreateBundleRequest) GetMetadata

func (x *CreateBundleRequest) GetMetadata() map[string]string

func (*CreateBundleRequest) GetParentPath

func (x *CreateBundleRequest) GetParentPath() string

func (*CreateBundleRequest) ProtoMessage

func (*CreateBundleRequest) ProtoMessage()

func (*CreateBundleRequest) ProtoReflect

func (x *CreateBundleRequest) ProtoReflect() protoreflect.Message

func (*CreateBundleRequest) Reset

func (x *CreateBundleRequest) Reset()

func (*CreateBundleRequest) String

func (x *CreateBundleRequest) String() string

type CreateEdgeRequest

type CreateEdgeRequest struct {
    SourceRevisionKref *Kref             `protobuf:"bytes,1,opt,name=source_revision_kref,json=sourceRevisionKref,proto3" json:"source_revision_kref,omitempty"`
    TargetRevisionKref *Kref             `protobuf:"bytes,2,opt,name=target_revision_kref,json=targetRevisionKref,proto3" json:"target_revision_kref,omitempty"`
    EdgeType           string            `protobuf:"bytes,3,opt,name=edge_type,json=edgeType,proto3" json:"edge_type,omitempty"`
    Metadata           map[string]string `protobuf:"bytes,4,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    ExistsError        bool              `protobuf:"varint,5,opt,name=exists_error,json=existsError,proto3" json:"exists_error,omitempty"`
    // contains filtered or unexported fields
}

func (*CreateEdgeRequest) Descriptor

func (*CreateEdgeRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateEdgeRequest.ProtoReflect.Descriptor instead.

func (*CreateEdgeRequest) GetEdgeType

func (x *CreateEdgeRequest) GetEdgeType() string

func (*CreateEdgeRequest) GetExistsError

func (x *CreateEdgeRequest) GetExistsError() bool

func (*CreateEdgeRequest) GetMetadata

func (x *CreateEdgeRequest) GetMetadata() map[string]string

func (*CreateEdgeRequest) GetSourceRevisionKref

func (x *CreateEdgeRequest) GetSourceRevisionKref() *Kref

func (*CreateEdgeRequest) GetTargetRevisionKref

func (x *CreateEdgeRequest) GetTargetRevisionKref() *Kref

func (*CreateEdgeRequest) ProtoMessage

func (*CreateEdgeRequest) ProtoMessage()

func (*CreateEdgeRequest) ProtoReflect

func (x *CreateEdgeRequest) ProtoReflect() protoreflect.Message

func (*CreateEdgeRequest) Reset

func (x *CreateEdgeRequest) Reset()

func (*CreateEdgeRequest) String

func (x *CreateEdgeRequest) String() string

type CreateItemRequest

type CreateItemRequest struct {
    ParentPath  string `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`
    ItemName    string `protobuf:"bytes,2,opt,name=item_name,json=itemName,proto3" json:"item_name,omitempty"`
    Kind        string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
    ExistsError bool   `protobuf:"varint,4,opt,name=exists_error,json=existsError,proto3" json:"exists_error,omitempty"`
    // contains filtered or unexported fields
}

func (*CreateItemRequest) Descriptor

func (*CreateItemRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateItemRequest.ProtoReflect.Descriptor instead.

func (*CreateItemRequest) GetExistsError

func (x *CreateItemRequest) GetExistsError() bool

func (*CreateItemRequest) GetItemName

func (x *CreateItemRequest) GetItemName() string

func (*CreateItemRequest) GetKind

func (x *CreateItemRequest) GetKind() string

func (*CreateItemRequest) GetParentPath

func (x *CreateItemRequest) GetParentPath() string

func (*CreateItemRequest) ProtoMessage

func (*CreateItemRequest) ProtoMessage()

func (*CreateItemRequest) ProtoReflect

func (x *CreateItemRequest) ProtoReflect() protoreflect.Message

func (*CreateItemRequest) Reset

func (x *CreateItemRequest) Reset()

func (*CreateItemRequest) String

func (x *CreateItemRequest) String() string

type CreateProjectRequest

type CreateProjectRequest struct {
    Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
    // contains filtered or unexported fields
}

func (*CreateProjectRequest) Descriptor

func (*CreateProjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateProjectRequest.ProtoReflect.Descriptor instead.

func (*CreateProjectRequest) GetDescription

func (x *CreateProjectRequest) GetDescription() string

func (*CreateProjectRequest) GetName

func (x *CreateProjectRequest) GetName() string

func (*CreateProjectRequest) ProtoMessage

func (*CreateProjectRequest) ProtoMessage()

func (*CreateProjectRequest) ProtoReflect

func (x *CreateProjectRequest) ProtoReflect() protoreflect.Message

func (*CreateProjectRequest) Reset

func (x *CreateProjectRequest) Reset()

func (*CreateProjectRequest) String

func (x *CreateProjectRequest) String() string

type CreateRevisionRequest

type CreateRevisionRequest struct {
    ItemKref      *Kref             `protobuf:"bytes,1,opt,name=item_kref,json=itemKref,proto3" json:"item_kref,omitempty"`
    Metadata      map[string]string `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    Number        int32             `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"` // 0 for next available, >0 for specific revision
    ExistsError   bool              `protobuf:"varint,4,opt,name=exists_error,json=existsError,proto3" json:"exists_error,omitempty"`
    EmbeddingText string            `protobuf:"bytes,5,opt,name=embedding_text,json=embeddingText,proto3" json:"embedding_text,omitempty"` // Optional: override auto-generated embedding text
    // contains filtered or unexported fields
}

func (*CreateRevisionRequest) Descriptor

func (*CreateRevisionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRevisionRequest.ProtoReflect.Descriptor instead.

func (*CreateRevisionRequest) GetEmbeddingText

func (x *CreateRevisionRequest) GetEmbeddingText() string

func (*CreateRevisionRequest) GetExistsError

func (x *CreateRevisionRequest) GetExistsError() bool

func (*CreateRevisionRequest) GetItemKref

func (x *CreateRevisionRequest) GetItemKref() *Kref

func (*CreateRevisionRequest) GetMetadata

func (x *CreateRevisionRequest) GetMetadata() map[string]string

func (*CreateRevisionRequest) GetNumber

func (x *CreateRevisionRequest) GetNumber() int32

func (*CreateRevisionRequest) ProtoMessage

func (*CreateRevisionRequest) ProtoMessage()

func (*CreateRevisionRequest) ProtoReflect

func (x *CreateRevisionRequest) ProtoReflect() protoreflect.Message

func (*CreateRevisionRequest) Reset

func (x *CreateRevisionRequest) Reset()

func (*CreateRevisionRequest) String

func (x *CreateRevisionRequest) String() string

type CreateSpaceRequest

type CreateSpaceRequest struct {
    ParentPath  string `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`
    SpaceName   string `protobuf:"bytes,2,opt,name=space_name,json=spaceName,proto3" json:"space_name,omitempty"`
    ExistsError bool   `protobuf:"varint,3,opt,name=exists_error,json=existsError,proto3" json:"exists_error,omitempty"`
    // contains filtered or unexported fields
}

func (*CreateSpaceRequest) Descriptor

func (*CreateSpaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateSpaceRequest.ProtoReflect.Descriptor instead.

func (*CreateSpaceRequest) GetExistsError

func (x *CreateSpaceRequest) GetExistsError() bool

func (*CreateSpaceRequest) GetParentPath

func (x *CreateSpaceRequest) GetParentPath() string

func (*CreateSpaceRequest) GetSpaceName

func (x *CreateSpaceRequest) GetSpaceName() string

func (*CreateSpaceRequest) ProtoMessage

func (*CreateSpaceRequest) ProtoMessage()

func (*CreateSpaceRequest) ProtoReflect

func (x *CreateSpaceRequest) ProtoReflect() protoreflect.Message

func (*CreateSpaceRequest) Reset

func (x *CreateSpaceRequest) Reset()

func (*CreateSpaceRequest) String

func (x *CreateSpaceRequest) String() string

type DeleteArtifactRequest

type DeleteArtifactRequest struct {
    Kref  *Kref `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Force bool  `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
    // contains filtered or unexported fields
}

func (*DeleteArtifactRequest) Descriptor

func (*DeleteArtifactRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteArtifactRequest.ProtoReflect.Descriptor instead.

func (*DeleteArtifactRequest) GetForce

func (x *DeleteArtifactRequest) GetForce() bool

func (*DeleteArtifactRequest) GetKref

func (x *DeleteArtifactRequest) GetKref() *Kref

func (*DeleteArtifactRequest) ProtoMessage

func (*DeleteArtifactRequest) ProtoMessage()

func (*DeleteArtifactRequest) ProtoReflect

func (x *DeleteArtifactRequest) ProtoReflect() protoreflect.Message

func (*DeleteArtifactRequest) Reset

func (x *DeleteArtifactRequest) Reset()

func (*DeleteArtifactRequest) String

func (x *DeleteArtifactRequest) String() string

type DeleteAttributeRequest

Delete a single metadata attribute

type DeleteAttributeRequest struct {
    Kref *Kref  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    // contains filtered or unexported fields
}

func (*DeleteAttributeRequest) Descriptor

func (*DeleteAttributeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAttributeRequest.ProtoReflect.Descriptor instead.

func (*DeleteAttributeRequest) GetKey

func (x *DeleteAttributeRequest) GetKey() string

func (*DeleteAttributeRequest) GetKref

func (x *DeleteAttributeRequest) GetKref() *Kref

func (*DeleteAttributeRequest) ProtoMessage

func (*DeleteAttributeRequest) ProtoMessage()

func (*DeleteAttributeRequest) ProtoReflect

func (x *DeleteAttributeRequest) ProtoReflect() protoreflect.Message

func (*DeleteAttributeRequest) Reset

func (x *DeleteAttributeRequest) Reset()

func (*DeleteAttributeRequest) String

func (x *DeleteAttributeRequest) String() string

type DeleteEdgeRequest

type DeleteEdgeRequest struct {
    SourceKref *Kref  `protobuf:"bytes,1,opt,name=source_kref,json=sourceKref,proto3" json:"source_kref,omitempty"`
    TargetKref *Kref  `protobuf:"bytes,2,opt,name=target_kref,json=targetKref,proto3" json:"target_kref,omitempty"`
    EdgeType   string `protobuf:"bytes,3,opt,name=edge_type,json=edgeType,proto3" json:"edge_type,omitempty"`
    // contains filtered or unexported fields
}

func (*DeleteEdgeRequest) Descriptor

func (*DeleteEdgeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteEdgeRequest.ProtoReflect.Descriptor instead.

func (*DeleteEdgeRequest) GetEdgeType

func (x *DeleteEdgeRequest) GetEdgeType() string

func (*DeleteEdgeRequest) GetSourceKref

func (x *DeleteEdgeRequest) GetSourceKref() *Kref

func (*DeleteEdgeRequest) GetTargetKref

func (x *DeleteEdgeRequest) GetTargetKref() *Kref

func (*DeleteEdgeRequest) ProtoMessage

func (*DeleteEdgeRequest) ProtoMessage()

func (*DeleteEdgeRequest) ProtoReflect

func (x *DeleteEdgeRequest) ProtoReflect() protoreflect.Message

func (*DeleteEdgeRequest) Reset

func (x *DeleteEdgeRequest) Reset()

func (*DeleteEdgeRequest) String

func (x *DeleteEdgeRequest) String() string

type DeleteItemRequest

type DeleteItemRequest struct {
    Kref  *Kref `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Force bool  `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
    // contains filtered or unexported fields
}

func (*DeleteItemRequest) Descriptor

func (*DeleteItemRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteItemRequest.ProtoReflect.Descriptor instead.

func (*DeleteItemRequest) GetForce

func (x *DeleteItemRequest) GetForce() bool

func (*DeleteItemRequest) GetKref

func (x *DeleteItemRequest) GetKref() *Kref

func (*DeleteItemRequest) ProtoMessage

func (*DeleteItemRequest) ProtoMessage()

func (*DeleteItemRequest) ProtoReflect

func (x *DeleteItemRequest) ProtoReflect() protoreflect.Message

func (*DeleteItemRequest) Reset

func (x *DeleteItemRequest) Reset()

func (*DeleteItemRequest) String

func (x *DeleteItemRequest) String() string

type DeleteProjectRequest

type DeleteProjectRequest struct {
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // force=true lets owner/admin hard-delete; otherwise deprecates.
    Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
    // contains filtered or unexported fields
}

func (*DeleteProjectRequest) Descriptor

func (*DeleteProjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteProjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteProjectRequest) GetForce

func (x *DeleteProjectRequest) GetForce() bool

func (*DeleteProjectRequest) GetProjectId

func (x *DeleteProjectRequest) GetProjectId() string

func (*DeleteProjectRequest) ProtoMessage

func (*DeleteProjectRequest) ProtoMessage()

func (*DeleteProjectRequest) ProtoReflect

func (x *DeleteProjectRequest) ProtoReflect() protoreflect.Message

func (*DeleteProjectRequest) Reset

func (x *DeleteProjectRequest) Reset()

func (*DeleteProjectRequest) String

func (x *DeleteProjectRequest) String() string

type DeleteRevisionRequest

type DeleteRevisionRequest struct {
    Kref  *Kref `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Force bool  `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
    // contains filtered or unexported fields
}

func (*DeleteRevisionRequest) Descriptor

func (*DeleteRevisionRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRevisionRequest.ProtoReflect.Descriptor instead.

func (*DeleteRevisionRequest) GetForce

func (x *DeleteRevisionRequest) GetForce() bool

func (*DeleteRevisionRequest) GetKref

func (x *DeleteRevisionRequest) GetKref() *Kref

func (*DeleteRevisionRequest) ProtoMessage

func (*DeleteRevisionRequest) ProtoMessage()

func (*DeleteRevisionRequest) ProtoReflect

func (x *DeleteRevisionRequest) ProtoReflect() protoreflect.Message

func (*DeleteRevisionRequest) Reset

func (x *DeleteRevisionRequest) Reset()

func (*DeleteRevisionRequest) String

func (x *DeleteRevisionRequest) String() string

type DeleteSpaceRequest

type DeleteSpaceRequest struct {
    Path  string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
    Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` // If true, allows admin to delete a space with items.
    // contains filtered or unexported fields
}

func (*DeleteSpaceRequest) Descriptor

func (*DeleteSpaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSpaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteSpaceRequest) GetForce

func (x *DeleteSpaceRequest) GetForce() bool

func (*DeleteSpaceRequest) GetPath

func (x *DeleteSpaceRequest) GetPath() string

func (*DeleteSpaceRequest) ProtoMessage

func (*DeleteSpaceRequest) ProtoMessage()

func (*DeleteSpaceRequest) ProtoReflect

func (x *DeleteSpaceRequest) ProtoReflect() protoreflect.Message

func (*DeleteSpaceRequest) Reset

func (x *DeleteSpaceRequest) Reset()

func (*DeleteSpaceRequest) String

func (x *DeleteSpaceRequest) String() string

type Edge

An Edge represents a directed, typed relationship between two revisions.

type Edge struct {
    SourceKref *Kref             `protobuf:"bytes,1,opt,name=source_kref,json=sourceKref,proto3" json:"source_kref,omitempty"`
    TargetKref *Kref             `protobuf:"bytes,2,opt,name=target_kref,json=targetKref,proto3" json:"target_kref,omitempty"`
    EdgeType   string            `protobuf:"bytes,3,opt,name=edge_type,json=edgeType,proto3" json:"edge_type,omitempty"`
    Metadata   map[string]string `protobuf:"bytes,4,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    CreatedAt  string            `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
    Author     string            `protobuf:"bytes,6,opt,name=author,proto3" json:"author,omitempty"`
    Username   string            `protobuf:"bytes,7,opt,name=username,proto3" json:"username,omitempty"`
    // contains filtered or unexported fields
}

func (*Edge) Descriptor

func (*Edge) Descriptor() ([]byte, []int)

Deprecated: Use Edge.ProtoReflect.Descriptor instead.

func (*Edge) GetAuthor

func (x *Edge) GetAuthor() string

func (*Edge) GetCreatedAt

func (x *Edge) GetCreatedAt() string

func (*Edge) GetEdgeType

func (x *Edge) GetEdgeType() string

func (*Edge) GetMetadata

func (x *Edge) GetMetadata() map[string]string

func (*Edge) GetSourceKref

func (x *Edge) GetSourceKref() *Kref

func (*Edge) GetTargetKref

func (x *Edge) GetTargetKref() *Kref

func (*Edge) GetUsername

func (x *Edge) GetUsername() string

func (*Edge) ProtoMessage

func (*Edge) ProtoMessage()

func (*Edge) ProtoReflect

func (x *Edge) ProtoReflect() protoreflect.Message

func (*Edge) Reset

func (x *Edge) Reset()

func (*Edge) String

func (x *Edge) String() string

type EdgeDirection

type EdgeDirection int32


const (
    EdgeDirection_OUTGOING EdgeDirection = 0
    EdgeDirection_INCOMING EdgeDirection = 1
    EdgeDirection_BOTH     EdgeDirection = 2
)

func (EdgeDirection) Descriptor

func (EdgeDirection) Descriptor() protoreflect.EnumDescriptor

func (EdgeDirection) Enum

func (x EdgeDirection) Enum() *EdgeDirection

func (EdgeDirection) EnumDescriptor

func (EdgeDirection) EnumDescriptor() ([]byte, []int)

Deprecated: Use EdgeDirection.Descriptor instead.

func (EdgeDirection) Number

func (x EdgeDirection) Number() protoreflect.EnumNumber

func (EdgeDirection) String

func (x EdgeDirection) String() string

func (EdgeDirection) Type

func (EdgeDirection) Type() protoreflect.EnumType

type Event

type Event struct {

    // A routing key describing the event, e.g., "item.model.created"
    RoutingKey string `protobuf:"bytes,1,opt,name=routing_key,json=routingKey,proto3" json:"routing_key,omitempty"`
    // The Kref of the object that was affected.
    Kref *Kref `protobuf:"bytes,2,opt,name=kref,proto3" json:"kref,omitempty"`
    // Timestamp of the event.
    Timestamp string `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    // The user who triggered the event.
    Author string `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
    // Tenant scope for isolation in shared deployments.
    TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
    // Additional details about the event, e.g., the tag that was added.
    Details  map[string]string `protobuf:"bytes,6,rep,name=details,proto3" json:"details,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    Username string            `protobuf:"bytes,7,opt,name=username,proto3" json:"username,omitempty"`
    // Cursor for resumable streaming (Creator tier and above).
    // Save this cursor and pass it in EventStreamRequest.cursor to resume
    // from this point after reconnection.
    Cursor string `protobuf:"bytes,8,opt,name=cursor,proto3" json:"cursor,omitempty"`
    // contains filtered or unexported fields
}

func (*Event) Descriptor

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAuthor

func (x *Event) GetAuthor() string

func (*Event) GetCursor

func (x *Event) GetCursor() string

func (*Event) GetDetails

func (x *Event) GetDetails() map[string]string

func (*Event) GetKref

func (x *Event) GetKref() *Kref

func (*Event) GetRoutingKey

func (x *Event) GetRoutingKey() string

func (*Event) GetTenantId

func (x *Event) GetTenantId() string

func (*Event) GetTimestamp

func (x *Event) GetTimestamp() string

func (*Event) GetUsername

func (x *Event) GetUsername() string

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type EventCapabilities

Event streaming capabilities for the current tenant tier

type EventCapabilities struct {

    // Whether this tier supports replaying past events
    SupportsReplay bool `protobuf:"varint,1,opt,name=supports_replay,json=supportsReplay,proto3" json:"supports_replay,omitempty"`
    // Whether cursor-based resume is supported
    SupportsCursor bool `protobuf:"varint,2,opt,name=supports_cursor,json=supportsCursor,proto3" json:"supports_cursor,omitempty"`
    // Whether consumer groups are supported (Enterprise only)
    SupportsConsumerGroups bool `protobuf:"varint,3,opt,name=supports_consumer_groups,json=supportsConsumerGroups,proto3" json:"supports_consumer_groups,omitempty"`
    // Maximum event retention in hours (0 = none, -1 = unlimited)
    MaxRetentionHours int64 `protobuf:"varint,4,opt,name=max_retention_hours,json=maxRetentionHours,proto3" json:"max_retention_hours,omitempty"`
    // Maximum events in buffer (0 = none, -1 = unlimited)
    MaxBufferSize int64 `protobuf:"varint,5,opt,name=max_buffer_size,json=maxBufferSize,proto3" json:"max_buffer_size,omitempty"`
    // Tier identifier (free, creator, studio, enterprise)
    Tier string `protobuf:"bytes,6,opt,name=tier,proto3" json:"tier,omitempty"`
    // contains filtered or unexported fields
}

func (*EventCapabilities) Descriptor

func (*EventCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use EventCapabilities.ProtoReflect.Descriptor instead.

func (*EventCapabilities) GetMaxBufferSize

func (x *EventCapabilities) GetMaxBufferSize() int64

func (*EventCapabilities) GetMaxRetentionHours

func (x *EventCapabilities) GetMaxRetentionHours() int64

func (*EventCapabilities) GetSupportsConsumerGroups

func (x *EventCapabilities) GetSupportsConsumerGroups() bool

func (*EventCapabilities) GetSupportsCursor

func (x *EventCapabilities) GetSupportsCursor() bool

func (*EventCapabilities) GetSupportsReplay

func (x *EventCapabilities) GetSupportsReplay() bool

func (*EventCapabilities) GetTier

func (x *EventCapabilities) GetTier() string

func (*EventCapabilities) ProtoMessage

func (*EventCapabilities) ProtoMessage()

func (*EventCapabilities) ProtoReflect

func (x *EventCapabilities) ProtoReflect() protoreflect.Message

func (*EventCapabilities) Reset

func (x *EventCapabilities) Reset()

func (*EventCapabilities) String

func (x *EventCapabilities) String() string

type EventStreamRequest

type EventStreamRequest struct {

    // A routing key filter, e.g., "item.model.created" or "revision.tagged.*"
    // An empty string subscribes to all events.
    RoutingKeyFilter string `protobuf:"bytes,1,opt,name=routing_key_filter,json=routingKeyFilter,proto3" json:"routing_key_filter,omitempty"`
    // A kref filter for filtering by object URI patterns, e.g., "kref://projectA/**/*.model"
    // Supports wildcards. An empty string means no kref filtering.
    KrefFilter string `protobuf:"bytes,2,opt,name=kref_filter,json=krefFilter,proto3" json:"kref_filter,omitempty"`
    // Cursor-based resume (Creator tier and above)
    // Resume from a previous event cursor to avoid missing events during disconnection.
    Cursor *string `protobuf:"bytes,3,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
    // Consumer group for load-balanced delivery (Enterprise tier only)
    // Multiple consumers in the same group will each receive different events.
    ConsumerGroup *string `protobuf:"bytes,4,opt,name=consumer_group,json=consumerGroup,proto3,oneof" json:"consumer_group,omitempty"`
    // Start position options (Creator tier and above)
    //
    // Types that are valid to be assigned to StartPosition:
    //
    //	*EventStreamRequest_FromLatest
    //	*EventStreamRequest_FromCursor
    //	*EventStreamRequest_FromTimestamp
    //	*EventStreamRequest_FromBeginning
    StartPosition isEventStreamRequest_StartPosition `protobuf_oneof:"start_position"`
    // contains filtered or unexported fields
}

func (*EventStreamRequest) Descriptor

func (*EventStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use EventStreamRequest.ProtoReflect.Descriptor instead.

func (*EventStreamRequest) GetConsumerGroup

func (x *EventStreamRequest) GetConsumerGroup() string

func (*EventStreamRequest) GetCursor

func (x *EventStreamRequest) GetCursor() string

func (*EventStreamRequest) GetFromBeginning

func (x *EventStreamRequest) GetFromBeginning() bool

func (*EventStreamRequest) GetFromCursor

func (x *EventStreamRequest) GetFromCursor() string

func (*EventStreamRequest) GetFromLatest

func (x *EventStreamRequest) GetFromLatest() bool

func (*EventStreamRequest) GetFromTimestamp

func (x *EventStreamRequest) GetFromTimestamp() string

func (*EventStreamRequest) GetKrefFilter

func (x *EventStreamRequest) GetKrefFilter() string

func (*EventStreamRequest) GetRoutingKeyFilter

func (x *EventStreamRequest) GetRoutingKeyFilter() string

func (*EventStreamRequest) GetStartPosition

func (x *EventStreamRequest) GetStartPosition() isEventStreamRequest_StartPosition

func (*EventStreamRequest) ProtoMessage

func (*EventStreamRequest) ProtoMessage()

func (*EventStreamRequest) ProtoReflect

func (x *EventStreamRequest) ProtoReflect() protoreflect.Message

func (*EventStreamRequest) Reset

func (x *EventStreamRequest) Reset()

func (*EventStreamRequest) String

func (x *EventStreamRequest) String() string

type EventStreamRequest_FromBeginning

type EventStreamRequest_FromBeginning struct {
    FromBeginning bool `protobuf:"varint,8,opt,name=from_beginning,json=fromBeginning,proto3,oneof"` // All available history (subject to retention)
}

type EventStreamRequest_FromCursor

type EventStreamRequest_FromCursor struct {
    FromCursor string `protobuf:"bytes,6,opt,name=from_cursor,json=fromCursor,proto3,oneof"` // Resume from cursor (same as cursor field, for explicit choice)
}

type EventStreamRequest_FromLatest

type EventStreamRequest_FromLatest struct {
    FromLatest bool `protobuf:"varint,5,opt,name=from_latest,json=fromLatest,proto3,oneof"` // Default: only new events from now
}

type EventStreamRequest_FromTimestamp

type EventStreamRequest_FromTimestamp struct {
    FromTimestamp string `protobuf:"bytes,7,opt,name=from_timestamp,json=fromTimestamp,proto3,oneof"` // Replay from ISO timestamp
}

type GetArtifactRequest

type GetArtifactRequest struct {
    RevisionKref *Kref  `protobuf:"bytes,1,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
    // contains filtered or unexported fields
}

func (*GetArtifactRequest) Descriptor

func (*GetArtifactRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetArtifactRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactRequest) GetName

func (x *GetArtifactRequest) GetName() string

func (*GetArtifactRequest) GetRevisionKref

func (x *GetArtifactRequest) GetRevisionKref() *Kref

func (*GetArtifactRequest) ProtoMessage

func (*GetArtifactRequest) ProtoMessage()

func (*GetArtifactRequest) ProtoReflect

func (x *GetArtifactRequest) ProtoReflect() protoreflect.Message

func (*GetArtifactRequest) Reset

func (x *GetArtifactRequest) Reset()

func (*GetArtifactRequest) String

func (x *GetArtifactRequest) String() string

type GetArtifactsByLocationRequest

type GetArtifactsByLocationRequest struct {
    Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
    // contains filtered or unexported fields
}

func (*GetArtifactsByLocationRequest) Descriptor

func (*GetArtifactsByLocationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetArtifactsByLocationRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactsByLocationRequest) GetLocation

func (x *GetArtifactsByLocationRequest) GetLocation() string

func (*GetArtifactsByLocationRequest) ProtoMessage

func (*GetArtifactsByLocationRequest) ProtoMessage()

func (*GetArtifactsByLocationRequest) ProtoReflect

func (x *GetArtifactsByLocationRequest) ProtoReflect() protoreflect.Message

func (*GetArtifactsByLocationRequest) Reset

func (x *GetArtifactsByLocationRequest) Reset()

func (*GetArtifactsByLocationRequest) String

func (x *GetArtifactsByLocationRequest) String() string

type GetArtifactsByLocationResponse

type GetArtifactsByLocationResponse struct {
    Artifacts []*ArtifactResponse `protobuf:"bytes,1,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
    // contains filtered or unexported fields
}

func (*GetArtifactsByLocationResponse) Descriptor

func (*GetArtifactsByLocationResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetArtifactsByLocationResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactsByLocationResponse) GetArtifacts

func (x *GetArtifactsByLocationResponse) GetArtifacts() []*ArtifactResponse

func (*GetArtifactsByLocationResponse) ProtoMessage

func (*GetArtifactsByLocationResponse) ProtoMessage()

func (*GetArtifactsByLocationResponse) ProtoReflect

func (x *GetArtifactsByLocationResponse) ProtoReflect() protoreflect.Message

func (*GetArtifactsByLocationResponse) Reset

func (x *GetArtifactsByLocationResponse) Reset()

func (*GetArtifactsByLocationResponse) String

func (x *GetArtifactsByLocationResponse) String() string

type GetArtifactsRequest

type GetArtifactsRequest struct {
    RevisionKref *Kref `protobuf:"bytes,1,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    // contains filtered or unexported fields
}

func (*GetArtifactsRequest) Descriptor

func (*GetArtifactsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetArtifactsRequest.ProtoReflect.Descriptor instead.

func (*GetArtifactsRequest) GetRevisionKref

func (x *GetArtifactsRequest) GetRevisionKref() *Kref

func (*GetArtifactsRequest) ProtoMessage

func (*GetArtifactsRequest) ProtoMessage()

func (*GetArtifactsRequest) ProtoReflect

func (x *GetArtifactsRequest) ProtoReflect() protoreflect.Message

func (*GetArtifactsRequest) Reset

func (x *GetArtifactsRequest) Reset()

func (*GetArtifactsRequest) String

func (x *GetArtifactsRequest) String() string

type GetArtifactsResponse

type GetArtifactsResponse struct {
    Artifacts []*ArtifactResponse `protobuf:"bytes,1,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
    // contains filtered or unexported fields
}

func (*GetArtifactsResponse) Descriptor

func (*GetArtifactsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetArtifactsResponse.ProtoReflect.Descriptor instead.

func (*GetArtifactsResponse) GetArtifacts

func (x *GetArtifactsResponse) GetArtifacts() []*ArtifactResponse

func (*GetArtifactsResponse) ProtoMessage

func (*GetArtifactsResponse) ProtoMessage()

func (*GetArtifactsResponse) ProtoReflect

func (x *GetArtifactsResponse) ProtoReflect() protoreflect.Message

func (*GetArtifactsResponse) Reset

func (x *GetArtifactsResponse) Reset()

func (*GetArtifactsResponse) String

func (x *GetArtifactsResponse) String() string

type GetAttributeRequest

Get a single metadata attribute

type GetAttributeRequest struct {
    Kref *Kref  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    // contains filtered or unexported fields
}

func (*GetAttributeRequest) Descriptor

func (*GetAttributeRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAttributeRequest.ProtoReflect.Descriptor instead.

func (*GetAttributeRequest) GetKey

func (x *GetAttributeRequest) GetKey() string

func (*GetAttributeRequest) GetKref

func (x *GetAttributeRequest) GetKref() *Kref

func (*GetAttributeRequest) ProtoMessage

func (*GetAttributeRequest) ProtoMessage()

func (*GetAttributeRequest) ProtoReflect

func (x *GetAttributeRequest) ProtoReflect() protoreflect.Message

func (*GetAttributeRequest) Reset

func (x *GetAttributeRequest) Reset()

func (*GetAttributeRequest) String

func (x *GetAttributeRequest) String() string

type GetAttributeResponse

type GetAttributeResponse struct {
    Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
    Value  string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
    Exists bool   `protobuf:"varint,3,opt,name=exists,proto3" json:"exists,omitempty"`
    // contains filtered or unexported fields
}

func (*GetAttributeResponse) Descriptor

func (*GetAttributeResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetAttributeResponse.ProtoReflect.Descriptor instead.

func (*GetAttributeResponse) GetExists

func (x *GetAttributeResponse) GetExists() bool

func (*GetAttributeResponse) GetKey

func (x *GetAttributeResponse) GetKey() string

func (*GetAttributeResponse) GetValue

func (x *GetAttributeResponse) GetValue() string

func (*GetAttributeResponse) ProtoMessage

func (*GetAttributeResponse) ProtoMessage()

func (*GetAttributeResponse) ProtoReflect

func (x *GetAttributeResponse) ProtoReflect() protoreflect.Message

func (*GetAttributeResponse) Reset

func (x *GetAttributeResponse) Reset()

func (*GetAttributeResponse) String

func (x *GetAttributeResponse) String() string

type GetBundleHistoryRequest

type GetBundleHistoryRequest struct {
    BundleKref *Kref `protobuf:"bytes,1,opt,name=bundle_kref,json=bundleKref,proto3" json:"bundle_kref,omitempty"`
    // contains filtered or unexported fields
}

func (*GetBundleHistoryRequest) Descriptor

func (*GetBundleHistoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetBundleHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetBundleHistoryRequest) GetBundleKref

func (x *GetBundleHistoryRequest) GetBundleKref() *Kref

func (*GetBundleHistoryRequest) ProtoMessage

func (*GetBundleHistoryRequest) ProtoMessage()

func (*GetBundleHistoryRequest) ProtoReflect

func (x *GetBundleHistoryRequest) ProtoReflect() protoreflect.Message

func (*GetBundleHistoryRequest) Reset

func (x *GetBundleHistoryRequest) Reset()

func (*GetBundleHistoryRequest) String

func (x *GetBundleHistoryRequest) String() string

type GetBundleHistoryResponse

type GetBundleHistoryResponse struct {
    History []*BundleRevisionHistory `protobuf:"bytes,1,rep,name=history,proto3" json:"history,omitempty"`
    // contains filtered or unexported fields
}

func (*GetBundleHistoryResponse) Descriptor

func (*GetBundleHistoryResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetBundleHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetBundleHistoryResponse) GetHistory

func (x *GetBundleHistoryResponse) GetHistory() []*BundleRevisionHistory

func (*GetBundleHistoryResponse) ProtoMessage

func (*GetBundleHistoryResponse) ProtoMessage()

func (*GetBundleHistoryResponse) ProtoReflect

func (x *GetBundleHistoryResponse) ProtoReflect() protoreflect.Message

func (*GetBundleHistoryResponse) Reset

func (x *GetBundleHistoryResponse) Reset()

func (*GetBundleHistoryResponse) String

func (x *GetBundleHistoryResponse) String() string

type GetBundleMembersRequest

type GetBundleMembersRequest struct {
    BundleKref     *Kref  `protobuf:"bytes,1,opt,name=bundle_kref,json=bundleKref,proto3" json:"bundle_kref,omitempty"`                    // The bundle item kref
    RevisionNumber *int32 `protobuf:"varint,2,opt,name=revision_number,json=revisionNumber,proto3,oneof" json:"revision_number,omitempty"` // Optional: specific revision (default: latest)
    // contains filtered or unexported fields
}

func (*GetBundleMembersRequest) Descriptor

func (*GetBundleMembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetBundleMembersRequest.ProtoReflect.Descriptor instead.

func (*GetBundleMembersRequest) GetBundleKref

func (x *GetBundleMembersRequest) GetBundleKref() *Kref

func (*GetBundleMembersRequest) GetRevisionNumber

func (x *GetBundleMembersRequest) GetRevisionNumber() int32

func (*GetBundleMembersRequest) ProtoMessage

func (*GetBundleMembersRequest) ProtoMessage()

func (*GetBundleMembersRequest) ProtoReflect

func (x *GetBundleMembersRequest) ProtoReflect() protoreflect.Message

func (*GetBundleMembersRequest) Reset

func (x *GetBundleMembersRequest) Reset()

func (*GetBundleMembersRequest) String

func (x *GetBundleMembersRequest) String() string

type GetBundleMembersResponse

type GetBundleMembersResponse struct {
    Members        []*BundleMember `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
    RevisionNumber int32           `protobuf:"varint,2,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"` // Which revision's membership this represents
    TotalCount     int32           `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
    // contains filtered or unexported fields
}

func (*GetBundleMembersResponse) Descriptor

func (*GetBundleMembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetBundleMembersResponse.ProtoReflect.Descriptor instead.

func (*GetBundleMembersResponse) GetMembers

func (x *GetBundleMembersResponse) GetMembers() []*BundleMember

func (*GetBundleMembersResponse) GetRevisionNumber

func (x *GetBundleMembersResponse) GetRevisionNumber() int32

func (*GetBundleMembersResponse) GetTotalCount

func (x *GetBundleMembersResponse) GetTotalCount() int32

func (*GetBundleMembersResponse) ProtoMessage

func (*GetBundleMembersResponse) ProtoMessage()

func (*GetBundleMembersResponse) ProtoReflect

func (x *GetBundleMembersResponse) ProtoReflect() protoreflect.Message

func (*GetBundleMembersResponse) Reset

func (x *GetBundleMembersResponse) Reset()

func (*GetBundleMembersResponse) String

func (x *GetBundleMembersResponse) String() string

type GetChildSpacesRequest

type GetChildSpacesRequest struct {
    ParentPath string `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"` // Empty string for root level spaces
    Recursive  bool   `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
    // Optional pagination parameters
    Pagination *PaginationRequest `protobuf:"bytes,3,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // contains filtered or unexported fields
}

func (*GetChildSpacesRequest) Descriptor

func (*GetChildSpacesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetChildSpacesRequest.ProtoReflect.Descriptor instead.

func (*GetChildSpacesRequest) GetPagination

func (x *GetChildSpacesRequest) GetPagination() *PaginationRequest

func (*GetChildSpacesRequest) GetParentPath

func (x *GetChildSpacesRequest) GetParentPath() string

func (*GetChildSpacesRequest) GetRecursive

func (x *GetChildSpacesRequest) GetRecursive() bool

func (*GetChildSpacesRequest) ProtoMessage

func (*GetChildSpacesRequest) ProtoMessage()

func (*GetChildSpacesRequest) ProtoReflect

func (x *GetChildSpacesRequest) ProtoReflect() protoreflect.Message

func (*GetChildSpacesRequest) Reset

func (x *GetChildSpacesRequest) Reset()

func (*GetChildSpacesRequest) String

func (x *GetChildSpacesRequest) String() string

type GetChildSpacesResponse

type GetChildSpacesResponse struct {
    Spaces []*SpaceResponse `protobuf:"bytes,1,rep,name=spaces,proto3" json:"spaces,omitempty"`
    // Pagination info for the response
    Pagination *PaginationResponse `protobuf:"bytes,2,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // contains filtered or unexported fields
}

func (*GetChildSpacesResponse) Descriptor

func (*GetChildSpacesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetChildSpacesResponse.ProtoReflect.Descriptor instead.

func (*GetChildSpacesResponse) GetPagination

func (x *GetChildSpacesResponse) GetPagination() *PaginationResponse

func (*GetChildSpacesResponse) GetSpaces

func (x *GetChildSpacesResponse) GetSpaces() []*SpaceResponse

func (*GetChildSpacesResponse) ProtoMessage

func (*GetChildSpacesResponse) ProtoMessage()

func (*GetChildSpacesResponse) ProtoReflect

func (x *GetChildSpacesResponse) ProtoReflect() protoreflect.Message

func (*GetChildSpacesResponse) Reset

func (x *GetChildSpacesResponse) Reset()

func (*GetChildSpacesResponse) String

func (x *GetChildSpacesResponse) String() string

type GetEdgesRequest

type GetEdgesRequest struct {
    Kref           *Kref         `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`                                             // The revision to get edges for.
    EdgeTypeFilter string        `protobuf:"bytes,2,opt,name=edge_type_filter,json=edgeTypeFilter,proto3" json:"edge_type_filter,omitempty"` // Optional: if empty, returns all edges.
    Direction      EdgeDirection `protobuf:"varint,3,opt,name=direction,proto3,enum=kumiho.EdgeDirection" json:"direction,omitempty"`        // Optional: defaults to OUTGOING
    // Optional pagination parameters
    Pagination *PaginationRequest `protobuf:"bytes,4,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // contains filtered or unexported fields
}

func (*GetEdgesRequest) Descriptor

func (*GetEdgesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetEdgesRequest.ProtoReflect.Descriptor instead.

func (*GetEdgesRequest) GetDirection

func (x *GetEdgesRequest) GetDirection() EdgeDirection

func (*GetEdgesRequest) GetEdgeTypeFilter

func (x *GetEdgesRequest) GetEdgeTypeFilter() string

func (*GetEdgesRequest) GetKref

func (x *GetEdgesRequest) GetKref() *Kref

func (*GetEdgesRequest) GetPagination

func (x *GetEdgesRequest) GetPagination() *PaginationRequest

func (*GetEdgesRequest) ProtoMessage

func (*GetEdgesRequest) ProtoMessage()

func (*GetEdgesRequest) ProtoReflect

func (x *GetEdgesRequest) ProtoReflect() protoreflect.Message

func (*GetEdgesRequest) Reset

func (x *GetEdgesRequest) Reset()

func (*GetEdgesRequest) String

func (x *GetEdgesRequest) String() string

type GetEdgesResponse

type GetEdgesResponse struct {
    Edges         []*Edge `protobuf:"bytes,1,rep,name=edges,proto3" json:"edges,omitempty"`
    RevisionKrefs []*Kref `protobuf:"bytes,2,rep,name=revision_krefs,json=revisionKrefs,proto3" json:"revision_krefs,omitempty"`
    // Pagination info for the response
    Pagination *PaginationResponse `protobuf:"bytes,3,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // contains filtered or unexported fields
}

func (*GetEdgesResponse) Descriptor

func (*GetEdgesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetEdgesResponse.ProtoReflect.Descriptor instead.

func (*GetEdgesResponse) GetEdges

func (x *GetEdgesResponse) GetEdges() []*Edge

func (*GetEdgesResponse) GetPagination

func (x *GetEdgesResponse) GetPagination() *PaginationResponse

func (*GetEdgesResponse) GetRevisionKrefs

func (x *GetEdgesResponse) GetRevisionKrefs() []*Kref

func (*GetEdgesResponse) ProtoMessage

func (*GetEdgesResponse) ProtoMessage()

func (*GetEdgesResponse) ProtoReflect

func (x *GetEdgesResponse) ProtoReflect() protoreflect.Message

func (*GetEdgesResponse) Reset

func (x *GetEdgesResponse) Reset()

func (*GetEdgesResponse) String

func (x *GetEdgesResponse) String() string

type GetEventCapabilitiesRequest

Request for event streaming capabilities

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

func (*GetEventCapabilitiesRequest) Descriptor

func (*GetEventCapabilitiesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetEventCapabilitiesRequest.ProtoReflect.Descriptor instead.

func (*GetEventCapabilitiesRequest) ProtoMessage

func (*GetEventCapabilitiesRequest) ProtoMessage()

func (*GetEventCapabilitiesRequest) ProtoReflect

func (x *GetEventCapabilitiesRequest) ProtoReflect() protoreflect.Message

func (*GetEventCapabilitiesRequest) Reset

func (x *GetEventCapabilitiesRequest) Reset()

func (*GetEventCapabilitiesRequest) String

func (x *GetEventCapabilitiesRequest) String() string

type GetItemRequest

type GetItemRequest struct {
    ParentPath string `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`
    ItemName   string `protobuf:"bytes,2,opt,name=item_name,json=itemName,proto3" json:"item_name,omitempty"`
    Kind       string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
    // contains filtered or unexported fields
}

func (*GetItemRequest) Descriptor

func (*GetItemRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetItemRequest.ProtoReflect.Descriptor instead.

func (*GetItemRequest) GetItemName

func (x *GetItemRequest) GetItemName() string

func (*GetItemRequest) GetKind

func (x *GetItemRequest) GetKind() string

func (*GetItemRequest) GetParentPath

func (x *GetItemRequest) GetParentPath() string

func (*GetItemRequest) ProtoMessage

func (*GetItemRequest) ProtoMessage()

func (*GetItemRequest) ProtoReflect

func (x *GetItemRequest) ProtoReflect() protoreflect.Message

func (*GetItemRequest) Reset

func (x *GetItemRequest) Reset()

func (*GetItemRequest) String

func (x *GetItemRequest) String() string

type GetItemsRequest

type GetItemsRequest struct {
    ParentPath     string `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`
    ItemNameFilter string `protobuf:"bytes,2,opt,name=item_name_filter,json=itemNameFilter,proto3" json:"item_name_filter,omitempty"`
    KindFilter     string `protobuf:"bytes,3,opt,name=kind_filter,json=kindFilter,proto3" json:"kind_filter,omitempty"`
    // Optional pagination parameters
    Pagination        *PaginationRequest `protobuf:"bytes,4,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    IncludeDeprecated bool               `protobuf:"varint,5,opt,name=include_deprecated,json=includeDeprecated,proto3" json:"include_deprecated,omitempty"`
    // contains filtered or unexported fields
}

func (*GetItemsRequest) Descriptor

func (*GetItemsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetItemsRequest.ProtoReflect.Descriptor instead.

func (*GetItemsRequest) GetIncludeDeprecated

func (x *GetItemsRequest) GetIncludeDeprecated() bool

func (*GetItemsRequest) GetItemNameFilter

func (x *GetItemsRequest) GetItemNameFilter() string

func (*GetItemsRequest) GetKindFilter

func (x *GetItemsRequest) GetKindFilter() string

func (*GetItemsRequest) GetPagination

func (x *GetItemsRequest) GetPagination() *PaginationRequest

func (*GetItemsRequest) GetParentPath

func (x *GetItemsRequest) GetParentPath() string

func (*GetItemsRequest) ProtoMessage

func (*GetItemsRequest) ProtoMessage()

func (*GetItemsRequest) ProtoReflect

func (x *GetItemsRequest) ProtoReflect() protoreflect.Message

func (*GetItemsRequest) Reset

func (x *GetItemsRequest) Reset()

func (*GetItemsRequest) String

func (x *GetItemsRequest) String() string

type GetItemsResponse

type GetItemsResponse struct {
    Items []*ItemResponse `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
    // Pagination info for the response
    Pagination *PaginationResponse `protobuf:"bytes,2,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // contains filtered or unexported fields
}

func (*GetItemsResponse) Descriptor

func (*GetItemsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetItemsResponse.ProtoReflect.Descriptor instead.

func (*GetItemsResponse) GetItems

func (x *GetItemsResponse) GetItems() []*ItemResponse

func (*GetItemsResponse) GetPagination

func (x *GetItemsResponse) GetPagination() *PaginationResponse

func (*GetItemsResponse) ProtoMessage

func (*GetItemsResponse) ProtoMessage()

func (*GetItemsResponse) ProtoReflect

func (x *GetItemsResponse) ProtoReflect() protoreflect.Message

func (*GetItemsResponse) Reset

func (x *GetItemsResponse) Reset()

func (*GetItemsResponse) String

func (x *GetItemsResponse) String() string

type GetProjectsRequest

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

func (*GetProjectsRequest) Descriptor

func (*GetProjectsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetProjectsRequest.ProtoReflect.Descriptor instead.

func (*GetProjectsRequest) ProtoMessage

func (*GetProjectsRequest) ProtoMessage()

func (*GetProjectsRequest) ProtoReflect

func (x *GetProjectsRequest) ProtoReflect() protoreflect.Message

func (*GetProjectsRequest) Reset

func (x *GetProjectsRequest) Reset()

func (*GetProjectsRequest) String

func (x *GetProjectsRequest) String() string

type GetProjectsResponse

type GetProjectsResponse struct {
    Projects []*ProjectResponse `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
    // contains filtered or unexported fields
}

func (*GetProjectsResponse) Descriptor

func (*GetProjectsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetProjectsResponse.ProtoReflect.Descriptor instead.

func (*GetProjectsResponse) GetProjects

func (x *GetProjectsResponse) GetProjects() []*ProjectResponse

func (*GetProjectsResponse) ProtoMessage

func (*GetProjectsResponse) ProtoMessage()

func (*GetProjectsResponse) ProtoReflect

func (x *GetProjectsResponse) ProtoReflect() protoreflect.Message

func (*GetProjectsResponse) Reset

func (x *GetProjectsResponse) Reset()

func (*GetProjectsResponse) String

func (x *GetProjectsResponse) String() string

type GetRevisionsRequest

type GetRevisionsRequest struct {
    ItemKref *Kref `protobuf:"bytes,1,opt,name=item_kref,json=itemKref,proto3" json:"item_kref,omitempty"`
    // Optional pagination parameters
    Pagination *PaginationRequest `protobuf:"bytes,2,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // contains filtered or unexported fields
}

func (*GetRevisionsRequest) Descriptor

func (*GetRevisionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRevisionsRequest.ProtoReflect.Descriptor instead.

func (*GetRevisionsRequest) GetItemKref

func (x *GetRevisionsRequest) GetItemKref() *Kref

func (*GetRevisionsRequest) GetPagination

func (x *GetRevisionsRequest) GetPagination() *PaginationRequest

func (*GetRevisionsRequest) ProtoMessage

func (*GetRevisionsRequest) ProtoMessage()

func (*GetRevisionsRequest) ProtoReflect

func (x *GetRevisionsRequest) ProtoReflect() protoreflect.Message

func (*GetRevisionsRequest) Reset

func (x *GetRevisionsRequest) Reset()

func (*GetRevisionsRequest) String

func (x *GetRevisionsRequest) String() string

type GetRevisionsResponse

type GetRevisionsResponse struct {
    Revisions []*RevisionResponse `protobuf:"bytes,1,rep,name=revisions,proto3" json:"revisions,omitempty"`
    // Pagination info for the response
    Pagination *PaginationResponse `protobuf:"bytes,2,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // contains filtered or unexported fields
}

func (*GetRevisionsResponse) Descriptor

func (*GetRevisionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRevisionsResponse.ProtoReflect.Descriptor instead.

func (*GetRevisionsResponse) GetPagination

func (x *GetRevisionsResponse) GetPagination() *PaginationResponse

func (*GetRevisionsResponse) GetRevisions

func (x *GetRevisionsResponse) GetRevisions() []*RevisionResponse

func (*GetRevisionsResponse) ProtoMessage

func (*GetRevisionsResponse) ProtoMessage()

func (*GetRevisionsResponse) ProtoReflect

func (x *GetRevisionsResponse) ProtoReflect() protoreflect.Message

func (*GetRevisionsResponse) Reset

func (x *GetRevisionsResponse) Reset()

func (*GetRevisionsResponse) String

func (x *GetRevisionsResponse) String() string

type GetSpaceRequest

type GetSpaceRequest struct {
    PathOrKref string `protobuf:"bytes,1,opt,name=path_or_kref,json=pathOrKref,proto3" json:"path_or_kref,omitempty"`
    // contains filtered or unexported fields
}

func (*GetSpaceRequest) Descriptor

func (*GetSpaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSpaceRequest.ProtoReflect.Descriptor instead.

func (*GetSpaceRequest) GetPathOrKref

func (x *GetSpaceRequest) GetPathOrKref() string

func (*GetSpaceRequest) ProtoMessage

func (*GetSpaceRequest) ProtoMessage()

func (*GetSpaceRequest) ProtoReflect

func (x *GetSpaceRequest) ProtoReflect() protoreflect.Message

func (*GetSpaceRequest) Reset

func (x *GetSpaceRequest) Reset()

func (*GetSpaceRequest) String

func (x *GetSpaceRequest) String() string

type GetTenantUsageRequest

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

func (*GetTenantUsageRequest) Descriptor

func (*GetTenantUsageRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTenantUsageRequest.ProtoReflect.Descriptor instead.

func (*GetTenantUsageRequest) ProtoMessage

func (*GetTenantUsageRequest) ProtoMessage()

func (*GetTenantUsageRequest) ProtoReflect

func (x *GetTenantUsageRequest) ProtoReflect() protoreflect.Message

func (*GetTenantUsageRequest) Reset

func (x *GetTenantUsageRequest) Reset()

func (*GetTenantUsageRequest) String

func (x *GetTenantUsageRequest) String() string

type HasTagRequest

type HasTagRequest struct {
    Kref *Kref  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Tag  string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
    // contains filtered or unexported fields
}

func (*HasTagRequest) Descriptor

func (*HasTagRequest) Descriptor() ([]byte, []int)

Deprecated: Use HasTagRequest.ProtoReflect.Descriptor instead.

func (*HasTagRequest) GetKref

func (x *HasTagRequest) GetKref() *Kref

func (*HasTagRequest) GetTag

func (x *HasTagRequest) GetTag() string

func (*HasTagRequest) ProtoMessage

func (*HasTagRequest) ProtoMessage()

func (*HasTagRequest) ProtoReflect

func (x *HasTagRequest) ProtoReflect() protoreflect.Message

func (*HasTagRequest) Reset

func (x *HasTagRequest) Reset()

func (*HasTagRequest) String

func (x *HasTagRequest) String() string

type HasTagResponse

type HasTagResponse struct {
    HasTag bool `protobuf:"varint,1,opt,name=has_tag,json=hasTag,proto3" json:"has_tag,omitempty"`
    // contains filtered or unexported fields
}

func (*HasTagResponse) Descriptor

func (*HasTagResponse) Descriptor() ([]byte, []int)

Deprecated: Use HasTagResponse.ProtoReflect.Descriptor instead.

func (*HasTagResponse) GetHasTag

func (x *HasTagResponse) GetHasTag() bool

func (*HasTagResponse) ProtoMessage

func (*HasTagResponse) ProtoMessage()

func (*HasTagResponse) ProtoReflect

func (x *HasTagResponse) ProtoReflect() protoreflect.Message

func (*HasTagResponse) Reset

func (x *HasTagResponse) Reset()

func (*HasTagResponse) String

func (x *HasTagResponse) String() string

type ImpactAnalysisRequest

Request for impact analysis (what depends on this revision, transitively)

type ImpactAnalysisRequest struct {
    RevisionKref   *Kref    `protobuf:"bytes,1,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    EdgeTypeFilter []string `protobuf:"bytes,2,rep,name=edge_type_filter,json=edgeTypeFilter,proto3" json:"edge_type_filter,omitempty"` // Usually ["DEPENDS_ON"]
    MaxDepth       int32    `protobuf:"varint,3,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`                    // Default: 10
    Limit          int32    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`                                          // Max results
    // contains filtered or unexported fields
}

func (*ImpactAnalysisRequest) Descriptor

func (*ImpactAnalysisRequest) Descriptor() ([]byte, []int)

Deprecated: Use ImpactAnalysisRequest.ProtoReflect.Descriptor instead.

func (*ImpactAnalysisRequest) GetEdgeTypeFilter

func (x *ImpactAnalysisRequest) GetEdgeTypeFilter() []string

func (*ImpactAnalysisRequest) GetLimit

func (x *ImpactAnalysisRequest) GetLimit() int32

func (*ImpactAnalysisRequest) GetMaxDepth

func (x *ImpactAnalysisRequest) GetMaxDepth() int32

func (*ImpactAnalysisRequest) GetRevisionKref

func (x *ImpactAnalysisRequest) GetRevisionKref() *Kref

func (*ImpactAnalysisRequest) ProtoMessage

func (*ImpactAnalysisRequest) ProtoMessage()

func (*ImpactAnalysisRequest) ProtoReflect

func (x *ImpactAnalysisRequest) ProtoReflect() protoreflect.Message

func (*ImpactAnalysisRequest) Reset

func (x *ImpactAnalysisRequest) Reset()

func (*ImpactAnalysisRequest) String

func (x *ImpactAnalysisRequest) String() string

type ImpactAnalysisResponse

type ImpactAnalysisResponse struct {
    ImpactedRevisions []*ImpactedRevision `protobuf:"bytes,1,rep,name=impacted_revisions,json=impactedRevisions,proto3" json:"impacted_revisions,omitempty"`
    TotalImpacted     int32               `protobuf:"varint,2,opt,name=total_impacted,json=totalImpacted,proto3" json:"total_impacted,omitempty"`
    Truncated         bool                `protobuf:"varint,3,opt,name=truncated,proto3" json:"truncated,omitempty"`
    // contains filtered or unexported fields
}

func (*ImpactAnalysisResponse) Descriptor

func (*ImpactAnalysisResponse) Descriptor() ([]byte, []int)

Deprecated: Use ImpactAnalysisResponse.ProtoReflect.Descriptor instead.

func (*ImpactAnalysisResponse) GetImpactedRevisions

func (x *ImpactAnalysisResponse) GetImpactedRevisions() []*ImpactedRevision

func (*ImpactAnalysisResponse) GetTotalImpacted

func (x *ImpactAnalysisResponse) GetTotalImpacted() int32

func (*ImpactAnalysisResponse) GetTruncated

func (x *ImpactAnalysisResponse) GetTruncated() bool

func (*ImpactAnalysisResponse) ProtoMessage

func (*ImpactAnalysisResponse) ProtoMessage()

func (*ImpactAnalysisResponse) ProtoReflect

func (x *ImpactAnalysisResponse) ProtoReflect() protoreflect.Message

func (*ImpactAnalysisResponse) Reset

func (x *ImpactAnalysisResponse) Reset()

func (*ImpactAnalysisResponse) String

func (x *ImpactAnalysisResponse) String() string

type ImpactedRevision

type ImpactedRevision struct {
    RevisionKref    *Kref    `protobuf:"bytes,1,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    ItemKref        *Kref    `protobuf:"bytes,2,opt,name=item_kref,json=itemKref,proto3" json:"item_kref,omitempty"`
    ImpactDepth     int32    `protobuf:"varint,3,opt,name=impact_depth,json=impactDepth,proto3" json:"impact_depth,omitempty"`              // How many hops away
    ImpactPathTypes []string `protobuf:"bytes,4,rep,name=impact_path_types,json=impactPathTypes,proto3" json:"impact_path_types,omitempty"` // Edge types in the impact chain
    // contains filtered or unexported fields
}

func (*ImpactedRevision) Descriptor

func (*ImpactedRevision) Descriptor() ([]byte, []int)

Deprecated: Use ImpactedRevision.ProtoReflect.Descriptor instead.

func (*ImpactedRevision) GetImpactDepth

func (x *ImpactedRevision) GetImpactDepth() int32

func (*ImpactedRevision) GetImpactPathTypes

func (x *ImpactedRevision) GetImpactPathTypes() []string

func (*ImpactedRevision) GetItemKref

func (x *ImpactedRevision) GetItemKref() *Kref

func (*ImpactedRevision) GetRevisionKref

func (x *ImpactedRevision) GetRevisionKref() *Kref

func (*ImpactedRevision) ProtoMessage

func (*ImpactedRevision) ProtoMessage()

func (*ImpactedRevision) ProtoReflect

func (x *ImpactedRevision) ProtoReflect() protoreflect.Message

func (*ImpactedRevision) Reset

func (x *ImpactedRevision) Reset()

func (*ImpactedRevision) String

func (x *ImpactedRevision) String() string

type ItemResponse

type ItemResponse struct {
    Kref       *Kref             `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Name       string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
    ItemName   string            `protobuf:"bytes,3,opt,name=item_name,json=itemName,proto3" json:"item_name,omitempty"`
    Kind       string            `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
    CreatedAt  string            `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
    ModifiedAt string            `protobuf:"bytes,6,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
    Author     string            `protobuf:"bytes,7,opt,name=author,proto3" json:"author,omitempty"`
    Metadata   map[string]string `protobuf:"bytes,8,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    Deprecated bool              `protobuf:"varint,9,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
    Username   string            `protobuf:"bytes,10,opt,name=username,proto3" json:"username,omitempty"`
    // contains filtered or unexported fields
}

func (*ItemResponse) Descriptor

func (*ItemResponse) Descriptor() ([]byte, []int)

Deprecated: Use ItemResponse.ProtoReflect.Descriptor instead.

func (*ItemResponse) GetAuthor

func (x *ItemResponse) GetAuthor() string

func (*ItemResponse) GetCreatedAt

func (x *ItemResponse) GetCreatedAt() string

func (*ItemResponse) GetDeprecated

func (x *ItemResponse) GetDeprecated() bool

func (*ItemResponse) GetItemName

func (x *ItemResponse) GetItemName() string

func (*ItemResponse) GetKind

func (x *ItemResponse) GetKind() string

func (*ItemResponse) GetKref

func (x *ItemResponse) GetKref() *Kref

func (*ItemResponse) GetMetadata

func (x *ItemResponse) GetMetadata() map[string]string

func (*ItemResponse) GetModifiedAt

func (x *ItemResponse) GetModifiedAt() string

func (*ItemResponse) GetName

func (x *ItemResponse) GetName() string

func (*ItemResponse) GetUsername

func (x *ItemResponse) GetUsername() string

func (*ItemResponse) ProtoMessage

func (*ItemResponse) ProtoMessage()

func (*ItemResponse) ProtoReflect

func (x *ItemResponse) ProtoReflect() protoreflect.Message

func (*ItemResponse) Reset

func (x *ItemResponse) Reset()

func (*ItemResponse) String

func (x *ItemResponse) String() string

type ItemSearchRequest

type ItemSearchRequest struct {
    ContextFilter  string `protobuf:"bytes,1,opt,name=context_filter,json=contextFilter,proto3" json:"context_filter,omitempty"`
    ItemNameFilter string `protobuf:"bytes,2,opt,name=item_name_filter,json=itemNameFilter,proto3" json:"item_name_filter,omitempty"`
    KindFilter     string `protobuf:"bytes,3,opt,name=kind_filter,json=kindFilter,proto3" json:"kind_filter,omitempty"`
    // Optional pagination parameters
    Pagination        *PaginationRequest `protobuf:"bytes,4,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    IncludeDeprecated bool               `protobuf:"varint,5,opt,name=include_deprecated,json=includeDeprecated,proto3" json:"include_deprecated,omitempty"`
    // contains filtered or unexported fields
}

func (*ItemSearchRequest) Descriptor

func (*ItemSearchRequest) Descriptor() ([]byte, []int)

Deprecated: Use ItemSearchRequest.ProtoReflect.Descriptor instead.

func (*ItemSearchRequest) GetContextFilter

func (x *ItemSearchRequest) GetContextFilter() string

func (*ItemSearchRequest) GetIncludeDeprecated

func (x *ItemSearchRequest) GetIncludeDeprecated() bool

func (*ItemSearchRequest) GetItemNameFilter

func (x *ItemSearchRequest) GetItemNameFilter() string

func (*ItemSearchRequest) GetKindFilter

func (x *ItemSearchRequest) GetKindFilter() string

func (*ItemSearchRequest) GetPagination

func (x *ItemSearchRequest) GetPagination() *PaginationRequest

func (*ItemSearchRequest) ProtoMessage

func (*ItemSearchRequest) ProtoMessage()

func (*ItemSearchRequest) ProtoReflect

func (x *ItemSearchRequest) ProtoReflect() protoreflect.Message

func (*ItemSearchRequest) Reset

func (x *ItemSearchRequest) Reset()

func (*ItemSearchRequest) String

func (x *ItemSearchRequest) String() string

type Kref

A Kumiho Reference (Kref) uniquely identifies any object in the system.

type Kref struct {
    Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
    // contains filtered or unexported fields
}

func (*Kref) Descriptor

func (*Kref) Descriptor() ([]byte, []int)

Deprecated: Use Kref.ProtoReflect.Descriptor instead.

func (*Kref) GetUri

func (x *Kref) GetUri() string

func (*Kref) ProtoMessage

func (*Kref) ProtoMessage()

func (*Kref) ProtoReflect

func (x *Kref) ProtoReflect() protoreflect.Message

func (*Kref) Reset

func (x *Kref) Reset()

func (*Kref) String

func (x *Kref) String() string

type KrefRequest

type KrefRequest struct {
    Kref *Kref `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    // contains filtered or unexported fields
}

func (*KrefRequest) Descriptor

func (*KrefRequest) Descriptor() ([]byte, []int)

Deprecated: Use KrefRequest.ProtoReflect.Descriptor instead.

func (*KrefRequest) GetKref

func (x *KrefRequest) GetKref() *Kref

func (*KrefRequest) ProtoMessage

func (*KrefRequest) ProtoMessage()

func (*KrefRequest) ProtoReflect

func (x *KrefRequest) ProtoReflect() protoreflect.Message

func (*KrefRequest) Reset

func (x *KrefRequest) Reset()

func (*KrefRequest) String

func (x *KrefRequest) String() string

type KumihoServiceClient

KumihoServiceClient is the client API for KumihoService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

The Kumiho service definition.

type KumihoServiceClient interface {
    // Project methods
    CreateProject(ctx context.Context, in *CreateProjectRequest, opts ...grpc.CallOption) (*ProjectResponse, error)
    GetProjects(ctx context.Context, in *GetProjectsRequest, opts ...grpc.CallOption) (*GetProjectsResponse, error)
    UpdateProject(ctx context.Context, in *UpdateProjectRequest, opts ...grpc.CallOption) (*ProjectResponse, error)
    DeleteProject(ctx context.Context, in *DeleteProjectRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    // Space methods
    CreateSpace(ctx context.Context, in *CreateSpaceRequest, opts ...grpc.CallOption) (*SpaceResponse, error)
    GetSpace(ctx context.Context, in *GetSpaceRequest, opts ...grpc.CallOption) (*SpaceResponse, error)
    GetChildSpaces(ctx context.Context, in *GetChildSpacesRequest, opts ...grpc.CallOption) (*GetChildSpacesResponse, error)
    DeleteSpace(ctx context.Context, in *DeleteSpaceRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    UpdateSpaceMetadata(ctx context.Context, in *UpdateMetadataRequest, opts ...grpc.CallOption) (*SpaceResponse, error)
    // Item methods
    CreateItem(ctx context.Context, in *CreateItemRequest, opts ...grpc.CallOption) (*ItemResponse, error)
    GetItem(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*ItemResponse, error)
    GetItems(ctx context.Context, in *GetItemsRequest, opts ...grpc.CallOption) (*GetItemsResponse, error)
    ItemSearch(ctx context.Context, in *ItemSearchRequest, opts ...grpc.CallOption) (*GetItemsResponse, error)
    DeleteItem(ctx context.Context, in *DeleteItemRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    UpdateItemMetadata(ctx context.Context, in *UpdateMetadataRequest, opts ...grpc.CallOption) (*ItemResponse, error)
    // Full-text search (Google-like fuzzy search across items)
    Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
    // Score specific revisions against a query (server-side embeddings + fulltext)
    ScoreRevisions(ctx context.Context, in *ScoreRevisionsRequest, opts ...grpc.CallOption) (*ScoreRevisionsResponse, error)
    // Revision methods
    ResolveKref(ctx context.Context, in *ResolveKrefRequest, opts ...grpc.CallOption) (*RevisionResponse, error)
    ResolveLocation(ctx context.Context, in *ResolveLocationRequest, opts ...grpc.CallOption) (*ResolveLocationResponse, error)
    CreateRevision(ctx context.Context, in *CreateRevisionRequest, opts ...grpc.CallOption) (*RevisionResponse, error)
    GetRevision(ctx context.Context, in *KrefRequest, opts ...grpc.CallOption) (*RevisionResponse, error)
    GetRevisions(ctx context.Context, in *GetRevisionsRequest, opts ...grpc.CallOption) (*GetRevisionsResponse, error)
    BatchGetRevisions(ctx context.Context, in *BatchGetRevisionsRequest, opts ...grpc.CallOption) (*BatchGetRevisionsResponse, error)
    DeleteRevision(ctx context.Context, in *DeleteRevisionRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    PeekNextRevision(ctx context.Context, in *PeekNextRevisionRequest, opts ...grpc.CallOption) (*PeekNextRevisionResponse, error)
    UpdateRevisionMetadata(ctx context.Context, in *UpdateMetadataRequest, opts ...grpc.CallOption) (*RevisionResponse, error)
    TagRevision(ctx context.Context, in *TagRevisionRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    UnTagRevision(ctx context.Context, in *UnTagRevisionRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    HasTag(ctx context.Context, in *HasTagRequest, opts ...grpc.CallOption) (*HasTagResponse, error)
    WasTagged(ctx context.Context, in *WasTaggedRequest, opts ...grpc.CallOption) (*WasTaggedResponse, error)
    SetDefaultArtifact(ctx context.Context, in *SetDefaultArtifactRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    // Artifact methods
    CreateArtifact(ctx context.Context, in *CreateArtifactRequest, opts ...grpc.CallOption) (*ArtifactResponse, error)
    GetArtifact(ctx context.Context, in *GetArtifactRequest, opts ...grpc.CallOption) (*ArtifactResponse, error)
    GetArtifacts(ctx context.Context, in *GetArtifactsRequest, opts ...grpc.CallOption) (*GetArtifactsResponse, error)
    GetArtifactsByLocation(ctx context.Context, in *GetArtifactsByLocationRequest, opts ...grpc.CallOption) (*GetArtifactsByLocationResponse, error)
    DeleteArtifact(ctx context.Context, in *DeleteArtifactRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    UpdateArtifactMetadata(ctx context.Context, in *UpdateMetadataRequest, opts ...grpc.CallOption) (*ArtifactResponse, error)
    // Attribute methods (granular metadata operations)
    // These work on any entity type (Revision, Item, Artifact, Space) identified by kref
    SetAttribute(ctx context.Context, in *SetAttributeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    GetAttribute(ctx context.Context, in *GetAttributeRequest, opts ...grpc.CallOption) (*GetAttributeResponse, error)
    DeleteAttribute(ctx context.Context, in *DeleteAttributeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    // Edge methods
    CreateEdge(ctx context.Context, in *CreateEdgeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    GetEdges(ctx context.Context, in *GetEdgesRequest, opts ...grpc.CallOption) (*GetEdgesResponse, error)
    DeleteEdge(ctx context.Context, in *DeleteEdgeRequest, opts ...grpc.CallOption) (*StatusResponse, error)
    // Graph Traversal methods
    TraverseEdges(ctx context.Context, in *TraverseEdgesRequest, opts ...grpc.CallOption) (*TraverseEdgesResponse, error)
    FindShortestPath(ctx context.Context, in *ShortestPathRequest, opts ...grpc.CallOption) (*ShortestPathResponse, error)
    AnalyzeImpact(ctx context.Context, in *ImpactAnalysisRequest, opts ...grpc.CallOption) (*ImpactAnalysisResponse, error)
    // Bundle methods
    CreateBundle(ctx context.Context, in *CreateBundleRequest, opts ...grpc.CallOption) (*ItemResponse, error)
    AddBundleMember(ctx context.Context, in *AddBundleMemberRequest, opts ...grpc.CallOption) (*AddBundleMemberResponse, error)
    RemoveBundleMember(ctx context.Context, in *RemoveBundleMemberRequest, opts ...grpc.CallOption) (*RemoveBundleMemberResponse, error)
    GetBundleMembers(ctx context.Context, in *GetBundleMembersRequest, opts ...grpc.CallOption) (*GetBundleMembersResponse, error)
    GetBundleHistory(ctx context.Context, in *GetBundleHistoryRequest, opts ...grpc.CallOption) (*GetBundleHistoryResponse, error)
    // Tenant methods
    GetTenantUsage(ctx context.Context, in *GetTenantUsageRequest, opts ...grpc.CallOption) (*TenantUsageResponse, error)
    // Event Streaming
    EventStream(ctx context.Context, in *EventStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Event], error)
    // Get event streaming capabilities for the authenticated tenant's tier
    GetEventCapabilities(ctx context.Context, in *GetEventCapabilitiesRequest, opts ...grpc.CallOption) (*EventCapabilities, error)
    // Deprecation methods
    SetDeprecated(ctx context.Context, in *SetDeprecatedRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

func NewKumihoServiceClient

func NewKumihoServiceClient(cc grpc.ClientConnInterface) KumihoServiceClient

type KumihoServiceServer

KumihoServiceServer is the server API for KumihoService service. All implementations must embed UnimplementedKumihoServiceServer for forward compatibility.

The Kumiho service definition.

type KumihoServiceServer interface {
    // Project methods
    CreateProject(context.Context, *CreateProjectRequest) (*ProjectResponse, error)
    GetProjects(context.Context, *GetProjectsRequest) (*GetProjectsResponse, error)
    UpdateProject(context.Context, *UpdateProjectRequest) (*ProjectResponse, error)
    DeleteProject(context.Context, *DeleteProjectRequest) (*StatusResponse, error)
    // Space methods
    CreateSpace(context.Context, *CreateSpaceRequest) (*SpaceResponse, error)
    GetSpace(context.Context, *GetSpaceRequest) (*SpaceResponse, error)
    GetChildSpaces(context.Context, *GetChildSpacesRequest) (*GetChildSpacesResponse, error)
    DeleteSpace(context.Context, *DeleteSpaceRequest) (*StatusResponse, error)
    UpdateSpaceMetadata(context.Context, *UpdateMetadataRequest) (*SpaceResponse, error)
    // Item methods
    CreateItem(context.Context, *CreateItemRequest) (*ItemResponse, error)
    GetItem(context.Context, *GetItemRequest) (*ItemResponse, error)
    GetItems(context.Context, *GetItemsRequest) (*GetItemsResponse, error)
    ItemSearch(context.Context, *ItemSearchRequest) (*GetItemsResponse, error)
    DeleteItem(context.Context, *DeleteItemRequest) (*StatusResponse, error)
    UpdateItemMetadata(context.Context, *UpdateMetadataRequest) (*ItemResponse, error)
    // Full-text search (Google-like fuzzy search across items)
    Search(context.Context, *SearchRequest) (*SearchResponse, error)
    // Score specific revisions against a query (server-side embeddings + fulltext)
    ScoreRevisions(context.Context, *ScoreRevisionsRequest) (*ScoreRevisionsResponse, error)
    // Revision methods
    ResolveKref(context.Context, *ResolveKrefRequest) (*RevisionResponse, error)
    ResolveLocation(context.Context, *ResolveLocationRequest) (*ResolveLocationResponse, error)
    CreateRevision(context.Context, *CreateRevisionRequest) (*RevisionResponse, error)
    GetRevision(context.Context, *KrefRequest) (*RevisionResponse, error)
    GetRevisions(context.Context, *GetRevisionsRequest) (*GetRevisionsResponse, error)
    BatchGetRevisions(context.Context, *BatchGetRevisionsRequest) (*BatchGetRevisionsResponse, error)
    DeleteRevision(context.Context, *DeleteRevisionRequest) (*StatusResponse, error)
    PeekNextRevision(context.Context, *PeekNextRevisionRequest) (*PeekNextRevisionResponse, error)
    UpdateRevisionMetadata(context.Context, *UpdateMetadataRequest) (*RevisionResponse, error)
    TagRevision(context.Context, *TagRevisionRequest) (*StatusResponse, error)
    UnTagRevision(context.Context, *UnTagRevisionRequest) (*StatusResponse, error)
    HasTag(context.Context, *HasTagRequest) (*HasTagResponse, error)
    WasTagged(context.Context, *WasTaggedRequest) (*WasTaggedResponse, error)
    SetDefaultArtifact(context.Context, *SetDefaultArtifactRequest) (*StatusResponse, error)
    // Artifact methods
    CreateArtifact(context.Context, *CreateArtifactRequest) (*ArtifactResponse, error)
    GetArtifact(context.Context, *GetArtifactRequest) (*ArtifactResponse, error)
    GetArtifacts(context.Context, *GetArtifactsRequest) (*GetArtifactsResponse, error)
    GetArtifactsByLocation(context.Context, *GetArtifactsByLocationRequest) (*GetArtifactsByLocationResponse, error)
    DeleteArtifact(context.Context, *DeleteArtifactRequest) (*StatusResponse, error)
    UpdateArtifactMetadata(context.Context, *UpdateMetadataRequest) (*ArtifactResponse, error)
    // Attribute methods (granular metadata operations)
    // These work on any entity type (Revision, Item, Artifact, Space) identified by kref
    SetAttribute(context.Context, *SetAttributeRequest) (*StatusResponse, error)
    GetAttribute(context.Context, *GetAttributeRequest) (*GetAttributeResponse, error)
    DeleteAttribute(context.Context, *DeleteAttributeRequest) (*StatusResponse, error)
    // Edge methods
    CreateEdge(context.Context, *CreateEdgeRequest) (*StatusResponse, error)
    GetEdges(context.Context, *GetEdgesRequest) (*GetEdgesResponse, error)
    DeleteEdge(context.Context, *DeleteEdgeRequest) (*StatusResponse, error)
    // Graph Traversal methods
    TraverseEdges(context.Context, *TraverseEdgesRequest) (*TraverseEdgesResponse, error)
    FindShortestPath(context.Context, *ShortestPathRequest) (*ShortestPathResponse, error)
    AnalyzeImpact(context.Context, *ImpactAnalysisRequest) (*ImpactAnalysisResponse, error)
    // Bundle methods
    CreateBundle(context.Context, *CreateBundleRequest) (*ItemResponse, error)
    AddBundleMember(context.Context, *AddBundleMemberRequest) (*AddBundleMemberResponse, error)
    RemoveBundleMember(context.Context, *RemoveBundleMemberRequest) (*RemoveBundleMemberResponse, error)
    GetBundleMembers(context.Context, *GetBundleMembersRequest) (*GetBundleMembersResponse, error)
    GetBundleHistory(context.Context, *GetBundleHistoryRequest) (*GetBundleHistoryResponse, error)
    // Tenant methods
    GetTenantUsage(context.Context, *GetTenantUsageRequest) (*TenantUsageResponse, error)
    // Event Streaming
    EventStream(*EventStreamRequest, grpc.ServerStreamingServer[Event]) error
    // Get event streaming capabilities for the authenticated tenant's tier
    GetEventCapabilities(context.Context, *GetEventCapabilitiesRequest) (*EventCapabilities, error)
    // Deprecation methods
    SetDeprecated(context.Context, *SetDeprecatedRequest) (*StatusResponse, error)
    // contains filtered or unexported methods
}

type KumihoService_EventStreamClient

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KumihoService_EventStreamClient = grpc.ServerStreamingClient[Event]

type KumihoService_EventStreamServer

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KumihoService_EventStreamServer = grpc.ServerStreamingServer[Event]

type PaginationRequest

Pagination parameters for list requests

type PaginationRequest struct {

    // Maximum number of items to return (default: 100, max: 1000)
    PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
    // Cursor for the next page (opaque string from previous response)
    Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
    // contains filtered or unexported fields
}

func (*PaginationRequest) Descriptor

func (*PaginationRequest) Descriptor() ([]byte, []int)

Deprecated: Use PaginationRequest.ProtoReflect.Descriptor instead.

func (*PaginationRequest) GetCursor

func (x *PaginationRequest) GetCursor() string

func (*PaginationRequest) GetPageSize

func (x *PaginationRequest) GetPageSize() int32

func (*PaginationRequest) ProtoMessage

func (*PaginationRequest) ProtoMessage()

func (*PaginationRequest) ProtoReflect

func (x *PaginationRequest) ProtoReflect() protoreflect.Message

func (*PaginationRequest) Reset

func (x *PaginationRequest) Reset()

func (*PaginationRequest) String

func (x *PaginationRequest) String() string

type PaginationResponse

Pagination info in list responses

type PaginationResponse struct {

    // Cursor for the next page, empty if no more results
    NextCursor string `protobuf:"bytes,1,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
    // Whether there are more results available
    HasMore bool `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
    // Total count of items (if available, -1 if unknown)
    TotalCount int32 `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
    // contains filtered or unexported fields
}

func (*PaginationResponse) Descriptor

func (*PaginationResponse) Descriptor() ([]byte, []int)

Deprecated: Use PaginationResponse.ProtoReflect.Descriptor instead.

func (*PaginationResponse) GetHasMore

func (x *PaginationResponse) GetHasMore() bool

func (*PaginationResponse) GetNextCursor

func (x *PaginationResponse) GetNextCursor() string

func (*PaginationResponse) GetTotalCount

func (x *PaginationResponse) GetTotalCount() int32

func (*PaginationResponse) ProtoMessage

func (*PaginationResponse) ProtoMessage()

func (*PaginationResponse) ProtoReflect

func (x *PaginationResponse) ProtoReflect() protoreflect.Message

func (*PaginationResponse) Reset

func (x *PaginationResponse) Reset()

func (*PaginationResponse) String

func (x *PaginationResponse) String() string

type PathStep

Represents a single step in a traversal path

type PathStep struct {
    RevisionKref *Kref  `protobuf:"bytes,1,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    EdgeType     string `protobuf:"bytes,2,opt,name=edge_type,json=edgeType,proto3" json:"edge_type,omitempty"` // The relationship type used to reach this node
    Depth        int32  `protobuf:"varint,3,opt,name=depth,proto3" json:"depth,omitempty"`                      // Distance from the origin (0 = origin)
    // contains filtered or unexported fields
}

func (*PathStep) Descriptor

func (*PathStep) Descriptor() ([]byte, []int)

Deprecated: Use PathStep.ProtoReflect.Descriptor instead.

func (*PathStep) GetDepth

func (x *PathStep) GetDepth() int32

func (*PathStep) GetEdgeType

func (x *PathStep) GetEdgeType() string

func (*PathStep) GetRevisionKref

func (x *PathStep) GetRevisionKref() *Kref

func (*PathStep) ProtoMessage

func (*PathStep) ProtoMessage()

func (*PathStep) ProtoReflect

func (x *PathStep) ProtoReflect() protoreflect.Message

func (*PathStep) Reset

func (x *PathStep) Reset()

func (*PathStep) String

func (x *PathStep) String() string

type PeekNextRevisionRequest

— Peek Next Revision Messages —

type PeekNextRevisionRequest struct {
    ItemKref *Kref `protobuf:"bytes,1,opt,name=item_kref,json=itemKref,proto3" json:"item_kref,omitempty"`
    // contains filtered or unexported fields
}

func (*PeekNextRevisionRequest) Descriptor

func (*PeekNextRevisionRequest) Descriptor() ([]byte, []int)

Deprecated: Use PeekNextRevisionRequest.ProtoReflect.Descriptor instead.

func (*PeekNextRevisionRequest) GetItemKref

func (x *PeekNextRevisionRequest) GetItemKref() *Kref

func (*PeekNextRevisionRequest) ProtoMessage

func (*PeekNextRevisionRequest) ProtoMessage()

func (*PeekNextRevisionRequest) ProtoReflect

func (x *PeekNextRevisionRequest) ProtoReflect() protoreflect.Message

func (*PeekNextRevisionRequest) Reset

func (x *PeekNextRevisionRequest) Reset()

func (*PeekNextRevisionRequest) String

func (x *PeekNextRevisionRequest) String() string

type PeekNextRevisionResponse

type PeekNextRevisionResponse struct {
    Number int32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
    // contains filtered or unexported fields
}

func (*PeekNextRevisionResponse) Descriptor

func (*PeekNextRevisionResponse) Descriptor() ([]byte, []int)

Deprecated: Use PeekNextRevisionResponse.ProtoReflect.Descriptor instead.

func (*PeekNextRevisionResponse) GetNumber

func (x *PeekNextRevisionResponse) GetNumber() int32

func (*PeekNextRevisionResponse) ProtoMessage

func (*PeekNextRevisionResponse) ProtoMessage()

func (*PeekNextRevisionResponse) ProtoReflect

func (x *PeekNextRevisionResponse) ProtoReflect() protoreflect.Message

func (*PeekNextRevisionResponse) Reset

func (x *PeekNextRevisionResponse) Reset()

func (*PeekNextRevisionResponse) String

func (x *PeekNextRevisionResponse) String() string

type ProjectResponse

type ProjectResponse struct {
    ProjectId   string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
    Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
    CreatedAt   string `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
    UpdatedAt   string `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
    Deprecated  bool   `protobuf:"varint,6,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
    AllowPublic bool   `protobuf:"varint,7,opt,name=allow_public,json=allowPublic,proto3" json:"allow_public,omitempty"`
    // contains filtered or unexported fields
}

func (*ProjectResponse) Descriptor

func (*ProjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProjectResponse.ProtoReflect.Descriptor instead.

func (*ProjectResponse) GetAllowPublic

func (x *ProjectResponse) GetAllowPublic() bool

func (*ProjectResponse) GetCreatedAt

func (x *ProjectResponse) GetCreatedAt() string

func (*ProjectResponse) GetDeprecated

func (x *ProjectResponse) GetDeprecated() bool

func (*ProjectResponse) GetDescription

func (x *ProjectResponse) GetDescription() string

func (*ProjectResponse) GetName

func (x *ProjectResponse) GetName() string

func (*ProjectResponse) GetProjectId

func (x *ProjectResponse) GetProjectId() string

func (*ProjectResponse) GetUpdatedAt

func (x *ProjectResponse) GetUpdatedAt() string

func (*ProjectResponse) ProtoMessage

func (*ProjectResponse) ProtoMessage()

func (*ProjectResponse) ProtoReflect

func (x *ProjectResponse) ProtoReflect() protoreflect.Message

func (*ProjectResponse) Reset

func (x *ProjectResponse) Reset()

func (*ProjectResponse) String

func (x *ProjectResponse) String() string

type RemoveBundleMemberRequest

type RemoveBundleMemberRequest struct {
    BundleKref     *Kref             `protobuf:"bytes,1,opt,name=bundle_kref,json=bundleKref,proto3" json:"bundle_kref,omitempty"`                                                     // The bundle item kref
    MemberItemKref *Kref             `protobuf:"bytes,2,opt,name=member_item_kref,json=memberItemKref,proto3" json:"member_item_kref,omitempty"`                                       // The item to remove
    Metadata       map[string]string `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // Optional metadata for revision tracking
    // contains filtered or unexported fields
}

func (*RemoveBundleMemberRequest) Descriptor

func (*RemoveBundleMemberRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveBundleMemberRequest.ProtoReflect.Descriptor instead.

func (*RemoveBundleMemberRequest) GetBundleKref

func (x *RemoveBundleMemberRequest) GetBundleKref() *Kref

func (*RemoveBundleMemberRequest) GetMemberItemKref

func (x *RemoveBundleMemberRequest) GetMemberItemKref() *Kref

func (*RemoveBundleMemberRequest) GetMetadata

func (x *RemoveBundleMemberRequest) GetMetadata() map[string]string

func (*RemoveBundleMemberRequest) ProtoMessage

func (*RemoveBundleMemberRequest) ProtoMessage()

func (*RemoveBundleMemberRequest) ProtoReflect

func (x *RemoveBundleMemberRequest) ProtoReflect() protoreflect.Message

func (*RemoveBundleMemberRequest) Reset

func (x *RemoveBundleMemberRequest) Reset()

func (*RemoveBundleMemberRequest) String

func (x *RemoveBundleMemberRequest) String() string

type RemoveBundleMemberResponse

type RemoveBundleMemberResponse struct {
    Success     bool              `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
    Message     string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    NewRevision *RevisionResponse `protobuf:"bytes,3,opt,name=new_revision,json=newRevision,proto3" json:"new_revision,omitempty"` // The new revision created for this change
    // contains filtered or unexported fields
}

func (*RemoveBundleMemberResponse) Descriptor

func (*RemoveBundleMemberResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveBundleMemberResponse.ProtoReflect.Descriptor instead.

func (*RemoveBundleMemberResponse) GetMessage

func (x *RemoveBundleMemberResponse) GetMessage() string

func (*RemoveBundleMemberResponse) GetNewRevision

func (x *RemoveBundleMemberResponse) GetNewRevision() *RevisionResponse

func (*RemoveBundleMemberResponse) GetSuccess

func (x *RemoveBundleMemberResponse) GetSuccess() bool

func (*RemoveBundleMemberResponse) ProtoMessage

func (*RemoveBundleMemberResponse) ProtoMessage()

func (*RemoveBundleMemberResponse) ProtoReflect

func (x *RemoveBundleMemberResponse) ProtoReflect() protoreflect.Message

func (*RemoveBundleMemberResponse) Reset

func (x *RemoveBundleMemberResponse) Reset()

func (*RemoveBundleMemberResponse) String

func (x *RemoveBundleMemberResponse) String() string

type ResolveKrefRequest

type ResolveKrefRequest struct {
    Kref string  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Tag  *string `protobuf:"bytes,2,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
    Time *string `protobuf:"bytes,3,opt,name=time,proto3,oneof" json:"time,omitempty"` // Time in YYYYMMDDHHMM format
    // contains filtered or unexported fields
}

func (*ResolveKrefRequest) Descriptor

func (*ResolveKrefRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResolveKrefRequest.ProtoReflect.Descriptor instead.

func (*ResolveKrefRequest) GetKref

func (x *ResolveKrefRequest) GetKref() string

func (*ResolveKrefRequest) GetTag

func (x *ResolveKrefRequest) GetTag() string

func (*ResolveKrefRequest) GetTime

func (x *ResolveKrefRequest) GetTime() string

func (*ResolveKrefRequest) ProtoMessage

func (*ResolveKrefRequest) ProtoMessage()

func (*ResolveKrefRequest) ProtoReflect

func (x *ResolveKrefRequest) ProtoReflect() protoreflect.Message

func (*ResolveKrefRequest) Reset

func (x *ResolveKrefRequest) Reset()

func (*ResolveKrefRequest) String

func (x *ResolveKrefRequest) String() string

type ResolveLocationRequest

type ResolveLocationRequest struct {
    Kref string  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Tag  *string `protobuf:"bytes,2,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
    Time *string `protobuf:"bytes,3,opt,name=time,proto3,oneof" json:"time,omitempty"`
    // contains filtered or unexported fields
}

func (*ResolveLocationRequest) Descriptor

func (*ResolveLocationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResolveLocationRequest.ProtoReflect.Descriptor instead.

func (*ResolveLocationRequest) GetKref

func (x *ResolveLocationRequest) GetKref() string

func (*ResolveLocationRequest) GetTag

func (x *ResolveLocationRequest) GetTag() string

func (*ResolveLocationRequest) GetTime

func (x *ResolveLocationRequest) GetTime() string

func (*ResolveLocationRequest) ProtoMessage

func (*ResolveLocationRequest) ProtoMessage()

func (*ResolveLocationRequest) ProtoReflect

func (x *ResolveLocationRequest) ProtoReflect() protoreflect.Message

func (*ResolveLocationRequest) Reset

func (x *ResolveLocationRequest) Reset()

func (*ResolveLocationRequest) String

func (x *ResolveLocationRequest) String() string

type ResolveLocationResponse

type ResolveLocationResponse struct {
    Location     string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
    ResolvedKref *Kref  `protobuf:"bytes,2,opt,name=resolved_kref,json=resolvedKref,proto3" json:"resolved_kref,omitempty"`
    ArtifactName string `protobuf:"bytes,3,opt,name=artifact_name,json=artifactName,proto3" json:"artifact_name,omitempty"`
    // contains filtered or unexported fields
}

func (*ResolveLocationResponse) Descriptor

func (*ResolveLocationResponse) Descriptor() ([]byte, []int)

Deprecated: Use ResolveLocationResponse.ProtoReflect.Descriptor instead.

func (*ResolveLocationResponse) GetArtifactName

func (x *ResolveLocationResponse) GetArtifactName() string

func (*ResolveLocationResponse) GetLocation

func (x *ResolveLocationResponse) GetLocation() string

func (*ResolveLocationResponse) GetResolvedKref

func (x *ResolveLocationResponse) GetResolvedKref() *Kref

func (*ResolveLocationResponse) ProtoMessage

func (*ResolveLocationResponse) ProtoMessage()

func (*ResolveLocationResponse) ProtoReflect

func (x *ResolveLocationResponse) ProtoReflect() protoreflect.Message

func (*ResolveLocationResponse) Reset

func (x *ResolveLocationResponse) Reset()

func (*ResolveLocationResponse) String

func (x *ResolveLocationResponse) String() string

type RevisionPath

Represents a complete path between two revisions

type RevisionPath struct {
    Steps      []*PathStep `protobuf:"bytes,1,rep,name=steps,proto3" json:"steps,omitempty"`
    TotalDepth int32       `protobuf:"varint,2,opt,name=total_depth,json=totalDepth,proto3" json:"total_depth,omitempty"`
    // contains filtered or unexported fields
}

func (*RevisionPath) Descriptor

func (*RevisionPath) Descriptor() ([]byte, []int)

Deprecated: Use RevisionPath.ProtoReflect.Descriptor instead.

func (*RevisionPath) GetSteps

func (x *RevisionPath) GetSteps() []*PathStep

func (*RevisionPath) GetTotalDepth

func (x *RevisionPath) GetTotalDepth() int32

func (*RevisionPath) ProtoMessage

func (*RevisionPath) ProtoMessage()

func (*RevisionPath) ProtoReflect

func (x *RevisionPath) ProtoReflect() protoreflect.Message

func (*RevisionPath) Reset

func (x *RevisionPath) Reset()

func (*RevisionPath) String

func (x *RevisionPath) String() string

type RevisionResponse

type RevisionResponse struct {
    Kref            *Kref             `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    ItemKref        *Kref             `protobuf:"bytes,2,opt,name=item_kref,json=itemKref,proto3" json:"item_kref,omitempty"`
    Number          int32             `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"`
    Tags            []string          `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
    Metadata        map[string]string `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    CreatedAt       string            `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
    ModifiedAt      string            `protobuf:"bytes,7,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
    Author          string            `protobuf:"bytes,8,opt,name=author,proto3" json:"author,omitempty"`
    Deprecated      bool              `protobuf:"varint,9,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
    Published       bool              `protobuf:"varint,10,opt,name=published,proto3" json:"published,omitempty"`
    Latest          bool              `protobuf:"varint,11,opt,name=latest,proto3" json:"latest,omitempty"`
    Username        string            `protobuf:"bytes,12,opt,name=username,proto3" json:"username,omitempty"`
    DefaultArtifact *string           `protobuf:"bytes,13,opt,name=default_artifact,json=defaultArtifact,proto3,oneof" json:"default_artifact,omitempty"`
    Name            string            `protobuf:"bytes,14,opt,name=name,proto3" json:"name,omitempty"`
    // contains filtered or unexported fields
}

func (*RevisionResponse) Descriptor

func (*RevisionResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevisionResponse.ProtoReflect.Descriptor instead.

func (*RevisionResponse) GetAuthor

func (x *RevisionResponse) GetAuthor() string

func (*RevisionResponse) GetCreatedAt

func (x *RevisionResponse) GetCreatedAt() string

func (*RevisionResponse) GetDefaultArtifact

func (x *RevisionResponse) GetDefaultArtifact() string

func (*RevisionResponse) GetDeprecated

func (x *RevisionResponse) GetDeprecated() bool

func (*RevisionResponse) GetItemKref

func (x *RevisionResponse) GetItemKref() *Kref

func (*RevisionResponse) GetKref

func (x *RevisionResponse) GetKref() *Kref

func (*RevisionResponse) GetLatest

func (x *RevisionResponse) GetLatest() bool

func (*RevisionResponse) GetMetadata

func (x *RevisionResponse) GetMetadata() map[string]string

func (*RevisionResponse) GetModifiedAt

func (x *RevisionResponse) GetModifiedAt() string

func (*RevisionResponse) GetName

func (x *RevisionResponse) GetName() string

func (*RevisionResponse) GetNumber

func (x *RevisionResponse) GetNumber() int32

func (*RevisionResponse) GetPublished

func (x *RevisionResponse) GetPublished() bool

func (*RevisionResponse) GetTags

func (x *RevisionResponse) GetTags() []string

func (*RevisionResponse) GetUsername

func (x *RevisionResponse) GetUsername() string

func (*RevisionResponse) ProtoMessage

func (*RevisionResponse) ProtoMessage()

func (*RevisionResponse) ProtoReflect

func (x *RevisionResponse) ProtoReflect() protoreflect.Message

func (*RevisionResponse) Reset

func (x *RevisionResponse) Reset()

func (*RevisionResponse) String

func (x *RevisionResponse) String() string

type ScoreRevisionsRequest

type ScoreRevisionsRequest struct {

    // Query to score revisions against
    Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
    // Revisions to score (max 100)
    RevisionKrefs []*Kref `protobuf:"bytes,2,rep,name=revision_krefs,json=revisionKrefs,proto3" json:"revision_krefs,omitempty"`
    // When non-empty, re-embed revisions from ONLY these metadata fields
    // instead of using the stored (broad) embedding.  Enables focused
    // scoring — e.g. ["title", "summary"] strips implications/events
    // so the most directly relevant revision ranks highest.
    // When empty (default), uses stored embeddings (current behavior).
    ScoreFields []string `protobuf:"bytes,3,rep,name=score_fields,json=scoreFields,proto3" json:"score_fields,omitempty"`
    // contains filtered or unexported fields
}

func (*ScoreRevisionsRequest) Descriptor

func (*ScoreRevisionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ScoreRevisionsRequest.ProtoReflect.Descriptor instead.

func (*ScoreRevisionsRequest) GetQuery

func (x *ScoreRevisionsRequest) GetQuery() string

func (*ScoreRevisionsRequest) GetRevisionKrefs

func (x *ScoreRevisionsRequest) GetRevisionKrefs() []*Kref

func (*ScoreRevisionsRequest) GetScoreFields

func (x *ScoreRevisionsRequest) GetScoreFields() []string

func (*ScoreRevisionsRequest) ProtoMessage

func (*ScoreRevisionsRequest) ProtoMessage()

func (*ScoreRevisionsRequest) ProtoReflect

func (x *ScoreRevisionsRequest) ProtoReflect() protoreflect.Message

func (*ScoreRevisionsRequest) Reset

func (x *ScoreRevisionsRequest) Reset()

func (*ScoreRevisionsRequest) String

func (x *ScoreRevisionsRequest) String() string

type ScoreRevisionsResponse

type ScoreRevisionsResponse struct {

    // Scored revisions ordered by score DESC
    ScoredRevisions []*ScoredRevision `protobuf:"bytes,1,rep,name=scored_revisions,json=scoredRevisions,proto3" json:"scored_revisions,omitempty"`
    // Overall search mode used: "vector", "fulltext", "hybrid", or "none"
    SearchMode string `protobuf:"bytes,2,opt,name=search_mode,json=searchMode,proto3" json:"search_mode,omitempty"`
    // contains filtered or unexported fields
}

func (*ScoreRevisionsResponse) Descriptor

func (*ScoreRevisionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ScoreRevisionsResponse.ProtoReflect.Descriptor instead.

func (*ScoreRevisionsResponse) GetScoredRevisions

func (x *ScoreRevisionsResponse) GetScoredRevisions() []*ScoredRevision

func (*ScoreRevisionsResponse) GetSearchMode

func (x *ScoreRevisionsResponse) GetSearchMode() string

func (*ScoreRevisionsResponse) ProtoMessage

func (*ScoreRevisionsResponse) ProtoMessage()

func (*ScoreRevisionsResponse) ProtoReflect

func (x *ScoreRevisionsResponse) ProtoReflect() protoreflect.Message

func (*ScoreRevisionsResponse) Reset

func (x *ScoreRevisionsResponse) Reset()

func (*ScoreRevisionsResponse) String

func (x *ScoreRevisionsResponse) String() string

type ScoredRevision

type ScoredRevision struct {

    // The revision kref
    Kref *Kref `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    // Relevance score (0.0 - 1.0)
    Score float32 `protobuf:"fixed32,2,opt,name=score,proto3" json:"score,omitempty"`
    // How the score was computed: "vector", "fulltext", or "hybrid"
    ScoreMethod string `protobuf:"bytes,3,opt,name=score_method,json=scoreMethod,proto3" json:"score_method,omitempty"`
    // contains filtered or unexported fields
}

func (*ScoredRevision) Descriptor

func (*ScoredRevision) Descriptor() ([]byte, []int)

Deprecated: Use ScoredRevision.ProtoReflect.Descriptor instead.

func (*ScoredRevision) GetKref

func (x *ScoredRevision) GetKref() *Kref

func (*ScoredRevision) GetScore

func (x *ScoredRevision) GetScore() float32

func (*ScoredRevision) GetScoreMethod

func (x *ScoredRevision) GetScoreMethod() string

func (*ScoredRevision) ProtoMessage

func (*ScoredRevision) ProtoMessage()

func (*ScoredRevision) ProtoReflect

func (x *ScoredRevision) ProtoReflect() protoreflect.Message

func (*ScoredRevision) Reset

func (x *ScoredRevision) Reset()

func (*ScoredRevision) String

func (x *ScoredRevision) String() string

type SearchRequest

type SearchRequest struct {

    // Search query string (supports Lucene syntax for advanced users)
    // Simple usage: "hero model" finds items matching both terms
    // Fuzzy matching is automatic - typos like "heros" will match "hero"
    Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
    // Optional: Restrict search to a kref prefix (e.g., "myproject/assets")
    ContextFilter string `protobuf:"bytes,2,opt,name=context_filter,json=contextFilter,proto3" json:"context_filter,omitempty"`
    // Optional: Filter by exact item kind (e.g., "model", "texture", "rig")
    KindFilter string `protobuf:"bytes,3,opt,name=kind_filter,json=kindFilter,proto3" json:"kind_filter,omitempty"`
    // Include soft-deleted (deprecated) items in results
    IncludeDeprecated bool `protobuf:"varint,4,opt,name=include_deprecated,json=includeDeprecated,proto3" json:"include_deprecated,omitempty"`
    // Pagination parameters
    Pagination *PaginationRequest `protobuf:"bytes,5,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // Minimum relevance score (0.0 to 1.0, default 0.0 returns all matches)
    MinScore float32 `protobuf:"fixed32,6,opt,name=min_score,json=minScore,proto3" json:"min_score,omitempty"`
    // Search depth options - control performance vs completeness tradeoff
    // Default: Only search Item index (fastest)
    // When enabled, also searches Revision/Artifact metadata (slower but more comprehensive)
    IncludeRevisionMetadata bool `protobuf:"varint,7,opt,name=include_revision_metadata,json=includeRevisionMetadata,proto3" json:"include_revision_metadata,omitempty"`
    IncludeArtifactMetadata bool `protobuf:"varint,8,opt,name=include_artifact_metadata,json=includeArtifactMetadata,proto3" json:"include_artifact_metadata,omitempty"`
    // contains filtered or unexported fields
}

func (*SearchRequest) Descriptor

func (*SearchRequest) Descriptor() ([]byte, []int)

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetContextFilter

func (x *SearchRequest) GetContextFilter() string

func (*SearchRequest) GetIncludeArtifactMetadata

func (x *SearchRequest) GetIncludeArtifactMetadata() bool

func (*SearchRequest) GetIncludeDeprecated

func (x *SearchRequest) GetIncludeDeprecated() bool

func (*SearchRequest) GetIncludeRevisionMetadata

func (x *SearchRequest) GetIncludeRevisionMetadata() bool

func (*SearchRequest) GetKindFilter

func (x *SearchRequest) GetKindFilter() string

func (*SearchRequest) GetMinScore

func (x *SearchRequest) GetMinScore() float32

func (*SearchRequest) GetPagination

func (x *SearchRequest) GetPagination() *PaginationRequest

func (*SearchRequest) GetQuery

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) ProtoMessage

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect

func (x *SearchRequest) ProtoReflect() protoreflect.Message

func (*SearchRequest) Reset

func (x *SearchRequest) Reset()

func (*SearchRequest) String

func (x *SearchRequest) String() string

type SearchResponse

type SearchResponse struct {

    // Search results ordered by relevance score (highest first)
    Results []*SearchResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
    // Pagination info
    Pagination *PaginationResponse `protobuf:"bytes,2,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
    // Search mode used: "fulltext" (Lucene only) or "hybrid" (fulltext + vector)
    // Hybrid mode is available for STUDIO+ tiers with vector embeddings enabled
    SearchMode *string `protobuf:"bytes,3,opt,name=search_mode,json=searchMode,proto3,oneof" json:"search_mode,omitempty"`
    // contains filtered or unexported fields
}

func (*SearchResponse) Descriptor

func (*SearchResponse) Descriptor() ([]byte, []int)

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetPagination

func (x *SearchResponse) GetPagination() *PaginationResponse

func (*SearchResponse) GetResults

func (x *SearchResponse) GetResults() []*SearchResult

func (*SearchResponse) GetSearchMode

func (x *SearchResponse) GetSearchMode() string

func (*SearchResponse) ProtoMessage

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect

func (x *SearchResponse) ProtoReflect() protoreflect.Message

func (*SearchResponse) Reset

func (x *SearchResponse) Reset()

func (*SearchResponse) String

func (x *SearchResponse) String() string

type SearchResult

type SearchResult struct {

    // The matched item (search always returns Items, even when matching on revision/artifact metadata)
    Item *ItemResponse `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
    // Relevance score from Lucene (higher = better match)
    Score float32 `protobuf:"fixed32,2,opt,name=score,proto3" json:"score,omitempty"`
    // Where the match was found: "item", "revision", "artifact"
    // Multiple values if matched in multiple places
    MatchedIn []string `protobuf:"bytes,3,rep,name=matched_in,json=matchedIn,proto3" json:"matched_in,omitempty"`
    // contains filtered or unexported fields
}

func (*SearchResult) Descriptor

func (*SearchResult) Descriptor() ([]byte, []int)

Deprecated: Use SearchResult.ProtoReflect.Descriptor instead.

func (*SearchResult) GetItem

func (x *SearchResult) GetItem() *ItemResponse

func (*SearchResult) GetMatchedIn

func (x *SearchResult) GetMatchedIn() []string

func (*SearchResult) GetScore

func (x *SearchResult) GetScore() float32

func (*SearchResult) ProtoMessage

func (*SearchResult) ProtoMessage()

func (*SearchResult) ProtoReflect

func (x *SearchResult) ProtoReflect() protoreflect.Message

func (*SearchResult) Reset

func (x *SearchResult) Reset()

func (*SearchResult) String

func (x *SearchResult) String() string

type SetAttributeRequest

Set a single metadata attribute (upsert)

type SetAttributeRequest struct {
    Kref  *Kref  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
    // contains filtered or unexported fields
}

func (*SetAttributeRequest) Descriptor

func (*SetAttributeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetAttributeRequest.ProtoReflect.Descriptor instead.

func (*SetAttributeRequest) GetKey

func (x *SetAttributeRequest) GetKey() string

func (*SetAttributeRequest) GetKref

func (x *SetAttributeRequest) GetKref() *Kref

func (*SetAttributeRequest) GetValue

func (x *SetAttributeRequest) GetValue() string

func (*SetAttributeRequest) ProtoMessage

func (*SetAttributeRequest) ProtoMessage()

func (*SetAttributeRequest) ProtoReflect

func (x *SetAttributeRequest) ProtoReflect() protoreflect.Message

func (*SetAttributeRequest) Reset

func (x *SetAttributeRequest) Reset()

func (*SetAttributeRequest) String

func (x *SetAttributeRequest) String() string

type SetDefaultArtifactRequest

type SetDefaultArtifactRequest struct {
    RevisionKref *Kref  `protobuf:"bytes,1,opt,name=revision_kref,json=revisionKref,proto3" json:"revision_kref,omitempty"`
    ArtifactName string `protobuf:"bytes,2,opt,name=artifact_name,json=artifactName,proto3" json:"artifact_name,omitempty"`
    // contains filtered or unexported fields
}

func (*SetDefaultArtifactRequest) Descriptor

func (*SetDefaultArtifactRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetDefaultArtifactRequest.ProtoReflect.Descriptor instead.

func (*SetDefaultArtifactRequest) GetArtifactName

func (x *SetDefaultArtifactRequest) GetArtifactName() string

func (*SetDefaultArtifactRequest) GetRevisionKref

func (x *SetDefaultArtifactRequest) GetRevisionKref() *Kref

func (*SetDefaultArtifactRequest) ProtoMessage

func (*SetDefaultArtifactRequest) ProtoMessage()

func (*SetDefaultArtifactRequest) ProtoReflect

func (x *SetDefaultArtifactRequest) ProtoReflect() protoreflect.Message

func (*SetDefaultArtifactRequest) Reset

func (x *SetDefaultArtifactRequest) Reset()

func (*SetDefaultArtifactRequest) String

func (x *SetDefaultArtifactRequest) String() string

type SetDeprecatedRequest

type SetDeprecatedRequest struct {
    Kref       *Kref `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Deprecated bool  `protobuf:"varint,2,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
    // contains filtered or unexported fields
}

func (*SetDeprecatedRequest) Descriptor

func (*SetDeprecatedRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetDeprecatedRequest.ProtoReflect.Descriptor instead.

func (*SetDeprecatedRequest) GetDeprecated

func (x *SetDeprecatedRequest) GetDeprecated() bool

func (*SetDeprecatedRequest) GetKref

func (x *SetDeprecatedRequest) GetKref() *Kref

func (*SetDeprecatedRequest) ProtoMessage

func (*SetDeprecatedRequest) ProtoMessage()

func (*SetDeprecatedRequest) ProtoReflect

func (x *SetDeprecatedRequest) ProtoReflect() protoreflect.Message

func (*SetDeprecatedRequest) Reset

func (x *SetDeprecatedRequest) Reset()

func (*SetDeprecatedRequest) String

func (x *SetDeprecatedRequest) String() string

type ShortestPathRequest

Request for shortest path between two revisions

type ShortestPathRequest struct {
    SourceKref     *Kref    `protobuf:"bytes,1,opt,name=source_kref,json=sourceKref,proto3" json:"source_kref,omitempty"`
    TargetKref     *Kref    `protobuf:"bytes,2,opt,name=target_kref,json=targetKref,proto3" json:"target_kref,omitempty"`
    EdgeTypeFilter []string `protobuf:"bytes,3,rep,name=edge_type_filter,json=edgeTypeFilter,proto3" json:"edge_type_filter,omitempty"` // Filter by edge types (empty = all)
    MaxDepth       int32    `protobuf:"varint,4,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`                    // Maximum path length to search (default: 10)
    AllShortest    bool     `protobuf:"varint,5,opt,name=all_shortest,json=allShortest,proto3" json:"all_shortest,omitempty"`           // Return all shortest paths, not just one
    // contains filtered or unexported fields
}

func (*ShortestPathRequest) Descriptor

func (*ShortestPathRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShortestPathRequest.ProtoReflect.Descriptor instead.

func (*ShortestPathRequest) GetAllShortest

func (x *ShortestPathRequest) GetAllShortest() bool

func (*ShortestPathRequest) GetEdgeTypeFilter

func (x *ShortestPathRequest) GetEdgeTypeFilter() []string

func (*ShortestPathRequest) GetMaxDepth

func (x *ShortestPathRequest) GetMaxDepth() int32

func (*ShortestPathRequest) GetSourceKref

func (x *ShortestPathRequest) GetSourceKref() *Kref

func (*ShortestPathRequest) GetTargetKref

func (x *ShortestPathRequest) GetTargetKref() *Kref

func (*ShortestPathRequest) ProtoMessage

func (*ShortestPathRequest) ProtoMessage()

func (*ShortestPathRequest) ProtoReflect

func (x *ShortestPathRequest) ProtoReflect() protoreflect.Message

func (*ShortestPathRequest) Reset

func (x *ShortestPathRequest) Reset()

func (*ShortestPathRequest) String

func (x *ShortestPathRequest) String() string

type ShortestPathResponse

type ShortestPathResponse struct {
    Paths      []*RevisionPath `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`                              // One or more shortest paths
    PathExists bool            `protobuf:"varint,2,opt,name=path_exists,json=pathExists,proto3" json:"path_exists,omitempty"` // True if any path was found
    PathLength int32           `protobuf:"varint,3,opt,name=path_length,json=pathLength,proto3" json:"path_length,omitempty"` // Length of shortest path(s)
    // contains filtered or unexported fields
}

func (*ShortestPathResponse) Descriptor

func (*ShortestPathResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShortestPathResponse.ProtoReflect.Descriptor instead.

func (*ShortestPathResponse) GetPathExists

func (x *ShortestPathResponse) GetPathExists() bool

func (*ShortestPathResponse) GetPathLength

func (x *ShortestPathResponse) GetPathLength() int32

func (*ShortestPathResponse) GetPaths

func (x *ShortestPathResponse) GetPaths() []*RevisionPath

func (*ShortestPathResponse) ProtoMessage

func (*ShortestPathResponse) ProtoMessage()

func (*ShortestPathResponse) ProtoReflect

func (x *ShortestPathResponse) ProtoReflect() protoreflect.Message

func (*ShortestPathResponse) Reset

func (x *ShortestPathResponse) Reset()

func (*ShortestPathResponse) String

func (x *ShortestPathResponse) String() string

type SpaceResponse

type SpaceResponse struct {
    Path       string            `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
    CreatedAt  string            `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
    ModifiedAt string            `protobuf:"bytes,3,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
    Author     string            `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
    Metadata   map[string]string `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    Username   string            `protobuf:"bytes,6,opt,name=username,proto3" json:"username,omitempty"`
    Name       string            `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
    Type       string            `protobuf:"bytes,8,opt,name=type,proto3" json:"type,omitempty"` // "root" or "sub"
    // contains filtered or unexported fields
}

func (*SpaceResponse) Descriptor

func (*SpaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use SpaceResponse.ProtoReflect.Descriptor instead.

func (*SpaceResponse) GetAuthor

func (x *SpaceResponse) GetAuthor() string

func (*SpaceResponse) GetCreatedAt

func (x *SpaceResponse) GetCreatedAt() string

func (*SpaceResponse) GetMetadata

func (x *SpaceResponse) GetMetadata() map[string]string

func (*SpaceResponse) GetModifiedAt

func (x *SpaceResponse) GetModifiedAt() string

func (*SpaceResponse) GetName

func (x *SpaceResponse) GetName() string

func (*SpaceResponse) GetPath

func (x *SpaceResponse) GetPath() string

func (*SpaceResponse) GetType

func (x *SpaceResponse) GetType() string

func (*SpaceResponse) GetUsername

func (x *SpaceResponse) GetUsername() string

func (*SpaceResponse) ProtoMessage

func (*SpaceResponse) ProtoMessage()

func (*SpaceResponse) ProtoReflect

func (x *SpaceResponse) ProtoReflect() protoreflect.Message

func (*SpaceResponse) Reset

func (x *SpaceResponse) Reset()

func (*SpaceResponse) String

func (x *SpaceResponse) String() string

type StatusResponse

type StatusResponse struct {
    Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
    Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    // contains filtered or unexported fields
}

func (*StatusResponse) Descriptor

func (*StatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetMessage

func (x *StatusResponse) GetMessage() string

func (*StatusResponse) GetSuccess

func (x *StatusResponse) GetSuccess() bool

func (*StatusResponse) ProtoMessage

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect

func (x *StatusResponse) ProtoReflect() protoreflect.Message

func (*StatusResponse) Reset

func (x *StatusResponse) Reset()

func (*StatusResponse) String

func (x *StatusResponse) String() string

type TagRevisionRequest

type TagRevisionRequest struct {
    Kref *Kref  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Tag  string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
    // contains filtered or unexported fields
}

func (*TagRevisionRequest) Descriptor

func (*TagRevisionRequest) Descriptor() ([]byte, []int)

Deprecated: Use TagRevisionRequest.ProtoReflect.Descriptor instead.

func (*TagRevisionRequest) GetKref

func (x *TagRevisionRequest) GetKref() *Kref

func (*TagRevisionRequest) GetTag

func (x *TagRevisionRequest) GetTag() string

func (*TagRevisionRequest) ProtoMessage

func (*TagRevisionRequest) ProtoMessage()

func (*TagRevisionRequest) ProtoReflect

func (x *TagRevisionRequest) ProtoReflect() protoreflect.Message

func (*TagRevisionRequest) Reset

func (x *TagRevisionRequest) Reset()

func (*TagRevisionRequest) String

func (x *TagRevisionRequest) String() string

type TenantUsageResponse

type TenantUsageResponse struct {
    NodeCount int64  `protobuf:"varint,1,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
    NodeLimit int64  `protobuf:"varint,2,opt,name=node_limit,json=nodeLimit,proto3" json:"node_limit,omitempty"`
    TenantId  string `protobuf:"bytes,3,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
    // contains filtered or unexported fields
}

func (*TenantUsageResponse) Descriptor

func (*TenantUsageResponse) Descriptor() ([]byte, []int)

Deprecated: Use TenantUsageResponse.ProtoReflect.Descriptor instead.

func (*TenantUsageResponse) GetNodeCount

func (x *TenantUsageResponse) GetNodeCount() int64

func (*TenantUsageResponse) GetNodeLimit

func (x *TenantUsageResponse) GetNodeLimit() int64

func (*TenantUsageResponse) GetTenantId

func (x *TenantUsageResponse) GetTenantId() string

func (*TenantUsageResponse) ProtoMessage

func (*TenantUsageResponse) ProtoMessage()

func (*TenantUsageResponse) ProtoReflect

func (x *TenantUsageResponse) ProtoReflect() protoreflect.Message

func (*TenantUsageResponse) Reset

func (x *TenantUsageResponse) Reset()

func (*TenantUsageResponse) String

func (x *TenantUsageResponse) String() string

type TraverseEdgesRequest

Request for transitive dependency/dependents traversal

type TraverseEdgesRequest struct {
    OriginKref     *Kref         `protobuf:"bytes,1,opt,name=origin_kref,json=originKref,proto3" json:"origin_kref,omitempty"`               // Starting revision
    Direction      EdgeDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=kumiho.EdgeDirection" json:"direction,omitempty"`        // OUTGOING = dependencies, INCOMING = dependents
    EdgeTypeFilter []string      `protobuf:"bytes,3,rep,name=edge_type_filter,json=edgeTypeFilter,proto3" json:"edge_type_filter,omitempty"` // Filter by edge types (empty = all)
    MaxDepth       int32         `protobuf:"varint,4,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`                    // Maximum traversal depth (0 = default of 10)
    Limit          int32         `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`                                          // Max results to return (default 100)
    IncludePath    bool          `protobuf:"varint,6,opt,name=include_path,json=includePath,proto3" json:"include_path,omitempty"`           // Whether to include full path info
    // contains filtered or unexported fields
}

func (*TraverseEdgesRequest) Descriptor

func (*TraverseEdgesRequest) Descriptor() ([]byte, []int)

Deprecated: Use TraverseEdgesRequest.ProtoReflect.Descriptor instead.

func (*TraverseEdgesRequest) GetDirection

func (x *TraverseEdgesRequest) GetDirection() EdgeDirection

func (*TraverseEdgesRequest) GetEdgeTypeFilter

func (x *TraverseEdgesRequest) GetEdgeTypeFilter() []string

func (*TraverseEdgesRequest) GetIncludePath

func (x *TraverseEdgesRequest) GetIncludePath() bool

func (*TraverseEdgesRequest) GetLimit

func (x *TraverseEdgesRequest) GetLimit() int32

func (*TraverseEdgesRequest) GetMaxDepth

func (x *TraverseEdgesRequest) GetMaxDepth() int32

func (*TraverseEdgesRequest) GetOriginKref

func (x *TraverseEdgesRequest) GetOriginKref() *Kref

func (*TraverseEdgesRequest) ProtoMessage

func (*TraverseEdgesRequest) ProtoMessage()

func (*TraverseEdgesRequest) ProtoReflect

func (x *TraverseEdgesRequest) ProtoReflect() protoreflect.Message

func (*TraverseEdgesRequest) Reset

func (x *TraverseEdgesRequest) Reset()

func (*TraverseEdgesRequest) String

func (x *TraverseEdgesRequest) String() string

type TraverseEdgesResponse

type TraverseEdgesResponse struct {
    Paths         []*RevisionPath `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`                                      // If include_path=true
    RevisionKrefs []*Kref         `protobuf:"bytes,2,rep,name=revision_krefs,json=revisionKrefs,proto3" json:"revision_krefs,omitempty"` // Flat list of discovered revisions
    Edges         []*Edge         `protobuf:"bytes,3,rep,name=edges,proto3" json:"edges,omitempty"`                                      // All traversed edges
    TotalCount    int32           `protobuf:"varint,4,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`         // Total nodes found
    Truncated     bool            `protobuf:"varint,5,opt,name=truncated,proto3" json:"truncated,omitempty"`                             // True if results were limited
    // contains filtered or unexported fields
}

func (*TraverseEdgesResponse) Descriptor

func (*TraverseEdgesResponse) Descriptor() ([]byte, []int)

Deprecated: Use TraverseEdgesResponse.ProtoReflect.Descriptor instead.

func (*TraverseEdgesResponse) GetEdges

func (x *TraverseEdgesResponse) GetEdges() []*Edge

func (*TraverseEdgesResponse) GetPaths

func (x *TraverseEdgesResponse) GetPaths() []*RevisionPath

func (*TraverseEdgesResponse) GetRevisionKrefs

func (x *TraverseEdgesResponse) GetRevisionKrefs() []*Kref

func (*TraverseEdgesResponse) GetTotalCount

func (x *TraverseEdgesResponse) GetTotalCount() int32

func (*TraverseEdgesResponse) GetTruncated

func (x *TraverseEdgesResponse) GetTruncated() bool

func (*TraverseEdgesResponse) ProtoMessage

func (*TraverseEdgesResponse) ProtoMessage()

func (*TraverseEdgesResponse) ProtoReflect

func (x *TraverseEdgesResponse) ProtoReflect() protoreflect.Message

func (*TraverseEdgesResponse) Reset

func (x *TraverseEdgesResponse) Reset()

func (*TraverseEdgesResponse) String

func (x *TraverseEdgesResponse) String() string

type UnTagRevisionRequest

type UnTagRevisionRequest struct {
    Kref *Kref  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Tag  string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
    // contains filtered or unexported fields
}

func (*UnTagRevisionRequest) Descriptor

func (*UnTagRevisionRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnTagRevisionRequest.ProtoReflect.Descriptor instead.

func (*UnTagRevisionRequest) GetKref

func (x *UnTagRevisionRequest) GetKref() *Kref

func (*UnTagRevisionRequest) GetTag

func (x *UnTagRevisionRequest) GetTag() string

func (*UnTagRevisionRequest) ProtoMessage

func (*UnTagRevisionRequest) ProtoMessage()

func (*UnTagRevisionRequest) ProtoReflect

func (x *UnTagRevisionRequest) ProtoReflect() protoreflect.Message

func (*UnTagRevisionRequest) Reset

func (x *UnTagRevisionRequest) Reset()

func (*UnTagRevisionRequest) String

func (x *UnTagRevisionRequest) String() string

type UnimplementedKumihoServiceServer

UnimplementedKumihoServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

type UnimplementedKumihoServiceServer struct{}

func (UnimplementedKumihoServiceServer) AddBundleMember

func (UnimplementedKumihoServiceServer) AddBundleMember(context.Context, *AddBundleMemberRequest) (*AddBundleMemberResponse, error)

func (UnimplementedKumihoServiceServer) AnalyzeImpact

func (UnimplementedKumihoServiceServer) AnalyzeImpact(context.Context, *ImpactAnalysisRequest) (*ImpactAnalysisResponse, error)

func (UnimplementedKumihoServiceServer) BatchGetRevisions

func (UnimplementedKumihoServiceServer) BatchGetRevisions(context.Context, *BatchGetRevisionsRequest) (*BatchGetRevisionsResponse, error)

func (UnimplementedKumihoServiceServer) CreateArtifact

func (UnimplementedKumihoServiceServer) CreateArtifact(context.Context, *CreateArtifactRequest) (*ArtifactResponse, error)

func (UnimplementedKumihoServiceServer) CreateBundle

func (UnimplementedKumihoServiceServer) CreateBundle(context.Context, *CreateBundleRequest) (*ItemResponse, error)

func (UnimplementedKumihoServiceServer) CreateEdge

func (UnimplementedKumihoServiceServer) CreateEdge(context.Context, *CreateEdgeRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) CreateItem

func (UnimplementedKumihoServiceServer) CreateItem(context.Context, *CreateItemRequest) (*ItemResponse, error)

func (UnimplementedKumihoServiceServer) CreateProject

func (UnimplementedKumihoServiceServer) CreateProject(context.Context, *CreateProjectRequest) (*ProjectResponse, error)

func (UnimplementedKumihoServiceServer) CreateRevision

func (UnimplementedKumihoServiceServer) CreateRevision(context.Context, *CreateRevisionRequest) (*RevisionResponse, error)

func (UnimplementedKumihoServiceServer) CreateSpace

func (UnimplementedKumihoServiceServer) CreateSpace(context.Context, *CreateSpaceRequest) (*SpaceResponse, error)

func (UnimplementedKumihoServiceServer) DeleteArtifact

func (UnimplementedKumihoServiceServer) DeleteArtifact(context.Context, *DeleteArtifactRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) DeleteAttribute

func (UnimplementedKumihoServiceServer) DeleteAttribute(context.Context, *DeleteAttributeRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) DeleteEdge

func (UnimplementedKumihoServiceServer) DeleteEdge(context.Context, *DeleteEdgeRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) DeleteItem

func (UnimplementedKumihoServiceServer) DeleteItem(context.Context, *DeleteItemRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) DeleteProject

func (UnimplementedKumihoServiceServer) DeleteProject(context.Context, *DeleteProjectRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) DeleteRevision

func (UnimplementedKumihoServiceServer) DeleteRevision(context.Context, *DeleteRevisionRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) DeleteSpace

func (UnimplementedKumihoServiceServer) DeleteSpace(context.Context, *DeleteSpaceRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) EventStream

func (UnimplementedKumihoServiceServer) EventStream(*EventStreamRequest, grpc.ServerStreamingServer[Event]) error

func (UnimplementedKumihoServiceServer) FindShortestPath

func (UnimplementedKumihoServiceServer) FindShortestPath(context.Context, *ShortestPathRequest) (*ShortestPathResponse, error)

func (UnimplementedKumihoServiceServer) GetArtifact

func (UnimplementedKumihoServiceServer) GetArtifact(context.Context, *GetArtifactRequest) (*ArtifactResponse, error)

func (UnimplementedKumihoServiceServer) GetArtifacts

func (UnimplementedKumihoServiceServer) GetArtifacts(context.Context, *GetArtifactsRequest) (*GetArtifactsResponse, error)

func (UnimplementedKumihoServiceServer) GetArtifactsByLocation

func (UnimplementedKumihoServiceServer) GetArtifactsByLocation(context.Context, *GetArtifactsByLocationRequest) (*GetArtifactsByLocationResponse, error)

func (UnimplementedKumihoServiceServer) GetAttribute

func (UnimplementedKumihoServiceServer) GetAttribute(context.Context, *GetAttributeRequest) (*GetAttributeResponse, error)

func (UnimplementedKumihoServiceServer) GetBundleHistory

func (UnimplementedKumihoServiceServer) GetBundleHistory(context.Context, *GetBundleHistoryRequest) (*GetBundleHistoryResponse, error)

func (UnimplementedKumihoServiceServer) GetBundleMembers

func (UnimplementedKumihoServiceServer) GetBundleMembers(context.Context, *GetBundleMembersRequest) (*GetBundleMembersResponse, error)

func (UnimplementedKumihoServiceServer) GetChildSpaces

func (UnimplementedKumihoServiceServer) GetChildSpaces(context.Context, *GetChildSpacesRequest) (*GetChildSpacesResponse, error)

func (UnimplementedKumihoServiceServer) GetEdges

func (UnimplementedKumihoServiceServer) GetEdges(context.Context, *GetEdgesRequest) (*GetEdgesResponse, error)

func (UnimplementedKumihoServiceServer) GetEventCapabilities

func (UnimplementedKumihoServiceServer) GetEventCapabilities(context.Context, *GetEventCapabilitiesRequest) (*EventCapabilities, error)

func (UnimplementedKumihoServiceServer) GetItem

func (UnimplementedKumihoServiceServer) GetItem(context.Context, *GetItemRequest) (*ItemResponse, error)

func (UnimplementedKumihoServiceServer) GetItems

func (UnimplementedKumihoServiceServer) GetItems(context.Context, *GetItemsRequest) (*GetItemsResponse, error)

func (UnimplementedKumihoServiceServer) GetProjects

func (UnimplementedKumihoServiceServer) GetProjects(context.Context, *GetProjectsRequest) (*GetProjectsResponse, error)

func (UnimplementedKumihoServiceServer) GetRevision

func (UnimplementedKumihoServiceServer) GetRevision(context.Context, *KrefRequest) (*RevisionResponse, error)

func (UnimplementedKumihoServiceServer) GetRevisions

func (UnimplementedKumihoServiceServer) GetRevisions(context.Context, *GetRevisionsRequest) (*GetRevisionsResponse, error)

func (UnimplementedKumihoServiceServer) GetSpace

func (UnimplementedKumihoServiceServer) GetSpace(context.Context, *GetSpaceRequest) (*SpaceResponse, error)

func (UnimplementedKumihoServiceServer) GetTenantUsage

func (UnimplementedKumihoServiceServer) GetTenantUsage(context.Context, *GetTenantUsageRequest) (*TenantUsageResponse, error)

func (UnimplementedKumihoServiceServer) HasTag

func (UnimplementedKumihoServiceServer) HasTag(context.Context, *HasTagRequest) (*HasTagResponse, error)

func (UnimplementedKumihoServiceServer) ItemSearch

func (UnimplementedKumihoServiceServer) ItemSearch(context.Context, *ItemSearchRequest) (*GetItemsResponse, error)

func (UnimplementedKumihoServiceServer) PeekNextRevision

func (UnimplementedKumihoServiceServer) PeekNextRevision(context.Context, *PeekNextRevisionRequest) (*PeekNextRevisionResponse, error)

func (UnimplementedKumihoServiceServer) RemoveBundleMember

func (UnimplementedKumihoServiceServer) RemoveBundleMember(context.Context, *RemoveBundleMemberRequest) (*RemoveBundleMemberResponse, error)

func (UnimplementedKumihoServiceServer) ResolveKref

func (UnimplementedKumihoServiceServer) ResolveKref(context.Context, *ResolveKrefRequest) (*RevisionResponse, error)

func (UnimplementedKumihoServiceServer) ResolveLocation

func (UnimplementedKumihoServiceServer) ResolveLocation(context.Context, *ResolveLocationRequest) (*ResolveLocationResponse, error)

func (UnimplementedKumihoServiceServer) ScoreRevisions

func (UnimplementedKumihoServiceServer) ScoreRevisions(context.Context, *ScoreRevisionsRequest) (*ScoreRevisionsResponse, error)

func (UnimplementedKumihoServiceServer) SetAttribute

func (UnimplementedKumihoServiceServer) SetAttribute(context.Context, *SetAttributeRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) SetDefaultArtifact

func (UnimplementedKumihoServiceServer) SetDefaultArtifact(context.Context, *SetDefaultArtifactRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) SetDeprecated

func (UnimplementedKumihoServiceServer) SetDeprecated(context.Context, *SetDeprecatedRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) TagRevision

func (UnimplementedKumihoServiceServer) TagRevision(context.Context, *TagRevisionRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) TraverseEdges

func (UnimplementedKumihoServiceServer) TraverseEdges(context.Context, *TraverseEdgesRequest) (*TraverseEdgesResponse, error)

func (UnimplementedKumihoServiceServer) UnTagRevision

func (UnimplementedKumihoServiceServer) UnTagRevision(context.Context, *UnTagRevisionRequest) (*StatusResponse, error)

func (UnimplementedKumihoServiceServer) UpdateArtifactMetadata

func (UnimplementedKumihoServiceServer) UpdateArtifactMetadata(context.Context, *UpdateMetadataRequest) (*ArtifactResponse, error)

func (UnimplementedKumihoServiceServer) UpdateItemMetadata

func (UnimplementedKumihoServiceServer) UpdateItemMetadata(context.Context, *UpdateMetadataRequest) (*ItemResponse, error)

func (UnimplementedKumihoServiceServer) UpdateProject

func (UnimplementedKumihoServiceServer) UpdateProject(context.Context, *UpdateProjectRequest) (*ProjectResponse, error)

func (UnimplementedKumihoServiceServer) UpdateRevisionMetadata

func (UnimplementedKumihoServiceServer) UpdateRevisionMetadata(context.Context, *UpdateMetadataRequest) (*RevisionResponse, error)

func (UnimplementedKumihoServiceServer) UpdateSpaceMetadata

func (UnimplementedKumihoServiceServer) UpdateSpaceMetadata(context.Context, *UpdateMetadataRequest) (*SpaceResponse, error)

func (UnimplementedKumihoServiceServer) WasTagged

func (UnimplementedKumihoServiceServer) WasTagged(context.Context, *WasTaggedRequest) (*WasTaggedResponse, error)

type UnsafeKumihoServiceServer

UnsafeKumihoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KumihoServiceServer will result in compilation errors.

type UnsafeKumihoServiceServer interface {
    // contains filtered or unexported methods
}

type UpdateMetadataRequest

— Metadata Update Messages —

type UpdateMetadataRequest struct {
    Kref     *Kref             `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Metadata map[string]string `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    // contains filtered or unexported fields
}

func (*UpdateMetadataRequest) Descriptor

func (*UpdateMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateMetadataRequest.ProtoReflect.Descriptor instead.

func (*UpdateMetadataRequest) GetKref

func (x *UpdateMetadataRequest) GetKref() *Kref

func (*UpdateMetadataRequest) GetMetadata

func (x *UpdateMetadataRequest) GetMetadata() map[string]string

func (*UpdateMetadataRequest) ProtoMessage

func (*UpdateMetadataRequest) ProtoMessage()

func (*UpdateMetadataRequest) ProtoReflect

func (x *UpdateMetadataRequest) ProtoReflect() protoreflect.Message

func (*UpdateMetadataRequest) Reset

func (x *UpdateMetadataRequest) Reset()

func (*UpdateMetadataRequest) String

func (x *UpdateMetadataRequest) String() string

type UpdateProjectRequest

type UpdateProjectRequest struct {
    ProjectId   string  `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    AllowPublic *bool   `protobuf:"varint,2,opt,name=allow_public,json=allowPublic,proto3,oneof" json:"allow_public,omitempty"`
    Description *string `protobuf:"bytes,3,opt,name=description,proto3,oneof" json:"description,omitempty"`
    // contains filtered or unexported fields
}

func (*UpdateProjectRequest) Descriptor

func (*UpdateProjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateProjectRequest.ProtoReflect.Descriptor instead.

func (*UpdateProjectRequest) GetAllowPublic

func (x *UpdateProjectRequest) GetAllowPublic() bool

func (*UpdateProjectRequest) GetDescription

func (x *UpdateProjectRequest) GetDescription() string

func (*UpdateProjectRequest) GetProjectId

func (x *UpdateProjectRequest) GetProjectId() string

func (*UpdateProjectRequest) ProtoMessage

func (*UpdateProjectRequest) ProtoMessage()

func (*UpdateProjectRequest) ProtoReflect

func (x *UpdateProjectRequest) ProtoReflect() protoreflect.Message

func (*UpdateProjectRequest) Reset

func (x *UpdateProjectRequest) Reset()

func (*UpdateProjectRequest) String

func (x *UpdateProjectRequest) String() string

type WasTaggedRequest

type WasTaggedRequest struct {
    Kref *Kref  `protobuf:"bytes,1,opt,name=kref,proto3" json:"kref,omitempty"`
    Tag  string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
    // contains filtered or unexported fields
}

func (*WasTaggedRequest) Descriptor

func (*WasTaggedRequest) Descriptor() ([]byte, []int)

Deprecated: Use WasTaggedRequest.ProtoReflect.Descriptor instead.

func (*WasTaggedRequest) GetKref

func (x *WasTaggedRequest) GetKref() *Kref

func (*WasTaggedRequest) GetTag

func (x *WasTaggedRequest) GetTag() string

func (*WasTaggedRequest) ProtoMessage

func (*WasTaggedRequest) ProtoMessage()

func (*WasTaggedRequest) ProtoReflect

func (x *WasTaggedRequest) ProtoReflect() protoreflect.Message

func (*WasTaggedRequest) Reset

func (x *WasTaggedRequest) Reset()

func (*WasTaggedRequest) String

func (x *WasTaggedRequest) String() string

type WasTaggedResponse

type WasTaggedResponse struct {
    WasTagged bool `protobuf:"varint,1,opt,name=was_tagged,json=wasTagged,proto3" json:"was_tagged,omitempty"`
    // contains filtered or unexported fields
}

func (*WasTaggedResponse) Descriptor

func (*WasTaggedResponse) Descriptor() ([]byte, []int)

Deprecated: Use WasTaggedResponse.ProtoReflect.Descriptor instead.

func (*WasTaggedResponse) GetWasTagged

func (x *WasTaggedResponse) GetWasTagged() bool

func (*WasTaggedResponse) ProtoMessage

func (*WasTaggedResponse) ProtoMessage()

func (*WasTaggedResponse) ProtoReflect

func (x *WasTaggedResponse) ProtoReflect() protoreflect.Message

func (*WasTaggedResponse) Reset

func (x *WasTaggedResponse) Reset()

func (*WasTaggedResponse) String

func (x *WasTaggedResponse) String() string

quickstart

import "github.com/KumihoIO/kumiho-SDKs/go/examples/quickstart"

Quickstart for the Kumiho Go SDK.

KUMIHO_SERVER_ENDPOINT=localhost:8080 go run ./examples/quickstart

With cached credentials (`kumiho-cli login`) discovery is automatic:

go run ./examples/quickstart

Index

Generated by gomarkdoc