ingestv1beta2

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.v1beta2.IngestAPI/StreamRecords"
	IngestAPI_IngestRecord_FullMethodName  = "/indykite.ingest.v1beta2.IngestAPI/IngestRecord"
)

Variables

View Source
var (
	Change_DataType_name = map[int32]string{
		0: "DATA_TYPE_INVALID",
		1: "DATA_TYPE_DIGITAL_TWIN",
		2: "DATA_TYPE_RESOURCE",
		3: "DATA_TYPE_RELATION",
	}
	Change_DataType_value = map[string]int32{
		"DATA_TYPE_INVALID":      0,
		"DATA_TYPE_DIGITAL_TWIN": 1,
		"DATA_TYPE_RESOURCE":     2,
		"DATA_TYPE_RELATION":     3,
	}
)

Enum value maps for Change_DataType.

View Source
var File_indykite_ingest_v1beta2_ingest_api_proto protoreflect.FileDescriptor
View Source
var File_indykite_ingest_v1beta2_model_proto protoreflect.FileDescriptor
View Source
var IngestAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "indykite.ingest.v1beta2.IngestAPI",
	HandlerType: (*IngestAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IngestRecord",
			Handler:    _IngestAPI_IngestRecord_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamRecords",
			Handler:       _IngestAPI_StreamRecords_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "indykite/ingest/v1beta2/ingest_api.proto",
}

IngestAPI_ServiceDesc is the grpc.ServiceDesc for IngestAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterIngestAPIServer

func RegisterIngestAPIServer(s grpc.ServiceRegistrar, srv IngestAPIServer)

Types

type Change added in v0.13.0

type Change struct {
	Id       string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DataType Change_DataType `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Change) Descriptor deprecated added in v0.13.0

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

Deprecated: Use Change.ProtoReflect.Descriptor instead.

func (*Change) GetDataType added in v0.13.0

func (x *Change) GetDataType() Change_DataType

func (*Change) GetId added in v0.13.0

func (x *Change) GetId() string

func (*Change) ProtoMessage added in v0.13.0

func (*Change) ProtoMessage()

func (*Change) ProtoReflect added in v0.13.0

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

func (*Change) Reset added in v0.13.0

func (x *Change) Reset()

func (*Change) String added in v0.13.0

func (x *Change) String() string

func (*Change) Validate added in v0.13.0

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 added in v0.13.0

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 added in v0.13.0

type ChangeMultiError []error

ChangeMultiError is an error wrapping multiple validation errors returned by Change.ValidateAll() if the designated constraints aren't met.

func (ChangeMultiError) AllErrors added in v0.13.0

func (m ChangeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ChangeMultiError) Error added in v0.13.0

func (m ChangeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ChangeValidationError added in v0.13.0

type ChangeValidationError struct {
	// contains filtered or unexported fields
}

ChangeValidationError is the validation error returned by Change.Validate if the designated constraints aren't met.

func (ChangeValidationError) Cause added in v0.13.0

func (e ChangeValidationError) Cause() error

Cause function returns cause value.

func (ChangeValidationError) Error added in v0.13.0

func (e ChangeValidationError) Error() string

Error satisfies the builtin error interface

func (ChangeValidationError) ErrorName added in v0.13.0

func (e ChangeValidationError) ErrorName() string

ErrorName returns error name.

func (ChangeValidationError) Field added in v0.13.0

func (e ChangeValidationError) Field() string

Field function returns field value.

func (ChangeValidationError) Key added in v0.13.0

func (e ChangeValidationError) Key() bool

Key function returns key value.

func (ChangeValidationError) Reason added in v0.13.0

func (e ChangeValidationError) Reason() string

Reason function returns reason value.

type Change_DataType added in v0.13.0

type Change_DataType int32
const (
	Change_DATA_TYPE_INVALID      Change_DataType = 0
	Change_DATA_TYPE_DIGITAL_TWIN Change_DataType = 1
	Change_DATA_TYPE_RESOURCE     Change_DataType = 2
	Change_DATA_TYPE_RELATION     Change_DataType = 3
)

func (Change_DataType) Descriptor added in v0.13.0

func (Change_DataType) Enum added in v0.13.0

func (x Change_DataType) Enum() *Change_DataType

func (Change_DataType) EnumDescriptor deprecated added in v0.13.0

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

Deprecated: Use Change_DataType.Descriptor instead.

func (Change_DataType) Number added in v0.13.0

func (Change_DataType) String added in v0.13.0

func (x Change_DataType) String() string

func (Change_DataType) Type added in v0.13.0

type DeleteData

type DeleteData struct {

	// Types that are assignable to Data:
	//
	//	*DeleteData_Node
	//	*DeleteData_Relation
	//	*DeleteData_NodeProperty
	//	*DeleteData_RelationProperty
	Data isDeleteData_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*DeleteData) Descriptor deprecated

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

Deprecated: Use DeleteData.ProtoReflect.Descriptor instead.

func (*DeleteData) GetData

func (m *DeleteData) GetData() isDeleteData_Data

func (*DeleteData) GetNode

func (x *DeleteData) GetNode() *NodeMatch

func (*DeleteData) GetNodeProperty

func (x *DeleteData) GetNodeProperty() *DeleteData_NodePropertyMatch

func (*DeleteData) GetRelation

func (x *DeleteData) GetRelation() *RelationMatch

func (*DeleteData) GetRelationProperty

func (x *DeleteData) GetRelationProperty() *DeleteData_RelationPropertyMatch

func (*DeleteData) ProtoMessage

func (*DeleteData) ProtoMessage()

func (*DeleteData) ProtoReflect

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

func (*DeleteData) Reset

func (x *DeleteData) Reset()

func (*DeleteData) String

func (x *DeleteData) String() string

func (*DeleteData) Validate

func (m *DeleteData) Validate() error

Validate checks the field values on DeleteData with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeleteData) ValidateAll

func (m *DeleteData) ValidateAll() error

ValidateAll checks the field values on DeleteData with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteDataMultiError, or nil if none found.

type DeleteDataMultiError

type DeleteDataMultiError []error

DeleteDataMultiError is an error wrapping multiple validation errors returned by DeleteData.ValidateAll() if the designated constraints aren't met.

func (DeleteDataMultiError) AllErrors

func (m DeleteDataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteDataMultiError) Error

func (m DeleteDataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DeleteDataValidationError

type DeleteDataValidationError struct {
	// contains filtered or unexported fields
}

DeleteDataValidationError is the validation error returned by DeleteData.Validate if the designated constraints aren't met.

func (DeleteDataValidationError) Cause

func (e DeleteDataValidationError) Cause() error

Cause function returns cause value.

func (DeleteDataValidationError) Error

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"`
	Key   string     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteData_NodePropertyMatch) Descriptor deprecated

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

