ingestv1beta3

package
v0.25.0 Latest Latest
Warning

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

Go to latest
Published: May 3, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const (
	IngestAPI_StreamRecords_FullMethodName = "/indykite.ingest.v1beta3.IngestAPI/StreamRecords"
	IngestAPI_IngestRecord_FullMethodName  = "/indykite.ingest.v1beta3.IngestAPI/IngestRecord"
)

Variables

View Source
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.

View Source
var File_indykite_ingest_v1beta3_ingest_api_proto protoreflect.FileDescriptor
View Source
var File_indykite_ingest_v1beta3_model_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Change.ProtoReflect.Descriptor instead.

func (*Change) GetDataType

func (x *Change) GetDataType() DataType

func (*Change) GetId

func (x *Change) GetId() string

func (*Change) ProtoMessage

func (*Change) ProtoMessage()

func (*Change) ProtoReflect

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

func (*Change) Reset

func (x *Change) Reset()

func (*Change) String

func (x *Change) String() string

func (*Change) Validate

func (m *Change) Validate() error

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

func (m *Change) ValidateAll() error

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
const (
	DataType_DATA_TYPE_INVALID      DataType = 0
	DataType_DATA_TYPE_NODE         DataType = 1
	DataType_DATA_TYPE_RELATIONSHIP DataType = 3
)

func (DataType) Descriptor

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String

func (x DataType) String() string

func (DataType) Type

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

Error satisfies the builtin error interface

func (DeleteDataValidationError) ErrorName

func (e DeleteDataValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteDataValidationError) Field

Field function returns field value.

func (DeleteDataValidationError) Key

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 (*DeleteData_NodePropertyMatch) Reset

func (x *DeleteData_NodePropertyMatch) Reset()

func (*DeleteData_NodePropertyMatch) 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

AllErrors returns a list of validation violation errors.

func (DeleteData_NodePropertyMatchMultiError) Error

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

Cause function returns cause value.

func (DeleteData_NodePropertyMatchValidationError) Error

Error satisfies the builtin error interface

func (DeleteData_NodePropertyMatchValidationError) ErrorName

ErrorName returns error name.

func (DeleteData_NodePropertyMatchValidationError) Field

Field function returns field value.

func (DeleteData_NodePropertyMatchValidationError) Key

Key function returns key value.

func (DeleteData_NodePropertyMatchValidationError) Reason

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 (*DeleteData_RelationshipPropertyMatch) GetTarget

func (*DeleteData_RelationshipPropertyMatch) GetType

func (*DeleteData_RelationshipPropertyMatch) ProtoMessage

func (*DeleteData_RelationshipPropertyMatch) ProtoMessage()

func (*DeleteData_RelationshipPropertyMatch) ProtoReflect

func (*DeleteData_RelationshipPropertyMatch) Reset

func (*DeleteData_RelationshipPropertyMatch) String

func (*DeleteData_RelationshipPropertyMatch) Validate

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

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

AllErrors returns a list of validation violation errors.

func (DeleteData_RelationshipPropertyMatchMultiError) Error

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

Cause function returns cause value.

func (DeleteData_RelationshipPropertyMatchValidationError) Error

Error satisfies the builtin error interface

func (DeleteData_RelationshipPropertyMatchValidationError) ErrorName

ErrorName returns error name.

func (DeleteData_RelationshipPropertyMatchValidationError) Field

Field function returns field value.

func (DeleteData_RelationshipPropertyMatchValidationError) Key

Key function returns key value.

func (DeleteData_RelationshipPropertyMatchValidationError) Reason

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) Descriptor() ([]byte, []int)

Deprecated: Use Info.ProtoReflect.Descriptor instead.

func (*Info) GetChanges

func (x *Info) GetChanges() []*Change

func (*Info) ProtoMessage

func (*Info) ProtoMessage()

func (*Info) ProtoReflect

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

func (*Info) Reset

func (x *Info) Reset()

func (*Info) String

func (x *Info) String() string

func (*Info) Validate

func (m *Info) Validate() error

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

func (m *Info) ValidateAll() error

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

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

Cause function returns cause value.

func (IngestRecordRequestValidationError) Error

Error satisfies the builtin error interface

func (IngestRecordRequestValidationError) ErrorName

ErrorName returns error name.

