Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterIngestAPIServer(s grpc.ServiceRegistrar, srv IngestAPIServer)
- type Change
- func (*Change) Descriptor() ([]byte, []int)deprecated
- func (x *Change) GetDataType() 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 DataType
- 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) GetRelationship() *Relationship
- func (x *DeleteData) GetRelationshipProperty() *DeleteData_RelationshipPropertyMatch
- 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) GetMatch() *NodeMatch
- func (x *DeleteData_NodePropertyMatch) GetPropertyType() string
- 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_Relationship
- type DeleteData_RelationshipProperty
- type DeleteData_RelationshipPropertyMatch
- func (*DeleteData_RelationshipPropertyMatch) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteData_RelationshipPropertyMatch) GetPropertyType() string
- func (x *DeleteData_RelationshipPropertyMatch) GetSource() *NodeMatch
- func (x *DeleteData_RelationshipPropertyMatch) GetTarget() *NodeMatch
- func (x *DeleteData_RelationshipPropertyMatch) GetType() string
- func (*DeleteData_RelationshipPropertyMatch) ProtoMessage()
- func (x *DeleteData_RelationshipPropertyMatch) ProtoReflect() protoreflect.Message
- func (x *DeleteData_RelationshipPropertyMatch) Reset()
- func (x *DeleteData_RelationshipPropertyMatch) String() string
- func (m *DeleteData_RelationshipPropertyMatch) Validate() error
- func (m *DeleteData_RelationshipPropertyMatch) ValidateAll() error
- type DeleteData_RelationshipPropertyMatchMultiError
- type DeleteData_RelationshipPropertyMatchValidationError
- func (e DeleteData_RelationshipPropertyMatchValidationError) Cause() error
- func (e DeleteData_RelationshipPropertyMatchValidationError) Error() string
- func (e DeleteData_RelationshipPropertyMatchValidationError) ErrorName() string
- func (e DeleteData_RelationshipPropertyMatchValidationError) Field() string
- func (e DeleteData_RelationshipPropertyMatchValidationError) Key() bool
- func (e DeleteData_RelationshipPropertyMatchValidationError) 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 (x *IngestRecordResponse) GetInfo() *Info
- func (x *IngestRecordResponse) GetRecordId() string
- 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 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 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) GetError() string
- 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 Relationship
- func (*Relationship) Descriptor() ([]byte, []int)deprecated
- func (x *Relationship) GetProperties() []*v1beta1.Property
- func (x *Relationship) GetSource() *NodeMatch
- func (x *Relationship) GetTarget() *NodeMatch
- func (x *Relationship) GetType() string
- func (*Relationship) ProtoMessage()
- func (x *Relationship) ProtoReflect() protoreflect.Message
- func (x *Relationship) Reset()
- func (x *Relationship) String() string
- func (m *Relationship) Validate() error
- func (m *Relationship) ValidateAll() error
- type RelationshipMultiError
- type RelationshipValidationError
- func (e RelationshipValidationError) Cause() error
- func (e RelationshipValidationError) Error() string
- func (e RelationshipValidationError) ErrorName() string
- func (e RelationshipValidationError) Field() string
- func (e RelationshipValidationError) Key() bool
- func (e RelationshipValidationError) Reason() string
- 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() *v1beta1.Node
- func (x *UpsertData) GetRelationship() *Relationship
- 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_Relationship
Constants ¶
const ( IngestAPI_StreamRecords_FullMethodName = "/indykite.ingest.v1beta3.IngestAPI/StreamRecords" IngestAPI_IngestRecord_FullMethodName = "/indykite.ingest.v1beta3.IngestAPI/IngestRecord" )
Variables ¶
var ( DataType_name = map[int32]string{ 0: "DATA_TYPE_INVALID", 1: "DATA_TYPE_NODE", 3: "DATA_TYPE_RELATIONSHIP", } DataType_value = map[string]int32{ "DATA_TYPE_INVALID": 0, "DATA_TYPE_NODE": 1, "DATA_TYPE_RELATIONSHIP": 3, } )
Enum value maps for DataType.
var File_indykite_ingest_v1beta3_ingest_api_proto protoreflect.FileDescriptor
var File_indykite_ingest_v1beta3_model_proto protoreflect.FileDescriptor
var IngestAPI_ServiceDesc = grpc.ServiceDesc{ ServiceName: "indykite.ingest.v1beta3.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/v1beta3/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 ¶
type Change struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` DataType DataType `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=indykite.ingest.v1beta3.DataType" json:"data_type,omitempty"` // contains filtered or unexported fields }
func (*Change) Descriptor
deprecated
func (*Change) GetDataType ¶
func (*Change) ProtoMessage ¶
func (*Change) ProtoMessage()
func (*Change) ProtoReflect ¶
func (x *Change) ProtoReflect() protoreflect.Message
func (*Change) Validate ¶
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 ¶
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 ¶
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 ¶
func (m ChangeMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ChangeMultiError) Error ¶
func (m ChangeMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ChangeValidationError ¶
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 ¶
func (e ChangeValidationError) Cause() error
Cause function returns cause value.
func (ChangeValidationError) Error ¶
func (e ChangeValidationError) Error() string
Error satisfies the builtin error interface
func (ChangeValidationError) ErrorName ¶
func (e ChangeValidationError) ErrorName() string
ErrorName returns error name.
func (ChangeValidationError) Field ¶
func (e ChangeValidationError) Field() string
Field function returns field value.
func (ChangeValidationError) Key ¶
func (e ChangeValidationError) Key() bool
Key function returns key value.
func (ChangeValidationError) Reason ¶
func (e ChangeValidationError) Reason() string
Reason function returns reason value.
type DataType ¶
type DataType int32
func (DataType) Descriptor ¶
func (DataType) Descriptor() protoreflect.EnumDescriptor
func (DataType) EnumDescriptor
deprecated
func (DataType) Number ¶
func (x DataType) Number() protoreflect.EnumNumber
func (DataType) Type ¶
func (DataType) Type() protoreflect.EnumType
type DeleteData ¶
type DeleteData struct { // Types that are assignable to Data: // // *DeleteData_Node // *DeleteData_Relationship // *DeleteData_NodeProperty // *DeleteData_RelationshipProperty 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) GetRelationship ¶
func (x *DeleteData) GetRelationship() *Relationship
func (*DeleteData) GetRelationshipProperty ¶
func (x *DeleteData) GetRelationshipProperty() *DeleteData_RelationshipPropertyMatch
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"` PropertyType string `protobuf:"bytes,2,opt,name=property_type,json=propertyType,proto3" json:"property_type,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) GetMatch ¶
func (x *DeleteData_NodePropertyMatch) GetMatch() *NodeMatch
func (*DeleteData_NodePropertyMatch) GetPropertyType ¶
func (x *DeleteData_NodePropertyMatch) GetPropertyType() string
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_Relationship ¶
type DeleteData_Relationship struct {
Relationship *Relationship `protobuf:"bytes,2,opt,name=relationship,proto3,oneof"`
}
type DeleteData_RelationshipProperty ¶
type DeleteData_RelationshipProperty struct {
RelationshipProperty *DeleteData_RelationshipPropertyMatch `protobuf:"bytes,4,opt,name=relationship_property,json=relationshipProperty,proto3,oneof"`
}
type DeleteData_RelationshipPropertyMatch ¶
type DeleteData_RelationshipPropertyMatch struct { Source *NodeMatch `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Target *NodeMatch `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` PropertyType string `protobuf:"bytes,4,opt,name=property_type,json=propertyType,proto3" json:"property_type,omitempty"` // contains filtered or unexported fields }
func (*DeleteData_RelationshipPropertyMatch) Descriptor
deprecated
func (*DeleteData_RelationshipPropertyMatch) Descriptor() ([]byte, []int)
Deprecated: Use DeleteData_RelationshipPropertyMatch.ProtoReflect.Descriptor instead.
func (*DeleteData_RelationshipPropertyMatch) GetPropertyType ¶
func (x *DeleteData_RelationshipPropertyMatch) GetPropertyType() string
func (*DeleteData_RelationshipPropertyMatch) GetSource ¶
func (x *DeleteData_RelationshipPropertyMatch) GetSource() *NodeMatch
func (*DeleteData_RelationshipPropertyMatch) GetTarget ¶
func (x *DeleteData_RelationshipPropertyMatch) GetTarget() *NodeMatch
func (*DeleteData_RelationshipPropertyMatch) GetType ¶
func (x *DeleteData_RelationshipPropertyMatch) GetType() string
func (*DeleteData_RelationshipPropertyMatch) ProtoMessage ¶
func (*DeleteData_RelationshipPropertyMatch) ProtoMessage()
func (*DeleteData_RelationshipPropertyMatch) ProtoReflect ¶
func (x *DeleteData_RelationshipPropertyMatch) ProtoReflect() protoreflect.Message
func (*DeleteData_RelationshipPropertyMatch) Reset ¶
func (x *DeleteData_RelationshipPropertyMatch) Reset()
func (*DeleteData_RelationshipPropertyMatch) String ¶
func (x *DeleteData_RelationshipPropertyMatch) String() string
func (*DeleteData_RelationshipPropertyMatch) Validate ¶
func (m *DeleteData_RelationshipPropertyMatch) Validate() error
Validate checks the field values on DeleteData_RelationshipPropertyMatch 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_RelationshipPropertyMatch) ValidateAll ¶
func (m *DeleteData_RelationshipPropertyMatch) ValidateAll() error
ValidateAll checks the field values on DeleteData_RelationshipPropertyMatch 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_RelationshipPropertyMatchMultiError, or nil if none found.
type DeleteData_RelationshipPropertyMatchMultiError ¶
type DeleteData_RelationshipPropertyMatchMultiError []error
DeleteData_RelationshipPropertyMatchMultiError is an error wrapping multiple validation errors returned by DeleteData_RelationshipPropertyMatch.ValidateAll() if the designated constraints aren't met.
func (DeleteData_RelationshipPropertyMatchMultiError) AllErrors ¶
func (m DeleteData_RelationshipPropertyMatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteData_RelationshipPropertyMatchMultiError) Error ¶
func (m DeleteData_RelationshipPropertyMatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteData_RelationshipPropertyMatchValidationError ¶
type DeleteData_RelationshipPropertyMatchValidationError struct {
// contains filtered or unexported fields
}
DeleteData_RelationshipPropertyMatchValidationError is the validation error returned by DeleteData_RelationshipPropertyMatch.Validate if the designated constraints aren't met.
func (DeleteData_RelationshipPropertyMatchValidationError) Cause ¶
func (e DeleteData_RelationshipPropertyMatchValidationError) Cause() error
Cause function returns cause value.
func (DeleteData_RelationshipPropertyMatchValidationError) Error ¶
func (e DeleteData_RelationshipPropertyMatchValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteData_RelationshipPropertyMatchValidationError) ErrorName ¶
func (e DeleteData_RelationshipPropertyMatchValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteData_RelationshipPropertyMatchValidationError) Field ¶
func (e DeleteData_RelationshipPropertyMatchValidationError) Field() string
Field function returns field value.
func (DeleteData_RelationshipPropertyMatchValidationError) Key ¶
func (e DeleteData_RelationshipPropertyMatchValidationError) Key() bool
Key function returns key value.
func (DeleteData_RelationshipPropertyMatchValidationError) Reason ¶
func (e DeleteData_RelationshipPropertyMatchValidationError) Reason() string
Reason function returns reason value.
type Info ¶
type Info struct { Changes []*Change `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"` // contains filtered or unexported fields }
func (*Info) Descriptor
deprecated
func (*Info) GetChanges ¶
func (*Info) ProtoMessage ¶
func (*Info) ProtoMessage()
func (*Info) ProtoReflect ¶
func (x *Info) ProtoReflect() protoreflect.Message
func (*Info) Validate ¶
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 ¶
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 ¶
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 ¶
func (m InfoMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (InfoMultiError) Error ¶
func (m InfoMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type InfoValidationError ¶
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 ¶
func (e InfoValidationError) Cause() error
Cause function returns cause value.
func (InfoValidationError) Error ¶
func (e InfoValidationError) Error() string
Error satisfies the builtin error interface
func (InfoValidationError) ErrorName ¶
func (e InfoValidationError) ErrorName() string
ErrorName returns error name.
func (InfoValidationError) Field ¶
func (e InfoValidationError) Field() string
Field function returns field value.
func (InfoValidationError) Key ¶
func (e InfoValidationError) Key() bool
Key function returns key value.
func (InfoValidationError) Reason ¶
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"` 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) GetInfo ¶
func (x *IngestRecordResponse) GetInfo() *Info
func (*IngestRecordResponse) GetRecordId ¶
func (x *IngestRecordResponse) GetRecordId() string
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 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 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 { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*RecordError) Descriptor
deprecated
func (*RecordError) Descriptor() ([]byte, []int)
Deprecated: Use RecordError.ProtoReflect.Descriptor instead.
func (*RecordError) GetError ¶
func (x *RecordError) GetError() string
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 Relationship ¶
type Relationship struct { Source *NodeMatch `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Target *NodeMatch `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` Properties []*v1beta1.Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
func (*Relationship) Descriptor
deprecated
func (*Relationship) Descriptor() ([]byte, []int)
Deprecated: Use Relationship.ProtoReflect.Descriptor instead.
func (*Relationship) GetProperties ¶
func (x *Relationship) GetProperties() []*v1beta1.Property
func (*Relationship) GetSource ¶
func (x *Relationship) GetSource() *NodeMatch
func (*Relationship) GetTarget ¶
func (x *Relationship) GetTarget() *NodeMatch
func (*Relationship) GetType ¶
func (x *Relationship) GetType() string
func (*Relationship) ProtoMessage ¶
func (*Relationship) ProtoMessage()
func (*Relationship) ProtoReflect ¶
func (x *Relationship) ProtoReflect() protoreflect.Message
func (*Relationship) Reset ¶
func (x *Relationship) Reset()
func (*Relationship) String ¶
func (x *Relationship) String() string
func (*Relationship) Validate ¶
func (m *Relationship) Validate() error
Validate checks the field values on Relationship 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 (*Relationship) ValidateAll ¶
func (m *Relationship) ValidateAll() error
ValidateAll checks the field values on Relationship 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 RelationshipMultiError, or nil if none found.
type RelationshipMultiError ¶
type RelationshipMultiError []error
RelationshipMultiError is an error wrapping multiple validation errors returned by Relationship.ValidateAll() if the designated constraints aren't met.
func (RelationshipMultiError) AllErrors ¶
func (m RelationshipMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RelationshipMultiError) Error ¶
func (m RelationshipMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RelationshipValidationError ¶
type RelationshipValidationError struct {
// contains filtered or unexported fields
}
RelationshipValidationError is the validation error returned by Relationship.Validate if the designated constraints aren't met.
func (RelationshipValidationError) Cause ¶
func (e RelationshipValidationError) Cause() error
Cause function returns cause value.
func (RelationshipValidationError) Error ¶
func (e RelationshipValidationError) Error() string
Error satisfies the builtin error interface
func (RelationshipValidationError) ErrorName ¶
func (e RelationshipValidationError) ErrorName() string
ErrorName returns error name.
func (RelationshipValidationError) Field ¶
func (e RelationshipValidationError) Field() string
Field function returns field value.
func (RelationshipValidationError) Key ¶
func (e RelationshipValidationError) Key() bool
Key function returns key value.
func (RelationshipValidationError) Reason ¶
func (e RelationshipValidationError) 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 ¶
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_Relationship 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() *v1beta1.Node
func (*UpsertData) GetRelationship ¶
func (x *UpsertData) GetRelationship() *Relationship
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_Relationship ¶
type UpsertData_Relationship struct {
Relationship *Relationship `protobuf:"bytes,2,opt,name=relationship,proto3,oneof"`
}