Deprecated: Use DeleteData_NodePropertyMatch.ProtoReflect.Descriptor instead.

func (*DeleteData_NodePropertyMatch) GetKey

func (*DeleteData_NodePropertyMatch) GetMatch

func (x *DeleteData_NodePropertyMatch) GetMatch() *NodeMatch

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_Relation

type DeleteData_Relation struct {
	Relation *RelationMatch `protobuf:"bytes,2,opt,name=relation,proto3,oneof"`
}

type DeleteData_RelationProperty

type DeleteData_RelationProperty struct {
	RelationProperty *DeleteData_RelationPropertyMatch `protobuf:"bytes,4,opt,name=relation_property,json=relationProperty,proto3,oneof"`
}

type DeleteData_RelationPropertyMatch

type DeleteData_RelationPropertyMatch struct {
	Match *RelationMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	Key   string         `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteData_RelationPropertyMatch) Descriptor deprecated

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

Deprecated: Use DeleteData_RelationPropertyMatch.ProtoReflect.Descriptor instead.

func (*DeleteData_RelationPropertyMatch) GetKey

func (*DeleteData_RelationPropertyMatch) GetMatch

func (*DeleteData_RelationPropertyMatch) ProtoMessage

func (*DeleteData_RelationPropertyMatch) ProtoMessage()

func (*DeleteData_RelationPropertyMatch) ProtoReflect

func (*DeleteData_RelationPropertyMatch) Reset

func (*DeleteData_RelationPropertyMatch) String

func (*DeleteData_RelationPropertyMatch) Validate

Validate checks the field values on DeleteData_RelationPropertyMatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeleteData_RelationPropertyMatch) ValidateAll

func (m *DeleteData_RelationPropertyMatch) ValidateAll() error

ValidateAll checks the field values on DeleteData_RelationPropertyMatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteData_RelationPropertyMatchMultiError, or nil if none found.

type DeleteData_RelationPropertyMatchMultiError

type DeleteData_RelationPropertyMatchMultiError []error

DeleteData_RelationPropertyMatchMultiError is an error wrapping multiple validation errors returned by DeleteData_RelationPropertyMatch.ValidateAll() if the designated constraints aren't met.

func (DeleteData_RelationPropertyMatchMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (DeleteData_RelationPropertyMatchMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeleteData_RelationPropertyMatchValidationError

type DeleteData_RelationPropertyMatchValidationError struct {
	// contains filtered or unexported fields
}

DeleteData_RelationPropertyMatchValidationError is the validation error returned by DeleteData_RelationPropertyMatch.Validate if the designated constraints aren't met.

func (DeleteData_RelationPropertyMatchValidationError) Cause

Cause function returns cause value.

func (DeleteData_RelationPropertyMatchValidationError) Error

Error satisfies the builtin error interface

func (DeleteData_RelationPropertyMatchValidationError) ErrorName

ErrorName returns error name.

func (DeleteData_RelationPropertyMatchValidationError) Field

Field function returns field value.

func (DeleteData_RelationPropertyMatchValidationError) Key

Key function returns key value.

func (DeleteData_RelationPropertyMatchValidationError) Reason

Reason function returns reason value.

type DigitalTwin

type DigitalTwin struct {
	ExternalId string   `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	Type       string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Tags       []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto.
	TenantId string `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto.
	IdentityProperties []*IdentityProperty `protobuf:"bytes,6,rep,name=identity_properties,json=identityProperties,proto3" json:"identity_properties,omitempty"`
	Properties         []*Property         `protobuf:"bytes,7,rep,name=properties,proto3" json:"properties,omitempty"`
	Id                 string              `protobuf:"bytes,8,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DigitalTwin) Descriptor deprecated

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

Deprecated: Use DigitalTwin.ProtoReflect.Descriptor instead.

func (*DigitalTwin) GetExternalId

func (x *DigitalTwin) GetExternalId() string

func (*DigitalTwin) GetId added in v0.18.0

func (x *DigitalTwin) GetId() string

func (*DigitalTwin) GetIdentityProperties deprecated

func (x *DigitalTwin) GetIdentityProperties() []*IdentityProperty

Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto.

func (*DigitalTwin) GetProperties

func (x *DigitalTwin) GetProperties() []*Property

func (*DigitalTwin) GetTags

func (x *DigitalTwin) GetTags() []string

func (*DigitalTwin) GetTenantId deprecated

func (x *DigitalTwin) GetTenantId() string

Deprecated: Marked as deprecated in indykite/ingest/v1beta2/model.proto.

func (*DigitalTwin) GetType

func (x *DigitalTwin) GetType() string

func (*DigitalTwin) ProtoMessage

func (*DigitalTwin) ProtoMessage()

func (*DigitalTwin) ProtoReflect

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

func (*DigitalTwin) Reset

func (x *DigitalTwin) Reset()

func (*DigitalTwin) String

func (x *DigitalTwin) String() string

func (*DigitalTwin) Validate

func (m *DigitalTwin) Validate() error

Validate checks the field values on DigitalTwin with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DigitalTwin) ValidateAll

