Enum value maps for JobState.
var (
JobState_name = map[int32]string{
0: "JOB_STATE_UNSPECIFIED",
9: "JOB_STATE_PENDING",
1: "JOB_STATE_RUNNING",
2: "JOB_STATE_SUCCEEDED",
3: "JOB_STATE_FAILED",
4: "JOB_STATE_CANCELLED",
5: "JOB_STATE_KNOWLEDGE_EXTRACTION",
6: "JOB_STATE_RECON_PREPROCESSING",
7: "JOB_STATE_CLUSTERING",
8: "JOB_STATE_EXPORTING_CLUSTERS",
}
JobState_value = map[string]int32{
"JOB_STATE_UNSPECIFIED": 0,
"JOB_STATE_PENDING": 9,
"JOB_STATE_RUNNING": 1,
"JOB_STATE_SUCCEEDED": 2,
"JOB_STATE_FAILED": 3,
"JOB_STATE_CANCELLED": 4,
"JOB_STATE_KNOWLEDGE_EXTRACTION": 5,
"JOB_STATE_RECON_PREPROCESSING": 6,
"JOB_STATE_CLUSTERING": 7,
"JOB_STATE_EXPORTING_CLUSTERS": 8,
}
)
Enum value maps for CommonOperationMetadata_State.
var (
CommonOperationMetadata_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "RUNNING",
2: "CANCELLING",
3: "SUCCEEDED",
4: "FAILED",
5: "CANCELLED",
6: "PENDING",
}
CommonOperationMetadata_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"RUNNING": 1,
"CANCELLING": 2,
"SUCCEEDED": 3,
"FAILED": 4,
"CANCELLED": 5,
"PENDING": 6,
}
)
Enum value maps for InputConfig_EntityType.
var (
InputConfig_EntityType_name = map[int32]string{
0: "ENTITY_TYPE_UNSPECIFIED",
1: "PEOPLE",
2: "ESTABLISHMENT",
3: "PROPERTY",
4: "PRODUCT",
5: "ORGANIZATION",
6: "LOCAL_BUSINESS",
7: "PERSON",
}
InputConfig_EntityType_value = map[string]int32{
"ENTITY_TYPE_UNSPECIFIED": 0,
"PEOPLE": 1,
"ESTABLISHMENT": 2,
"PROPERTY": 3,
"PRODUCT": 4,
"ORGANIZATION": 5,
"LOCAL_BUSINESS": 6,
"PERSON": 7,
}
)
var File_google_cloud_enterpriseknowledgegraph_v1_job_state_proto protoreflect.FileDescriptor
var File_google_cloud_enterpriseknowledgegraph_v1_operation_metadata_proto protoreflect.FileDescriptor
var File_google_cloud_enterpriseknowledgegraph_v1_service_proto protoreflect.FileDescriptor
func RegisterEnterpriseKnowledgeGraphServiceServer(s *grpc.Server, srv EnterpriseKnowledgeGraphServiceServer)
Options for affinity clustering.
type AffinityClusteringConfig struct {
// Number of iterations to perform. Default value is 1.
CompressionRoundCount int64 `protobuf:"varint,1,opt,name=compression_round_count,json=compressionRoundCount,proto3" json:"compression_round_count,omitempty"`
// contains filtered or unexported fields
}
func (*AffinityClusteringConfig) Descriptor() ([]byte, []int)
Deprecated: Use AffinityClusteringConfig.ProtoReflect.Descriptor instead.
func (x *AffinityClusteringConfig) GetCompressionRoundCount() int64
func (*AffinityClusteringConfig) ProtoMessage()
func (x *AffinityClusteringConfig) ProtoReflect() protoreflect.Message
func (x *AffinityClusteringConfig) Reset()
func (x *AffinityClusteringConfig) String() string
The input config for BigQuery tables.
type BigQueryInputConfig struct {
// Required. Format is `projects/*/datasets/*/tables/*`.
BigqueryTable string `protobuf:"bytes,1,opt,name=bigquery_table,json=bigqueryTable,proto3" json:"bigquery_table,omitempty"`
// Required. Schema mapping file
GcsUri string `protobuf:"bytes,2,opt,name=gcs_uri,json=gcsUri,proto3" json:"gcs_uri,omitempty"`
// contains filtered or unexported fields
}
func (*BigQueryInputConfig) Descriptor() ([]byte, []int)
Deprecated: Use BigQueryInputConfig.ProtoReflect.Descriptor instead.
func (x *BigQueryInputConfig) GetBigqueryTable() string
func (x *BigQueryInputConfig) GetGcsUri() string
func (*BigQueryInputConfig) ProtoMessage()
func (x *BigQueryInputConfig) ProtoReflect() protoreflect.Message
func (x *BigQueryInputConfig) Reset()
func (x *BigQueryInputConfig) String() string
Request message for CancelEntityReconciliationJob.
type CancelEntityReconciliationJobRequest struct {
// Required. The name of the EntityReconciliationJob resource.
// Format:
// `projects/{project}/locations/{location}/entityReconciliationJobs/{entity_reconciliation_job}`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*CancelEntityReconciliationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelEntityReconciliationJobRequest.ProtoReflect.Descriptor instead.
func (x *CancelEntityReconciliationJobRequest) GetName() string
func (*CancelEntityReconciliationJobRequest) ProtoMessage()
func (x *CancelEntityReconciliationJobRequest) ProtoReflect() protoreflect.Message
func (x *CancelEntityReconciliationJobRequest) Reset()
func (x *CancelEntityReconciliationJobRequest) String() string
The common metadata for long running operations.
type CommonOperationMetadata struct {
// The state of the operation.
State CommonOperationMetadata_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.enterpriseknowledgegraph.v1.CommonOperationMetadata_State" json:"state,omitempty"`
// The creation time of the operation.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// The last update time of the operation.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// contains filtered or unexported fields
}
func (*CommonOperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use CommonOperationMetadata.ProtoReflect.Descriptor instead.
func (x *CommonOperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (x *CommonOperationMetadata) GetState() CommonOperationMetadata_State
func (x *CommonOperationMetadata) GetUpdateTime() *timestamppb.Timestamp
func (*CommonOperationMetadata) ProtoMessage()
func (x *CommonOperationMetadata) ProtoReflect() protoreflect.Message
func (x *CommonOperationMetadata) Reset()
func (x *CommonOperationMetadata) String() string
State of the longrunning operation.
type CommonOperationMetadata_State int32
const (
// Unspecified state.
CommonOperationMetadata_STATE_UNSPECIFIED CommonOperationMetadata_State = 0
// Operation is still running.
CommonOperationMetadata_RUNNING CommonOperationMetadata_State = 1
// Operation is being cancelled.
CommonOperationMetadata_CANCELLING CommonOperationMetadata_State = 2
// Operation succeeded.
CommonOperationMetadata_SUCCEEDED CommonOperationMetadata_State = 3
// Operation failed.
CommonOperationMetadata_FAILED CommonOperationMetadata_State = 4
// Operation is cancelled.
CommonOperationMetadata_CANCELLED CommonOperationMetadata_State = 5
// Operation is pending not running yet.
CommonOperationMetadata_PENDING CommonOperationMetadata_State = 6
)
func (CommonOperationMetadata_State) Descriptor() protoreflect.EnumDescriptor
func (x CommonOperationMetadata_State) Enum() *CommonOperationMetadata_State
func (CommonOperationMetadata_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use CommonOperationMetadata_State.Descriptor instead.
func (x CommonOperationMetadata_State) Number() protoreflect.EnumNumber
func (x CommonOperationMetadata_State) String() string
func (CommonOperationMetadata_State) Type() protoreflect.EnumType
Options for connected components.
type ConnectedComponentsConfig struct {
// Threshold used for connected components. Default value is 0.85.
WeightThreshold float32 `protobuf:"fixed32,1,opt,name=weight_threshold,json=weightThreshold,proto3" json:"weight_threshold,omitempty"`
// contains filtered or unexported fields
}
func (*ConnectedComponentsConfig) Descriptor() ([]byte, []int)
Deprecated: Use ConnectedComponentsConfig.ProtoReflect.Descriptor instead.
func (x *ConnectedComponentsConfig) GetWeightThreshold() float32
func (*ConnectedComponentsConfig) ProtoMessage()
func (x *ConnectedComponentsConfig) ProtoReflect() protoreflect.Message
func (x *ConnectedComponentsConfig) Reset()
func (x *ConnectedComponentsConfig) String() string
Request message for CreateEntityReconciliationJob.
type CreateEntityReconciliationJobRequest struct {
// Required. The resource name of the Location to create the
// EntityReconciliationJob in. Format:
// `projects/{project}/locations/{location}`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The EntityReconciliationJob to create.
EntityReconciliationJob *EntityReconciliationJob `protobuf:"bytes,2,opt,name=entity_reconciliation_job,json=entityReconciliationJob,proto3" json:"entity_reconciliation_job,omitempty"`
// contains filtered or unexported fields
}
func (*CreateEntityReconciliationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateEntityReconciliationJobRequest.ProtoReflect.Descriptor instead.
func (x *CreateEntityReconciliationJobRequest) GetEntityReconciliationJob() *EntityReconciliationJob
func (x *CreateEntityReconciliationJobRequest) GetParent() string
func (*CreateEntityReconciliationJobRequest) ProtoMessage()
func (x *CreateEntityReconciliationJobRequest) ProtoReflect() protoreflect.Message
func (x *CreateEntityReconciliationJobRequest) Reset()
func (x *CreateEntityReconciliationJobRequest) String() string
Request message for DeleteEntityReconciliationJob.
type DeleteEntityReconciliationJobRequest struct {
// Required. The name of the EntityReconciliationJob resource.
// Format:
// `projects/{project}/locations/{location}/entityReconciliationJobs/{entity_reconciliation_job}`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteEntityReconciliationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEntityReconciliationJobRequest.ProtoReflect.Descriptor instead.
func (x *DeleteEntityReconciliationJobRequest) GetName() string
func (*DeleteEntityReconciliationJobRequest) ProtoMessage()
func (x *DeleteEntityReconciliationJobRequest) ProtoReflect() protoreflect.Message
func (x *DeleteEntityReconciliationJobRequest) Reset()
func (x *DeleteEntityReconciliationJobRequest) String() string
Details of operations that perform deletes of any entities.
type DeleteOperationMetadata struct {
// The common part of the operation metadata.
CommonMetadata *CommonOperationMetadata `protobuf:"bytes,1,opt,name=common_metadata,json=commonMetadata,proto3" json:"common_metadata,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteOperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DeleteOperationMetadata.ProtoReflect.Descriptor instead.
func (x *DeleteOperationMetadata) GetCommonMetadata() *CommonOperationMetadata
func (*DeleteOperationMetadata) ProtoMessage()
func (x *DeleteOperationMetadata) ProtoReflect() protoreflect.Message
func (x *DeleteOperationMetadata) Reset()
func (x *DeleteOperationMetadata) String() string
EnterpriseKnowledgeGraphServiceClient is the client API for EnterpriseKnowledgeGraphService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type EnterpriseKnowledgeGraphServiceClient interface {
// Creates a EntityReconciliationJob. A EntityReconciliationJob once created
// will right away be attempted to start.
CreateEntityReconciliationJob(ctx context.Context, in *CreateEntityReconciliationJobRequest, opts ...grpc.CallOption) (*EntityReconciliationJob, error)
// Gets a EntityReconciliationJob.
GetEntityReconciliationJob(ctx context.Context, in *GetEntityReconciliationJobRequest, opts ...grpc.CallOption) (*EntityReconciliationJob, error)
// Lists Entity Reconciliation Jobs.
ListEntityReconciliationJobs(ctx context.Context, in *ListEntityReconciliationJobsRequest, opts ...grpc.CallOption) (*ListEntityReconciliationJobsResponse, error)
// Cancels a EntityReconciliationJob. Success of cancellation is not
// guaranteed.
CancelEntityReconciliationJob(ctx context.Context, in *CancelEntityReconciliationJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Deletes a EntityReconciliationJob.
// It only deletes the job when the job state is in FAILED, SUCCEEDED, and
// CANCELLED.
DeleteEntityReconciliationJob(ctx context.Context, in *DeleteEntityReconciliationJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Finds the Cloud KG entities with CKG ID(s).
Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
// Searches the Cloud KG entities with entity name.
Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
// Finds the public KG entities with public KG ID(s).
LookupPublicKg(ctx context.Context, in *LookupPublicKgRequest, opts ...grpc.CallOption) (*LookupPublicKgResponse, error)
// Searches the public KG entities with entity name.
SearchPublicKg(ctx context.Context, in *SearchPublicKgRequest, opts ...grpc.CallOption) (*SearchPublicKgResponse, error)
}
func NewEnterpriseKnowledgeGraphServiceClient(cc grpc.ClientConnInterface) EnterpriseKnowledgeGraphServiceClient
EnterpriseKnowledgeGraphServiceServer is the server API for EnterpriseKnowledgeGraphService service.
type EnterpriseKnowledgeGraphServiceServer interface {
// Creates a EntityReconciliationJob. A EntityReconciliationJob once created
// will right away be attempted to start.
CreateEntityReconciliationJob(context.Context, *CreateEntityReconciliationJobRequest) (*EntityReconciliationJob, error)
// Gets a EntityReconciliationJob.
GetEntityReconciliationJob(context.Context, *GetEntityReconciliationJobRequest) (*EntityReconciliationJob, error)
// Lists Entity Reconciliation Jobs.
ListEntityReconciliationJobs(context.Context, *ListEntityReconciliationJobsRequest) (*ListEntityReconciliationJobsResponse, error)
// Cancels a EntityReconciliationJob. Success of cancellation is not
// guaranteed.
CancelEntityReconciliationJob(context.Context, *CancelEntityReconciliationJobRequest) (*emptypb.Empty, error)
// Deletes a EntityReconciliationJob.
// It only deletes the job when the job state is in FAILED, SUCCEEDED, and
// CANCELLED.
DeleteEntityReconciliationJob(context.Context, *DeleteEntityReconciliationJobRequest) (*emptypb.Empty, error)
// Finds the Cloud KG entities with CKG ID(s).
Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
// Searches the Cloud KG entities with entity name.
Search(context.Context, *SearchRequest) (*SearchResponse, error)
// Finds the public KG entities with public KG ID(s).
LookupPublicKg(context.Context, *LookupPublicKgRequest) (*LookupPublicKgResponse, error)
// Searches the public KG entities with entity name.
SearchPublicKg(context.Context, *SearchPublicKgRequest) (*SearchPublicKgResponse, error)
}
Entity reconciliation job message.
type EntityReconciliationJob struct {
// Output only. Resource name of the EntityReconciliationJob.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Required. Information about the input BigQuery tables.
InputConfig *InputConfig `protobuf:"bytes,2,opt,name=input_config,json=inputConfig,proto3" json:"input_config,omitempty"`
// Required. The desired output location.
OutputConfig *OutputConfig `protobuf:"bytes,3,opt,name=output_config,json=outputConfig,proto3" json:"output_config,omitempty"`
// Output only. The detailed state of the job.
State JobState `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.enterpriseknowledgegraph.v1.JobState" json:"state,omitempty"`
// Output only. Only populated when the job's state is JOB_STATE_FAILED or
// JOB_STATE_CANCELLED.
Error *status.Status `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
// Output only. Time when the EntityReconciliationJob was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. Time when the EntityReconciliationJob entered any of the
// following states: `JOB_STATE_SUCCEEDED`, `JOB_STATE_FAILED`,
// `JOB_STATE_CANCELLED`.
EndTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Output only. Time when the EntityReconciliationJob was most recently
// updated.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Optional. Recon configs to adjust the clustering behavior.
ReconConfig *ReconConfig `protobuf:"bytes,9,opt,name=recon_config,json=reconConfig,proto3" json:"recon_config,omitempty"`
// contains filtered or unexported fields
}
func (*EntityReconciliationJob) Descriptor() ([]byte, []int)
Deprecated: Use EntityReconciliationJob.ProtoReflect.Descriptor instead.
func (x *EntityReconciliationJob) GetCreateTime() *timestamppb.Timestamp
func (x *EntityReconciliationJob) GetEndTime() *timestamppb.Timestamp
func (x *EntityReconciliationJob) GetError() *status.Status
func (x *EntityReconciliationJob) GetInputConfig() *InputConfig
func (x *EntityReconciliationJob) GetName() string
func (x *EntityReconciliationJob) GetOutputConfig() *OutputConfig
func (x *EntityReconciliationJob) GetReconConfig() *ReconConfig
func (x *EntityReconciliationJob) GetState() JobState
func (x *EntityReconciliationJob) GetUpdateTime() *timestamppb.Timestamp
func (*EntityReconciliationJob) ProtoMessage()
func (x *EntityReconciliationJob) ProtoReflect() protoreflect.Message
func (x *EntityReconciliationJob) Reset()
func (x *EntityReconciliationJob) String() string
Request message for GetEntityReconciliationJob.
type GetEntityReconciliationJobRequest struct {
// Required. The name of the EntityReconciliationJob resource.
// Format:
// `projects/{project}/locations/{location}/entityReconciliationJobs/{entity_reconciliation_job}`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetEntityReconciliationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityReconciliationJobRequest.ProtoReflect.Descriptor instead.
func (x *GetEntityReconciliationJobRequest) GetName() string
func (*GetEntityReconciliationJobRequest) ProtoMessage()
func (x *GetEntityReconciliationJobRequest) ProtoReflect() protoreflect.Message
func (x *GetEntityReconciliationJobRequest) Reset()
func (x *GetEntityReconciliationJobRequest) String() string
The desired input location and metadata.
type InputConfig struct {
// Set of input BigQuery tables.
BigqueryInputConfigs []*BigQueryInputConfig `protobuf:"bytes,1,rep,name=bigquery_input_configs,json=bigqueryInputConfigs,proto3" json:"bigquery_input_configs,omitempty"`
// Entity type
EntityType InputConfig_EntityType `protobuf:"varint,2,opt,name=entity_type,json=entityType,proto3,enum=google.cloud.enterpriseknowledgegraph.v1.InputConfig_EntityType" json:"entity_type,omitempty"`
// Optional. Provide the bigquery table containing the previous results if
// cluster ID stability is desired. Format is
// `projects/*/datasets/*/tables/*`.
PreviousResultBigqueryTable string `protobuf:"bytes,3,opt,name=previous_result_bigquery_table,json=previousResultBigqueryTable,proto3" json:"previous_result_bigquery_table,omitempty"`
// contains filtered or unexported fields
}
func (*InputConfig) Descriptor() ([]byte, []int)
Deprecated: Use InputConfig.ProtoReflect.Descriptor instead.
func (x *InputConfig) GetBigqueryInputConfigs() []*BigQueryInputConfig
func (x *InputConfig) GetEntityType() InputConfig_EntityType
func (x *InputConfig) GetPreviousResultBigqueryTable() string
func (*InputConfig) ProtoMessage()
func (x *InputConfig) ProtoReflect() protoreflect.Message
func (x *InputConfig) Reset()
func (x *InputConfig) String() string
The type of entities we will support. Currently, we only support people, establishment, property, and product types. If the type is unspecified, it will be generic type.
type InputConfig_EntityType int32
const (
// The default value.
InputConfig_ENTITY_TYPE_UNSPECIFIED InputConfig_EntityType = 0
// People entity.
//
// Deprecated: Do not use.
InputConfig_PEOPLE InputConfig_EntityType = 1
// Establishment entity.
//
// Deprecated: Do not use.
InputConfig_ESTABLISHMENT InputConfig_EntityType = 2
// Property entity. e.g. real estate property.
//
// Deprecated: Do not use.
InputConfig_PROPERTY InputConfig_EntityType = 3
// Product entity.
InputConfig_PRODUCT InputConfig_EntityType = 4
// Organization entity.
InputConfig_ORGANIZATION InputConfig_EntityType = 5
// Local Business entity.
InputConfig_LOCAL_BUSINESS InputConfig_EntityType = 6
// Person entity.
InputConfig_PERSON InputConfig_EntityType = 7
)
func (InputConfig_EntityType) Descriptor() protoreflect.EnumDescriptor
func (x InputConfig_EntityType) Enum() *InputConfig_EntityType
func (InputConfig_EntityType) EnumDescriptor() ([]byte, []int)
Deprecated: Use InputConfig_EntityType.Descriptor instead.
func (x InputConfig_EntityType) Number() protoreflect.EnumNumber
func (x InputConfig_EntityType) String() string
func (InputConfig_EntityType) Type() protoreflect.EnumType
Describes the state of a job.
type JobState int32
const (
// The job state is unspecified.
JobState_JOB_STATE_UNSPECIFIED JobState = 0
// The service is preparing to run the job.
JobState_JOB_STATE_PENDING JobState = 9
// The job is in progress.
JobState_JOB_STATE_RUNNING JobState = 1
// The job completed successfully.
JobState_JOB_STATE_SUCCEEDED JobState = 2
// The job failed.
JobState_JOB_STATE_FAILED JobState = 3
// The job has been cancelled.
JobState_JOB_STATE_CANCELLED JobState = 4
// Entity Recon API: The knowledge extraction job is running.
JobState_JOB_STATE_KNOWLEDGE_EXTRACTION JobState = 5
// Entity Recon API: The preprocessing job is running.
JobState_JOB_STATE_RECON_PREPROCESSING JobState = 6
// Entity Recon API: The clustering job is running.
JobState_JOB_STATE_CLUSTERING JobState = 7
// Entity Recon API: The exporting clusters job is running.
JobState_JOB_STATE_EXPORTING_CLUSTERS JobState = 8
)
func (JobState) Descriptor() protoreflect.EnumDescriptor
func (x JobState) Enum() *JobState
func (JobState) EnumDescriptor() ([]byte, []int)
Deprecated: Use JobState.Descriptor instead.
func (x JobState) Number() protoreflect.EnumNumber
func (x JobState) String() string
func (JobState) Type() protoreflect.EnumType
Request message for [EnterpriseKnowledgeGraphService.ListEntityReconciliationJobs][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.ListEntityReconciliationJobs].
type ListEntityReconciliationJobsRequest struct {
// Required. The name of the EntityReconciliationJob's parent resource.
// Format: `projects/{project}/locations/{location}`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// An expression for filtering the results of the request. For field names
// both snake_case and camelCase are supported.
Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
// The standard list page size.
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The standard list page token.
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListEntityReconciliationJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEntityReconciliationJobsRequest.ProtoReflect.Descriptor instead.
func (x *ListEntityReconciliationJobsRequest) GetFilter() string
func (x *ListEntityReconciliationJobsRequest) GetPageSize() int32
func (x *ListEntityReconciliationJobsRequest) GetPageToken() string
func (x *ListEntityReconciliationJobsRequest) GetParent() string
func (*ListEntityReconciliationJobsRequest) ProtoMessage()
func (x *ListEntityReconciliationJobsRequest) ProtoReflect() protoreflect.Message
func (x *ListEntityReconciliationJobsRequest) Reset()
func (x *ListEntityReconciliationJobsRequest) String() string
Response message for [EnterpriseKnowledgeGraphService.ListEntityReconciliationJobs][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.ListEntityReconciliationJobs].
type ListEntityReconciliationJobsResponse struct {
// A list of EntityReconciliationJobs that matches the specified filter in the
// request.
EntityReconciliationJobs []*EntityReconciliationJob `protobuf:"bytes,1,rep,name=entity_reconciliation_jobs,json=entityReconciliationJobs,proto3" json:"entity_reconciliation_jobs,omitempty"`
// The standard List next-page token.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListEntityReconciliationJobsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEntityReconciliationJobsResponse.ProtoReflect.Descriptor instead.
func (x *ListEntityReconciliationJobsResponse) GetEntityReconciliationJobs() []*EntityReconciliationJob
func (x *ListEntityReconciliationJobsResponse) GetNextPageToken() string
func (*ListEntityReconciliationJobsResponse) ProtoMessage()
func (x *ListEntityReconciliationJobsResponse) ProtoReflect() protoreflect.Message
func (x *ListEntityReconciliationJobsResponse) Reset()
func (x *ListEntityReconciliationJobsResponse) String() string
Request message for [EnterpriseKnowledgeGraphService.LookupPublicKg][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.LookupPublicKg].
type LookupPublicKgRequest struct {
// Required. The name of the Entity's parent resource.
// Format:
// `projects/{project}/locations/{location}`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The list of entity ids to be used for lookup.
Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
// The list of language codes (defined in ISO 693) to run the query with,
// e.g. 'en'.
Languages []string `protobuf:"bytes,3,rep,name=languages,proto3" json:"languages,omitempty"`
// contains filtered or unexported fields
}
func (*LookupPublicKgRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupPublicKgRequest.ProtoReflect.Descriptor instead.
func (x *LookupPublicKgRequest) GetIds() []string
func (x *LookupPublicKgRequest) GetLanguages() []string
func (x *LookupPublicKgRequest) GetParent() string
func (*LookupPublicKgRequest) ProtoMessage()
func (x *LookupPublicKgRequest) ProtoReflect() protoreflect.Message
func (x *LookupPublicKgRequest) Reset()
func (x *LookupPublicKgRequest) String() string
Response message for [EnterpriseKnowledgeGraphService.LookupPublicKg][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.LookupPublicKg].
type LookupPublicKgResponse struct {
// The local context applicable for the response. See more details at
// http://www.w3.org/TR/json-ld/#context-definitions.
Context *structpb.Value `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
// The schema type of top-level JSON-LD object, e.g. ItemList.
Type *structpb.Value `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
// The item list of search results.
ItemListElement *structpb.ListValue `protobuf:"bytes,3,opt,name=item_list_element,json=itemListElement,proto3" json:"item_list_element,omitempty"`
// contains filtered or unexported fields
}
func (*LookupPublicKgResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupPublicKgResponse.ProtoReflect.Descriptor instead.
func (x *LookupPublicKgResponse) GetContext() *structpb.Value
func (x *LookupPublicKgResponse) GetItemListElement() *structpb.ListValue
func (x *LookupPublicKgResponse) GetType() *structpb.Value
func (*LookupPublicKgResponse) ProtoMessage()
func (x *LookupPublicKgResponse) ProtoReflect() protoreflect.Message
func (x *LookupPublicKgResponse) Reset()
func (x *LookupPublicKgResponse) String() string
Request message for [EnterpriseKnowledgeGraphService.Lookup][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.Lookup].
type LookupRequest struct {
// Required. The name of the Entity's parent resource.
// Format:
// `projects/{project}/locations/{location}`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The list of entity ids to be used for lookup.
Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
// The list of language codes (defined in ISO 693) to run the query with,
// e.g. 'en'.
Languages []string `protobuf:"bytes,3,rep,name=languages,proto3" json:"languages,omitempty"`
// contains filtered or unexported fields
}
func (*LookupRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupRequest.ProtoReflect.Descriptor instead.
func (x *LookupRequest) GetIds() []string
func (x *LookupRequest) GetLanguages() []string
func (x *LookupRequest) GetParent() string
func (*LookupRequest) ProtoMessage()
func (x *LookupRequest) ProtoReflect() protoreflect.Message
func (x *LookupRequest) Reset()
func (x *LookupRequest) String() string
Response message for [EnterpriseKnowledgeGraphService.Lookup][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.Lookup].
type LookupResponse struct {
// The local context applicable for the response. See more details at
// http://www.w3.org/TR/json-ld/#context-definitions.
Context *structpb.Value `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
// The schema type of top-level JSON-LD object, e.g. ItemList.
Type *structpb.Value `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
// The item list of search results.
ItemListElement *structpb.ListValue `protobuf:"bytes,3,opt,name=item_list_element,json=itemListElement,proto3" json:"item_list_element,omitempty"`
// contains filtered or unexported fields
}
func (*LookupResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupResponse.ProtoReflect.Descriptor instead.
func (x *LookupResponse) GetContext() *structpb.Value
func (x *LookupResponse) GetItemListElement() *structpb.ListValue
func (x *LookupResponse) GetType() *structpb.Value
func (*LookupResponse) ProtoMessage()
func (x *LookupResponse) ProtoReflect() protoreflect.Message
func (x *LookupResponse) Reset()
func (x *LookupResponse) String() string
The desired output location and metadata.
type OutputConfig struct {
// Format is “projects/*/datasets/*”.
BigqueryDataset string `protobuf:"bytes,1,opt,name=bigquery_dataset,json=bigqueryDataset,proto3" json:"bigquery_dataset,omitempty"`
// contains filtered or unexported fields
}
func (*OutputConfig) Descriptor() ([]byte, []int)
Deprecated: Use OutputConfig.ProtoReflect.Descriptor instead.
func (x *OutputConfig) GetBigqueryDataset() string
func (*OutputConfig) ProtoMessage()
func (x *OutputConfig) ProtoReflect() protoreflect.Message
func (x *OutputConfig) Reset()
func (x *OutputConfig) String() string
Recon configs
type ReconConfig struct {
// Choice of clustering algorithm. Default is ConnectedComponentsConfig.
//
// Types that are assignable to ClusteringConfig:
//
// *ReconConfig_ConnectedComponentsConfig
// *ReconConfig_AffinityClusteringConfig
ClusteringConfig isReconConfig_ClusteringConfig `protobuf_oneof:"clustering_config"`
// Extra options that affect entity clustering behavior.
Options *ReconConfig_Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
// Model Configs
ModelConfig *ReconConfig_ModelConfig `protobuf:"bytes,4,opt,name=model_config,json=modelConfig,proto3" json:"model_config,omitempty"`
// contains filtered or unexported fields
}
func (*ReconConfig) Descriptor() ([]byte, []int)
Deprecated: Use ReconConfig.ProtoReflect.Descriptor instead.
func (x *ReconConfig) GetAffinityClusteringConfig() *AffinityClusteringConfig
func (m *ReconConfig) GetClusteringConfig() isReconConfig_ClusteringConfig
func (x *ReconConfig) GetConnectedComponentsConfig() *ConnectedComponentsConfig
func (x *ReconConfig) GetModelConfig() *ReconConfig_ModelConfig
func (x *ReconConfig) GetOptions() *ReconConfig_Options
func (*ReconConfig) ProtoMessage()
func (x *ReconConfig) ProtoReflect() protoreflect.Message
func (x *ReconConfig) Reset()
func (x *ReconConfig) String() string
type ReconConfig_AffinityClusteringConfig struct {
// Configs for affinity clustering.
AffinityClusteringConfig *AffinityClusteringConfig `protobuf:"bytes,2,opt,name=affinity_clustering_config,json=affinityClusteringConfig,proto3,oneof"`
}
type ReconConfig_ConnectedComponentsConfig struct {
// Configs for connected components.
ConnectedComponentsConfig *ConnectedComponentsConfig `protobuf:"bytes,1,opt,name=connected_components_config,json=connectedComponentsConfig,proto3,oneof"`
}
Model Configs
type ReconConfig_ModelConfig struct {
// Model name. Refer to external documentation for valid names.
// If unspecified, it defaults to the one mentioned in the documentation.
ModelName string `protobuf:"bytes,1,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
// Model version tag. Refer to external documentation for valid tags.
// If unspecified, it defaults to the one mentioned in the documentation.
VersionTag string `protobuf:"bytes,2,opt,name=version_tag,json=versionTag,proto3" json:"version_tag,omitempty"`
// contains filtered or unexported fields
}
func (*ReconConfig_ModelConfig) Descriptor() ([]byte, []int)
Deprecated: Use ReconConfig_ModelConfig.ProtoReflect.Descriptor instead.
func (x *ReconConfig_ModelConfig) GetModelName() string
func (x *ReconConfig_ModelConfig) GetVersionTag() string
func (*ReconConfig_ModelConfig) ProtoMessage()
func (x *ReconConfig_ModelConfig) ProtoReflect() protoreflect.Message
func (x *ReconConfig_ModelConfig) Reset()
func (x *ReconConfig_ModelConfig) String() string
Options for experimental changes on entity clustering behavior.
type ReconConfig_Options struct {
// If true, separate clusters by their geographic region (from geocoding).
// Uses the following entity features:
//
// - schema.org/addressLocality
// - schema.org/addressRegion
// - schema.org/addressCountry
// Warning: processing will no longer be regionalized!
EnableGeocodingSeparation bool `protobuf:"varint,100,opt,name=enable_geocoding_separation,json=enableGeocodingSeparation,proto3" json:"enable_geocoding_separation,omitempty"`
// contains filtered or unexported fields
}
func (*ReconConfig_Options) Descriptor() ([]byte, []int)
Deprecated: Use ReconConfig_Options.ProtoReflect.Descriptor instead.
func (x *ReconConfig_Options) GetEnableGeocodingSeparation() bool
func (*ReconConfig_Options) ProtoMessage()
func (x *ReconConfig_Options) ProtoReflect() protoreflect.Message
func (x *ReconConfig_Options) Reset()
func (x *ReconConfig_Options) String() string
Request message for [EnterpriseKnowledgeGraphService.Search][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.Search].
type SearchPublicKgRequest struct {
// Required. The name of the Entity's parent resource.
// Format:
// `projects/{project}/locations/{location}`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The literal query string for search.
Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
// The list of language codes (defined in ISO 693) to run the query with,
// e.g. 'en'.
Languages []string `protobuf:"bytes,3,rep,name=languages,proto3" json:"languages,omitempty"`
// Restricts returned entities with these types, e.g. Person
// (as defined in http://schema.org/Person). If multiple types are specified,
// returned entities will contain one or more of these types.
Types []string `protobuf:"bytes,4,rep,name=types,proto3" json:"types,omitempty"`
// Limits the number of entities to be returned.
Limit *wrapperspb.Int32Value `protobuf:"bytes,6,opt,name=limit,proto3" json:"limit,omitempty"`
// contains filtered or unexported fields
}
func (*SearchPublicKgRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchPublicKgRequest.ProtoReflect.Descriptor instead.
func (x *SearchPublicKgRequest) GetLanguages() []string
func (x *SearchPublicKgRequest) GetLimit() *wrapperspb.Int32Value
func (x *SearchPublicKgRequest) GetParent() string
func (x *SearchPublicKgRequest) GetQuery() string
func (x *SearchPublicKgRequest) GetTypes() []string
func (*SearchPublicKgRequest) ProtoMessage()
func (x *SearchPublicKgRequest) ProtoReflect() protoreflect.Message
func (x *SearchPublicKgRequest) Reset()
func (x *SearchPublicKgRequest) String() string
Response message for [EnterpriseKnowledgeGraphService.Search][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.Search].
type SearchPublicKgResponse struct {
// The local context applicable for the response. See more details at
// http://www.w3.org/TR/json-ld/#context-definitions.
Context *structpb.Value `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
// The schema type of top-level JSON-LD object, e.g. ItemList.
Type *structpb.Value `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
// The item list of search results.
ItemListElement *structpb.ListValue `protobuf:"bytes,3,opt,name=item_list_element,json=itemListElement,proto3" json:"item_list_element,omitempty"`
// contains filtered or unexported fields
}
func (*SearchPublicKgResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchPublicKgResponse.ProtoReflect.Descriptor instead.
func (x *SearchPublicKgResponse) GetContext() *structpb.Value
func (x *SearchPublicKgResponse) GetItemListElement() *structpb.ListValue
func (x *SearchPublicKgResponse) GetType() *structpb.Value
func (*SearchPublicKgResponse) ProtoMessage()
func (x *SearchPublicKgResponse) ProtoReflect() protoreflect.Message
func (x *SearchPublicKgResponse) Reset()
func (x *SearchPublicKgResponse) String() string
Request message for [EnterpriseKnowledgeGraphService.Search][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.Search].
type SearchRequest struct {
// Required. The name of the Entity's parent resource.
// Format:
// `projects/{project}/locations/{location}`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The literal query string for search.
Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
// The list of language codes (defined in ISO 693) to run the query with,
// e.g. 'en'.
Languages []string `protobuf:"bytes,3,rep,name=languages,proto3" json:"languages,omitempty"`
// Restricts returned entities with these types, e.g. Person
// (as defined in http://schema.org/Person). If multiple types are specified,
// returned entities will contain one or more of these types.
Types []string `protobuf:"bytes,4,rep,name=types,proto3" json:"types,omitempty"`
// Limits the number of entities to be returned.
Limit *wrapperspb.Int32Value `protobuf:"bytes,6,opt,name=limit,proto3" json:"limit,omitempty"`
// contains filtered or unexported fields
}
func (*SearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
func (x *SearchRequest) GetLanguages() []string
func (x *SearchRequest) GetLimit() *wrapperspb.Int32Value
func (x *SearchRequest) GetParent() string
func (x *SearchRequest) GetQuery() string
func (x *SearchRequest) GetTypes() []string
func (*SearchRequest) ProtoMessage()
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (x *SearchRequest) Reset()
func (x *SearchRequest) String() string
Response message for [EnterpriseKnowledgeGraphService.Search][google.cloud.enterpriseknowledgegraph.v1.EnterpriseKnowledgeGraphService.Search].
type SearchResponse struct {
// The local context applicable for the response. See more details at
// http://www.w3.org/TR/json-ld/#context-definitions.
Context *structpb.Value `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
// The schema type of top-level JSON-LD object, e.g. ItemList.
Type *structpb.Value `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
// The item list of search results.
ItemListElement *structpb.ListValue `protobuf:"bytes,3,opt,name=item_list_element,json=itemListElement,proto3" json:"item_list_element,omitempty"`
// contains filtered or unexported fields
}
func (*SearchResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.
func (x *SearchResponse) GetContext() *structpb.Value
func (x *SearchResponse) GetItemListElement() *structpb.ListValue
func (x *SearchResponse) GetType() *structpb.Value
func (*SearchResponse) ProtoMessage()
func (x *SearchResponse) ProtoReflect() protoreflect.Message
func (x *SearchResponse) Reset()
func (x *SearchResponse) String() string
UnimplementedEnterpriseKnowledgeGraphServiceServer can be embedded to have forward compatible implementations.
type UnimplementedEnterpriseKnowledgeGraphServiceServer struct {
}
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) CancelEntityReconciliationJob(context.Context, *CancelEntityReconciliationJobRequest) (*emptypb.Empty, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) CreateEntityReconciliationJob(context.Context, *CreateEntityReconciliationJobRequest) (*EntityReconciliationJob, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) DeleteEntityReconciliationJob(context.Context, *DeleteEntityReconciliationJobRequest) (*emptypb.Empty, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) GetEntityReconciliationJob(context.Context, *GetEntityReconciliationJobRequest) (*EntityReconciliationJob, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) ListEntityReconciliationJobs(context.Context, *ListEntityReconciliationJobsRequest) (*ListEntityReconciliationJobsResponse, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) LookupPublicKg(context.Context, *LookupPublicKgRequest) (*LookupPublicKgResponse, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
func (*UnimplementedEnterpriseKnowledgeGraphServiceServer) SearchPublicKg(context.Context, *SearchPublicKgRequest) (*SearchPublicKgResponse, error)