Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterIngestAPIServer(s grpc.ServiceRegistrar, srv IngestAPIServer)
- type Change
- func (*Change) Descriptor() ([]byte, []int)deprecated
- func (x *Change) GetDataType() Change_DataType
- func (x *Change) GetId() string
- func (*Change) ProtoMessage()
- func (x *Change) ProtoReflect() protoreflect.Message
- func (x *Change) Reset()
- func (x *Change) String() string
- func (m *Change) Validate() error
- func (m *Change) ValidateAll() error
- type ChangeMultiError
- type ChangeValidationError
- type Change_DataType
- func (Change_DataType) Descriptor() protoreflect.EnumDescriptor
- func (x Change_DataType) Enum() *Change_DataType
- func (Change_DataType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Change_DataType) Number() protoreflect.EnumNumber
- func (x Change_DataType) String() string
- func (Change_DataType) Type() protoreflect.EnumType
- type DeleteData
- func (*DeleteData) Descriptor() ([]byte, []int)deprecated
- func (m *DeleteData) GetData() isDeleteData_Data
- func (x *DeleteData) GetNode() *NodeMatch
- func (x *DeleteData) GetNodeProperty() *DeleteData_NodePropertyMatch
- func (x *DeleteData) GetRelation() *RelationMatch
- func (x *DeleteData) GetRelationProperty() *DeleteData_RelationPropertyMatch
- func (*DeleteData) ProtoMessage()
- func (x *DeleteData) ProtoReflect() protoreflect.Message
- func (x *DeleteData) Reset()
- func (x *DeleteData) String() string
- func (m *DeleteData) Validate() error
- func (m *DeleteData) ValidateAll() error
- type DeleteDataMultiError
- type DeleteDataValidationError
- type DeleteData_Node
- type DeleteData_NodeProperty
- type DeleteData_NodePropertyMatch
- func (*DeleteData_NodePropertyMatch) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteData_NodePropertyMatch) GetKey() string
- func (x *DeleteData_NodePropertyMatch) GetMatch() *NodeMatch
- func (*DeleteData_NodePropertyMatch) ProtoMessage()
- func (x *DeleteData_NodePropertyMatch) ProtoReflect() protoreflect.Message
- func (x *DeleteData_NodePropertyMatch) Reset()
- func (x *DeleteData_NodePropertyMatch) String() string
- func (m *DeleteData_NodePropertyMatch) Validate() error
- func (m *DeleteData_NodePropertyMatch) ValidateAll() error
- type DeleteData_NodePropertyMatchMultiError
- type DeleteData_NodePropertyMatchValidationError
- func (e DeleteData_NodePropertyMatchValidationError) Cause() error
- func (e DeleteData_NodePropertyMatchValidationError) Error() string
- func (e DeleteData_NodePropertyMatchValidationError) ErrorName() string
- func (e DeleteData_NodePropertyMatchValidationError) Field() string
- func (e DeleteData_NodePropertyMatchValidationError) Key() bool
- func (e DeleteData_NodePropertyMatchValidationError) Reason() string
- type DeleteData_Relation
- type DeleteData_RelationProperty
- type DeleteData_RelationPropertyMatch
- func (*DeleteData_RelationPropertyMatch) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteData_RelationPropertyMatch) GetKey() string
- func (x *DeleteData_RelationPropertyMatch) GetMatch() *RelationMatch
- func (*DeleteData_RelationPropertyMatch) ProtoMessage()
- func (x *DeleteData_RelationPropertyMatch) ProtoReflect() protoreflect.Message
- func (x *DeleteData_RelationPropertyMatch) Reset()
- func (x *DeleteData_RelationPropertyMatch) String() string
- func (m *DeleteData_RelationPropertyMatch) Validate() error
- func (m *DeleteData_RelationPropertyMatch) ValidateAll() error
- type DeleteData_RelationPropertyMatchMultiError
- type DeleteData_RelationPropertyMatchValidationError
- func (e DeleteData_RelationPropertyMatchValidationError) Cause() error
- func (e DeleteData_RelationPropertyMatchValidationError) Error() string
- func (e DeleteData_RelationPropertyMatchValidationError) ErrorName() string
- func (e DeleteData_RelationPropertyMatchValidationError) Field() string
- func (e DeleteData_RelationPropertyMatchValidationError) Key() bool
- func (e DeleteData_RelationPropertyMatchValidationError) Reason() string
- type DigitalTwin
- func (*DigitalTwin) Descriptor() ([]byte, []int)deprecated
- func (x *DigitalTwin) GetExternalId() string
- func (x *DigitalTwin) GetId() string
- func (x *DigitalTwin) GetIdentityProperties() []*IdentityPropertydeprecated
- func (x *DigitalTwin) GetProperties() []*Property
- func (x *DigitalTwin) GetTags() []string
- func (x *DigitalTwin) GetTenantId() stringdeprecated
- func (x *DigitalTwin) GetType() string
- func (*DigitalTwin) ProtoMessage()
- func (x *DigitalTwin) ProtoReflect() protoreflect.Message
- func (x *DigitalTwin) Reset()
- func (x *DigitalTwin) String() string
- func (m *DigitalTwin) Validate() error
- func (m *DigitalTwin) ValidateAll() error
- type DigitalTwinMultiError
- type DigitalTwinValidationError
- func (e DigitalTwinValidationError) Cause() error
- func (e DigitalTwinValidationError) Error() string
- func (e DigitalTwinValidationError) ErrorName() string
- func (e DigitalTwinValidationError) Field() string
- func (e DigitalTwinValidationError) Key() bool
- func (e DigitalTwinValidationError) Reason() string
- type IdentityProperty
- func (*IdentityProperty) Descriptor() ([]byte, []int)deprecated
- func (x *IdentityProperty) GetKey() string
- func (x *IdentityProperty) GetValue() *v1beta1.Value
- func (*IdentityProperty) ProtoMessage()
- func (x *IdentityProperty) ProtoReflect() protoreflect.Message
- func (x *IdentityProperty) Reset()
- func (x *IdentityProperty) String() string
- func (m *IdentityProperty) Validate() error
- func (m *IdentityProperty) ValidateAll() error
- type IdentityPropertyMultiError
- type IdentityPropertyValidationError
- func (e IdentityPropertyValidationError) Cause() error
- func (e IdentityPropertyValidationError) Error() string
- func (e IdentityPropertyValidationError) ErrorName() string
- func (e IdentityPropertyValidationError) Field() string
- func (e IdentityPropertyValidationError) Key() bool
- func (e IdentityPropertyValidationError) Reason() string
- type Info
- type InfoMultiError
- type InfoValidationError
- type IngestAPIClient
- type IngestAPIServer
- type IngestAPI_StreamRecordsClient
- type IngestAPI_StreamRecordsServer
- type IngestRecordRequest
- func (*IngestRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IngestRecordRequest) GetRecord() *Record
- func (*IngestRecordRequest) ProtoMessage()
- func (x *IngestRecordRequest) ProtoReflect() protoreflect.Message
- func (x *IngestRecordRequest) Reset()
- func (x *IngestRecordRequest) String() string
- func (m *IngestRecordRequest) Validate() error
- func (m *IngestRecordRequest) ValidateAll() error
- type IngestRecordRequestMultiError
- type IngestRecordRequestValidationError
- func (e IngestRecordRequestValidationError) Cause() error
- func (e IngestRecordRequestValidationError) Error() string
- func (e IngestRecordRequestValidationError) ErrorName() string
- func (e IngestRecordRequestValidationError) Field() string
- func (e IngestRecordRequestValidationError) Key() bool
- func (e IngestRecordRequestValidationError) Reason() string
- type IngestRecordResponse
- func (*IngestRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (m *IngestRecordResponse) GetError() isIngestRecordResponse_Error
- func (x *IngestRecordResponse) GetInfo() *Info
- func (x *IngestRecordResponse) GetRecordError() *RecordError
- func (x *IngestRecordResponse) GetRecordId() string
- func (x *IngestRecordResponse) GetStatusError() *status.Status
- func (*IngestRecordResponse) ProtoMessage()
- func (x *IngestRecordResponse) ProtoReflect() protoreflect.Message
- func (x *IngestRecordResponse) Reset()
- func (x *IngestRecordResponse) String() string
- func (m *IngestRecordResponse) Validate() error
- func (m *IngestRecordResponse) ValidateAll() error
- type IngestRecordResponseMultiError
- type IngestRecordResponseValidationError
- func (e IngestRecordResponseValidationError) Cause() error
- func (e IngestRecordResponseValidationError) Error() string
- func (e IngestRecordResponseValidationError) ErrorName() string
- func (e IngestRecordResponseValidationError) Field() string
- func (e IngestRecordResponseValidationError) Key() bool
- func (e IngestRecordResponseValidationError) Reason() string
- type IngestRecordResponse_RecordError
- type IngestRecordResponse_StatusError
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetDigitalTwin() *DigitalTwin
- func (x *Node) GetResource() *Resource
- func (m *Node) GetType() isNode_Type
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- func (m *Node) Validate() error
- func (m *Node) ValidateAll() error
- type NodeMatch
- func (*NodeMatch) Descriptor() ([]byte, []int)deprecated
- func (x *NodeMatch) GetExternalId() string
- func (x *NodeMatch) GetType() string
- func (*NodeMatch) ProtoMessage()
- func (x *NodeMatch) ProtoReflect() protoreflect.Message
- func (x *NodeMatch) Reset()
- func (x *NodeMatch) String() string
- func (m *NodeMatch) Validate() error
- func (m *NodeMatch) ValidateAll() error
- type NodeMatchMultiError
- type NodeMatchValidationError
- type NodeMultiError
- type NodeValidationError
- type Node_DigitalTwin
- type Node_Resource
- type Property
- func (*Property) Descriptor() ([]byte, []int)deprecated
- func (x *Property) GetKey() string
- func (x *Property) GetValue() *v1beta1.Value
- func (*Property) ProtoMessage()
- func (x *Property) ProtoReflect() protoreflect.Message
- func (x *Property) Reset()
- func (x *Property) String() string
- func (m *Property) Validate() error
- func (m *Property) ValidateAll() error
- type PropertyError
- func (*PropertyError) Descriptor() ([]byte, []int)deprecated
- func (x *PropertyError) GetMessages() []string
- func (*PropertyError) ProtoMessage()
- func (x *PropertyError) ProtoReflect() protoreflect.Message
- func (x *PropertyError) Reset()
- func (x *PropertyError) String() string
- func (m *PropertyError) Validate() error
- func (m *PropertyError) ValidateAll() error
- type PropertyErrorMultiError
- type PropertyErrorValidationError
- func (e PropertyErrorValidationError) Cause() error
- func (e PropertyErrorValidationError) Error() string
- func (e PropertyErrorValidationError) ErrorName() string
- func (e PropertyErrorValidationError) Field() string
- func (e PropertyErrorValidationError) Key() bool
- func (e PropertyErrorValidationError) Reason() string
- type PropertyMultiError
- type PropertyValidationError
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetDelete() *DeleteData
- func (x *Record) GetId() string
- func (m *Record) GetOperation() isRecord_Operation
- func (x *Record) GetUpsert() *UpsertData
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (x *Record) String() string
- func (m *Record) Validate() error
- func (m *Record) ValidateAll() error
- type RecordError
- func (*RecordError) Descriptor() ([]byte, []int)deprecated
- func (x *RecordError) GetPropertyErrors() map[string]*PropertyError
- func (*RecordError) ProtoMessage()
- func (x *RecordError) ProtoReflect() protoreflect.Message
- func (x *RecordError) Reset()
- func (x *RecordError) String() string
- func (m *RecordError) Validate() error
- func (m *RecordError) ValidateAll() error
- type RecordErrorMultiError
- type RecordErrorValidationError
- func (e RecordErrorValidationError) Cause() error
- func (e RecordErrorValidationError) Error() string
- func (e RecordErrorValidationError) ErrorName() string
- func (e RecordErrorValidationError) Field() string
- func (e RecordErrorValidationError) Key() bool
- func (e RecordErrorValidationError) Reason() string
- type RecordMultiError
- type RecordValidationError
- type Record_Delete
- type Record_Upsert
- type Relation
- func (*Relation) Descriptor() ([]byte, []int)deprecated
- func (x *Relation) GetMatch() *RelationMatch
- func (x *Relation) GetProperties() []*Property
- func (*Relation) ProtoMessage()
- func (x *Relation) ProtoReflect() protoreflect.Message
- func (x *Relation) Reset()
- func (x *Relation) String() string
- func (m *Relation) Validate() error
- func (m *Relation) ValidateAll() error
- type RelationMatch
- func (*RelationMatch) Descriptor() ([]byte, []int)deprecated
- func (x *RelationMatch) GetSourceMatch() *NodeMatch
- func (x *RelationMatch) GetTargetMatch() *NodeMatch
- func (x *RelationMatch) GetType() string
- func (*RelationMatch) ProtoMessage()
- func (x *RelationMatch) ProtoReflect() protoreflect.Message
- func (x *RelationMatch) Reset()
- func (x *RelationMatch) String() string
- func (m *RelationMatch) Validate() error
- func (m *RelationMatch) ValidateAll() error
- type RelationMatchMultiError
- type RelationMatchValidationError
- func (e RelationMatchValidationError) Cause() error
- func (e RelationMatchValidationError) Error() string
- func (e RelationMatchValidationError) ErrorName() string
- func (e RelationMatchValidationError) Field() string
- func (e RelationMatchValidationError) Key() bool
- func (e RelationMatchValidationError) Reason() string
- type RelationMultiError
- type RelationValidationError
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetExternalId() string
- func (x *Resource) GetProperties() []*Property
- func (x *Resource) GetTags() []string
- func (x *Resource) GetType() string
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- func (m *Resource) Validate() error
- func (m *Resource) ValidateAll() error
- type ResourceMultiError
- type ResourceValidationError
- type StreamRecordsRequest
- func (*StreamRecordsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRecordsRequest) GetRecord() *Record
- func (*StreamRecordsRequest) ProtoMessage()
- func (x *StreamRecordsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRecordsRequest) Reset()
- func (x *StreamRecordsRequest) String() string
- func (m *StreamRecordsRequest) Validate() error
- func (m *StreamRecordsRequest) ValidateAll() error
- type StreamRecordsRequestMultiError
- type StreamRecordsRequestValidationError
- func (e StreamRecordsRequestValidationError) Cause() error
- func (e StreamRecordsRequestValidationError) Error() string
- func (e StreamRecordsRequestValidationError) ErrorName() string
- func (e StreamRecordsRequestValidationError) Field() string
- func (e StreamRecordsRequestValidationError) Key() bool
- func (e StreamRecordsRequestValidationError) Reason() string
- type StreamRecordsResponse
- func (*StreamRecordsResponse) Descriptor() ([]byte, []int)deprecated
- func (m *StreamRecordsResponse) GetError() isStreamRecordsResponse_Error
- func (x *StreamRecordsResponse) GetInfo() *Info
- func (x *StreamRecordsResponse) GetRecordError() *RecordError
- func (x *StreamRecordsResponse) GetRecordId() string
- func (x *StreamRecordsResponse) GetRecordIndex() uint32
- func (x *StreamRecordsResponse) GetStatusError() *status.Status
- func (*StreamRecordsResponse) ProtoMessage()
- func (x *StreamRecordsResponse) ProtoReflect() protoreflect.Message
- func (x *StreamRecordsResponse) Reset()
- func (x *StreamRecordsResponse) String() string
- func (m *StreamRecordsResponse) Validate() error
- func (m *StreamRecordsResponse) ValidateAll() error
- type StreamRecordsResponseMultiError
- type StreamRecordsResponseValidationError
- func (e StreamRecordsResponseValidationError) Cause() error
- func (e StreamRecordsResponseValidationError) Error() string
- func (e StreamRecordsResponseValidationError) ErrorName() string
- func (e StreamRecordsResponseValidationError) Field() string
- func (e StreamRecordsResponseValidationError) Key() bool
- func (e StreamRecordsResponseValidationError) Reason() string
- type StreamRecordsResponse_RecordError
- type StreamRecordsResponse_StatusError
- type UnimplementedIngestAPIServer
- type UnsafeIngestAPIServer
- type UpsertData
- func (*UpsertData) Descriptor() ([]byte, []int)deprecated
- func (m *UpsertData) GetData() isUpsertData_Data
- func (x *UpsertData) GetNode() *Node
- func (x *UpsertData) GetRelation() *Relation
- func (*UpsertData) ProtoMessage()
- func (x *UpsertData) ProtoReflect() protoreflect.Message
- func (x *UpsertData) Reset()
- func (x *UpsertData) String() string
- func (m *UpsertData) Validate() error
- func (m *UpsertData) ValidateAll() error
- type UpsertDataMultiError
- type UpsertDataValidationError
- type UpsertData_Node
- type UpsertData_Relation
Constants ¶
const ( IngestAPI_StreamRecords_FullMethodName = "/indykite.ingest.v1beta2.IngestAPI/StreamRecords" IngestAPI_IngestRecord_FullMethodName = "/indykite.ingest.v1beta2.IngestAPI/IngestRecord" )
Variables ¶
var ( Change_DataType_name = map[int32]string{ 0: "DATA_TYPE_INVALID", 1: "DATA_TYPE_DIGITAL_TWIN", 2: "DATA_TYPE_RESOURCE", 3: "DATA_TYPE_RELATION", } Change_DataType_value = map[string]int32{ "DATA_TYPE_INVALID": 0, "DATA_TYPE_DIGITAL_TWIN": 1, "DATA_TYPE_RESOURCE": 2, "DATA_TYPE_RELATION": 3, } )
Enum value maps for Change_DataType.
var File_indykite_ingest_v1beta2_ingest_api_proto protoreflect.FileDescriptor
var File_indykite_ingest_v1beta2_model_proto protoreflect.FileDescriptor
var IngestAPI_ServiceDesc = grpc.ServiceDesc{ ServiceName: "indykite.ingest.v1beta2.IngestAPI", HandlerType: (*IngestAPIServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "IngestRecord", Handler: _IngestAPI_IngestRecord_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamRecords", Handler: _IngestAPI_StreamRecords_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "indykite/ingest/v1beta2/ingest_api.proto", }
IngestAPI_ServiceDesc is the grpc.ServiceDesc for IngestAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIngestAPIServer ¶
func RegisterIngestAPIServer(s grpc.ServiceRegistrar, srv IngestAPIServer)
Types ¶
type Change ¶ added in v0.13.0
type Change struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` DataType Change_DataType `` /* 131-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Change) Descriptor
deprecated
added in
v0.13.0
func (*Change) GetDataType ¶ added in v0.13.0
func (x *Change) GetDataType() Change_DataType
func (*Change) ProtoMessage ¶ added in v0.13.0
func (*Change) ProtoMessage()
func (*Change) ProtoReflect ¶ added in v0.13.0
func (x *Change) ProtoReflect() protoreflect.Message
func (*Change) Validate ¶ added in v0.13.0
Validate checks the field values on Change with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Change) ValidateAll ¶ added in v0.13.0
ValidateAll checks the field values on Change with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ChangeMultiError, or nil if none found.
type ChangeMultiError ¶ added in v0.13.0
type ChangeMultiError []error
ChangeMultiError is an error wrapping multiple validation errors returned by Change.ValidateAll() if the designated constraints aren't met.
func (ChangeMultiError) AllErrors ¶ added in v0.13.0
func (m ChangeMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ChangeMultiError) Error ¶ added in v0.13.0
func (m ChangeMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ChangeValidationError ¶ added in v0.13.0
type ChangeValidationError struct {
// contains filtered or unexported fields
}
ChangeValidationError is the validation error returned by Change.Validate if the designated constraints aren't met.
func (ChangeValidationError) Cause ¶ added in v0.13.0
func (e ChangeValidationError) Cause() error
Cause function returns cause value.
func (ChangeValidationError) Error ¶ added in v0.13.0
func (e ChangeValidationError) Error() string
Error satisfies the builtin error interface
func (ChangeValidationError) ErrorName ¶ added in v0.13.0
func (e ChangeValidationError) ErrorName() string
ErrorName returns error name.
func (ChangeValidationError) Field ¶ added in v0.13.0
func (e ChangeValidationError) Field() string
Field function returns field value.
func (ChangeValidationError) Key ¶ added in v0.13.0
func (e ChangeValidationError) Key() bool
Key function returns key value.
func (ChangeValidationError) Reason ¶ added in v0.13.0
func (e ChangeValidationError) Reason() string
Reason function returns reason value.
type Change_DataType ¶ added in v0.13.0
type Change_DataType int32
const ( Change_DATA_TYPE_INVALID Change_DataType = 0 Change_DATA_TYPE_DIGITAL_TWIN Change_DataType = 1 Change_DATA_TYPE_RESOURCE Change_DataType = 2 Change_DATA_TYPE_RELATION Change_DataType = 3 )
func (Change_DataType) Descriptor ¶ added in v0.13.0
func (Change_DataType) Descriptor() protoreflect.EnumDescriptor
func (Change_DataType) Enum ¶ added in v0.13.0
func (x Change_DataType) Enum() *Change_DataType
func (Change_DataType) EnumDescriptor
deprecated
added in
v0.13.0
func (Change_DataType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Change_DataType.Descriptor instead.
func (Change_DataType) Number ¶ added in v0.13.0
func (x Change_DataType) Number() protoreflect.EnumNumber
func (Change_DataType) String ¶ added in v0.13.0
func (x Change_DataType) String() string
func (Change_DataType) Type ¶ added in v0.13.0
func (Change_DataType) Type() protoreflect.EnumType
type DeleteData ¶
type DeleteData struct { // Types that are assignable to Data: // // *DeleteData_Node // *DeleteData_Relation // *DeleteData_NodeProperty // *DeleteData_RelationProperty Data isDeleteData_Data `protobuf_oneof:"data"` // contains filtered or unexported fields }
func (*DeleteData) Descriptor
deprecated
func (*DeleteData) Descriptor() ([]byte, []int)
Deprecated: Use DeleteData.ProtoReflect.Descriptor instead.
func (*DeleteData) GetData ¶
func (m *DeleteData) GetData() isDeleteData_Data
func (*DeleteData) GetNode ¶
func (x *DeleteData) GetNode() *NodeMatch
func (*DeleteData) GetNodeProperty ¶
func (x *DeleteData) GetNodeProperty() *DeleteData_NodePropertyMatch
func (*DeleteData) GetRelation ¶
func (x *DeleteData) GetRelation() *RelationMatch
func (*DeleteData) GetRelationProperty ¶
func (x *DeleteData) GetRelationProperty() *DeleteData_RelationPropertyMatch
func (*DeleteData) ProtoMessage ¶
func (*DeleteData) ProtoMessage()
func (*DeleteData) ProtoReflect ¶
func (x *DeleteData) ProtoReflect() protoreflect.Message
func (*DeleteData) Reset ¶
func (x *DeleteData) Reset()
func (*DeleteData) String ¶
func (x *DeleteData) String() string
func (*DeleteData) Validate ¶
func (m *DeleteData) Validate() error
Validate checks the field values on DeleteData with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*DeleteData) ValidateAll ¶
func (m *DeleteData) ValidateAll() error
ValidateAll checks the field values on DeleteData with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteDataMultiError, or nil if none found.
type DeleteDataMultiError ¶
type DeleteDataMultiError []error
DeleteDataMultiError is an error wrapping multiple validation errors returned by DeleteData.ValidateAll() if the designated constraints aren't met.
func (DeleteDataMultiError) AllErrors ¶
func (m DeleteDataMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteDataMultiError) Error ¶
func (m DeleteDataMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteDataValidationError ¶
type DeleteDataValidationError struct {
// contains filtered or unexported fields
}
DeleteDataValidationError is the validation error returned by DeleteData.Validate if the designated constraints aren't met.
func (DeleteDataValidationError) Cause ¶
func (e DeleteDataValidationError) Cause() error
Cause function returns cause value.
func (DeleteDataValidationError) Error ¶
func (e DeleteDataValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteDataValidationError) ErrorName ¶
func (e DeleteDataValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteDataValidationError) Field ¶
func (e DeleteDataValidationError) Field() string
Field function returns field value.
func (DeleteDataValidationError) Key ¶
func (e DeleteDataValidationError) Key() bool
Key function returns key value.
func (DeleteDataValidationError) Reason ¶
func (e DeleteDataValidationError) Reason() string
Reason function returns reason value.
type DeleteData_Node ¶
type DeleteData_Node struct {
Node *NodeMatch `protobuf:"bytes,1,opt,name=node,proto3,oneof"`
}
type DeleteData_NodeProperty ¶
type DeleteData_NodeProperty struct {
NodeProperty *DeleteData_NodePropertyMatch `protobuf:"bytes,3,opt,name=node_property,json=nodeProperty,proto3,oneof"`
}
type DeleteData_NodePropertyMatch ¶
type DeleteData_NodePropertyMatch struct { Match *NodeMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*DeleteData_NodePropertyMatch) Descriptor
deprecated
func (*DeleteData_NodePropertyMatch) Descriptor() ([]byte, []int)
Deprecated: Use DeleteData_NodePropertyMatch.ProtoReflect.Descriptor instead.
func (*DeleteData_NodePropertyMatch) GetKey ¶
func (x *DeleteData_NodePropertyMatch) GetKey() string
func (*DeleteData_NodePropertyMatch) GetMatch ¶
func (x *DeleteData_NodePropertyMatch) GetMatch() *NodeMatch
func (*DeleteData_NodePropertyMatch) ProtoMessage ¶
func (*DeleteData_NodePropertyMatch) ProtoMessage()
func (*DeleteData_NodePropertyMatch) ProtoReflect ¶
func (x *DeleteData_NodePropertyMatch) ProtoReflect() protoreflect.Message
func (*DeleteData_NodePropertyMatch) Reset ¶
func (x *DeleteData_NodePropertyMatch) Reset()
func (*DeleteData_NodePropertyMatch) String ¶
func (x *DeleteData_NodePropertyMatch) String() string
func (*DeleteData_NodePropertyMatch) Validate ¶
func (m *DeleteData_NodePropertyMatch) Validate() error
Validate checks the field values on DeleteData_NodePropertyMatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*DeleteData_NodePropertyMatch) ValidateAll ¶
func (m *DeleteData_NodePropertyMatch) ValidateAll() error
ValidateAll checks the field values on DeleteData_NodePropertyMatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteData_NodePropertyMatchMultiError, or nil if none found.
type DeleteData_NodePropertyMatchMultiError ¶
type DeleteData_NodePropertyMatchMultiError []error
DeleteData_NodePropertyMatchMultiError is an error wrapping multiple validation errors returned by DeleteData_NodePropertyMatch.ValidateAll() if the designated constraints aren't met.
func (DeleteData_NodePropertyMatchMultiError) AllErrors ¶
func (m DeleteData_NodePropertyMatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteData_NodePropertyMatchMultiError) Error ¶
func (m DeleteData_NodePropertyMatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteData_NodePropertyMatchValidationError ¶
type DeleteData_NodePropertyMatchValidationError struct {
// contains filtered or unexported fields
}
DeleteData_NodePropertyMatchValidationError is the validation error returned by DeleteData_NodePropertyMatch.Validate if the designated constraints aren't met.
func (DeleteData_NodePropertyMatchValidationError) Cause ¶
func (e DeleteData_NodePropertyMatchValidationError) Cause() error
Cause function returns cause value.
func (DeleteData_NodePropertyMatchValidationError) Error ¶
func (e DeleteData_NodePropertyMatchValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteData_NodePropertyMatchValidationError) ErrorName ¶
func (e DeleteData_NodePropertyMatchValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteData_NodePropertyMatchValidationError) Field ¶
func (e DeleteData_NodePropertyMatchValidationError) Field() string
Field function returns field value.
func (DeleteData_NodePropertyMatchValidationError) Key ¶
func (e DeleteData_NodePropertyMatchValidationError) Key() bool
Key function returns key value.
func (DeleteData_NodePropertyMatchValidationError) Reason ¶
func (e DeleteData_NodePropertyMatchValidationError) Reason() string
Reason function returns reason value.
type DeleteData_Relation ¶
type DeleteData_Relation struct {
Relation *RelationMatch `protobuf:"bytes,2,opt,name=relation,proto3,oneof"`
}
type DeleteData_RelationProperty ¶
type DeleteData_RelationProperty struct {
RelationProperty *DeleteData_RelationPropertyMatch `protobuf:"bytes,4,opt,name=relation_property,json=relationProperty,proto3,oneof"`
}
type DeleteData_RelationPropertyMatch ¶
type DeleteData_RelationPropertyMatch struct { Match *RelationMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*DeleteData_RelationPropertyMatch) Descriptor
deprecated
func (*DeleteData_RelationPropertyMatch) Descriptor() ([]byte, []int)
Deprecated: Use DeleteData_RelationPropertyMatch.ProtoReflect.Descriptor instead.
func (*DeleteData_RelationPropertyMatch) GetKey ¶
func (x *DeleteData_RelationPropertyMatch) GetKey() string
func (*DeleteData_RelationPropertyMatch) GetMatch ¶
func (x *DeleteData_RelationPropertyMatch) GetMatch() *RelationMatch
func (*DeleteData_RelationPropertyMatch) ProtoMessage ¶
func (*DeleteData_RelationPropertyMatch) ProtoMessage()
func (*DeleteData_RelationPropertyMatch) ProtoReflect ¶
func (x *DeleteData_RelationPropertyMatch) ProtoReflect() protoreflect.Message
func (*DeleteData_RelationPropertyMatch) Reset ¶
func (x *DeleteData_RelationPropertyMatch) Reset()
func (*DeleteData_RelationPropertyMatch) String ¶
func (x *DeleteData_RelationPropertyMatch) String() string
func (*DeleteData_RelationPropertyMatch) Validate ¶
func (m *DeleteData_RelationPropertyMatch) Validate() error
Validate checks the field values on DeleteData_RelationPropertyMatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*DeleteData_RelationPropertyMatch) ValidateAll ¶
func (m *DeleteData_RelationPropertyMatch) ValidateAll() error
ValidateAll checks the field values on DeleteData_RelationPropertyMatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteData_RelationPropertyMatchMultiError, or nil if none found.
type DeleteData_RelationPropertyMatchMultiError ¶
type DeleteData_RelationPropertyMatchMultiError []error
DeleteData_RelationPropertyMatchMultiError is an error wrapping multiple validation errors returned by DeleteData_RelationPropertyMatch.ValidateAll() if the designated constraints aren't met.
func (DeleteData_RelationPropertyMatchMultiError) AllErrors ¶
func (m DeleteData_RelationPropertyMatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteData_RelationPropertyMatchMultiError) Error ¶
func (m DeleteData_RelationPropertyMatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteData_RelationPropertyMatchValidationError ¶
type DeleteData_RelationPropertyMatchValidationError struct {
// contains filtered or unexported fields
}
DeleteData_RelationPropertyMatchValidationError is the validation error returned by DeleteData_RelationPropertyMatch.Validate if the designated constraints aren't met.
func (DeleteData_RelationPropertyMatchValidationError) Cause ¶
func (e DeleteData_RelationPropertyMatchValidationError) Cause() error
Cause function returns cause value.
func (DeleteData_RelationPropertyMatchValidationError) Error ¶
func (e DeleteData_RelationPropertyMatchValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteData_RelationPropertyMatchValidationError) ErrorName ¶
func (e DeleteData_RelationPropertyMatchValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteData_RelationPropertyMatchValidationError) Field ¶
func (e DeleteData_RelationPropertyMatchValidationError) Field() string
Field function returns field value.
func (DeleteData_RelationPropertyMatchValidationError) Key ¶
func (e DeleteData_RelationPropertyMatchValidationError) Key() bool
Key function returns key value.
func (DeleteData_RelationPropertyMatchValidationError) Reason ¶
func (e DeleteData_RelationPropertyMatchValidationError) Reason() string
Reason function returns reason value.
type DigitalTwin ¶
type DigitalTwin struct { ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` // Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto. TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"` // Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto. IdentityProperties []*IdentityProperty `protobuf:"bytes,6,rep,name=identity_properties,json=identityProperties,proto3" json:"identity_properties,omitempty"` Properties []*Property `protobuf:"bytes,7,rep,name=properties,proto3" json:"properties,omitempty"` Id string `protobuf:"bytes,8,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*DigitalTwin) Descriptor
deprecated
func (*DigitalTwin) Descriptor() ([]byte, []int)
Deprecated: Use DigitalTwin.ProtoReflect.Descriptor instead.
func (*DigitalTwin) GetExternalId ¶
func (x *DigitalTwin) GetExternalId() string
func (*DigitalTwin) GetId ¶ added in v0.18.0
func (x *DigitalTwin) GetId() string
func (*DigitalTwin) GetIdentityProperties
deprecated
func (x *DigitalTwin) GetIdentityProperties() []*IdentityProperty
Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto.
func (*DigitalTwin) GetProperties ¶
func (x *DigitalTwin) GetProperties() []*Property
func (*DigitalTwin) GetTags ¶
func (x *DigitalTwin) GetTags() []string
func (*DigitalTwin) GetTenantId
deprecated
func (x *DigitalTwin) GetTenantId() string
Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto.
func (*DigitalTwin) GetType ¶
func (x *DigitalTwin) GetType() string
func (*DigitalTwin) ProtoMessage ¶
func (*DigitalTwin) ProtoMessage()
func (*DigitalTwin) ProtoReflect ¶
func (x *DigitalTwin) ProtoReflect() protoreflect.Message
func (*DigitalTwin) Reset ¶
func (x *DigitalTwin) Reset()
func (*DigitalTwin) String ¶
func (x *DigitalTwin) String() string
func (*DigitalTwin) Validate ¶
func (m *DigitalTwin) Validate() error
Validate checks the field values on DigitalTwin with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*DigitalTwin) ValidateAll ¶
func (m *DigitalTwin) ValidateAll() error
ValidateAll checks the field values on DigitalTwin with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DigitalTwinMultiError, or nil if none found.
type DigitalTwinMultiError ¶
type DigitalTwinMultiError []error
DigitalTwinMultiError is an error wrapping multiple validation errors returned by DigitalTwin.ValidateAll() if the designated constraints aren't met.
func (DigitalTwinMultiError) AllErrors ¶
func (m DigitalTwinMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DigitalTwinMultiError) Error ¶
func (m DigitalTwinMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DigitalTwinValidationError ¶
type DigitalTwinValidationError struct {
// contains filtered or unexported fields
}
DigitalTwinValidationError is the validation error returned by DigitalTwin.Validate if the designated constraints aren't met.
func (DigitalTwinValidationError) Cause ¶
func (e DigitalTwinValidationError) Cause() error
Cause function returns cause value.
func (DigitalTwinValidationError) Error ¶
func (e DigitalTwinValidationError) Error() string
Error satisfies the builtin error interface
func (DigitalTwinValidationError) ErrorName ¶
func (e DigitalTwinValidationError) ErrorName() string
ErrorName returns error name.
func (DigitalTwinValidationError) Field ¶
func (e DigitalTwinValidationError) Field() string
Field function returns field value.
func (DigitalTwinValidationError) Key ¶
func (e DigitalTwinValidationError) Key() bool
Key function returns key value.
func (DigitalTwinValidationError) Reason ¶
func (e DigitalTwinValidationError) Reason() string
Reason function returns reason value.
type IdentityProperty ¶
type IdentityProperty struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *v1beta1.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // todo: add metadata // contains filtered or unexported fields }
func (*IdentityProperty) Descriptor
deprecated
func (*IdentityProperty) Descriptor() ([]byte, []int)
Deprecated: Use IdentityProperty.ProtoReflect.Descriptor instead.
func (*IdentityProperty) GetKey ¶
func (x *IdentityProperty) GetKey() string
func (*IdentityProperty) GetValue ¶
func (x *IdentityProperty) GetValue() *v1beta1.Value
func (*IdentityProperty) ProtoMessage ¶
func (*IdentityProperty) ProtoMessage()
func (*IdentityProperty) ProtoReflect ¶
func (x *IdentityProperty) ProtoReflect() protoreflect.Message
func (*IdentityProperty) Reset ¶
func (x *IdentityProperty) Reset()
func (*IdentityProperty) String ¶
func (x *IdentityProperty) String() string
func (*IdentityProperty) Validate ¶
func (m *IdentityProperty) Validate() error
Validate checks the field values on IdentityProperty with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*IdentityProperty) ValidateAll ¶
func (m *IdentityProperty) ValidateAll() error
ValidateAll checks the field values on IdentityProperty with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IdentityPropertyMultiError, or nil if none found.
type IdentityPropertyMultiError ¶
type IdentityPropertyMultiError []error
IdentityPropertyMultiError is an error wrapping multiple validation errors returned by IdentityProperty.ValidateAll() if the designated constraints aren't met.
func (IdentityPropertyMultiError) AllErrors ¶
func (m IdentityPropertyMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (IdentityPropertyMultiError) Error ¶
func (m IdentityPropertyMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type IdentityPropertyValidationError ¶
type IdentityPropertyValidationError struct {
// contains filtered or unexported fields
}
IdentityPropertyValidationError is the validation error returned by IdentityProperty.Validate if the designated constraints aren't met.
func (IdentityPropertyValidationError) Cause ¶
func (e IdentityPropertyValidationError) Cause() error
Cause function returns cause value.
func (IdentityPropertyValidationError) Error ¶
func (e IdentityPropertyValidationError) Error() string
Error satisfies the builtin error interface
func (IdentityPropertyValidationError) ErrorName ¶
func (e IdentityPropertyValidationError) ErrorName() string
ErrorName returns error name.
func (IdentityPropertyValidationError) Field ¶
func (e IdentityPropertyValidationError) Field() string
Field function returns field value.
func (IdentityPropertyValidationError) Key ¶
func (e IdentityPropertyValidationError) Key() bool
Key function returns key value.
func (IdentityPropertyValidationError) Reason ¶
func (e IdentityPropertyValidationError) Reason() string
Reason function returns reason value.
type Info ¶ added in v0.13.0
type Info struct { Changes []*Change `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"` // contains filtered or unexported fields }
func (*Info) Descriptor
deprecated
added in
v0.13.0
func (*Info) GetChanges ¶ added in v0.13.0
func (*Info) ProtoMessage ¶ added in v0.13.0
func (*Info) ProtoMessage()
func (*Info) ProtoReflect ¶ added in v0.13.0
func (x *Info) ProtoReflect() protoreflect.Message
func (*Info) Validate ¶ added in v0.13.0
Validate checks the field values on Info with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Info) ValidateAll ¶ added in v0.13.0
ValidateAll checks the field values on Info with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in InfoMultiError, or nil if none found.
type InfoMultiError ¶ added in v0.13.0
type InfoMultiError []error
InfoMultiError is an error wrapping multiple validation errors returned by Info.ValidateAll() if the designated constraints aren't met.
func (InfoMultiError) AllErrors ¶ added in v0.13.0
func (m InfoMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (InfoMultiError) Error ¶ added in v0.13.0
func (m InfoMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type InfoValidationError ¶ added in v0.13.0
type InfoValidationError struct {
// contains filtered or unexported fields
}
InfoValidationError is the validation error returned by Info.Validate if the designated constraints aren't met.
func (InfoValidationError) Cause ¶ added in v0.13.0
func (e InfoValidationError) Cause() error
Cause function returns cause value.
func (InfoValidationError) Error ¶ added in v0.13.0
func (e InfoValidationError) Error() string
Error satisfies the builtin error interface
func (InfoValidationError) ErrorName ¶ added in v0.13.0
func (e InfoValidationError) ErrorName() string
ErrorName returns error name.
func (InfoValidationError) Field ¶ added in v0.13.0
func (e InfoValidationError) Field() string
Field function returns field value.
func (InfoValidationError) Key ¶ added in v0.13.0
func (e InfoValidationError) Key() bool
Key function returns key value.
func (InfoValidationError) Reason ¶ added in v0.13.0
func (e InfoValidationError) Reason() string
Reason function returns reason value.
type IngestAPIClient ¶
type IngestAPIClient interface { StreamRecords(ctx context.Context, opts ...grpc.CallOption) (IngestAPI_StreamRecordsClient, error) IngestRecord(ctx context.Context, in *IngestRecordRequest, opts ...grpc.CallOption) (*IngestRecordResponse, error) }
IngestAPIClient is the client API for IngestAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIngestAPIClient ¶
func NewIngestAPIClient(cc grpc.ClientConnInterface) IngestAPIClient
type IngestAPIServer ¶
type IngestAPIServer interface { StreamRecords(IngestAPI_StreamRecordsServer) error IngestRecord(context.Context, *IngestRecordRequest) (*IngestRecordResponse, error) }
IngestAPIServer is the server API for IngestAPI service. All implementations should embed UnimplementedIngestAPIServer for forward compatibility
type IngestAPI_StreamRecordsClient ¶
type IngestAPI_StreamRecordsClient interface { Send(*StreamRecordsRequest) error Recv() (*StreamRecordsResponse, error) grpc.ClientStream }
type IngestAPI_StreamRecordsServer ¶
type IngestAPI_StreamRecordsServer interface { Send(*StreamRecordsResponse) error Recv() (*StreamRecordsRequest, error) grpc.ServerStream }
type IngestRecordRequest ¶
type IngestRecordRequest struct { Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // contains filtered or unexported fields }
func (*IngestRecordRequest) Descriptor
deprecated
func (*IngestRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use IngestRecordRequest.ProtoReflect.Descriptor instead.
func (*IngestRecordRequest) GetRecord ¶
func (x *IngestRecordRequest) GetRecord() *Record
func (*IngestRecordRequest) ProtoMessage ¶
func (*IngestRecordRequest) ProtoMessage()
func (*IngestRecordRequest) ProtoReflect ¶
func (x *IngestRecordRequest) ProtoReflect() protoreflect.Message
func (*IngestRecordRequest) Reset ¶
func (x *IngestRecordRequest) Reset()
func (*IngestRecordRequest) String ¶
func (x *IngestRecordRequest) String() string
func (*IngestRecordRequest) Validate ¶
func (m *IngestRecordRequest) Validate() error
Validate checks the field values on IngestRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*IngestRecordRequest) ValidateAll ¶
func (m *IngestRecordRequest) ValidateAll() error
ValidateAll checks the field values on IngestRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IngestRecordRequestMultiError, or nil if none found.
type IngestRecordRequestMultiError ¶
type IngestRecordRequestMultiError []error
IngestRecordRequestMultiError is an error wrapping multiple validation errors returned by IngestRecordRequest.ValidateAll() if the designated constraints aren't met.
func (IngestRecordRequestMultiError) AllErrors ¶
func (m IngestRecordRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (IngestRecordRequestMultiError) Error ¶
func (m IngestRecordRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type IngestRecordRequestValidationError ¶
type IngestRecordRequestValidationError struct {
// contains filtered or unexported fields
}
IngestRecordRequestValidationError is the validation error returned by IngestRecordRequest.Validate if the designated constraints aren't met.
func (IngestRecordRequestValidationError) Cause ¶
func (e IngestRecordRequestValidationError) Cause() error
Cause function returns cause value.
func (IngestRecordRequestValidationError) Error ¶
func (e IngestRecordRequestValidationError) Error() string
Error satisfies the builtin error interface
func (IngestRecordRequestValidationError) ErrorName ¶
func (e IngestRecordRequestValidationError) ErrorName() string
ErrorName returns error name.
func (IngestRecordRequestValidationError) Field ¶
func (e IngestRecordRequestValidationError) Field() string
Field function returns field value.
func (IngestRecordRequestValidationError) Key ¶
func (e IngestRecordRequestValidationError) Key() bool
Key function returns key value.
func (IngestRecordRequestValidationError) Reason ¶
func (e IngestRecordRequestValidationError) Reason() string
Reason function returns reason value.
type IngestRecordResponse ¶
type IngestRecordResponse struct { RecordId string `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"` // Types that are assignable to Error: // // *IngestRecordResponse_RecordError // *IngestRecordResponse_StatusError Error isIngestRecordResponse_Error `protobuf_oneof:"error"` Info *Info `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*IngestRecordResponse) Descriptor
deprecated
func (*IngestRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use IngestRecordResponse.ProtoReflect.Descriptor instead.
func (*IngestRecordResponse) GetError ¶ added in v0.13.0
func (m *IngestRecordResponse) GetError() isIngestRecordResponse_Error
func (*IngestRecordResponse) GetInfo ¶ added in v0.13.0
func (x *IngestRecordResponse) GetInfo() *Info
func (*IngestRecordResponse) GetRecordError ¶
func (x *IngestRecordResponse) GetRecordError() *RecordError
func (*IngestRecordResponse) GetRecordId ¶ added in v0.13.0
func (x *IngestRecordResponse) GetRecordId() string
func (*IngestRecordResponse) GetStatusError ¶ added in v0.13.0
func (x *IngestRecordResponse) GetStatusError() *status.Status
func (*IngestRecordResponse) ProtoMessage ¶
func (*IngestRecordResponse) ProtoMessage()
func (*IngestRecordResponse) ProtoReflect ¶
func (x *IngestRecordResponse) ProtoReflect() protoreflect.Message
func (*IngestRecordResponse) Reset ¶
func (x *IngestRecordResponse) Reset()
func (*IngestRecordResponse) String ¶
func (x *IngestRecordResponse) String() string
func (*IngestRecordResponse) Validate ¶
func (m *IngestRecordResponse) Validate() error
Validate checks the field values on IngestRecordResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*IngestRecordResponse) ValidateAll ¶
func (m *IngestRecordResponse) ValidateAll() error
ValidateAll checks the field values on IngestRecordResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IngestRecordResponseMultiError, or nil if none found.
type IngestRecordResponseMultiError ¶
type IngestRecordResponseMultiError []error
IngestRecordResponseMultiError is an error wrapping multiple validation errors returned by IngestRecordResponse.ValidateAll() if the designated constraints aren't met.
func (IngestRecordResponseMultiError) AllErrors ¶
func (m IngestRecordResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (IngestRecordResponseMultiError) Error ¶
func (m IngestRecordResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type IngestRecordResponseValidationError ¶
type IngestRecordResponseValidationError struct {
// contains filtered or unexported fields
}
IngestRecordResponseValidationError is the validation error returned by IngestRecordResponse.Validate if the designated constraints aren't met.
func (IngestRecordResponseValidationError) Cause ¶
func (e IngestRecordResponseValidationError) Cause() error
Cause function returns cause value.
func (IngestRecordResponseValidationError) Error ¶
func (e IngestRecordResponseValidationError) Error() string
Error satisfies the builtin error interface
func (IngestRecordResponseValidationError) ErrorName ¶
func (e IngestRecordResponseValidationError) ErrorName() string
ErrorName returns error name.
func (IngestRecordResponseValidationError) Field ¶
func (e IngestRecordResponseValidationError) Field() string
Field function returns field value.
func (IngestRecordResponseValidationError) Key ¶
func (e IngestRecordResponseValidationError) Key() bool
Key function returns key value.
func (IngestRecordResponseValidationError) Reason ¶
func (e IngestRecordResponseValidationError) Reason() string
Reason function returns reason value.
type IngestRecordResponse_RecordError ¶ added in v0.13.0
type IngestRecordResponse_RecordError struct {
RecordError *RecordError `protobuf:"bytes,3,opt,name=record_error,json=recordError,proto3,oneof"`
}
type IngestRecordResponse_StatusError ¶ added in v0.13.0
type Node ¶
type Node struct { // Types that are assignable to Type: // // *Node_DigitalTwin // *Node_Resource Type isNode_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*Node) Descriptor
deprecated
func (*Node) GetDigitalTwin ¶
func (x *Node) GetDigitalTwin() *DigitalTwin
func (*Node) GetResource ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
func (*Node) Validate ¶
Validate checks the field values on Node with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Node) ValidateAll ¶
ValidateAll checks the field values on Node with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NodeMultiError, or nil if none found.
type NodeMatch ¶
type NodeMatch struct { ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*NodeMatch) Descriptor
deprecated
func (*NodeMatch) GetExternalId ¶
func (*NodeMatch) ProtoMessage ¶
func (*NodeMatch) ProtoMessage()
func (*NodeMatch) ProtoReflect ¶
func (x *NodeMatch) ProtoReflect() protoreflect.Message
func (*NodeMatch) Validate ¶
Validate checks the field values on NodeMatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*NodeMatch) ValidateAll ¶
ValidateAll checks the field values on NodeMatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NodeMatchMultiError, or nil if none found.
type NodeMatchMultiError ¶
type NodeMatchMultiError []error
NodeMatchMultiError is an error wrapping multiple validation errors returned by NodeMatch.ValidateAll() if the designated constraints aren't met.
func (NodeMatchMultiError) AllErrors ¶
func (m NodeMatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (NodeMatchMultiError) Error ¶
func (m NodeMatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type NodeMatchValidationError ¶
type NodeMatchValidationError struct {
// contains filtered or unexported fields
}
NodeMatchValidationError is the validation error returned by NodeMatch.Validate if the designated constraints aren't met.
func (NodeMatchValidationError) Cause ¶
func (e NodeMatchValidationError) Cause() error
Cause function returns cause value.
func (NodeMatchValidationError) Error ¶
func (e NodeMatchValidationError) Error() string
Error satisfies the builtin error interface
func (NodeMatchValidationError) ErrorName ¶
func (e NodeMatchValidationError) ErrorName() string
ErrorName returns error name.
func (NodeMatchValidationError) Field ¶
func (e NodeMatchValidationError) Field() string
Field function returns field value.
func (NodeMatchValidationError) Key ¶
func (e NodeMatchValidationError) Key() bool
Key function returns key value.
func (NodeMatchValidationError) Reason ¶
func (e NodeMatchValidationError) Reason() string
Reason function returns reason value.
type NodeMultiError ¶
type NodeMultiError []error
NodeMultiError is an error wrapping multiple validation errors returned by Node.ValidateAll() if the designated constraints aren't met.
func (NodeMultiError) AllErrors ¶
func (m NodeMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (NodeMultiError) Error ¶
func (m NodeMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type NodeValidationError ¶
type NodeValidationError struct {
// contains filtered or unexported fields
}
NodeValidationError is the validation error returned by Node.Validate if the designated constraints aren't met.
func (NodeValidationError) Cause ¶
func (e NodeValidationError) Cause() error
Cause function returns cause value.
func (NodeValidationError) Error ¶
func (e NodeValidationError) Error() string
Error satisfies the builtin error interface
func (NodeValidationError) ErrorName ¶
func (e NodeValidationError) ErrorName() string
ErrorName returns error name.
func (NodeValidationError) Field ¶
func (e NodeValidationError) Field() string
Field function returns field value.
func (NodeValidationError) Key ¶
func (e NodeValidationError) Key() bool
Key function returns key value.
func (NodeValidationError) Reason ¶
func (e NodeValidationError) Reason() string
Reason function returns reason value.
type Node_DigitalTwin ¶
type Node_DigitalTwin struct {
DigitalTwin *DigitalTwin `protobuf:"bytes,1,opt,name=digital_twin,json=digitalTwin,proto3,oneof"`
}
type Node_Resource ¶
type Node_Resource struct {
Resource *Resource `protobuf:"bytes,2,opt,name=resource,proto3,oneof"`
}
type Property ¶
type Property struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *v1beta1.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Property) Descriptor
deprecated
func (*Property) ProtoMessage ¶
func (*Property) ProtoMessage()
func (*Property) ProtoReflect ¶
func (x *Property) ProtoReflect() protoreflect.Message
func (*Property) Validate ¶
Validate checks the field values on Property with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Property) ValidateAll ¶
ValidateAll checks the field values on Property with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PropertyMultiError, or nil if none found.
type PropertyError ¶
type PropertyError struct { Messages []string `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*PropertyError) Descriptor
deprecated
func (*PropertyError) Descriptor() ([]byte, []int)
Deprecated: Use PropertyError.ProtoReflect.Descriptor instead.
func (*PropertyError) GetMessages ¶
func (x *PropertyError) GetMessages() []string
func (*PropertyError) ProtoMessage ¶
func (*PropertyError) ProtoMessage()
func (*PropertyError) ProtoReflect ¶
func (x *PropertyError) ProtoReflect() protoreflect.Message
func (*PropertyError) Reset ¶
func (x *PropertyError) Reset()
func (*PropertyError) String ¶
func (x *PropertyError) String() string
func (*PropertyError) Validate ¶
func (m *PropertyError) Validate() error
Validate checks the field values on PropertyError with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PropertyError) ValidateAll ¶
func (m *PropertyError) ValidateAll() error
ValidateAll checks the field values on PropertyError with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PropertyErrorMultiError, or nil if none found.
type PropertyErrorMultiError ¶
type PropertyErrorMultiError []error
PropertyErrorMultiError is an error wrapping multiple validation errors returned by PropertyError.ValidateAll() if the designated constraints aren't met.
func (PropertyErrorMultiError) AllErrors ¶
func (m PropertyErrorMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PropertyErrorMultiError) Error ¶
func (m PropertyErrorMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PropertyErrorValidationError ¶
type PropertyErrorValidationError struct {
// contains filtered or unexported fields
}
PropertyErrorValidationError is the validation error returned by PropertyError.Validate if the designated constraints aren't met.
func (PropertyErrorValidationError) Cause ¶
func (e PropertyErrorValidationError) Cause() error
Cause function returns cause value.
func (PropertyErrorValidationError) Error ¶
func (e PropertyErrorValidationError) Error() string
Error satisfies the builtin error interface
func (PropertyErrorValidationError) ErrorName ¶
func (e PropertyErrorValidationError) ErrorName() string
ErrorName returns error name.
func (PropertyErrorValidationError) Field ¶
func (e PropertyErrorValidationError) Field() string
Field function returns field value.
func (PropertyErrorValidationError) Key ¶
func (e PropertyErrorValidationError) Key() bool
Key function returns key value.
func (PropertyErrorValidationError) Reason ¶
func (e PropertyErrorValidationError) Reason() string
Reason function returns reason value.
type PropertyMultiError ¶
type PropertyMultiError []error
PropertyMultiError is an error wrapping multiple validation errors returned by Property.ValidateAll() if the designated constraints aren't met.
func (PropertyMultiError) AllErrors ¶
func (m PropertyMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PropertyMultiError) Error ¶
func (m PropertyMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PropertyValidationError ¶
type PropertyValidationError struct {
// contains filtered or unexported fields
}
PropertyValidationError is the validation error returned by Property.Validate if the designated constraints aren't met.
func (PropertyValidationError) Cause ¶
func (e PropertyValidationError) Cause() error
Cause function returns cause value.
func (PropertyValidationError) Error ¶
func (e PropertyValidationError) Error() string
Error satisfies the builtin error interface
func (PropertyValidationError) ErrorName ¶
func (e PropertyValidationError) ErrorName() string
ErrorName returns error name.
func (PropertyValidationError) Field ¶
func (e PropertyValidationError) Field() string
Field function returns field value.
func (PropertyValidationError) Key ¶
func (e PropertyValidationError) Key() bool
Key function returns key value.
func (PropertyValidationError) Reason ¶
func (e PropertyValidationError) Reason() string
Reason function returns reason value.
type Record ¶
type Record struct { // Unique identifier of the record, for client side reference Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are assignable to Operation: // // *Record_Upsert // *Record_Delete Operation isRecord_Operation `protobuf_oneof:"operation"` // contains filtered or unexported fields }
func (*Record) Descriptor
deprecated
func (*Record) GetDelete ¶
func (x *Record) GetDelete() *DeleteData
func (*Record) GetOperation ¶
func (m *Record) GetOperation() isRecord_Operation
func (*Record) GetUpsert ¶
func (x *Record) GetUpsert() *UpsertData
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
func (*Record) Validate ¶
Validate checks the field values on Record with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Record) ValidateAll ¶
ValidateAll checks the field values on Record with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RecordMultiError, or nil if none found.
type RecordError ¶
type RecordError struct { // map from property type to property error, if any PropertyErrors map[string]*PropertyError `` /* 191-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RecordError) Descriptor
deprecated
func (*RecordError) Descriptor() ([]byte, []int)
Deprecated: Use RecordError.ProtoReflect.Descriptor instead.
func (*RecordError) GetPropertyErrors ¶
func (x *RecordError) GetPropertyErrors() map[string]*PropertyError
func (*RecordError) ProtoMessage ¶
func (*RecordError) ProtoMessage()
func (*RecordError) ProtoReflect ¶
func (x *RecordError) ProtoReflect() protoreflect.Message
func (*RecordError) Reset ¶
func (x *RecordError) Reset()
func (*RecordError) String ¶
func (x *RecordError) String() string
func (*RecordError) Validate ¶
func (m *RecordError) Validate() error
Validate checks the field values on RecordError with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*RecordError) ValidateAll ¶
func (m *RecordError) ValidateAll() error
ValidateAll checks the field values on RecordError with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RecordErrorMultiError, or nil if none found.
type RecordErrorMultiError ¶
type RecordErrorMultiError []error
RecordErrorMultiError is an error wrapping multiple validation errors returned by RecordError.ValidateAll() if the designated constraints aren't met.
func (RecordErrorMultiError) AllErrors ¶
func (m RecordErrorMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RecordErrorMultiError) Error ¶
func (m RecordErrorMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RecordErrorValidationError ¶
type RecordErrorValidationError struct {
// contains filtered or unexported fields
}
RecordErrorValidationError is the validation error returned by RecordError.Validate if the designated constraints aren't met.
func (RecordErrorValidationError) Cause ¶
func (e RecordErrorValidationError) Cause() error
Cause function returns cause value.
func (RecordErrorValidationError) Error ¶
func (e RecordErrorValidationError) Error() string
Error satisfies the builtin error interface
func (RecordErrorValidationError) ErrorName ¶
func (e RecordErrorValidationError) ErrorName() string
ErrorName returns error name.
func (RecordErrorValidationError) Field ¶
func (e RecordErrorValidationError) Field() string
Field function returns field value.
func (RecordErrorValidationError) Key ¶
func (e RecordErrorValidationError) Key() bool
Key function returns key value.
func (RecordErrorValidationError) Reason ¶
func (e RecordErrorValidationError) Reason() string
Reason function returns reason value.
type RecordMultiError ¶
type RecordMultiError []error
RecordMultiError is an error wrapping multiple validation errors returned by Record.ValidateAll() if the designated constraints aren't met.
func (RecordMultiError) AllErrors ¶
func (m RecordMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RecordMultiError) Error ¶
func (m RecordMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RecordValidationError ¶
type RecordValidationError struct {
// contains filtered or unexported fields
}
RecordValidationError is the validation error returned by Record.Validate if the designated constraints aren't met.
func (RecordValidationError) Cause ¶
func (e RecordValidationError) Cause() error
Cause function returns cause value.
func (RecordValidationError) Error ¶
func (e RecordValidationError) Error() string
Error satisfies the builtin error interface
func (RecordValidationError) ErrorName ¶
func (e RecordValidationError) ErrorName() string
ErrorName returns error name.
func (RecordValidationError) Field ¶
func (e RecordValidationError) Field() string
Field function returns field value.
func (RecordValidationError) Key ¶
func (e RecordValidationError) Key() bool
Key function returns key value.
func (RecordValidationError) Reason ¶
func (e RecordValidationError) Reason() string
Reason function returns reason value.
type Record_Delete ¶
type Record_Delete struct {
Delete *DeleteData `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}
type Record_Upsert ¶
type Record_Upsert struct {
Upsert *UpsertData `protobuf:"bytes,2,opt,name=upsert,proto3,oneof"`
}
type Relation ¶
type Relation struct { Match *RelationMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"` Properties []*Property `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
func (*Relation) Descriptor
deprecated
func (*Relation) GetMatch ¶
func (x *Relation) GetMatch() *RelationMatch
func (*Relation) GetProperties ¶
func (*Relation) ProtoMessage ¶
func (*Relation) ProtoMessage()
func (*Relation) ProtoReflect ¶
func (x *Relation) ProtoReflect() protoreflect.Message
func (*Relation) Validate ¶
Validate checks the field values on Relation with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Relation) ValidateAll ¶
ValidateAll checks the field values on Relation with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RelationMultiError, or nil if none found.
type RelationMatch ¶
type RelationMatch struct { SourceMatch *NodeMatch `protobuf:"bytes,1,opt,name=source_match,json=sourceMatch,proto3" json:"source_match,omitempty"` TargetMatch *NodeMatch `protobuf:"bytes,2,opt,name=target_match,json=targetMatch,proto3" json:"target_match,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*RelationMatch) Descriptor
deprecated
func (*RelationMatch) Descriptor() ([]byte, []int)
Deprecated: Use RelationMatch.ProtoReflect.Descriptor instead.
func (*RelationMatch) GetSourceMatch ¶
func (x *RelationMatch) GetSourceMatch() *NodeMatch
func (*RelationMatch) GetTargetMatch ¶
func (x *RelationMatch) GetTargetMatch() *NodeMatch
func (*RelationMatch) GetType ¶
func (x *RelationMatch) GetType() string
func (*RelationMatch) ProtoMessage ¶
func (*RelationMatch) ProtoMessage()
func (*RelationMatch) ProtoReflect ¶
func (x *RelationMatch) ProtoReflect() protoreflect.Message
func (*RelationMatch) Reset ¶
func (x *RelationMatch) Reset()
func (*RelationMatch) String ¶
func (x *RelationMatch) String() string
func (*RelationMatch) Validate ¶
func (m *RelationMatch) Validate() error
Validate checks the field values on RelationMatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*RelationMatch) ValidateAll ¶
func (m *RelationMatch) ValidateAll() error
ValidateAll checks the field values on RelationMatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RelationMatchMultiError, or nil if none found.
type RelationMatchMultiError ¶
type RelationMatchMultiError []error
RelationMatchMultiError is an error wrapping multiple validation errors returned by RelationMatch.ValidateAll() if the designated constraints aren't met.
func (RelationMatchMultiError) AllErrors ¶
func (m RelationMatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RelationMatchMultiError) Error ¶
func (m RelationMatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RelationMatchValidationError ¶
type RelationMatchValidationError struct {
// contains filtered or unexported fields
}
RelationMatchValidationError is the validation error returned by RelationMatch.Validate if the designated constraints aren't met.
func (RelationMatchValidationError) Cause ¶
func (e RelationMatchValidationError) Cause() error
Cause function returns cause value.
func (RelationMatchValidationError) Error ¶
func (e RelationMatchValidationError) Error() string
Error satisfies the builtin error interface
func (RelationMatchValidationError) ErrorName ¶
func (e RelationMatchValidationError) ErrorName() string
ErrorName returns error name.
func (RelationMatchValidationError) Field ¶
func (e RelationMatchValidationError) Field() string
Field function returns field value.
func (RelationMatchValidationError) Key ¶
func (e RelationMatchValidationError) Key() bool
Key function returns key value.
func (RelationMatchValidationError) Reason ¶
func (e RelationMatchValidationError) Reason() string
Reason function returns reason value.
type RelationMultiError ¶
type RelationMultiError []error
RelationMultiError is an error wrapping multiple validation errors returned by Relation.ValidateAll() if the designated constraints aren't met.
func (RelationMultiError) AllErrors ¶
func (m RelationMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RelationMultiError) Error ¶
func (m RelationMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RelationValidationError ¶
type RelationValidationError struct {
// contains filtered or unexported fields
}
RelationValidationError is the validation error returned by Relation.Validate if the designated constraints aren't met.
func (RelationValidationError) Cause ¶
func (e RelationValidationError) Cause() error
Cause function returns cause value.
func (RelationValidationError) Error ¶
func (e RelationValidationError) Error() string
Error satisfies the builtin error interface
func (RelationValidationError) ErrorName ¶
func (e RelationValidationError) ErrorName() string
ErrorName returns error name.
func (RelationValidationError) Field ¶
func (e RelationValidationError) Field() string
Field function returns field value.
func (RelationValidationError) Key ¶
func (e RelationValidationError) Key() bool
Key function returns key value.
func (RelationValidationError) Reason ¶
func (e RelationValidationError) Reason() string
Reason function returns reason value.
type Resource ¶
type Resource struct { ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` Properties []*Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
func (*Resource) Descriptor
deprecated
func (*Resource) GetExternalId ¶
func (*Resource) GetProperties ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
func (*Resource) Validate ¶
Validate checks the field values on Resource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Resource) ValidateAll ¶
ValidateAll checks the field values on Resource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ResourceMultiError, or nil if none found.
type ResourceMultiError ¶
type ResourceMultiError []error
ResourceMultiError is an error wrapping multiple validation errors returned by Resource.ValidateAll() if the designated constraints aren't met.
func (ResourceMultiError) AllErrors ¶
func (m ResourceMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ResourceMultiError) Error ¶
func (m ResourceMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ResourceValidationError ¶
type ResourceValidationError struct {
// contains filtered or unexported fields
}
ResourceValidationError is the validation error returned by Resource.Validate if the designated constraints aren't met.
func (ResourceValidationError) Cause ¶
func (e ResourceValidationError) Cause() error
Cause function returns cause value.
func (ResourceValidationError) Error ¶
func (e ResourceValidationError) Error() string
Error satisfies the builtin error interface
func (ResourceValidationError) ErrorName ¶
func (e ResourceValidationError) ErrorName() string
ErrorName returns error name.
func (ResourceValidationError) Field ¶
func (e ResourceValidationError) Field() string
Field function returns field value.
func (ResourceValidationError) Key ¶
func (e ResourceValidationError) Key() bool
Key function returns key value.
func (ResourceValidationError) Reason ¶
func (e ResourceValidationError) Reason() string
Reason function returns reason value.
type StreamRecordsRequest ¶
type StreamRecordsRequest struct { Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // contains filtered or unexported fields }
func (*StreamRecordsRequest) Descriptor
deprecated
func (*StreamRecordsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRecordsRequest.ProtoReflect.Descriptor instead.
func (*StreamRecordsRequest) GetRecord ¶
func (x *StreamRecordsRequest) GetRecord() *Record
func (*StreamRecordsRequest) ProtoMessage ¶
func (*StreamRecordsRequest) ProtoMessage()
func (*StreamRecordsRequest) ProtoReflect ¶
func (x *StreamRecordsRequest) ProtoReflect() protoreflect.Message
func (*StreamRecordsRequest) Reset ¶
func (x *StreamRecordsRequest) Reset()
func (*StreamRecordsRequest) String ¶
func (x *StreamRecordsRequest) String() string
func (*StreamRecordsRequest) Validate ¶
func (m *StreamRecordsRequest) Validate() error
Validate checks the field values on StreamRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamRecordsRequest) ValidateAll ¶
func (m *StreamRecordsRequest) ValidateAll() error
ValidateAll checks the field values on StreamRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamRecordsRequestMultiError, or nil if none found.
type StreamRecordsRequestMultiError ¶
type StreamRecordsRequestMultiError []error
StreamRecordsRequestMultiError is an error wrapping multiple validation errors returned by StreamRecordsRequest.ValidateAll() if the designated constraints aren't met.
func (StreamRecordsRequestMultiError) AllErrors ¶
func (m StreamRecordsRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamRecordsRequestMultiError) Error ¶
func (m StreamRecordsRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamRecordsRequestValidationError ¶
type StreamRecordsRequestValidationError struct {
// contains filtered or unexported fields
}
StreamRecordsRequestValidationError is the validation error returned by StreamRecordsRequest.Validate if the designated constraints aren't met.
func (StreamRecordsRequestValidationError) Cause ¶
func (e StreamRecordsRequestValidationError) Cause() error
Cause function returns cause value.
func (StreamRecordsRequestValidationError) Error ¶
func (e StreamRecordsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StreamRecordsRequestValidationError) ErrorName ¶
func (e StreamRecordsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StreamRecordsRequestValidationError) Field ¶
func (e StreamRecordsRequestValidationError) Field() string
Field function returns field value.
func (StreamRecordsRequestValidationError) Key ¶
func (e StreamRecordsRequestValidationError) Key() bool
Key function returns key value.
func (StreamRecordsRequestValidationError) Reason ¶
func (e StreamRecordsRequestValidationError) Reason() string
Reason function returns reason value.
type StreamRecordsResponse ¶
type StreamRecordsResponse struct { RecordId string `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"` RecordIndex uint32 `protobuf:"varint,2,opt,name=record_index,json=recordIndex,proto3" json:"record_index,omitempty"` // Types that are assignable to Error: // // *StreamRecordsResponse_RecordError // *StreamRecordsResponse_StatusError Error isStreamRecordsResponse_Error `protobuf_oneof:"error"` Info *Info `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*StreamRecordsResponse) Descriptor
deprecated
func (*StreamRecordsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamRecordsResponse.ProtoReflect.Descriptor instead.
func (*StreamRecordsResponse) GetError ¶
func (m *StreamRecordsResponse) GetError() isStreamRecordsResponse_Error
func (*StreamRecordsResponse) GetInfo ¶ added in v0.13.0
func (x *StreamRecordsResponse) GetInfo() *Info
func (*StreamRecordsResponse) GetRecordError ¶
func (x *StreamRecordsResponse) GetRecordError() *RecordError
func (*StreamRecordsResponse) GetRecordId ¶
func (x *StreamRecordsResponse) GetRecordId() string
func (*StreamRecordsResponse) GetRecordIndex ¶
func (x *StreamRecordsResponse) GetRecordIndex() uint32
func (*StreamRecordsResponse) GetStatusError ¶
func (x *StreamRecordsResponse) GetStatusError() *status.Status
func (*StreamRecordsResponse) ProtoMessage ¶
func (*StreamRecordsResponse) ProtoMessage()
func (*StreamRecordsResponse) ProtoReflect ¶
func (x *StreamRecordsResponse) ProtoReflect() protoreflect.Message
func (*StreamRecordsResponse) Reset ¶
func (x *StreamRecordsResponse) Reset()
func (*StreamRecordsResponse) String ¶
func (x *StreamRecordsResponse) String() string
func (*StreamRecordsResponse) Validate ¶
func (m *StreamRecordsResponse) Validate() error
Validate checks the field values on StreamRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamRecordsResponse) ValidateAll ¶
func (m *StreamRecordsResponse) ValidateAll() error
ValidateAll checks the field values on StreamRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamRecordsResponseMultiError, or nil if none found.
type StreamRecordsResponseMultiError ¶
type StreamRecordsResponseMultiError []error
StreamRecordsResponseMultiError is an error wrapping multiple validation errors returned by StreamRecordsResponse.ValidateAll() if the designated constraints aren't met.
func (StreamRecordsResponseMultiError) AllErrors ¶
func (m StreamRecordsResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamRecordsResponseMultiError) Error ¶
func (m StreamRecordsResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamRecordsResponseValidationError ¶
type StreamRecordsResponseValidationError struct {
// contains filtered or unexported fields
}
StreamRecordsResponseValidationError is the validation error returned by StreamRecordsResponse.Validate if the designated constraints aren't met.
func (StreamRecordsResponseValidationError) Cause ¶
func (e StreamRecordsResponseValidationError) Cause() error
Cause function returns cause value.
func (StreamRecordsResponseValidationError) Error ¶
func (e StreamRecordsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (StreamRecordsResponseValidationError) ErrorName ¶
func (e StreamRecordsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (StreamRecordsResponseValidationError) Field ¶
func (e StreamRecordsResponseValidationError) Field() string
Field function returns field value.
func (StreamRecordsResponseValidationError) Key ¶
func (e StreamRecordsResponseValidationError) Key() bool
Key function returns key value.
func (StreamRecordsResponseValidationError) Reason ¶
func (e StreamRecordsResponseValidationError) Reason() string
Reason function returns reason value.
type StreamRecordsResponse_RecordError ¶
type StreamRecordsResponse_RecordError struct {
RecordError *RecordError `protobuf:"bytes,3,opt,name=record_error,json=recordError,proto3,oneof"`
}
type UnimplementedIngestAPIServer ¶
type UnimplementedIngestAPIServer struct { }
UnimplementedIngestAPIServer should be embedded to have forward compatible implementations.
func (UnimplementedIngestAPIServer) IngestRecord ¶
func (UnimplementedIngestAPIServer) IngestRecord(context.Context, *IngestRecordRequest) (*IngestRecordResponse, error)
func (UnimplementedIngestAPIServer) StreamRecords ¶
func (UnimplementedIngestAPIServer) StreamRecords(IngestAPI_StreamRecordsServer) error
type UnsafeIngestAPIServer ¶
type UnsafeIngestAPIServer interface {
// contains filtered or unexported methods
}
UnsafeIngestAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngestAPIServer will result in compilation errors.
type UpsertData ¶
type UpsertData struct { // Types that are assignable to Data: // // *UpsertData_Node // *UpsertData_Relation Data isUpsertData_Data `protobuf_oneof:"data"` // contains filtered or unexported fields }
func (*UpsertData) Descriptor
deprecated
func (*UpsertData) Descriptor() ([]byte, []int)
Deprecated: Use UpsertData.ProtoReflect.Descriptor instead.
func (*UpsertData) GetData ¶
func (m *UpsertData) GetData() isUpsertData_Data
func (*UpsertData) GetNode ¶
func (x *UpsertData) GetNode() *Node
func (*UpsertData) GetRelation ¶
func (x *UpsertData) GetRelation() *Relation
func (*UpsertData) ProtoMessage ¶
func (*UpsertData) ProtoMessage()
func (*UpsertData) ProtoReflect ¶
func (x *UpsertData) ProtoReflect() protoreflect.Message
func (*UpsertData) Reset ¶
func (x *UpsertData) Reset()
func (*UpsertData) String ¶
func (x *UpsertData) String() string
func (*UpsertData) Validate ¶
func (m *UpsertData) Validate() error
Validate checks the field values on UpsertData with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*UpsertData) ValidateAll ¶
func (m *UpsertData) ValidateAll() error
ValidateAll checks the field values on UpsertData with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpsertDataMultiError, or nil if none found.
type UpsertDataMultiError ¶
type UpsertDataMultiError []error
UpsertDataMultiError is an error wrapping multiple validation errors returned by UpsertData.ValidateAll() if the designated constraints aren't met.
func (UpsertDataMultiError) AllErrors ¶
func (m UpsertDataMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (UpsertDataMultiError) Error ¶
func (m UpsertDataMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type UpsertDataValidationError ¶
type UpsertDataValidationError struct {
// contains filtered or unexported fields
}
UpsertDataValidationError is the validation error returned by UpsertData.Validate if the designated constraints aren't met.
func (UpsertDataValidationError) Cause ¶
func (e UpsertDataValidationError) Cause() error
Cause function returns cause value.
func (UpsertDataValidationError) Error ¶
func (e UpsertDataValidationError) Error() string
Error satisfies the builtin error interface
func (UpsertDataValidationError) ErrorName ¶
func (e UpsertDataValidationError) ErrorName() string
ErrorName returns error name.
func (UpsertDataValidationError) Field ¶
func (e UpsertDataValidationError) Field() string
Field function returns field value.
func (UpsertDataValidationError) Key ¶
func (e UpsertDataValidationError) Key() bool
Key function returns key value.
func (UpsertDataValidationError) Reason ¶
func (e UpsertDataValidationError) Reason() string
Reason function returns reason value.
type UpsertData_Node ¶
type UpsertData_Node struct {
Node *Node `protobuf:"bytes,1,opt,name=node,proto3,oneof"`
}
type UpsertData_Relation ¶
type UpsertData_Relation struct {
Relation *Relation `protobuf:"bytes,2,opt,name=relation,proto3,oneof"`
}