func (m *DigitalTwin) ValidateAll() error

ValidateAll checks the field values on DigitalTwin with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DigitalTwinMultiError, or nil if none found.

type DigitalTwinMultiError

type DigitalTwinMultiError []error

DigitalTwinMultiError is an error wrapping multiple validation errors returned by DigitalTwin.ValidateAll() if the designated constraints aren't met.

func (DigitalTwinMultiError) AllErrors

func (m DigitalTwinMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DigitalTwinMultiError) Error

func (m DigitalTwinMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DigitalTwinValidationError

type DigitalTwinValidationError struct {
	// contains filtered or unexported fields
}

DigitalTwinValidationError is the validation error returned by DigitalTwin.Validate if the designated constraints aren't met.

func (DigitalTwinValidationError) Cause

Cause function returns cause value.

func (DigitalTwinValidationError) Error

Error satisfies the builtin error interface

func (DigitalTwinValidationError) ErrorName

func (e DigitalTwinValidationError) ErrorName() string

ErrorName returns error name.

func (DigitalTwinValidationError) Field

Field function returns field value.

func (DigitalTwinValidationError) Key

Key function returns key value.

func (DigitalTwinValidationError) Reason

Reason function returns reason value.

type IdentityProperty

type IdentityProperty struct {
	Key   string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *v1beta1.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // todo: add metadata
	// contains filtered or unexported fields
}

func (*IdentityProperty) Descriptor deprecated

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

Deprecated: Use IdentityProperty.ProtoReflect.Descriptor instead.

func (*IdentityProperty) GetKey

func (x *IdentityProperty) GetKey() string

func (*IdentityProperty) GetValue

func (x *IdentityProperty) GetValue() *v1beta1.Value

func (*IdentityProperty) ProtoMessage

func (*IdentityProperty) ProtoMessage()

func (*IdentityProperty) ProtoReflect

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

func (*IdentityProperty) Reset

func (x *IdentityProperty) Reset()

func (*IdentityProperty) String

func (x *IdentityProperty) String() string

func (*IdentityProperty) Validate

func (m *IdentityProperty) Validate() error

Validate checks the field values on IdentityProperty with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*IdentityProperty) ValidateAll

func (m *IdentityProperty) ValidateAll() error

ValidateAll checks the field values on IdentityProperty with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IdentityPropertyMultiError, or nil if none found.

type IdentityPropertyMultiError

type IdentityPropertyMultiError []error

IdentityPropertyMultiError is an error wrapping multiple validation errors returned by IdentityProperty.ValidateAll() if the designated constraints aren't met.

func (IdentityPropertyMultiError) AllErrors