func (IngestRecordRequestValidationError) Field

Field function returns field value.

func (IngestRecordRequestValidationError) Key

Key function returns key value.

func (IngestRecordRequestValidationError) Reason

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

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

Cause function returns cause value.

func (IngestRecordResponseValidationError) Error

Error satisfies the builtin error interface

func (IngestRecordResponseValidationError) ErrorName

ErrorName returns error name.

func (IngestRecordResponseValidationError) Field

Field function returns field value.

func (IngestRecordResponseValidationError) Key

Key function returns key value.

func (IngestRecordResponseValidationError) Reason

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) Descriptor() ([]byte, []int)

Deprecated: Use NodeMatch.ProtoReflect.Descriptor instead.

func (*NodeMatch) GetExternalId

func (x *NodeMatch) GetExternalId() string

func (*NodeMatch) GetType

func (x *NodeMatch) GetType() string

func (*NodeMatch) ProtoMessage

func (*NodeMatch) ProtoMessage()

func (*NodeMatch) ProtoReflect

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

func (*NodeMatch) Reset

func (x *NodeMatch) Reset()

func (*NodeMatch) String

func (x *NodeMatch) String() string

func (*NodeMatch) Validate

func (m *NodeMatch) Validate() error

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

func (m *NodeMatch) ValidateAll() error

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetDelete

func (x *Record) GetDelete() *DeleteData

func (*Record) GetId

func (x *Record) GetId() string

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) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

func (*Record) Validate

func (m *Record) Validate() error

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

func (m *Record) ValidateAll() error

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

Cause function returns cause value.

func (RecordErrorValidationError) Error

Error satisfies the builtin error interface

func (RecordErrorValidationError) ErrorName

func (e RecordErrorValidationError) ErrorName() string

ErrorName returns error name.

func (RecordErrorValidationError) Field

Field function returns field value.

func (RecordErrorValidationError) Key

Key function returns key value.

func (RecordErrorValidationError) Reason

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

Cause function returns cause value.

func (RelationshipValidationError) Error

Error satisfies the builtin error interface

func (RelationshipValidationError) ErrorName

func (e RelationshipValidationError) ErrorName() string

ErrorName returns error name.

func (RelationshipValidationError) Field

Field function returns field value.

func (RelationshipValidationError) Key

Key function returns key value.

func (RelationshipValidationError) Reason

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

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

Cause function returns cause value.

func (StreamRecordsRequestValidationError) Error

Error satisfies the builtin error interface

func (StreamRecordsRequestValidationError) ErrorName

ErrorName returns error name.

func (StreamRecordsRequestValidationError) Field

Field function returns field value.

func (StreamRecordsRequestValidationError) Key

Key function returns key value.

func (StreamRecordsRequestValidationError) Reason

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

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

Cause function returns cause value.

func (StreamRecordsResponseValidationError) Error

Error satisfies the builtin error interface

func (StreamRecordsResponseValidationError) ErrorName

ErrorName returns error name.

func (StreamRecordsResponseValidationError) Field

Field function returns field value.

func (StreamRecordsResponseValidationError) Key

Key function returns key value.

func (StreamRecordsResponseValidationError) Reason

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 StreamRecordsResponse_StatusError

type StreamRecordsResponse_StatusError struct {
	StatusError *status.Status `protobuf:"bytes,4,opt,name=status_error,json=statusError,proto3,oneof"`
}

type UnimplementedIngestAPIServer

type UnimplementedIngestAPIServer struct {
}

UnimplementedIngestAPIServer should be embedded to have forward compatible implementations.

func (UnimplementedIngestAPIServer) IngestRecord

func (UnimplementedIngestAPIServer) StreamRecords

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

Error satisfies the builtin error interface

func (UpsertDataValidationError) ErrorName

func (e UpsertDataValidationError) ErrorName() string

ErrorName returns error name.

func (UpsertDataValidationError) Field

Field function returns field value.

func (UpsertDataValidationError) Key

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 *v1beta1.Node `protobuf:"bytes,1,opt,name=node,proto3,oneof"`
}

type UpsertData_Relationship

type UpsertData_Relationship struct {
	Relationship *Relationship `protobuf:"bytes,2,opt,name=relationship,proto3,oneof"`
}

Jump to

Keyboard shortcuts

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