admin

package
v0.0.0-...-c66870c Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2018 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CommonMetadata_State_name = map[int32]string{
	0: "STATE_UNSPECIFIED",
	1: "INITIALIZING",
	2: "PROCESSING",
	3: "CANCELLING",
	4: "FINALIZING",
	5: "SUCCESSFUL",
	6: "FAILED",
	7: "CANCELLED",
}
View Source 
var CommonMetadata_State_value = map[string]int32{
	"STATE_UNSPECIFIED": 0,
	"INITIALIZING":      1,
	"PROCESSING":        2,
	"CANCELLING":        3,
	"FINALIZING":        4,
	"SUCCESSFUL":        5,
	"FAILED":            6,
	"CANCELLED":         7,
}
View Source 
var Index_AncestorMode_name = map[int32]string{
	0: "ANCESTOR_MODE_UNSPECIFIED",
	1: "NONE",
	2: "ALL_ANCESTORS",
}
View Source 
var Index_AncestorMode_value = map[string]int32{
	"ANCESTOR_MODE_UNSPECIFIED": 0,
	"NONE":                      1,
	"ALL_ANCESTORS":             2,
}
View Source 
var Index_Direction_name = map[int32]string{
	0: "DIRECTION_UNSPECIFIED",
	1: "ASCENDING",
	2: "DESCENDING",
}
View Source 
var Index_Direction_value = map[string]int32{
	"DIRECTION_UNSPECIFIED": 0,
	"ASCENDING":             1,
	"DESCENDING":            2,
}
View Source 
var Index_State_name = map[int32]string{
	0: "STATE_UNSPECIFIED",
	1: "CREATING",
	2: "READY",
	3: "DELETING",
	4: "ERROR",
}
View Source 
var Index_State_value = map[string]int32{
	"STATE_UNSPECIFIED": 0,
	"CREATING":          1,
	"READY":             2,
	"DELETING":          3,
	"ERROR":             4,
}
View Source 
var OperationType_name = map[int32]string{
	0: "OPERATION_TYPE_UNSPECIFIED",
	1: "EXPORT_ENTITIES",
	2: "IMPORT_ENTITIES",
	3: "CREATE_INDEX",
	4: "DELETE_INDEX",
}
View Source 
var OperationType_value = map[string]int32{
	"OPERATION_TYPE_UNSPECIFIED": 0,
	"EXPORT_ENTITIES":            1,
	"IMPORT_ENTITIES":            2,
	"CREATE_INDEX":               3,
	"DELETE_INDEX":               4,
}

Functions

func RegisterDatastoreAdminServer 

func RegisterDatastoreAdminServer(s *grpc.Server, srv DatastoreAdminServer)

Types

type CommonMetadata 