func (m IdentityPropertyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IdentityPropertyMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type IdentityPropertyValidationError

type IdentityPropertyValidationError struct {
	// contains filtered or unexported fields
}

IdentityPropertyValidationError is the validation error returned by IdentityProperty.Validate if the designated constraints aren't met.

func (IdentityPropertyValidationError) Cause

Cause function returns cause value.

func (IdentityPropertyValidationError) Error

Error satisfies the builtin error interface

func (IdentityPropertyValidationError) ErrorName

ErrorName returns error name.

func (IdentityPropertyValidationError) Field

Field function returns field value.

func (IdentityPropertyValidationError) Key

Key function returns key value.

func (IdentityPropertyValidationError) Reason

Reason function returns reason value.

type Info added in v0.13.0

type Info struct {
	Changes []*Change `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
	// contains filtered or unexported fields
}

func (*Info) Descriptor deprecated added in v0.13.0

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

Deprecated: Use Info.ProtoReflect.Descriptor instead.

func (*Info) GetChanges added in v0.13.0

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

func (*Info) ProtoMessage added in v0.13.0

func (*Info) ProtoMessage()

func (*Info) ProtoReflect added in v0.13.0

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

func (*Info) Reset added in v0.13.0

func (x *Info) Reset()

func (*Info) String added in v0.13.0

func (x *Info) String() string

func (*Info) Validate added in v0.13.0

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 added in v0.13.0

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 added in v0.13.0

type InfoMultiError []error

InfoMultiError is an error wrapping multiple validation errors returned by Info.ValidateAll() if the designated constraints aren't met.

func (InfoMultiError) AllErrors added in v0.13.0

func (m InfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InfoMultiError) Error added in v0.13.0

func (m InfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type InfoValidationError added in v0.13.0

type InfoValidationError struct {
	// contains filtered or unexported fields
}

InfoValidationError is the validation error returned by Info.Validate if the designated constraints aren't met.

func (InfoValidationError) Cause added in v0.13.0

func (e InfoValidationError) Cause() error

Cause function returns cause value.

func (InfoValidationError) Error added in v0.13.0

func (e InfoValidationError) Error() string

Error satisfies the builtin error interface

func (InfoValidationError) ErrorName added in v0.13.0

func (e InfoValidationError) ErrorName() string

ErrorName returns error name.

func (InfoValidationError) Field added in v0.13.0

func (e InfoValidationError) Field() string

Field function returns field value.

func (InfoValidationError) Key added in v0.13.0

func (e InfoValidationError) Key() bool

Key function returns key value.

func (InfoValidationError) Reason added in v0.13.0

func (e InfoValidationError) Reason() string

Reason function returns reason value.

type IngestAPIClient

type IngestAPIClient interface {
	StreamRecords(ctx context.Context, opts ...grpc.CallOption) (IngestAPI_StreamRecordsClient, error)
	IngestRecord(ctx context.Context, in *IngestRecordRequest, opts ...grpc.CallOption) (*IngestRecordResponse, error)
}

IngestAPIClient is the client API for IngestAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIngestAPIClient

func NewIngestAPIClient(cc grpc.ClientConnInterface) IngestAPIClient

type IngestAPIServer

type IngestAPIServer interface {
	StreamRecords(IngestAPI_StreamRecordsServer) error
	IngestRecord(context.Context, *IngestRecordRequest) (*IngestRecordResponse, error)
}

IngestAPIServer is the server API for IngestAPI service. All implementations should embed UnimplementedIngestAPIServer for forward compatibility

type IngestAPI_StreamRecordsClient

type IngestAPI_StreamRecordsClient interface {
	Send(*StreamRecordsRequest) error
	Recv() (*StreamRecordsResponse, error)
	grpc.ClientStream
}

type IngestAPI_StreamRecordsServer

type IngestAPI_StreamRecordsServer interface {
	Send(*StreamRecordsResponse) error
	Recv() (*StreamRecordsRequest, error)
	grpc.ServerStream
}

type IngestRecordRequest

type IngestRecordRequest struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestRecordRequest) Descriptor deprecated

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

Deprecated: Use IngestRecordRequest.ProtoReflect.Descriptor instead.

func (*IngestRecordRequest) GetRecord

func (x *IngestRecordRequest) GetRecord() *Record

func (*IngestRecordRequest) ProtoMessage

func (*IngestRecordRequest) ProtoMessage()

func (*IngestRecordRequest) ProtoReflect

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

func (*IngestRecordRequest) Reset

func (x *IngestRecordRequest) Reset()

func (*IngestRecordRequest) String

func (x *IngestRecordRequest) String() string

func (*IngestRecordRequest) Validate

func (m *IngestRecordRequest) Validate() error

Validate checks the field values on IngestRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*IngestRecordRequest) ValidateAll

func (m *IngestRecordRequest) ValidateAll() error

ValidateAll checks the field values on IngestRecordRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IngestRecordRequestMultiError, or nil if none found.

type IngestRecordRequestMultiError

type IngestRecordRequestMultiError []error

IngestRecordRequestMultiError is an error wrapping multiple validation errors returned by IngestRecordRequest.ValidateAll() if the designated constraints aren't met.

func (IngestRecordRequestMultiError) AllErrors

func (m IngestRecordRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IngestRecordRequestMultiError) Error

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"`
	// Types that are assignable to Error:
	//
	//	*IngestRecordResponse_RecordError
	//	*IngestRecordResponse_StatusError
	Error isIngestRecordResponse_Error `protobuf_oneof:"error"`
	Info  *Info                        `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestRecordResponse) Descriptor deprecated

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

Deprecated: Use IngestRecordResponse.ProtoReflect.Descriptor instead.

func (*IngestRecordResponse) GetError added in v0.13.0

func (m *IngestRecordResponse) GetError() isIngestRecordResponse_Error

func (*IngestRecordResponse) GetInfo added in v0.13.0

func (x *IngestRecordResponse) GetInfo() *Info

func (*IngestRecordResponse) GetRecordError

func (x *IngestRecordResponse) GetRecordError() *RecordError

func (*IngestRecordResponse) GetRecordId added in v0.13.0

func (x *IngestRecordResponse) GetRecordId() string

func (*IngestRecordResponse) GetStatusError added in v0.13.0

func (x *IngestRecordResponse) GetStatusError() *status.Status

func (*IngestRecordResponse) ProtoMessage

func (*IngestRecordResponse) ProtoMessage()

func (*IngestRecordResponse) ProtoReflect

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

func (*IngestRecordResponse) Reset

func (x *IngestRecordResponse) Reset()

func (*IngestRecordResponse) String

func (x *IngestRecordResponse) String() string

func (*IngestRecordResponse) Validate

func (m *IngestRecordResponse) Validate() error

Validate checks the field values on IngestRecordResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*IngestRecordResponse) ValidateAll

func (m *IngestRecordResponse) ValidateAll() error

ValidateAll checks the field values on IngestRecordResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in IngestRecordResponseMultiError, or nil if none found.

type IngestRecordResponseMultiError

type IngestRecordResponseMultiError []error

IngestRecordResponseMultiError is an error wrapping multiple validation errors returned by IngestRecordResponse.ValidateAll() if the designated constraints aren't met.

func (IngestRecordResponseMultiError) AllErrors

func (m IngestRecordResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (IngestRecordResponseMultiError) Error

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 IngestRecordResponse_RecordError added in v0.13.0

type IngestRecordResponse_RecordError struct {
	RecordError *RecordError `protobuf:"bytes,3,opt,name=record_error,json=recordError,proto3,oneof"`
}

type IngestRecordResponse_StatusError added in v0.13.0

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

type Node

type Node struct {

	// Types that are assignable to Type:
	//
	//	*Node_DigitalTwin
	//	*Node_Resource
	Type isNode_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetDigitalTwin

func (x *Node) GetDigitalTwin() *DigitalTwin

func (*Node) GetResource

func (x *Node) GetResource() *Resource

func (*Node) GetType

func (m *Node) GetType() isNode_Type

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

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

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

func (*Node) Validate

func (m *Node) Validate() error

Validate checks the field values on Node with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Node) ValidateAll

func (m *Node) ValidateAll() error

ValidateAll checks the field values on Node with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NodeMultiError, or nil if none found.

type NodeMatch

type NodeMatch struct {
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	Type       string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeMatch) Descriptor deprecated

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

type NodeMultiError []error

NodeMultiError is an error wrapping multiple validation errors returned by Node.ValidateAll() if the designated constraints aren't met.

func (NodeMultiError) AllErrors

func (m NodeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NodeMultiError) Error

func (m NodeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NodeValidationError

type NodeValidationError struct {
	// contains filtered or unexported fields
}

NodeValidationError is the validation error returned by Node.Validate if the designated constraints aren't met.

func (NodeValidationError) Cause

func (e NodeValidationError) Cause() error

Cause function returns cause value.

func (NodeValidationError) Error

func (e NodeValidationError) Error() string

Error satisfies the builtin error interface

func (NodeValidationError) ErrorName

func (e NodeValidationError) ErrorName() string

ErrorName returns error name.

func (NodeValidationError) Field

func (e NodeValidationError) Field() string

Field function returns field value.

func (NodeValidationError) Key

func (e NodeValidationError) Key() bool

Key function returns key value.

func (NodeValidationError) Reason

func (e NodeValidationError) Reason() string

Reason function returns reason value.

type Node_DigitalTwin

type Node_DigitalTwin struct {
	DigitalTwin *DigitalTwin `protobuf:"bytes,1,opt,name=digital_twin,json=digitalTwin,proto3,oneof"`
}

type Node_Resource

type Node_Resource struct {
	Resource *Resource `protobuf:"bytes,2,opt,name=resource,proto3,oneof"`
}

type Property

type Property struct {
	Key   string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *v1beta1.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Property) Descriptor deprecated

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

Deprecated: Use Property.ProtoReflect.Descriptor instead.

func (*Property) GetKey

func (x *Property) GetKey() string

func (*Property) GetValue

func (x *Property) GetValue() *v1beta1.Value

func (*Property) ProtoMessage

func (*Property) ProtoMessage()

func (*Property) ProtoReflect

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

func (*Property) Reset

func (x *Property) Reset()

func (*Property) String

func (x *Property) String() string

func (*Property) Validate

func (m *Property) Validate() error

Validate checks the field values on Property with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Property) ValidateAll

func (m *Property) ValidateAll() error

ValidateAll checks the field values on Property with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PropertyMultiError, or nil if none found.

type PropertyError

type PropertyError struct {
	Messages []string `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*PropertyError) Descriptor deprecated

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

Deprecated: Use PropertyError.ProtoReflect.Descriptor instead.

func (*PropertyError) GetMessages

func (x *PropertyError) GetMessages() []string

func (*PropertyError) ProtoMessage

func (*PropertyError) ProtoMessage()

func (*PropertyError) ProtoReflect

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

func (*PropertyError) Reset

func (x *PropertyError) Reset()

func (*PropertyError) String

func (x *PropertyError) String() string

func (*PropertyError) Validate

func (m *PropertyError) Validate() error

Validate checks the field values on PropertyError with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PropertyError) ValidateAll

