assetsv1beta2

package
v0.8.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 24, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_gotocompany_assets_v1beta2_application_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_asset_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_bucket_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_common_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_dashboard_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_experiment_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_feature_table_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_group_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_job_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_metric_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_model_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_table_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_topic_proto protoreflect.FileDescriptor
View Source
var File_gotocompany_assets_v1beta2_user_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Application

type Application struct {

	// The service/application's ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Optional: The version of the service.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the service's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the service was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Application) Descriptor deprecated

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

Deprecated: Use Application.ProtoReflect.Descriptor instead.

func (*Application) GetAttributes

func (x *Application) GetAttributes() *structpb.Struct

func (*Application) GetCreateTime

func (x *Application) GetCreateTime() *timestamppb.Timestamp

func (*Application) GetId

func (x *Application) GetId() string

func (*Application) GetUpdateTime

func (x *Application) GetUpdateTime() *timestamppb.Timestamp

func (*Application) GetVersion

func (x *Application) GetVersion() string

func (*Application) ProtoMessage

func (*Application) ProtoMessage()

func (*Application) ProtoReflect

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

func (*Application) Reset

func (x *Application) Reset()

func (*Application) String

func (x *Application) String() string

type Asset

type Asset struct {

	// The unique identifier of the asset.
	// Example: `user:jdoe` or `group:accounting`.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// The name of the asset.
	// Example: `John Doe` or `Accounting`.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The source of the asset.
	// Example: `github` or `bigquery`.
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// The type of the asset.
	// Example: `user` or `group`.
	Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// The REST URL for accessing the resource. URL returns the resource itself.
	// Example: `https://xyz.com/v1/users/user-123`
	Url string `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// The description of the resource.
	// Example: `This resource is being used for storing important number`
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Represents Data in asset, can be of type bucket, dashboard, group ... user
	Data *anypb.Any `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// The ownership of the job.
	// For an example check out Owner.
	Owners []*Owner `protobuf:"bytes,31,rep,name=owners,proto3" json:"owners,omitempty"`
	// The lineage of the job.
	// For an example check out lineage schema.
	Lineage *Lineage `protobuf:"bytes,32,opt,name=lineage,proto3" json:"lineage,omitempty"`
	//Optional. List of labels the user has.
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// The timestamp of the generated event.
	// Event schemas is defined in the common event schema.
	Event *Event `protobuf:"bytes,100,opt,name=event,proto3" json:"event,omitempty"`
	// The timestamp when the asset was created.
	// This information is expected to be maintained by the system.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the asset was last modified.
	// This information is expected to be maintained by the system.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Asset is a resource that represents any type of asset.

func (*Asset) Descriptor deprecated

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

Deprecated: Use Asset.ProtoReflect.Descriptor instead.

func (*Asset) GetCreateTime

func (x *Asset) GetCreateTime() *timestamppb.Timestamp

func (*Asset) GetData

func (x *Asset) GetData() *anypb.Any

func (*Asset) GetDescription

func (x *Asset) GetDescription() string

func (*Asset) GetEvent

func (x *Asset) GetEvent() *Event

func (*Asset) GetLabels

func (x *Asset) GetLabels() map[string]string

func (*Asset) GetLineage

func (x *Asset) GetLineage() *Lineage

func (*Asset) GetName

func (x *Asset) GetName() string

func (*Asset) GetOwners

func (x *Asset) GetOwners() []*Owner

func (*Asset) GetService

func (x *Asset) GetService() string

func (*Asset) GetType

func (x *Asset) GetType() string

func (*Asset) GetUpdateTime

func (x *Asset) GetUpdateTime() *timestamppb.Timestamp

func (*Asset) GetUrl

func (x *Asset) GetUrl() string

func (*Asset) GetUrn

func (x *Asset) GetUrn() string

func (*Asset) ProtoMessage

func (*Asset) ProtoMessage()

func (*Asset) ProtoReflect

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

func (*Asset) Reset

func (x *Asset) Reset()

func (*Asset) String

func (x *Asset) String() string

type Blob

type Blob struct {

	// The URN of the blob.
	// Example: `location/bucket-name/file-name`.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// The name of the blob.
	// Example: `file-name`.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The source of the blob.
	// Example: `gcs`.
	Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	// The length of the object content.
	// Example: `300`
	Size int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	// Delete time of the blob object.
	DeleteTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
	// Expire time of the blob object.
	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,7,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The ownership of the blob.
	// For an example check out ownership.
	Ownership []*Owner `protobuf:"bytes,31,rep,name=ownership,proto3" json:"ownership,omitempty"`
	// The timestamp of the blob's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the blob was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Blob) Descriptor deprecated

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

Deprecated: Use Blob.ProtoReflect.Descriptor instead.

func (*Blob) GetAttributes

func (x *Blob) GetAttributes() *structpb.Struct

func (*Blob) GetCreateTime

func (x *Blob) GetCreateTime() *timestamppb.Timestamp

func (*Blob) GetDeleteTime

func (x *Blob) GetDeleteTime() *timestamppb.Timestamp

func (*Blob) GetExpireTime

func (x *Blob) GetExpireTime() *timestamppb.Timestamp

func (*Blob) GetName

func (x *Blob) GetName() string

func (*Blob) GetOwnership

func (x *Blob) GetOwnership() []*Owner

func (*Blob) GetSize

func (x *Blob) GetSize() int64

func (*Blob) GetSource

func (x *Blob) GetSource() string

func (*Blob) GetUpdateTime

func (x *Blob) GetUpdateTime() *timestamppb.Timestamp

func (*Blob) GetUrn

func (x *Blob) GetUrn() string

func (*Blob) ProtoMessage

func (*Blob) ProtoMessage()

func (*Blob) ProtoReflect

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

func (*Blob) Reset

func (x *Blob) Reset()

func (*Blob) String

func (x *Blob) String() string

type Bucket

type Bucket struct {

	// The description of the bucket.
	// Example: `This bucket was created by the product team.`
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// The location of the bucket. Can differ based on cloud storage used. (e.g. GCS, S3, etc)
	// Example: `ASIA`
	Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	// The type of the storage. Can differ based on cloud storage used. (e.g. GCS, S3, etc)
	// Example: `STANDARD`
	StorageType string `protobuf:"bytes,3,opt,name=storage_type,json=storageType,proto3" json:"storage_type,omitempty"`
	// List of blobs in the bucket.
	Blobs []*Blob `protobuf:"bytes,4,rep,name=blobs,proto3" json:"blobs,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,10,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the bucket's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the bucket was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Bucket) Descriptor deprecated

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

Deprecated: Use Bucket.ProtoReflect.Descriptor instead.

func (*Bucket) GetAttributes

func (x *Bucket) GetAttributes() *structpb.Struct

func (*Bucket) GetBlobs

func (x *Bucket) GetBlobs() []*Blob

func (*Bucket) GetCreateTime

func (x *Bucket) GetCreateTime() *timestamppb.Timestamp

func (*Bucket) GetDescription

func (x *Bucket) GetDescription() string

func (*Bucket) GetLocation

func (x *Bucket) GetLocation() string

func (*Bucket) GetStorageType

func (x *Bucket) GetStorageType() string

func (*Bucket) GetUpdateTime

func (x *Bucket) GetUpdateTime() *timestamppb.Timestamp

func (*Bucket) ProtoMessage

func (*Bucket) ProtoMessage()

func (*Bucket) ProtoReflect

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

func (*Bucket) Reset

func (x *Bucket) Reset()

func (*Bucket) String

func (x *Bucket) String() string

type Chart

type Chart struct {

	// The URN of the chart.
	// Example: `chart:1`.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// The name of the chart.
	// Example: `My Chart`.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The type of the chart.
	// Example: `line`.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// The source of the chart.
	// Example: `metabase`.
	Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	// The description of the chart.
	// Example: `This is a chart for my dashboard.`
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// The url of the chart.
	// Example: `http://metabase.com/charts/mychart`.
	Url string `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	// The raw query of the chart.
	// Example: `SELECT * FROM my_table`.
	RawQuery string `protobuf:"bytes,7,opt,name=raw_query,json=rawQuery,proto3" json:"raw_query,omitempty"`
	// The source of the data.
	// Example: `bigquery,graphite`.
	DataSource string `protobuf:"bytes,8,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// The dashboard ur of the chart.
	// Example: `dashboard:1`.
	DashboardUrn string `protobuf:"bytes,9,opt,name=dashboard_urn,json=dashboardUrn,proto3" json:"dashboard_urn,omitempty"`
	// The source of the dashboard of the chart.
	// Example: `metabase`.
	DashboardSource string `protobuf:"bytes,10,opt,name=dashboard_source,json=dashboardSource,proto3" json:"dashboard_source,omitempty"`
	// The ownership of the dashboard.
	// For an example check out ownership.
	Owners []*Owner `protobuf:"bytes,31,rep,name=owners,proto3" json:"owners,omitempty"`
	// List of properties the model has.
	Attributes *structpb.Struct `protobuf:"bytes,32,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The lineage of the chart.
	// For an example check out lineage schema.
	Lineage *Lineage `protobuf:"bytes,33,opt,name=lineage,proto3" json:"lineage,omitempty"`
	// The timestamp when the object was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,34,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the object was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,35,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// The timestamp of the generated event.
	// Event schemas is defined in the common event schema.
	Event *Event `protobuf:"bytes,100,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*Chart) Descriptor deprecated

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

Deprecated: Use Chart.ProtoReflect.Descriptor instead.

func (*Chart) GetAttributes

func (x *Chart) GetAttributes() *structpb.Struct

func (*Chart) GetCreateTime

func (x *Chart) GetCreateTime() *timestamppb.Timestamp

func (*Chart) GetDashboardSource

func (x *Chart) GetDashboardSource() string

func (*Chart) GetDashboardUrn

func (x *Chart) GetDashboardUrn() string

func (*Chart) GetDataSource

func (x *Chart) GetDataSource() string

func (*Chart) GetDescription

func (x *Chart) GetDescription() string

func (*Chart) GetEvent

func (x *Chart) GetEvent() *Event

func (*Chart) GetLineage

func (x *Chart) GetLineage() *Lineage

func (*Chart) GetName

func (x *Chart) GetName() string

func (*Chart) GetOwners

func (x *Chart) GetOwners() []*Owner

func (*Chart) GetRawQuery

func (x *Chart) GetRawQuery() string

func (*Chart) GetSource

func (x *Chart) GetSource() string

func (*Chart) GetType

func (x *Chart) GetType() string

func (*Chart) GetUpdateTime

func (x *Chart) GetUpdateTime() *timestamppb.Timestamp

func (*Chart) GetUrl

func (x *Chart) GetUrl() string

func (*Chart) GetUrn

func (x *Chart) GetUrn() string

func (*Chart) ProtoMessage

func (*Chart) ProtoMessage()

func (*Chart) ProtoReflect

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

func (*Chart) Reset

func (x *Chart) Reset()

func (*Chart) String

func (x *Chart) String() string

type Column

type Column struct {

	// The name of the column.
	// Example: `customer_id`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The description of the column.
	// Example: `The unique id of the customer`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	DataType    string `protobuf:"bytes,3,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	// The format of the column.
	// Example: `true`.
	IsNullable bool `protobuf:"varint,4,opt,name=is_nullable,json=isNullable,proto3" json:"is_nullable,omitempty"`
	// The length of the column.
	// Example: `10`.
	Length int64 `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"`
	// The profile of the column.
	Profile *ColumnProfile `protobuf:"bytes,6,opt,name=profile,proto3" json:"profile,omitempty"`
	// To capture nested columns.
	Columns []*Column `protobuf:"bytes,7,rep,name=columns,proto3" json:"columns,omitempty"`
	// Representation of the column properties.
	// Properties facet can be used to set custom properties, tags and labels for a column.
	Attributes *structpb.Struct `protobuf:"bytes,31,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Column represents a column in a table or a file.

func (*Column) Descriptor deprecated

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetAttributes

func (x *Column) GetAttributes() *structpb.Struct

func (*Column) GetColumns

func (x *Column) GetColumns() []*Column

func (*Column) GetDataType

func (x *Column) GetDataType() string

func (*Column) GetDescription

func (x *Column) GetDescription() string

func (*Column) GetIsNullable

func (x *Column) GetIsNullable() bool

func (*Column) GetLength

func (x *Column) GetLength() int64

func (*Column) GetName

func (x *Column) GetName() string

func (*Column) GetProfile

func (x *Column) GetProfile() *ColumnProfile

func (*Column) ProtoMessage

func (*Column) ProtoMessage()

func (*Column) ProtoReflect

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

func (*Column) Reset

func (x *Column) Reset()

func (*Column) String

func (x *Column) String() string

type ColumnProfile

type ColumnProfile struct {
	Min    string  `protobuf:"bytes,1,opt,name=min,proto3" json:"min,omitempty"`
	Max    string  `protobuf:"bytes,2,opt,name=max,proto3" json:"max,omitempty"`
	Avg    float64 `protobuf:"fixed64,3,opt,name=avg,proto3" json:"avg,omitempty"`
	Med    float64 `protobuf:"fixed64,4,opt,name=med,proto3" json:"med,omitempty"`
	Unique int64   `protobuf:"varint,5,opt,name=unique,proto3" json:"unique,omitempty"`
	Count  int64   `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	Top    string  `protobuf:"bytes,7,opt,name=top,proto3" json:"top,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnProfile) Descriptor deprecated

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

Deprecated: Use ColumnProfile.ProtoReflect.Descriptor instead.

func (*ColumnProfile) GetAvg

func (x *ColumnProfile) GetAvg() float64

func (*ColumnProfile) GetCount

func (x *ColumnProfile) GetCount() int64

func (*ColumnProfile) GetMax

func (x *ColumnProfile) GetMax() string

func (*ColumnProfile) GetMed

func (x *ColumnProfile) GetMed() float64

func (*ColumnProfile) GetMin

func (x *ColumnProfile) GetMin() string

func (*ColumnProfile) GetTop

func (x *ColumnProfile) GetTop() string

func (*ColumnProfile) GetUnique

func (x *ColumnProfile) GetUnique() int64

func (*ColumnProfile) ProtoMessage

func (*ColumnProfile) ProtoMessage()

func (*ColumnProfile) ProtoReflect

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

func (*ColumnProfile) Reset

func (x *ColumnProfile) Reset()

func (*ColumnProfile) String

func (x *ColumnProfile) String() string

type Dashboard

type Dashboard struct {

	// The list of the charts in the dashboard.
	// For an example, check the schema of the chart.
	Charts []*Chart `protobuf:"bytes,1,rep,name=charts,proto3" json:"charts,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,8,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the dashboard's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the dashboard was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Dashboard is a resource that represents a dashboard.

func (*Dashboard) Descriptor deprecated

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

Deprecated: Use Dashboard.ProtoReflect.Descriptor instead.

func (*Dashboard) GetAttributes

func (x *Dashboard) GetAttributes() *structpb.Struct

func (*Dashboard) GetCharts

func (x *Dashboard) GetCharts() []*Chart

func (*Dashboard) GetCreateTime

func (x *Dashboard) GetCreateTime() *timestamppb.Timestamp

func (*Dashboard) GetUpdateTime

func (x *Dashboard) GetUpdateTime() *timestamppb.Timestamp

func (*Dashboard) ProtoMessage

func (*Dashboard) ProtoMessage()

func (*Dashboard) ProtoReflect

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

func (*Dashboard) Reset

func (x *Dashboard) Reset()

func (*Dashboard) String

func (x *Dashboard) String() string

type Event

type Event struct {

	// The timestamp of the event.
	// Example: `2018-01-01T00:00:00Z`.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The activity that created the event.
	// Example: `create`, `update`.
	Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// The description of the event.
	// Example: `user is created from signup form`.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

Event represents an event in the system. Event is majorly used to represent the state of the system in the form of events. It can be used in any schema which intend to produce events to message bus.

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAction

func (x *Event) GetAction() string

func (*Event) GetDescription

func (x *Event) GetDescription() string

func (*Event) GetTimestamp

func (x *Event) GetTimestamp() *timestamppb.Timestamp

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 Experiment

type Experiment struct {

	// Optional: Type of the entity being experimented over. ex: customer, session,
	// device, driver etc.
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// Optional: Percentage of the traffic that the experiment is enabled for.
	TrafficPercent float32 `protobuf:"fixed32,2,opt,name=traffic_percent,json=trafficPercent,proto3" json:"traffic_percent,omitempty"`
	// The variants of the experiment possibly including the control group.
	Variants []*Experiment_Variant `protobuf:"bytes,3,rep,name=variants,proto3" json:"variants,omitempty"`
	// Optional: List of attributes the experiment has. This could include the
	// following:
	// - client_id[string]: The ID if the client running the experiment.
	// - client_name[string]: The name of the client running the experiment.
	// - primary_metric[string]: Used to determine a statistically significant
	//   winning or losing variant.
	// - guardrail_metric[string]: Business metric designed to indirectly measure
	//   business value and track any potentially misleading or erroneous results
	//   and analysis.
	// - variant_sample_size[double]: Sample size per variant.
	// - filter_rules[repeated string]: Textual representation of rules required
	//   to be satisfied for experiment to be shown to the user.
	// - start_time[RFC 3339 string]: The timestamp at which the
	//   experiment would start.
	// - end_time[RFC 3339 string]: The timestamp at which the
	//   experiment would end.
	Attributes *structpb.Struct `protobuf:"bytes,5,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the experiment's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the experiment was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

An experiment is the set of configurations and filters that allow for systematically varying some independent variables to impact some other dependent variables.

func (*Experiment) Descriptor deprecated

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

Deprecated: Use Experiment.ProtoReflect.Descriptor instead.

func (*Experiment) GetAttributes

func (x *Experiment) GetAttributes() *structpb.Struct

func (*Experiment) GetCreateTime

func (x *Experiment) GetCreateTime() *timestamppb.Timestamp

func (*Experiment) GetEntity

func (x *Experiment) GetEntity() string

func (*Experiment) GetTrafficPercent

func (x *Experiment) GetTrafficPercent() float32

func (*Experiment) GetUpdateTime

func (x *Experiment) GetUpdateTime() *timestamppb.Timestamp

func (*Experiment) GetVariants

func (x *Experiment) GetVariants() []*Experiment_Variant

func (*Experiment) ProtoMessage

func (*Experiment) ProtoMessage()

func (*Experiment) ProtoReflect

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

func (*Experiment) Reset

func (x *Experiment) Reset()

func (*Experiment) String

func (x *Experiment) String() string

type Experiment_Variant

type Experiment_Variant struct {

	// Name of the experiment variant.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Traffic percent enabled for the variant.
	TrafficPercent float32 `protobuf:"fixed32,2,opt,name=traffic_percent,json=trafficPercent,proto3" json:"traffic_percent,omitempty"`
	// Indicated whether the variant is the control for the experiment.
	IsControl bool `protobuf:"varint,3,opt,name=is_control,json=isControl,proto3" json:"is_control,omitempty"`
	// List of properties the entity has.
	Attributes *structpb.Struct `protobuf:"bytes,4,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// Whether the variant has been promoted to all users.
	IsPromoted bool `protobuf:"varint,5,opt,name=is_promoted,json=isPromoted,proto3" json:"is_promoted,omitempty"`
	// contains filtered or unexported fields
}

Instance of configurations to be compared in the experiment.

func (*Experiment_Variant) Descriptor deprecated

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

Deprecated: Use Experiment_Variant.ProtoReflect.Descriptor instead.

func (*Experiment_Variant) GetAttributes

func (x *Experiment_Variant) GetAttributes() *structpb.Struct

func (*Experiment_Variant) GetIsControl

func (x *Experiment_Variant) GetIsControl() bool

func (*Experiment_Variant) GetIsPromoted

func (x *Experiment_Variant) GetIsPromoted() bool

func (*Experiment_Variant) GetName

func (x *Experiment_Variant) GetName() string

func (*Experiment_Variant) GetTrafficPercent

func (x *Experiment_Variant) GetTrafficPercent() float32

func (*Experiment_Variant) ProtoMessage

func (*Experiment_Variant) ProtoMessage()

func (*Experiment_Variant) ProtoReflect

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

func (*Experiment_Variant) Reset

func (x *Experiment_Variant) Reset()

func (*Experiment_Variant) String

func (x *Experiment_Variant) String() string

type Feature

type Feature struct {

	// The name of the field.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The data type associated with an individual ML Feature.
	DataType string `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	// Optional: Name of the algorithm used to compute the feature, e.g., PCA,
	// bucketing etc.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Optional: Name of the entity instance.
	EntityName string `protobuf:"bytes,4,opt,name=entity_name,json=entityName,proto3" json:"entity_name,omitempty"`
	// contains filtered or unexported fields
}

Feature is a Machine Learning(ML) feature. In machine learning, a feature is an individual measurable property, typically represented by a column, that serves as an input for Machine Learning (ML) algorithms.

func (*Feature) Descriptor deprecated

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

Deprecated: Use Feature.ProtoReflect.Descriptor instead.

func (*Feature) GetAlgorithm

func (x *Feature) GetAlgorithm() string

func (*Feature) GetDataType

func (x *Feature) GetDataType() string

func (*Feature) GetEntityName

func (x *Feature) GetEntityName() string

func (*Feature) GetName

func (x *Feature) GetName() string

func (*Feature) ProtoMessage

func (*Feature) ProtoMessage()

func (*Feature) ProtoReflect

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

func (*Feature) Reset

func (x *Feature) Reset()

func (*Feature) String

func (x *Feature) String() string

type FeatureTable

type FeatureTable struct {

	// Optional: Feature store's namespace or project.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Optional: The list of entities that this feature view is associated with.
	Entities []*FeatureTable_Entity `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	// Features that are part of the table, akin to columns in a table.
	Features []*Feature `protobuf:"bytes,3,rep,name=features,proto3" json:"features,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,4,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp when the feature table was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the feature table was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

FeatureTable is a Machine Learning(ML) feature table or view that represents a logical group of time-series feature data as it is found in a data source.

func (*FeatureTable) Descriptor deprecated

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

Deprecated: Use FeatureTable.ProtoReflect.Descriptor instead.

func (*FeatureTable) GetAttributes

func (x *FeatureTable) GetAttributes() *structpb.Struct

func (*FeatureTable) GetCreateTime

func (x *FeatureTable) GetCreateTime() *timestamppb.Timestamp

func (*FeatureTable) GetEntities

func (x *FeatureTable) GetEntities() []*FeatureTable_Entity

func (*FeatureTable) GetFeatures

func (x *FeatureTable) GetFeatures() []*Feature

func (*FeatureTable) GetNamespace

func (x *FeatureTable) GetNamespace() string

func (*FeatureTable) GetUpdateTime

func (x *FeatureTable) GetUpdateTime() *timestamppb.Timestamp

func (*FeatureTable) ProtoMessage

func (*FeatureTable) ProtoMessage()

func (*FeatureTable) ProtoReflect

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

func (*FeatureTable) Reset

func (x *FeatureTable) Reset()

func (*FeatureTable) String

func (x *FeatureTable) String() string

type FeatureTable_Entity

type FeatureTable_Entity struct {

	// The unique name of the entity.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// A property that uniquely identifies different entities within the
	// collection. The join_key property is typically used for joining entities
	// with their associated features.
	JoinKeys []string `protobuf:"bytes,2,rep,name=join_keys,json=joinKeys,proto3" json:"join_keys,omitempty"`
	// Optional: Arbitrary metadata.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Optional: Description of the entity.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Optional: Data type of the entity.
	Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

An entity is a collection of semantically related features. Users define entities to map to the domain of their use case. For example, a ride-hailing service could have customers and drivers as their entities, which group related features that correspond to these customers and drivers.

func (*FeatureTable_Entity) Descriptor deprecated

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

Deprecated: Use FeatureTable_Entity.ProtoReflect.Descriptor instead.

func (*FeatureTable_Entity) GetDescription

func (x *FeatureTable_Entity) GetDescription() string

func (*FeatureTable_Entity) GetJoinKeys

func (x *FeatureTable_Entity) GetJoinKeys() []string

func (*FeatureTable_Entity) GetLabels

func (x *FeatureTable_Entity) GetLabels() map[string]string

func (*FeatureTable_Entity) GetName

func (x *FeatureTable_Entity) GetName() string

func (*FeatureTable_Entity) GetType

func (x *FeatureTable_Entity) GetType() string

func (*FeatureTable_Entity) ProtoMessage

func (*FeatureTable_Entity) ProtoMessage()

func (*FeatureTable_Entity) ProtoReflect

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

func (*FeatureTable_Entity) Reset

func (x *FeatureTable_Entity) Reset()

func (*FeatureTable_Entity) String

func (x *FeatureTable_Entity) String() string

type Group

type Group struct {

	// The email of the group.
	// Example: `xyz@xyz.com`
	Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	// The members of the group.
	// For example look at schema of the member.
	Members []*Member `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,10,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Group represents a group of users and resources.

func (*Group) Descriptor deprecated

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

Deprecated: Use Group.ProtoReflect.Descriptor instead.

func (*Group) GetAttributes

func (x *Group) GetAttributes() *structpb.Struct

func (*Group) GetEmail

func (x *Group) GetEmail() string

func (*Group) GetMembers

func (x *Group) GetMembers() []*Member

func (*Group) ProtoMessage

func (*Group) ProtoMessage()

func (*Group) ProtoReflect

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

func (*Group) Reset

func (x *Group) Reset()

func (*Group) String

func (x *Group) String() string

type Job

type Job struct {

	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,10,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the job's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the job was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Job is a resource that represents a job.

func (*Job) Descriptor deprecated

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetAttributes

func (x *Job) GetAttributes() *structpb.Struct

func (*Job) GetCreateTime

func (x *Job) GetCreateTime() *timestamppb.Timestamp

func (*Job) GetUpdateTime

func (x *Job) GetUpdateTime() *timestamppb.Timestamp

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) ProtoReflect

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

func (*Job) Reset

func (x *Job) Reset()

func (*Job) String

func (x *Job) String() string

type Lineage

type Lineage struct {

	// The resource that is the source of the relationship.
	// Example: a resource that is the parent of another resource.
	Upstreams []*Resource `protobuf:"bytes,1,rep,name=upstreams,proto3" json:"upstreams,omitempty"`
	// The resource that is the destination of the relationship.
	// Example: a resource that is the child of another resource.
	Downstreams []*Resource `protobuf:"bytes,2,rep,name=downstreams,proto3" json:"downstreams,omitempty"`
	// contains filtered or unexported fields
}

Linage represents the relationship of resource to other resources. Relation is way of describing the relationship between two resources.

func (*Lineage) Descriptor deprecated

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

Deprecated: Use Lineage.ProtoReflect.Descriptor instead.

func (*Lineage) GetDownstreams

func (x *Lineage) GetDownstreams() []*Resource

func (*Lineage) GetUpstreams

func (x *Lineage) GetUpstreams() []*Resource

func (*Lineage) ProtoMessage

func (*Lineage) ProtoMessage()

func (*Lineage) ProtoReflect

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

func (*Lineage) Reset

func (x *Lineage) Reset()

func (*Lineage) String

func (x *Lineage) String() string

type Member

type Member struct {

	// The unique identifier for the user.
	// Example: `user:example`.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// The role of the user.
	// Example: `owner`.
	Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

Member represents a user.

func (*Member) Descriptor deprecated

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetRole

func (x *Member) GetRole() string

func (*Member) GetUrn

func (x *Member) GetUrn() string

func (*Member) ProtoMessage

func (*Member) ProtoMessage()

func (*Member) ProtoReflect

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

func (*Member) Reset

func (x *Member) Reset()

func (*Member) String

func (x *Member) String() string

type Membership

type Membership struct {

	// The unique identifier of the group.
	// Example: `group:mygroup`
	GroupUrn string `protobuf:"bytes,1,opt,name=group_urn,json=groupUrn,proto3" json:"group_urn,omitempty"`
	// The role user has in the group.
	// Example: "owner"
	Role []string `protobuf:"bytes,2,rep,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

Membership is a relationship between a user and a group.

func (*Membership) Descriptor deprecated

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

Deprecated: Use Membership.ProtoReflect.Descriptor instead.

func (*Membership) GetGroupUrn

func (x *Membership) GetGroupUrn() string

func (*Membership) GetRole

func (x *Membership) GetRole() []string

func (*Membership) ProtoMessage

func (*Membership) ProtoMessage()

func (*Membership) ProtoReflect

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

func (*Membership) Reset

func (x *Membership) Reset()

func (*Membership) String

func (x *Membership) String() string

type Metric

type Metric struct {

	// Namespace of the metric. Something like `{project}-{model}` for dbt and
	// `schema` for Cube.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The field being used to calculate a metric.
	FieldName string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// Type of the evaluated metric. ex: count_distinct, average etc.
	MeasureType string `protobuf:"bytes,3,opt,name=measure_type,json=measureType,proto3" json:"measure_type,omitempty"`
	// Optional: The query, possibly in SQL representation, with filters and aggregations.
	Query string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	// Optional: List of attributes the metric has. This could include the
	// following:
	// - time_grains[repeated string]: One or more "grains" at which the metric
	//   can be evaluated. Ex: [day, week, month].
	// - dimensions[repeated string]: A list of dimensions to group or filter the
	//   metric by. Ex: [plan, country].
	// - filters[repeated map<string, string>]: Predicates for the metric. Ex:
	//   [{"field": "is_paying", "operator": "is", "value": "true"}].
	Attributes *structpb.Struct `protobuf:"bytes,5,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the metric's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the metric was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

A metric is a timeseries aggregation over a table that supports zero or more dimensions.

func (*Metric) Descriptor deprecated

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetAttributes

func (x *Metric) GetAttributes() *structpb.Struct

func (*Metric) GetCreateTime

func (x *Metric) GetCreateTime() *timestamppb.Timestamp

func (*Metric) GetFieldName

func (x *Metric) GetFieldName() string

func (*Metric) GetMeasureType

func (x *Metric) GetMeasureType() string

func (*Metric) GetNamespace

func (x *Metric) GetNamespace() string

func (*Metric) GetQuery

func (x *Metric) GetQuery() string

func (*Metric) GetUpdateTime

func (x *Metric) GetUpdateTime() *timestamppb.Timestamp

func (*Metric) ProtoMessage

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect

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

func (*Metric) Reset

func (x *Metric) Reset()

func (*Metric) String

func (x *Metric) String() string

type Model

type Model struct {

	// Optional: Model's namespace or project.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Flavor of the ML Model. ex: pytorch, tensorflow etc.
	Flavor string `protobuf:"bytes,2,opt,name=flavor,proto3" json:"flavor,omitempty"`
	// Optional: Algorithm used to train the ML Model.
	Algorithm string `protobuf:"bytes,3,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// Status of the model. ex: active/deleted etc.
	Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// Versions of the model, similar to experiment runs in MLFlow and model
	// version in Merlin.
	Versions []*ModelVersion `protobuf:"bytes,5,rep,name=versions,proto3" json:"versions,omitempty"`
	// List of attributes the model version has. This could include the following:
	// - project_id[double]: ID of project the model is present in.
	// - project_name[string]: Name of project the model is present in.
	// - mlflow_experiment_id[double]: MLFlow experiment ID associated with the
	//   model. Relevant for Merlin models.
	// - mlflow_experiment_url[string]: URL of MLFlow experiment associated with
	//   the model. Relevant for Merlin models.
	// - endpoint_urls[repeated string]: List of URLs associated with endpoints
	//   that are serving requests for the model. Relevant for Merlin models.
	Attributes *structpb.Struct `protobuf:"bytes,6,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the model's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the model was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Model represents a Data Science Model commonly used for Machine Learning (ML). Models are algorithms trained on data to find patterns or make predictions. Models typically consume ML features to generate a meaningful output. The inputs can also include contextual information that is made available in realtime as part of the request to the model server.

func (*Model) Descriptor deprecated

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

Deprecated: Use Model.ProtoReflect.Descriptor instead.

func (*Model) GetAlgorithm

func (x *Model) GetAlgorithm() string

func (*Model) GetAttributes

func (x *Model) GetAttributes() *structpb.Struct

func (*Model) GetCreateTime

func (x *Model) GetCreateTime() *timestamppb.Timestamp

func (*Model) GetFlavor

func (x *Model) GetFlavor() string

func (*Model) GetNamespace

func (x *Model) GetNamespace() string

func (*Model) GetStatus

func (x *Model) GetStatus() string

func (*Model) GetUpdateTime

func (x *Model) GetUpdateTime() *timestamppb.Timestamp

func (*Model) GetVersions

func (x *Model) GetVersions() []*ModelVersion

func (*Model) ProtoMessage

func (*Model) ProtoMessage()

func (*Model) ProtoReflect

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

func (*Model) Reset

func (x *Model) Reset()

func (*Model) String

func (x *Model) String() string

type ModelSignature

type ModelSignature struct {
	Inputs  []*ModelSignature_Parameter `protobuf:"bytes,1,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs []*ModelSignature_Parameter `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

Schema of the model's inputs and outputs. Strongly inspired by https://mlflow.org/docs/latest/python_api/mlflow.models.html#mlflow.models.ModelSignature.

func (*ModelSignature) Descriptor deprecated

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

Deprecated: Use ModelSignature.ProtoReflect.Descriptor instead.

func (*ModelSignature) GetInputs

func (x *ModelSignature) GetInputs() []*ModelSignature_Parameter

func (*ModelSignature) GetOutputs

func (x *ModelSignature) GetOutputs() []*ModelSignature_Parameter

func (*ModelSignature) ProtoMessage

func (*ModelSignature) ProtoMessage()

func (*ModelSignature) ProtoReflect

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

func (*ModelSignature) Reset

func (x *ModelSignature) Reset()

func (*ModelSignature) String

func (x *ModelSignature) String() string

type ModelSignature_Parameter

type ModelSignature_Parameter struct {

	// Optional: Name of the input or output parameter.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Data type of the parameter. Ex: boolean, double, numpy's dtypes etc.
	DataType string `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	// Optional: The tensor shape.
	Shape []int64 `protobuf:"varint,3,rep,packed,name=shape,proto3" json:"shape,omitempty"`
	// contains filtered or unexported fields
}

Specification of name and type of a single column in a dataset.

func (*ModelSignature_Parameter) Descriptor deprecated

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

Deprecated: Use ModelSignature_Parameter.ProtoReflect.Descriptor instead.

func (*ModelSignature_Parameter) GetDataType

func (x *ModelSignature_Parameter) GetDataType() string

func (*ModelSignature_Parameter) GetName

func (x *ModelSignature_Parameter) GetName() string

func (*ModelSignature_Parameter) GetShape

func (x *ModelSignature_Parameter) GetShape() []int64

func (*ModelSignature_Parameter) ProtoMessage

func (*ModelSignature_Parameter) ProtoMessage()

func (*ModelSignature_Parameter) ProtoReflect

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

func (*ModelSignature_Parameter) Reset

func (x *ModelSignature_Parameter) Reset()

func (*ModelSignature_Parameter) String

func (x *ModelSignature_Parameter) String() string

type ModelVersion

type ModelVersion struct {

	// The schema of a model version’s inputs and outputs.
	Signature *ModelSignature `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	// Status of the model version. ex: pending/ready/serving/terminated etc.
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Version of the model
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// List of attributes the model version has. This could include the following:
	// - mlflow_run_id[string]: MLFlow expriment run ID associated with the model
	//   version. Relevant for Merlin models.
	// - mlflow_run_url[string]: URL of MLFlow experiment run associated with
	//   the model. Relevant for Merlin models.
	// - endpoint_url[string]: Endpoint that the model is serving requests on.
	//   Ex: http://<model_name>-<version>.<project_name>.<merlin_base_url>.
	// - version_endpoint_url[string]: Endpoint that the model is serving
	//   requests on for the specific version. Ex:
	//   http://<model_name>-<version>.<project_name>.<merlin_base_url>.
	// - traffic[double]: Percentage of traffic being served by this version of
	//   the model.
	// - weight[double]: Weightage for the model version endpoint.
	// - params[map<string, string>]: Parameters for the Model's run.
	// - metrics[map<string, double>]: Metrics for the model's run.
	Attributes *structpb.Struct `protobuf:"bytes,4,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// Optional. List of labels the model version has.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The timestamp of the model's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the model was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ModelVersion) Descriptor deprecated

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

Deprecated: Use ModelVersion.ProtoReflect.Descriptor instead.

func (*ModelVersion) GetAttributes

func (x *ModelVersion) GetAttributes() *structpb.Struct

func (*ModelVersion) GetCreateTime

func (x *ModelVersion) GetCreateTime() *timestamppb.Timestamp

func (*ModelVersion) GetLabels

func (x *ModelVersion) GetLabels() map[string]string

func (*ModelVersion) GetSignature

func (x *ModelVersion) GetSignature() *ModelSignature

func (*ModelVersion) GetStatus

func (x *ModelVersion) GetStatus() string

func (*ModelVersion) GetUpdateTime

func (x *ModelVersion) GetUpdateTime() *timestamppb.Timestamp

func (*ModelVersion) GetVersion

func (x *ModelVersion) GetVersion() string

func (*ModelVersion) ProtoMessage

func (*ModelVersion) ProtoMessage()

func (*ModelVersion) ProtoReflect

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

func (*ModelVersion) Reset

func (x *ModelVersion) Reset()

func (*ModelVersion) String

func (x *ModelVersion) String() string

type Owner

type Owner struct {
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// The name of the owner.
	// Example: `John Doe`.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The role of the owner.
	// Example: `admin`, `steward`.
	Role string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	// The email of the owner.
	// Example: `abc@email.com`
	Email string `protobuf:"bytes,4,opt,name=email,proto3" json:"email,omitempty"`
	// contains filtered or unexported fields
}

Owner is a facet that describes the owner of a resource.

func (*Owner) Descriptor deprecated

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

Deprecated: Use Owner.ProtoReflect.Descriptor instead.

func (*Owner) GetEmail

func (x *Owner) GetEmail() string

func (*Owner) GetName

func (x *Owner) GetName() string

func (*Owner) GetRole

func (x *Owner) GetRole() string

func (*Owner) GetUrn

func (x *Owner) GetUrn() string

func (*Owner) ProtoMessage

func (*Owner) ProtoMessage()

func (*Owner) ProtoReflect

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

func (*Owner) Reset

func (x *Owner) Reset()

func (*Owner) String

func (x *Owner) String() string

type Profile

type Profile struct {

	// The unique identifier of the profile.
	// Example: `profile:jdoe`
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The type of the profile.
	// Example: `github`
	Platform string `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	// The url of the profile.
	// Example: `http://github.com/jdoe`
	Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

Profile is a social media account of the user.

func (*Profile) Descriptor deprecated

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

Deprecated: Use Profile.ProtoReflect.Descriptor instead.

func (*Profile) GetId

func (x *Profile) GetId() string

func (*Profile) GetPlatform

func (x *Profile) GetPlatform() string

func (*Profile) GetUrl

func (x *Profile) GetUrl() string

func (*Profile) ProtoMessage

func (*Profile) ProtoMessage()

func (*Profile) ProtoReflect

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

func (*Profile) Reset

func (x *Profile) Reset()

func (*Profile) String

func (x *Profile) String() string

type Resource

type Resource struct {

	// The unique identifier of the resource.
	// Example: `user:jdoe` or `group:accounting`.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// The name of the resource.
	// Example: `John Doe` or `Accounting`.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The source of the resource.
	// Example: `github` or `bigquery`.
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// The type of the asset.
	// Example: `user` or `group`.
	Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetName

func (x *Resource) GetName() string

func (*Resource) GetService

func (x *Resource) GetService() string

func (*Resource) GetType

func (x *Resource) GetType() string

func (*Resource) GetUrn

func (x *Resource) GetUrn() string

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect

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

func (*Resource) Reset

func (x *Resource) Reset()

func (*Resource) String

func (x *Resource) String() string

type Table

type Table struct {

	// The metrics about the table.
	// For example check the profile schem.
	Profile *TableProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// The columns of the table.
	// Example: 'id', `name`, `age'.
	Columns []*Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// preview_fields of the table.
	PreviewFields []string `protobuf:"bytes,3,rep,name=preview_fields,json=previewFields,proto3" json:"preview_fields,omitempty"`
	// preview_rows is a multidimensional array containing preview of table
	PreviewRows *structpb.ListValue `protobuf:"bytes,4,opt,name=preview_rows,json=previewRows,proto3" json:"preview_rows,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,10,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the table's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the table was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Table is a table in a database. It can be a file, a table, a view, a materialized view, a temporary table, or a virtual table.

func (*Table) Descriptor deprecated

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetAttributes

func (x *Table) GetAttributes() *structpb.Struct

func (*Table) GetColumns

func (x *Table) GetColumns() []*Column

func (*Table) GetCreateTime

func (x *Table) GetCreateTime() *timestamppb.Timestamp

func (*Table) GetPreviewFields

func (x *Table) GetPreviewFields() []string

func (*Table) GetPreviewRows

func (x *Table) GetPreviewRows() *structpb.ListValue

func (*Table) GetProfile

func (x *Table) GetProfile() *TableProfile

func (*Table) GetUpdateTime

func (x *Table) GetUpdateTime() *timestamppb.Timestamp

func (*Table) ProtoMessage

func (*Table) ProtoMessage()

func (*Table) ProtoReflect

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

func (*Table) Reset

func (x *Table) Reset()

func (*Table) String

func (x *Table) String() string

type TableCommonJoin

type TableCommonJoin struct {
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// The number of how many times table is being joined with a certain table urn
	Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// The information of `join conditions` applied to the table
	Conditions []string `protobuf:"bytes,3,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// contains filtered or unexported fields
}

Join is the metric of which are other tables that are joined with this table

func (*TableCommonJoin) Descriptor deprecated

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

Deprecated: Use TableCommonJoin.ProtoReflect.Descriptor instead.

func (*TableCommonJoin) GetConditions

func (x *TableCommonJoin) GetConditions() []string

func (*TableCommonJoin) GetCount

func (x *TableCommonJoin) GetCount() int64

func (*TableCommonJoin) GetUrn

func (x *TableCommonJoin) GetUrn() string

func (*TableCommonJoin) ProtoMessage

func (*TableCommonJoin) ProtoMessage()

func (*TableCommonJoin) ProtoReflect

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

func (*TableCommonJoin) Reset

func (x *TableCommonJoin) Reset()

func (*TableCommonJoin) String

func (x *TableCommonJoin) String() string

type TableProfile

type TableProfile struct {

	// The number of rows in the table.
	// Example: `100`.
	TotalRows int64 `protobuf:"varint,1,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	// The number of rows in the table that are not deleted.
	// Example: `event_timestamp`.
	PartitionKey   string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	PartitionValue string `protobuf:"bytes,3,opt,name=partition_value,json=partitionValue,proto3" json:"partition_value,omitempty"`
	// The number of how many times table is being used
	UsageCount int64 `protobuf:"varint,4,opt,name=usage_count,json=usageCount,proto3" json:"usage_count,omitempty"`
	// The information of `join` applied to the table
	CommonJoins []*TableCommonJoin `protobuf:"bytes,5,rep,name=common_joins,json=commonJoins,proto3" json:"common_joins,omitempty"`
	// The information of `filter` applied to the table
	Filters []string `protobuf:"bytes,6,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

TableProfile is the metrics about the table.

func (*TableProfile) Descriptor deprecated

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

Deprecated: Use TableProfile.ProtoReflect.Descriptor instead.

func (*TableProfile) GetCommonJoins

func (x *TableProfile) GetCommonJoins() []*TableCommonJoin

func (*TableProfile) GetFilters

func (x *TableProfile) GetFilters() []string

func (*TableProfile) GetPartitionKey

func (x *TableProfile) GetPartitionKey() string

func (*TableProfile) GetPartitionValue

func (x *TableProfile) GetPartitionValue() string

func (*TableProfile) GetTotalRows

func (x *TableProfile) GetTotalRows() int64

func (*TableProfile) GetUsageCount

func (x *TableProfile) GetUsageCount() int64

func (*TableProfile) ProtoMessage

func (*TableProfile) ProtoMessage()

func (*TableProfile) ProtoReflect

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

func (*TableProfile) Reset

func (x *TableProfile) Reset()

func (*TableProfile) String

func (x *TableProfile) String() string

type Topic

type Topic struct {

	// The metrics of the topic.
	// For an example check out topic profile schema.
	Profile *TopicProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// The schema of the topic.
	// For an example check out topic schema.
	Schema *TopicSchema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,10,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the topic's creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the topic was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Topic is resource that represents a logical group of messages in message bus like kafka, pubsub, pulsar etc.

func (*Topic) Descriptor deprecated

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetAttributes

func (x *Topic) GetAttributes() *structpb.Struct

func (*Topic) GetCreateTime

func (x *Topic) GetCreateTime() *timestamppb.Timestamp

func (*Topic) GetProfile

func (x *Topic) GetProfile() *TopicProfile

func (*Topic) GetSchema

func (x *Topic) GetSchema() *TopicSchema

func (*Topic) GetUpdateTime

func (x *Topic) GetUpdateTime() *timestamppb.Timestamp

func (*Topic) ProtoMessage

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect

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

func (*Topic) Reset

func (x *Topic) Reset()

func (*Topic) String

func (x *Topic) String() string

type TopicProfile

type TopicProfile struct {

	// The throughput of the topic.
	// Example: `1m/minute`.
	Throughput string `protobuf:"bytes,1,opt,name=throughput,proto3" json:"throughput,omitempty"`
	// The number of partitions in the topic.
	// Example: `12`.
	NumberOfPartitions int64 `protobuf:"varint,2,opt,name=number_of_partitions,json=numberOfPartitions,proto3" json:"number_of_partitions,omitempty"`
	// contains filtered or unexported fields
}

TopicProfile is the profile of the topic.

func (*TopicProfile) Descriptor deprecated

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

Deprecated: Use TopicProfile.ProtoReflect.Descriptor instead.

func (*TopicProfile) GetNumberOfPartitions

func (x *TopicProfile) GetNumberOfPartitions() int64

func (*TopicProfile) GetThroughput

func (x *TopicProfile) GetThroughput() string

func (*TopicProfile) ProtoMessage

func (*TopicProfile) ProtoMessage()

func (*TopicProfile) ProtoReflect

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

func (*TopicProfile) Reset

func (x *TopicProfile) Reset()

func (*TopicProfile) String

func (x *TopicProfile) String() string

type TopicSchema

type TopicSchema struct {
	SchemaUrl string `protobuf:"bytes,1,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"`
	Format    string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// contains filtered or unexported fields
}

TopicSchema represents a schema for message bus. It is facet used to specify the schema of a message bus.

func (*TopicSchema) Descriptor deprecated

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

Deprecated: Use TopicSchema.ProtoReflect.Descriptor instead.

func (*TopicSchema) GetFormat

func (x *TopicSchema) GetFormat() string

func (*TopicSchema) GetSchemaUrl

func (x *TopicSchema) GetSchemaUrl() string

func (*TopicSchema) ProtoMessage

func (*TopicSchema) ProtoMessage()

func (*TopicSchema) ProtoReflect

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

func (*TopicSchema) Reset

func (x *TopicSchema) Reset()

func (*TopicSchema) String

func (x *TopicSchema) String() string

type User

type User struct {

	// The email address of the user.
	// Example: `job.deo@gmail.com`
	Email string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	// The username of the user.
	// Example: `johndoe`
	Username string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	// The first name of the user.
	// Example: `john`
	FirstName string `protobuf:"bytes,5,opt,name=first_name,json=firstName,proto3" json:"first_name,omitempty"`
	// The last name of the user.
	// Example: `doe`
	LastName string `protobuf:"bytes,6,opt,name=last_name,json=lastName,proto3" json:"last_name,omitempty"`
	// The full name of the user.
	// Example: `john mayer doe`
	FullName string `protobuf:"bytes,7,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	// The display name of the user.
	// Example: `John M. Doe`
	DisplayName string `protobuf:"bytes,8,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// The job title of the user.
	// Example: `data engineer`
	Title string `protobuf:"bytes,9,opt,name=title,proto3" json:"title,omitempty"`
	// The status of the user.
	// Example: `active`
	Status string `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
	// The email of the manger of the user.
	// Example: `rambo.ryan@gmail.com`
	ManagerEmail string `protobuf:"bytes,11,opt,name=manager_email,json=managerEmail,proto3" json:"manager_email,omitempty"`
	// List of the user social media accounts.
	// For an example check out the profile schema.
	Profiles []*Profile `protobuf:"bytes,21,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// List of the groups user belongs to.
	// A user can be part of multiple groups and have a different role in every group.
	Memberships []*Membership `protobuf:"bytes,22,rep,name=memberships,proto3" json:"memberships,omitempty"`
	// List of attributes the model has.
	Attributes *structpb.Struct `protobuf:"bytes,30,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The timestamp of the user's account creation.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The timestamp when the user's account details were last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

User is a person who uses or operates something. It can be a user of the system, or a user of a device. User is a resource that represents a user.

func (*User) Descriptor deprecated

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetAttributes

func (x *User) GetAttributes() *structpb.Struct

func (*User) GetCreateTime

func (x *User) GetCreateTime() *timestamppb.Timestamp

func (*User) GetDisplayName

func (x *User) GetDisplayName() string

func (*User) GetEmail

func (x *User) GetEmail() string

func (*User) GetFirstName

func (x *User) GetFirstName() string

func (*User) GetFullName

func (x *User) GetFullName() string

func (*User) GetLastName

func (x *User) GetLastName() string

func (*User) GetManagerEmail

func (x *User) GetManagerEmail() string

func (*User) GetMemberships

func (x *User) GetMemberships() []*Membership

func (*User) GetProfiles

func (x *User) GetProfiles() []*Profile

func (*User) GetStatus

func (x *User) GetStatus() string

func (*User) GetTitle

func (x *User) GetTitle() string

func (*User) GetUpdateTime

func (x *User) GetUpdateTime() *timestamppb.Timestamp

func (*User) GetUsername

func (x *User) GetUsername() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

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

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string

Jump to

Keyboard shortcuts

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