type CommonMetadata struct {
	// The time that work began on the operation.
	StartTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The time the operation ended, either successfully or otherwise.
	EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The type of the operation. Can be used as a filter in
	// ListOperationsRequest.
	OperationType OperationType `` /* 146-byte string literal not displayed */
	// The client-assigned labels which were provided when the operation was
	// created. May also include additional labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The current state of the Operation.
	State                CommonMetadata_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.datastore.admin.v1.CommonMetadata_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Metadata common to all Datastore Admin operations.

func (*CommonMetadata) Descriptor 

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

func (*CommonMetadata) GetEndTime 

func (m *CommonMetadata) GetEndTime() *timestamp.Timestamp

func (*CommonMetadata) GetLabels 

func (m *CommonMetadata) GetLabels() map[string]string

func (*CommonMetadata) GetOperationType 

func (m *CommonMetadata) GetOperationType() OperationType

func (*CommonMetadata) GetStartTime 

func (m *CommonMetadata) GetStartTime() *timestamp.Timestamp

func (*CommonMetadata) GetState 

func (m *CommonMetadata) GetState() CommonMetadata_State

func (*CommonMetadata) ProtoMessage 

func (*CommonMetadata) ProtoMessage()

func (*CommonMetadata) Reset 

func (m *CommonMetadata) Reset()

func (*CommonMetadata) String 

func (m *CommonMetadata) String() string

func (*CommonMetadata) XXX_DiscardUnknown 

func (m *CommonMetadata) XXX_DiscardUnknown()

func (*CommonMetadata) XXX_Marshal 

func (m *CommonMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonMetadata) XXX_Merge 

func (dst *CommonMetadata) XXX_Merge(src proto.Message)

func (*CommonMetadata) XXX_Size 

func (m *CommonMetadata) XXX_Size() int

func (*CommonMetadata) XXX_Unmarshal 

func (m *CommonMetadata) XXX_Unmarshal(b []byte) error

type CommonMetadata_State 

type CommonMetadata_State int32

The various possible states for an ongoing Operation. 

const (
	// Unspecified.
	CommonMetadata_STATE_UNSPECIFIED CommonMetadata_State = 0
	// Request is being prepared for processing.
	CommonMetadata_INITIALIZING CommonMetadata_State = 1
	// Request is actively being processed.
	CommonMetadata_PROCESSING CommonMetadata_State = 2
	// Request is in the process of being cancelled after user called
	// google.longrunning.Operations.CancelOperation on the operation.
	CommonMetadata_CANCELLING CommonMetadata_State = 3
	// Request has been processed and is in its finalization stage.
	CommonMetadata_FINALIZING CommonMetadata_State = 4
	// Request has completed successfully.
	CommonMetadata_SUCCESSFUL CommonMetadata_State = 5
	// Request has finished being processed, but encountered an error.
	CommonMetadata_FAILED CommonMetadata_State = 6
	// Request has finished being cancelled after user called
	// google.longrunning.Operations.CancelOperation.
	CommonMetadata_CANCELLED CommonMetadata_State = 7
)

func (CommonMetadata_State) EnumDescriptor 

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

func (CommonMetadata_State) String 

func (x CommonMetadata_State) String() string

type DatastoreAdminClient 

type DatastoreAdminClient interface {
	// Exports a copy of all or a subset of entities from Google Cloud Datastore
	// to another storage system, such as Google Cloud Storage. Recent updates to
	// entities may not be reflected in the export. The export occurs in the
	// background and its progress can be monitored and managed via the
	// Operation resource that is created. The output of an export may only be
	// used once the associated operation is done. If an export operation is
	// cancelled before completion it may leave partial data behind in Google
	// Cloud Storage.
	ExportEntities(ctx context.Context, in *ExportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Imports entities into Google Cloud Datastore. Existing entities with the
	// same key are overwritten. The import occurs in the background and its
	// progress can be monitored and managed via the Operation resource that is
	// created. If an ImportEntities operation is cancelled, it is possible
	// that a subset of the data has already been imported to Cloud Datastore.
	ImportEntities(ctx context.Context, in *ImportEntitiesRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Gets an index.
	GetIndex(ctx context.Context, in *GetIndexRequest, opts ...grpc.CallOption) (*Index, error)
	// Lists the indexes that match the specified filters.  Datastore uses an
	// eventually consistent query to fetch the list of indexes and may
	// occasionally return stale results.
	ListIndexes(ctx context.Context, in *ListIndexesRequest, opts ...grpc.CallOption) (*ListIndexesResponse, error)
}

DatastoreAdminClient is the client API for DatastoreAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDatastoreAdminClient 

func NewDatastoreAdminClient(cc *grpc.ClientConn) DatastoreAdminClient

type DatastoreAdminServer 

type DatastoreAdminServer interface {
	// Exports a copy of all or a subset of entities from Google Cloud Datastore
	// to another storage system, such as Google Cloud Storage. Recent updates to
	// entities may not be reflected in the export. The export occurs in the
	// background and its progress can be monitored and managed via the
	// Operation resource that is created. The output of an export may only be
	// used once the associated operation is done. If an export operation is
	// cancelled before completion it may leave partial data behind in Google
	// Cloud Storage.
	ExportEntities(context.Context, *ExportEntitiesRequest) (*longrunning.Operation, error)
	// Imports entities into Google Cloud Datastore. Existing entities with the
	// same key are overwritten. The import occurs in the background and its
	// progress can be monitored and managed via the Operation resource that is
	// created. If an ImportEntities operation is cancelled, it is possible
	// that a subset of the data has already been imported to Cloud Datastore.
	ImportEntities(context.Context, *ImportEntitiesRequest) (*longrunning.Operation, error)
	// Gets an index.
	GetIndex(context.Context, *GetIndexRequest) (*Index, error)
	// Lists the indexes that match the specified filters.  Datastore uses an
	// eventually consistent query to fetch the list of indexes and may
	// occasionally return stale results.
	ListIndexes(context.Context, *ListIndexesRequest) (*ListIndexesResponse, error)
}

DatastoreAdminServer is the server API for DatastoreAdmin service.

type EntityFilter 

type EntityFilter struct {
	// If empty, then this represents all kinds.
	Kinds []string `protobuf:"bytes,1,rep,name=kinds,proto3" json:"kinds,omitempty"`
	// An empty list represents all namespaces. This is the preferred
	// usage for projects that don't use namespaces.
	//
	// An empty string element represents the default namespace. This should be
	// used if the project has data in non-default namespaces, but doesn't want to
	// include them.
	// Each namespace in this list must be unique.
	NamespaceIds         []string `protobuf:"bytes,2,rep,name=namespace_ids,json=namespaceIds,proto3" json:"namespace_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identifies a subset of entities in a project. This is specified as combinations of kinds and namespaces (either or both of which may be all, as described in the following examples). Example usage:

Entire project: 

kinds=[], namespace_ids=[]

Kinds Foo and Bar in all namespaces: 

kinds=['Foo', 'Bar'], namespace_ids=[]

Kinds Foo and Bar only in the default namespace: 

kinds=['Foo', 'Bar'], namespace_ids=['']

Kinds Foo and Bar in both the default and Baz namespaces: 

kinds=['Foo', 'Bar'], namespace_ids=['', 'Baz']

The entire Baz namespace: 

kinds=[], namespace_ids=['Baz']

func (*EntityFilter) Descriptor 

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

func (*EntityFilter) GetKinds 

func (m *EntityFilter) GetKinds() []string

func (*EntityFilter) GetNamespaceIds 

func (m *EntityFilter) GetNamespaceIds() []string

func (*EntityFilter) ProtoMessage 

func (*EntityFilter) ProtoMessage()

func (*EntityFilter) Reset 

func (m *EntityFilter) Reset()

func (*EntityFilter) String 

func (m *EntityFilter) String() string

func (*EntityFilter) XXX_DiscardUnknown 

func (m *EntityFilter) XXX_DiscardUnknown()

func (*EntityFilter) XXX_Marshal 

func (m *EntityFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EntityFilter) XXX_Merge 

func (dst *EntityFilter) XXX_Merge(src proto.Message)

func (*EntityFilter) XXX_Size 

func (m *EntityFilter) XXX_Size() int

func (*EntityFilter) XXX_Unmarshal 

func (m *EntityFilter) XXX_Unmarshal(b []byte) error

type ExportEntitiesMetadata 

type ExportEntitiesMetadata struct {
	// Metadata common to all Datastore Admin operations.
	Common *CommonMetadata `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"`
	// An estimate of the number of entities processed.
	ProgressEntities *Progress `protobuf:"bytes,2,opt,name=progress_entities,json=progressEntities,proto3" json:"progress_entities,omitempty"`
	// An estimate of the number of bytes processed.
	ProgressBytes *Progress `protobuf:"bytes,3,opt,name=progress_bytes,json=progressBytes,proto3" json:"progress_bytes,omitempty"`
	// Description of which entities are being exported.
	EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"`
	// Location for the export metadata and data files. This will be the same
	// value as the
	// [google.datastore.admin.v1.ExportEntitiesRequest.output_url_prefix][google.datastore.admin.v1.ExportEntitiesRequest.output_url_prefix]
	// field. The final output location is provided in
	// [google.datastore.admin.v1.ExportEntitiesResponse.output_url][google.datastore.admin.v1.ExportEntitiesResponse.output_url].
	OutputUrlPrefix      string   `protobuf:"bytes,5,opt,name=output_url_prefix,json=outputUrlPrefix,proto3" json:"output_url_prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Metadata for ExportEntities operations.

func (*ExportEntitiesMetadata) Descriptor 

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

func (*ExportEntitiesMetadata) GetCommon 

func (m *ExportEntitiesMetadata) GetCommon() *CommonMetadata

func (*ExportEntitiesMetadata) GetEntityFilter 

func (m *ExportEntitiesMetadata) GetEntityFilter() *EntityFilter

func (*ExportEntitiesMetadata) GetOutputUrlPrefix 

func (m *ExportEntitiesMetadata) GetOutputUrlPrefix() string

func (*ExportEntitiesMetadata) GetProgressBytes 

func (m *ExportEntitiesMetadata) GetProgressBytes() *Progress

func (*ExportEntitiesMetadata) GetProgressEntities 

func (m *ExportEntitiesMetadata) GetProgressEntities() *Progress

func (*ExportEntitiesMetadata) ProtoMessage 

func (*ExportEntitiesMetadata) ProtoMessage()

func (*ExportEntitiesMetadata) Reset 

func (m *ExportEntitiesMetadata) Reset()

func (*ExportEntitiesMetadata) String 

func (m *ExportEntitiesMetadata) String() string

func (*ExportEntitiesMetadata) XXX_DiscardUnknown 

func (m *ExportEntitiesMetadata) XXX_DiscardUnknown()

func (*ExportEntitiesMetadata) XXX_Marshal 

func (m *ExportEntitiesMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExportEntitiesMetadata) XXX_Merge 

func (dst *ExportEntitiesMetadata) XXX_Merge(src proto.Message)

func (*ExportEntitiesMetadata) XXX_Size 

func (m *ExportEntitiesMetadata) XXX_Size() int

func (*ExportEntitiesMetadata) XXX_Unmarshal 

func (m *ExportEntitiesMetadata) XXX_Unmarshal(b []byte) error

type ExportEntitiesRequest 

type ExportEntitiesRequest struct {
	// Project ID against which to make the request.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Client-assigned labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Description of what data from the project is included in the export.
	EntityFilter *EntityFilter `protobuf:"bytes,3,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"`
	// Location for the export metadata and data files.
	//
	// The full resource URL of the external storage location. Currently, only
	// Google Cloud Storage is supported. So output_url_prefix should be of the
	// form: `gs://BUCKET_NAME[/NAMESPACE_PATH]`, where `BUCKET_NAME` is the
	// name of the Cloud Storage bucket and `NAMESPACE_PATH` is an optional Cloud
	// Storage namespace path (this is not a Cloud Datastore namespace). For more
	// information about Cloud Storage namespace paths, see
	// [Object name
	// considerations](https://cloud.google.com/storage/docs/naming#object-considerations).
	//
	// The resulting files will be nested deeper than the specified URL prefix.
	// The final output URL will be provided in the
	// [google.datastore.admin.v1.ExportEntitiesResponse.output_url][google.datastore.admin.v1.ExportEntitiesResponse.output_url] field. That
	// value should be used for subsequent ImportEntities operations.
	//
	// By nesting the data files deeper, the same Cloud Storage bucket can be used
	// in multiple ExportEntities operations without conflict.
	OutputUrlPrefix      string   `protobuf:"bytes,4,opt,name=output_url_prefix,json=outputUrlPrefix,proto3" json:"output_url_prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request for [google.datastore.admin.v1.DatastoreAdmin.ExportEntities][google.datastore.admin.v1.DatastoreAdmin.ExportEntities].

func (*ExportEntitiesRequest) Descriptor 

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

func (*ExportEntitiesRequest) GetEntityFilter 

func (m *ExportEntitiesRequest) GetEntityFilter() *EntityFilter

func (*ExportEntitiesRequest) GetLabels 

func (m *ExportEntitiesRequest) GetLabels() map[string]string

func (*ExportEntitiesRequest) GetOutputUrlPrefix 

func (m *ExportEntitiesRequest) GetOutputUrlPrefix() string

func (*ExportEntitiesRequest) GetProjectId 

func (m *ExportEntitiesRequest) GetProjectId() string

func (*ExportEntitiesRequest) ProtoMessage 

func (*ExportEntitiesRequest) ProtoMessage()

func (*ExportEntitiesRequest) Reset 

func (m *ExportEntitiesRequest) Reset()

func (*ExportEntitiesRequest) String 

func (m *ExportEntitiesRequest) String() string

func (*ExportEntitiesRequest) XXX_DiscardUnknown 

func (m *ExportEntitiesRequest) XXX_DiscardUnknown()

func (*ExportEntitiesRequest) XXX_Marshal 

func (m *ExportEntitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExportEntitiesRequest) XXX_Merge 

func (dst *ExportEntitiesRequest) XXX_Merge(src proto.Message)

func (*ExportEntitiesRequest) XXX_Size 

func (m *ExportEntitiesRequest) XXX_Size() int

func (*ExportEntitiesRequest) XXX_Unmarshal 

func (m *ExportEntitiesRequest) XXX_Unmarshal(b []byte) error

type ExportEntitiesResponse 

type ExportEntitiesResponse struct {
	// Location of the output metadata file. This can be used to begin an import
	// into Cloud Datastore (this project or another project). See
	// [google.datastore.admin.v1.ImportEntitiesRequest.input_url][google.datastore.admin.v1.ImportEntitiesRequest.input_url].
	// Only present if the operation completed successfully.
	OutputUrl            string   `protobuf:"bytes,1,opt,name=output_url,json=outputUrl,proto3" json:"output_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response for [google.datastore.admin.v1.DatastoreAdmin.ExportEntities][google.datastore.admin.v1.DatastoreAdmin.ExportEntities].

func (*ExportEntitiesResponse) Descriptor 

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

func (*ExportEntitiesResponse) GetOutputUrl 

func (m *ExportEntitiesResponse) GetOutputUrl() string

func (*ExportEntitiesResponse) ProtoMessage 

func (*ExportEntitiesResponse) ProtoMessage()

func (*ExportEntitiesResponse) Reset 

func (m *ExportEntitiesResponse) Reset()

func (*ExportEntitiesResponse) String 

func (m *ExportEntitiesResponse) String() string

func (*ExportEntitiesResponse) XXX_DiscardUnknown 

func (m *ExportEntitiesResponse) XXX_DiscardUnknown()

func (*ExportEntitiesResponse) XXX_Marshal 

func (m *ExportEntitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExportEntitiesResponse) XXX_Merge 

func (dst *ExportEntitiesResponse) XXX_Merge(src proto.Message)

func (*ExportEntitiesResponse) XXX_Size 

func (m *ExportEntitiesResponse) XXX_Size() int

func (*ExportEntitiesResponse) XXX_Unmarshal 

func (m *ExportEntitiesResponse) XXX_Unmarshal(b []byte) error

type GetIndexRequest 

type GetIndexRequest struct {
	// Project ID against which to make the request.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The resource ID of the index to get.
	IndexId              string   `protobuf:"bytes,3,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request for [google.datastore.admin.v1.DatastoreAdmin.GetIndex][google.datastore.admin.v1.DatastoreAdmin.GetIndex].

func (*GetIndexRequest) Descriptor 

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

func (*GetIndexRequest) GetIndexId 

func (m *GetIndexRequest) GetIndexId() string

func (*GetIndexRequest) GetProjectId 

func (m *GetIndexRequest) GetProjectId() string

func (*GetIndexRequest) ProtoMessage 

func (*GetIndexRequest) ProtoMessage()

func (*GetIndexRequest) Reset 

func (m *GetIndexRequest) Reset()

func (*GetIndexRequest) String 

func (m *GetIndexRequest) String() string

func (*GetIndexRequest) XXX_DiscardUnknown 

func (m *GetIndexRequest) XXX_DiscardUnknown()

func (*GetIndexRequest) XXX_Marshal 

func (m *GetIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetIndexRequest) XXX_Merge 

func (dst *GetIndexRequest) XXX_Merge(src proto.Message)

func (*GetIndexRequest) XXX_Size 

func (m *GetIndexRequest) XXX_Size() int

func (*GetIndexRequest) XXX_Unmarshal 

func (m *GetIndexRequest) XXX_Unmarshal(b []byte) error

type ImportEntitiesMetadata 

type ImportEntitiesMetadata struct {
	// Metadata common to all Datastore Admin operations.
	Common *CommonMetadata `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"`
	// An estimate of the number of entities processed.
	ProgressEntities *Progress `protobuf:"bytes,2,opt,name=progress_entities,json=progressEntities,proto3" json:"progress_entities,omitempty"`
	// An estimate of the number of bytes processed.
	ProgressBytes *Progress `protobuf:"bytes,3,opt,name=progress_bytes,json=progressBytes,proto3" json:"progress_bytes,omitempty"`
	// Description of which entities are being imported.
	EntityFilter *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"`
	// The location of the import metadata file. This will be the same value as
	// the [google.datastore.admin.v1.ExportEntitiesResponse.output_url][google.datastore.admin.v1.ExportEntitiesResponse.output_url] field.
	InputUrl             string   `protobuf:"bytes,5,opt,name=input_url,json=inputUrl,proto3" json:"input_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Metadata for ImportEntities operations.

func (*ImportEntitiesMetadata) Descriptor 

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

func (*ImportEntitiesMetadata) GetCommon 

func (m *ImportEntitiesMetadata) GetCommon() *CommonMetadata

func (*ImportEntitiesMetadata) GetEntityFilter 

func (m *ImportEntitiesMetadata) GetEntityFilter() *EntityFilter

func (*ImportEntitiesMetadata) GetInputUrl 

func (m *ImportEntitiesMetadata) GetInputUrl() string

func (*ImportEntitiesMetadata) GetProgressBytes 

func (m *ImportEntitiesMetadata) GetProgressBytes() *Progress

func (*ImportEntitiesMetadata) GetProgressEntities 

func (m *ImportEntitiesMetadata) GetProgressEntities() *Progress

func (*ImportEntitiesMetadata) ProtoMessage 

func (*ImportEntitiesMetadata) ProtoMessage()

func (*ImportEntitiesMetadata) Reset 

func (m *ImportEntitiesMetadata) Reset()

func (*ImportEntitiesMetadata) String 

func (m *ImportEntitiesMetadata) String() string

func (*ImportEntitiesMetadata) XXX_DiscardUnknown 

func (m *ImportEntitiesMetadata) XXX_DiscardUnknown()

func (*ImportEntitiesMetadata) XXX_Marshal 

func (m *ImportEntitiesMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportEntitiesMetadata) XXX_Merge 

func (dst *ImportEntitiesMetadata) XXX_Merge(src proto.Message)

func (*ImportEntitiesMetadata) XXX_Size 

func (m *ImportEntitiesMetadata) XXX_Size() int

func (*ImportEntitiesMetadata) XXX_Unmarshal 

func (m *ImportEntitiesMetadata) XXX_Unmarshal(b []byte) error

type ImportEntitiesRequest 

type ImportEntitiesRequest struct {
	// Project ID against which to make the request.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Client-assigned labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The full resource URL of the external storage location. Currently, only
	// Google Cloud Storage is supported. So input_url should be of the form:
	// `gs://BUCKET_NAME[/NAMESPACE_PATH]/OVERALL_EXPORT_METADATA_FILE`, where
	// `BUCKET_NAME` is the name of the Cloud Storage bucket, `NAMESPACE_PATH` is
	// an optional Cloud Storage namespace path (this is not a Cloud Datastore
	// namespace), and `OVERALL_EXPORT_METADATA_FILE` is the metadata file written
	// by the ExportEntities operation. For more information about Cloud Storage
	// namespace paths, see
	// [Object name
	// considerations](https://cloud.google.com/storage/docs/naming#object-considerations).
	//
	// For more information, see
	// [google.datastore.admin.v1.ExportEntitiesResponse.output_url][google.datastore.admin.v1.ExportEntitiesResponse.output_url].
	InputUrl string `protobuf:"bytes,3,opt,name=input_url,json=inputUrl,proto3" json:"input_url,omitempty"`
	// Optionally specify which kinds/namespaces are to be imported. If provided,
	// the list must be a subset of the EntityFilter used in creating the export,
	// otherwise a FAILED_PRECONDITION error will be returned. If no filter is
	// specified then all entities from the export are imported.
	EntityFilter         *EntityFilter `protobuf:"bytes,4,opt,name=entity_filter,json=entityFilter,proto3" json:"entity_filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

The request for [google.datastore.admin.v1.DatastoreAdmin.ImportEntities][google.datastore.admin.v1.DatastoreAdmin.ImportEntities].

func (*ImportEntitiesRequest) Descriptor 

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

func (*ImportEntitiesRequest) GetEntityFilter 

func (m *ImportEntitiesRequest) GetEntityFilter() *EntityFilter

func (*ImportEntitiesRequest) GetInputUrl 

func (m *ImportEntitiesRequest) GetInputUrl() string

func (*ImportEntitiesRequest) GetLabels 

func (m *ImportEntitiesRequest) GetLabels() map[string]string

func (*ImportEntitiesRequest) GetProjectId 

func (m *ImportEntitiesRequest) GetProjectId() string

func (*ImportEntitiesRequest) ProtoMessage 

func (*ImportEntitiesRequest) ProtoMessage()

func (*ImportEntitiesRequest) Reset 

func (m *ImportEntitiesRequest) Reset()

func (*ImportEntitiesRequest) String 

func (m *ImportEntitiesRequest) String() string

func (*ImportEntitiesRequest) XXX_DiscardUnknown 

func (m *ImportEntitiesRequest) XXX_DiscardUnknown()

func (*ImportEntitiesRequest) XXX_Marshal 

func (m *ImportEntitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportEntitiesRequest) XXX_Merge 

func (dst *ImportEntitiesRequest) XXX_Merge(src proto.Message)

func (*ImportEntitiesRequest) XXX_Size 

func (m *ImportEntitiesRequest) XXX_Size() int

func (*ImportEntitiesRequest) XXX_Unmarshal 

func (m *ImportEntitiesRequest) XXX_Unmarshal(b []byte) error

type Index 

type Index struct {
	// Project ID.
	// Output only.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The resource ID of the index.
	// Output only.
	IndexId string `protobuf:"bytes,3,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	// The entity kind to which this index applies.
	// Required.
	Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	// The index's ancestor mode.  Must not be ANCESTOR_MODE_UNSPECIFIED.
	// Required.
	Ancestor Index_AncestorMode `protobuf:"varint,5,opt,name=ancestor,proto3,enum=google.datastore.admin.v1.Index_AncestorMode" json:"ancestor,omitempty"`
	// An ordered sequence of property names and their index attributes.
	// Required.
	Properties []*Index_IndexedProperty `protobuf:"bytes,6,rep,name=properties,proto3" json:"properties,omitempty"`
	// The state of the index.
	// Output only.
	State                Index_State `protobuf:"varint,7,opt,name=state,proto3,enum=google.datastore.admin.v1.Index_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

A minimal index definition. Next tag: 8

func (*Index) Descriptor 

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

func (*Index) GetAncestor 

func (m *Index) GetAncestor() Index_AncestorMode

func (*Index) GetIndexId 

func (m *Index) GetIndexId() string

func (*Index) GetKind 

func (m *Index) GetKind() string

func (*Index) GetProjectId 

func (m *Index) GetProjectId() string

func (*Index) GetProperties 

func (m *Index) GetProperties() []*Index_IndexedProperty

func (*Index) GetState 

func (m *Index) GetState() Index_State

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) Reset 

func (m *Index) Reset()

func (*Index) String 

func (m *Index) String() string

func (*Index) XXX_DiscardUnknown 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal 

func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Index) XXX_Merge 

func (dst *Index) XXX_Merge(src proto.Message)

func (*Index) XXX_Size 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal 

func (m *Index) XXX_Unmarshal(b []byte) error

type IndexOperationMetadata 

type IndexOperationMetadata struct {
	// Metadata common to all Datastore Admin operations.
	Common *CommonMetadata `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"`
	// An estimate of the number of entities processed.
	ProgressEntities *Progress `protobuf:"bytes,2,opt,name=progress_entities,json=progressEntities,proto3" json:"progress_entities,omitempty"`
	// The index resource ID that this operation is acting on.
	IndexId              string   `protobuf:"bytes,3,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Metadata for Index operations.

func (*IndexOperationMetadata) Descriptor 

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

func (*IndexOperationMetadata) GetCommon 

func (m *IndexOperationMetadata) GetCommon() *CommonMetadata

func (*IndexOperationMetadata) GetIndexId 

func (m *IndexOperationMetadata) GetIndexId() string

func (*IndexOperationMetadata) GetProgressEntities 

func (m *IndexOperationMetadata) GetProgressEntities() *Progress

func (*IndexOperationMetadata) ProtoMessage 

func (*IndexOperationMetadata) ProtoMessage()

func (*IndexOperationMetadata) Reset 

func (m *IndexOperationMetadata) Reset()

func (*IndexOperationMetadata) String 

func (m *IndexOperationMetadata) String() string

func (*IndexOperationMetadata) XXX_DiscardUnknown 

func (m *IndexOperationMetadata) XXX_DiscardUnknown()

func (*IndexOperationMetadata) XXX_Marshal 

func (m *IndexOperationMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexOperationMetadata) XXX_Merge 

func (dst *IndexOperationMetadata) XXX_Merge(src proto.Message)

func (*IndexOperationMetadata) XXX_Size 

func (m *IndexOperationMetadata) XXX_Size() int

func (*IndexOperationMetadata) XXX_Unmarshal 

func (m *IndexOperationMetadata) XXX_Unmarshal(b []byte) error

type Index_AncestorMode 

type Index_AncestorMode int32

For an ordered index, specifies whether each of the entity's ancestors will be included. 

const (
	// The ancestor mode is unspecified.
	Index_ANCESTOR_MODE_UNSPECIFIED Index_AncestorMode = 0
	// Do not include the entity's ancestors in the index.
	Index_NONE Index_AncestorMode = 1
	// Include all the entity's ancestors in the index.
	Index_ALL_ANCESTORS Index_AncestorMode = 2
)

func (Index_AncestorMode) EnumDescriptor 

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

func (Index_AncestorMode) String 

func (x Index_AncestorMode) String() string

type Index_Direction 

type Index_Direction int32

The direction determines how a property is indexed. 

const (
	// The direction is unspecified.
	Index_DIRECTION_UNSPECIFIED Index_Direction = 0
	// The property's values are indexed so as to support sequencing in
	// ascending order and also query by <, >, <=, >=, and =.
	Index_ASCENDING Index_Direction = 1
	// The property's values are indexed so as to support sequencing in
	// descending order and also query by <, >, <=, >=, and =.
	Index_DESCENDING Index_Direction = 2
)

func (Index_Direction) EnumDescriptor 

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

func (Index_Direction) String 

func (x Index_Direction) String() string

type Index_IndexedProperty 

type Index_IndexedProperty struct {
	// The property name to index.
	// Required.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The indexed property's direction.  Must not be DIRECTION_UNSPECIFIED.
	// Required.
	Direction            Index_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=google.datastore.admin.v1.Index_Direction" json:"direction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Next tag: 3

func (*Index_IndexedProperty) Descriptor 

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

func (*Index_IndexedProperty) GetDirection 

func (m *Index_IndexedProperty) GetDirection() Index_Direction

func (*Index_IndexedProperty) GetName 

func (m *Index_IndexedProperty) GetName() string

func (*Index_IndexedProperty) ProtoMessage 

func (*Index_IndexedProperty) ProtoMessage()

func (*Index_IndexedProperty) Reset 

func (m *Index_IndexedProperty) Reset()

func (*Index_IndexedProperty) String 

func (m *Index_IndexedProperty) String() string

func (*Index_IndexedProperty) XXX_DiscardUnknown 

func (m *Index_IndexedProperty) XXX_DiscardUnknown()

func (*Index_IndexedProperty) XXX_Marshal 

func (m *Index_IndexedProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Index_IndexedProperty) XXX_Merge 

func (dst *Index_IndexedProperty) XXX_Merge(src proto.Message)

func (*Index_IndexedProperty) XXX_Size 

func (m *Index_IndexedProperty) XXX_Size() int

func (*Index_IndexedProperty) XXX_Unmarshal 

func (m *Index_IndexedProperty) XXX_Unmarshal(b []byte) error

type Index_State 

type Index_State int32

The possible set of states of an index. 

const (
	// The state is unspecified.
	Index_STATE_UNSPECIFIED Index_State = 0
	// The index is being created, and cannot be used by queries.
	// There is an active long-running operation for the index.
	// The index is updated when writing an entity.
	// Some index data may exist.
	Index_CREATING Index_State = 1
	// The index is ready to be used.
	// The index is updated when writing an entity.
	// The index is fully populated from all stored entities it applies to.
	Index_READY Index_State = 2
	// The index is being deleted, and cannot be used by queries.
	// There is an active long-running operation for the index.
	// The index is not updated when writing an entity.
	// Some index data may exist.
	Index_DELETING Index_State = 3
	// The index was being created or deleted, but something went wrong.
	// The index cannot by used by queries.
	// There is no active long-running operation for the index,
	// and the most recently finished long-running operation failed.
	// The index is not updated when writing an entity.
	// Some index data may exist.
	Index_ERROR Index_State = 4
)

func (Index_State) EnumDescriptor 

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

func (Index_State) String 

func (x Index_State) String() string

type ListIndexesRequest 

type ListIndexesRequest struct {
	// Project ID against which to make the request.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Filter    string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// The maximum number of items to return.  If zero, then all results will be
	// returned.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The next_page_token value returned from a previous List request, if any.
	PageToken            string   `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request for [google.datastore.admin.v1.DatastoreAdmin.ListIndexes][google.datastore.admin.v1.DatastoreAdmin.ListIndexes].

func (*ListIndexesRequest) Descriptor 

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

func (*ListIndexesRequest) GetFilter 

func (m *ListIndexesRequest) GetFilter() string

func (*ListIndexesRequest) GetPageSize 

func (m *ListIndexesRequest) GetPageSize() int32

func (*ListIndexesRequest) GetPageToken 

func (m *ListIndexesRequest) GetPageToken() string

func (*ListIndexesRequest) GetProjectId 

func (m *ListIndexesRequest) GetProjectId() string

func (*ListIndexesRequest) ProtoMessage 

func (*ListIndexesRequest) ProtoMessage()

func (*ListIndexesRequest) Reset 

func (m *ListIndexesRequest) Reset()

func (*ListIndexesRequest) String 

func (m *ListIndexesRequest) String() string

func (*ListIndexesRequest) XXX_DiscardUnknown 

func (m *ListIndexesRequest) XXX_DiscardUnknown()

func (*ListIndexesRequest) XXX_Marshal 

func (m *ListIndexesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListIndexesRequest) XXX_Merge 

func (dst *ListIndexesRequest) XXX_Merge(src proto.Message)

func (*ListIndexesRequest) XXX_Size 

func (m *ListIndexesRequest) XXX_Size() int

func (*ListIndexesRequest) XXX_Unmarshal 

func (m *ListIndexesRequest) XXX_Unmarshal(b []byte) error

type ListIndexesResponse 

type ListIndexesResponse struct {
	// The indexes.
	Indexes []*Index `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response for [google.datastore.admin.v1.DatastoreAdmin.ListIndexes][google.datastore.admin.v1.DatastoreAdmin.ListIndexes].

func (*ListIndexesResponse) Descriptor 

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

func (*ListIndexesResponse) GetIndexes 

func (m *ListIndexesResponse) GetIndexes() []*Index

func (*ListIndexesResponse) GetNextPageToken 

func (m *ListIndexesResponse) GetNextPageToken() string

func (*ListIndexesResponse) ProtoMessage 

func (*ListIndexesResponse) ProtoMessage()

func (*ListIndexesResponse) Reset 

func (m *ListIndexesResponse) Reset()

func (*ListIndexesResponse) String 

func (m *ListIndexesResponse) String() string

func (*ListIndexesResponse) XXX_DiscardUnknown 

func (m *ListIndexesResponse) XXX_DiscardUnknown()

func (*ListIndexesResponse) XXX_Marshal 

func (m *ListIndexesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListIndexesResponse) XXX_Merge 

func (dst *ListIndexesResponse) XXX_Merge(src proto.Message)

func (*ListIndexesResponse) XXX_Size 

func (m *ListIndexesResponse) XXX_Size() int

func (*ListIndexesResponse) XXX_Unmarshal 

func (m *ListIndexesResponse) XXX_Unmarshal(b []byte) error

type OperationType 

type OperationType int32

Operation types. 

const (
	// Unspecified.
	OperationType_OPERATION_TYPE_UNSPECIFIED OperationType = 0
	// ExportEntities.
	OperationType_EXPORT_ENTITIES OperationType = 1
	// ImportEntities.
	OperationType_IMPORT_ENTITIES OperationType = 2
	// CreateIndex.
	OperationType_CREATE_INDEX OperationType = 3
	// DeleteIndex.
	OperationType_DELETE_INDEX OperationType = 4
)

func (OperationType) EnumDescriptor 

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

func (OperationType) String 

func (x OperationType) String() string

type Progress 

type Progress struct {
	// The amount of work that has been completed. Note that this may be greater
	// than work_estimated.
	WorkCompleted int64 `protobuf:"varint,1,opt,name=work_completed,json=workCompleted,proto3" json:"work_completed,omitempty"`
	// An estimate of how much work needs to be performed. May be zero if the
	// work estimate is unavailable.
	WorkEstimated        int64    `protobuf:"varint,2,opt,name=work_estimated,json=workEstimated,proto3" json:"work_estimated,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Measures the progress of a particular metric.

func (*Progress) Descriptor 

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

func (*Progress) GetWorkCompleted 

func (m *Progress) GetWorkCompleted() int64

func (*Progress) GetWorkEstimated 

func (m *Progress) GetWorkEstimated() int64

func (*Progress) ProtoMessage 

func (*Progress) ProtoMessage()

func (*Progress) Reset 

func (m *Progress) Reset()

func (*Progress) String 

func (m *Progress) String() string

func (*Progress) XXX_DiscardUnknown 

func (m *Progress) XXX_DiscardUnknown()

func (*Progress) XXX_Marshal 

func (m *Progress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Progress) XXX_Merge 

func (dst *Progress) XXX_Merge(src proto.Message)

func (*Progress) XXX_Size 

func (m *Progress) XXX_Size() int

func (*Progress) XXX_Unmarshal 

func (m *Progress) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.