func (m *PropertyError) ValidateAll() error

ValidateAll checks the field values on PropertyError with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PropertyErrorMultiError, or nil if none found.

type PropertyErrorMultiError

type PropertyErrorMultiError []error

PropertyErrorMultiError is an error wrapping multiple validation errors returned by PropertyError.ValidateAll() if the designated constraints aren't met.

func (PropertyErrorMultiError) AllErrors

func (m PropertyErrorMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PropertyErrorMultiError) Error

func (m PropertyErrorMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PropertyErrorValidationError

type PropertyErrorValidationError struct {
	// contains filtered or unexported fields
}

PropertyErrorValidationError is the validation error returned by PropertyError.Validate if the designated constraints aren't met.

func (PropertyErrorValidationError) Cause

Cause function returns cause value.

func (PropertyErrorValidationError) Error

Error satisfies the builtin error interface

func (PropertyErrorValidationError) ErrorName

func (e PropertyErrorValidationError) ErrorName() string

ErrorName returns error name.

func (PropertyErrorValidationError) Field

Field function returns field value.

func (PropertyErrorValidationError) Key

Key function returns key value.

func (PropertyErrorValidationError) Reason

Reason function returns reason value.

type PropertyMultiError

type PropertyMultiError []error

PropertyMultiError is an error wrapping multiple validation errors returned by Property.ValidateAll() if the designated constraints aren't met.

func (PropertyMultiError) AllErrors

func (m PropertyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PropertyMultiError) Error

func (m PropertyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PropertyValidationError

type PropertyValidationError struct {
	// contains filtered or unexported fields
}

PropertyValidationError is the validation error returned by Property.Validate if the designated constraints aren't met.

func (PropertyValidationError) Cause

func (e PropertyValidationError) Cause() error

Cause function returns cause value.

func (PropertyValidationError) Error

func (e PropertyValidationError) Error() string

Error satisfies the builtin error interface

func (PropertyValidationError) ErrorName

func (e PropertyValidationError) ErrorName() string

ErrorName returns error name.

func (PropertyValidationError) Field

func (e PropertyValidationError) Field() string

Field function returns field value.

func (PropertyValidationError) Key

func (e PropertyValidationError) Key() bool

Key function returns key value.

func (PropertyValidationError) Reason

func (e PropertyValidationError) Reason() string

Reason function returns reason value.

type Record

type Record struct {

	// Unique identifier of the record, for client side reference
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Operation:
	//
	//	*Record_Upsert
	//	*Record_Delete
	Operation isRecord_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated

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

	// map from property type to property error, if any
	PropertyErrors map[string]*PropertyError `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RecordError) Descriptor deprecated

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

Deprecated: Use RecordError.ProtoReflect.Descriptor instead.

func (*RecordError) GetPropertyErrors

func (x *RecordError) GetPropertyErrors() map[string]*PropertyError

func (*RecordError) ProtoMessage

func (*RecordError) ProtoMessage()

func (*RecordError) ProtoReflect

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

func (*RecordError) Reset

func (x *RecordError) Reset()

func (*RecordError) String

func (x *RecordError) String() string

func (*RecordError) Validate

func (m *RecordError) Validate() error

Validate checks the field values on RecordError with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RecordError) ValidateAll

func (m *RecordError) ValidateAll() error

ValidateAll checks the field values on RecordError with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RecordErrorMultiError, or nil if none found.

type RecordErrorMultiError

type RecordErrorMultiError []error

RecordErrorMultiError is an error wrapping multiple validation errors returned by RecordError.ValidateAll() if the designated constraints aren't met.

func (RecordErrorMultiError) AllErrors

func (m RecordErrorMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RecordErrorMultiError) Error

func (m RecordErrorMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RecordErrorValidationError

type RecordErrorValidationError struct {
	// contains filtered or unexported fields
}

RecordErrorValidationError is the validation error returned by RecordError.Validate if the designated constraints aren't met.

func (RecordErrorValidationError) Cause

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 Relation

type Relation struct {
	Match      *RelationMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	Properties []*Property    `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*Relation) Descriptor deprecated

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

Deprecated: Use Relation.ProtoReflect.Descriptor instead.

func (*Relation) GetMatch

func (x *Relation) GetMatch() *RelationMatch

func (*Relation) GetProperties

func (x *Relation) GetProperties() []*Property

func (*Relation) ProtoMessage

func (*Relation) ProtoMessage()

func (*Relation) ProtoReflect

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

func (*Relation) Reset

func (x *Relation) Reset()

func (*Relation) String

func (x *Relation) String() string

func (*Relation) Validate

func (m *Relation) Validate() error

Validate checks the field values on Relation with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Relation) ValidateAll

func (m *Relation) ValidateAll() error

ValidateAll checks the field values on Relation with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RelationMultiError, or nil if none found.

type RelationMatch

type RelationMatch struct {
	SourceMatch *NodeMatch `protobuf:"bytes,1,opt,name=source_match,json=sourceMatch,proto3" json:"source_match,omitempty"`
	TargetMatch *NodeMatch `protobuf:"bytes,2,opt,name=target_match,json=targetMatch,proto3" json:"target_match,omitempty"`
	Type        string     `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*RelationMatch) Descriptor deprecated

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

Deprecated: Use RelationMatch.ProtoReflect.Descriptor instead.

func (*RelationMatch) GetSourceMatch

func (x *RelationMatch) GetSourceMatch() *NodeMatch

func (*RelationMatch) GetTargetMatch

func (x *RelationMatch) GetTargetMatch() *NodeMatch

func (*RelationMatch) GetType

func (x *RelationMatch) GetType() string

func (*RelationMatch) ProtoMessage

func (*RelationMatch) ProtoMessage()

func (*RelationMatch) ProtoReflect

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

func (*RelationMatch) Reset

func (x *RelationMatch) Reset()

func (*RelationMatch) String

func (x *RelationMatch) String() string

func (*RelationMatch) Validate

func (m *RelationMatch) Validate() error

Validate checks the field values on RelationMatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RelationMatch) ValidateAll

func (m *RelationMatch) ValidateAll() error

ValidateAll checks the field values on RelationMatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RelationMatchMultiError, or nil if none found.

type RelationMatchMultiError

type RelationMatchMultiError []error

RelationMatchMultiError is an error wrapping multiple validation errors returned by RelationMatch.ValidateAll() if the designated constraints aren't met.

func (RelationMatchMultiError) AllErrors

func (m RelationMatchMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RelationMatchMultiError) Error

func (m RelationMatchMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RelationMatchValidationError

type RelationMatchValidationError struct {
	// contains filtered or unexported fields
}

RelationMatchValidationError is the validation error returned by RelationMatch.Validate if the designated constraints aren't met.

func (RelationMatchValidationError) Cause

Cause function returns cause value.

func (RelationMatchValidationError) Error

Error satisfies the builtin error interface

func (RelationMatchValidationError) ErrorName

func (e RelationMatchValidationError) ErrorName() string

ErrorName returns error name.

func (RelationMatchValidationError) Field

Field function returns field value.

func (RelationMatchValidationError) Key

Key function returns key value.

func (RelationMatchValidationError) Reason

Reason function returns reason value.

type RelationMultiError

type RelationMultiError []error

RelationMultiError is an error wrapping multiple validation errors returned by Relation.ValidateAll() if the designated constraints aren't met.

func (RelationMultiError) AllErrors

func (m RelationMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RelationMultiError) Error

func (m RelationMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RelationValidationError

type RelationValidationError struct {
	// contains filtered or unexported fields
}

RelationValidationError is the validation error returned by Relation.Validate if the designated constraints aren't met.

func (RelationValidationError) Cause

func (e RelationValidationError) Cause() error

Cause function returns cause value.

func (RelationValidationError) Error

func (e RelationValidationError) Error() string

Error satisfies the builtin error interface

func (RelationValidationError) ErrorName

func (e RelationValidationError) ErrorName() string

ErrorName returns error name.

func (RelationValidationError) Field

func (e RelationValidationError) Field() string

Field function returns field value.

func (RelationValidationError) Key

func (e RelationValidationError) Key() bool

Key function returns key value.

func (RelationValidationError) Reason

func (e RelationValidationError) Reason() string

Reason function returns reason value.

type Resource

type Resource struct {
	ExternalId string      `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	Type       string      `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Tags       []string    `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Properties []*Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetExternalId

func (x *Resource) GetExternalId() string

func (*Resource) GetProperties

func (x *Resource) GetProperties() []*Property

func (*Resource) GetTags

func (x *Resource) GetTags() []string

func (*Resource) GetType

func (x *Resource) GetType() string

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect

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

func (*Resource) Reset

func (x *Resource) Reset()

func (*Resource) String

func (x *Resource) String() string

func (*Resource) Validate

func (m *Resource) Validate() error

Validate checks the field values on Resource with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Resource) ValidateAll

func (m *Resource) ValidateAll() error

ValidateAll checks the field values on Resource with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ResourceMultiError, or nil if none found.

type ResourceMultiError

type ResourceMultiError []error

ResourceMultiError is an error wrapping multiple validation errors returned by Resource.ValidateAll() if the designated constraints aren't met.

func (ResourceMultiError) AllErrors

func (m ResourceMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ResourceMultiError) Error

func (m ResourceMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ResourceValidationError

type ResourceValidationError struct {
	// contains filtered or unexported fields
}

ResourceValidationError is the validation error returned by Resource.Validate if the designated constraints aren't met.

func (ResourceValidationError) Cause

func (e ResourceValidationError) Cause() error

Cause function returns cause value.

func (ResourceValidationError) Error

func (e ResourceValidationError) Error() string

Error satisfies the builtin error interface

func (ResourceValidationError) ErrorName

func (e ResourceValidationError) ErrorName() string

ErrorName returns error name.

func (ResourceValidationError) Field

func (e ResourceValidationError) Field() string

Field function returns field value.

func (ResourceValidationError) Key

func (e ResourceValidationError) Key() bool

Key function returns key value.

func (ResourceValidationError) Reason

func (e ResourceValidationError) Reason() string

Reason function returns reason value.

type StreamRecordsRequest

type StreamRecordsRequest struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRecordsRequest) Descriptor deprecated

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

Deprecated: Use StreamRecordsRequest.ProtoReflect.Descriptor instead.

func (*StreamRecordsRequest) GetRecord

func (x *StreamRecordsRequest) GetRecord() *Record

func (*StreamRecordsRequest) ProtoMessage

func (*StreamRecordsRequest) ProtoMessage()

func (*StreamRecordsRequest) ProtoReflect

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

func (*StreamRecordsRequest) Reset

func (x *StreamRecordsRequest) Reset()

func (*StreamRecordsRequest) String

func (x *StreamRecordsRequest) String() string

func (*StreamRecordsRequest) Validate

func (m *StreamRecordsRequest) Validate() error

Validate checks the field values on StreamRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StreamRecordsRequest) ValidateAll

func (m *StreamRecordsRequest) ValidateAll() error

ValidateAll checks the field values on StreamRecordsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamRecordsRequestMultiError, or nil if none found.

type StreamRecordsRequestMultiError

type StreamRecordsRequestMultiError []error

StreamRecordsRequestMultiError is an error wrapping multiple validation errors returned by StreamRecordsRequest.ValidateAll() if the designated constraints aren't met.

func (StreamRecordsRequestMultiError) AllErrors

func (m StreamRecordsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StreamRecordsRequestMultiError) Error

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 added in v0.13.0

func (x *StreamRecordsResponse) GetInfo() *Info

func (*StreamRecordsResponse) GetRecordError

func (x *StreamRecordsResponse) GetRecordError() *RecordError

func (*StreamRecordsResponse) GetRecordId

func (x *StreamRecordsResponse) GetRecordId() string

func (*StreamRecordsResponse) GetRecordIndex

func (x *StreamRecordsResponse) GetRecordIndex() uint32

func (*StreamRecordsResponse) GetStatusError

func (x *StreamRecordsResponse) GetStatusError() *status.Status

func (*StreamRecordsResponse) ProtoMessage

func (*StreamRecordsResponse) ProtoMessage()

func (*StreamRecordsResponse) ProtoReflect

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

func (*StreamRecordsResponse) Reset

func (x *StreamRecordsResponse) Reset()

func (*StreamRecordsResponse) String

func (x *StreamRecordsResponse) String() string

func (*StreamRecordsResponse) Validate

func (m *StreamRecordsResponse) Validate() error

Validate checks the field values on StreamRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StreamRecordsResponse) ValidateAll

func (m *StreamRecordsResponse) ValidateAll() error

ValidateAll checks the field values on StreamRecordsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamRecordsResponseMultiError, or nil if none found.

type StreamRecordsResponseMultiError

type StreamRecordsResponseMultiError []error

StreamRecordsResponseMultiError is an error wrapping multiple validation errors returned by StreamRecordsResponse.ValidateAll() if the designated constraints aren't met.

func (StreamRecordsResponseMultiError) AllErrors

func (m StreamRecordsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StreamRecordsResponseMultiError) Error

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_Relation
	Data isUpsertData_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*UpsertData) Descriptor deprecated

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

Deprecated: Use UpsertData.ProtoReflect.Descriptor instead.

func (*UpsertData) GetData

func (m *UpsertData) GetData() isUpsertData_Data

func (*UpsertData) GetNode

func (x *UpsertData) GetNode() *Node

func (*UpsertData) GetRelation

func (x *UpsertData) GetRelation() *Relation

func (*UpsertData) ProtoMessage

func (*UpsertData) ProtoMessage()

func (*UpsertData) ProtoReflect

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

func (*UpsertData) Reset

func (x *UpsertData) Reset()

func (*UpsertData) String

func (x *UpsertData) String() string

func (*UpsertData) Validate

func (m *UpsertData) Validate() error

Validate checks the field values on UpsertData with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UpsertData) ValidateAll

func (m *UpsertData) ValidateAll() error

ValidateAll checks the field values on UpsertData with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpsertDataMultiError, or nil if none found.

type UpsertDataMultiError

type UpsertDataMultiError []error

UpsertDataMultiError is an error wrapping multiple validation errors returned by UpsertData.ValidateAll() if the designated constraints aren't met.

func (UpsertDataMultiError) AllErrors

func (m UpsertDataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpsertDataMultiError) Error

func (m UpsertDataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UpsertDataValidationError

type UpsertDataValidationError struct {
	// contains filtered or unexported fields
}

UpsertDataValidationError is the validation error returned by UpsertData.Validate if the designated constraints aren't met.

func (UpsertDataValidationError) Cause

func (e UpsertDataValidationError) Cause() error

Cause function returns cause value.

func (UpsertDataValidationError) Error

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

type UpsertData_Relation

type UpsertData_Relation struct {
	Relation *Relation `protobuf:"bytes,2,opt,name=relation,proto3,oneof"`
}

Jump to

Keyboard shortcuts

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