datalayer

package

Go to main page

Versions in this module

v1

v1.3.0

Apr 11, 2023

Changes in this version

+ const TimeoutSettingReconnect

v1.2.0

Dec 9, 2022

Changes in this version

+ func DeleteBulk(b *Bulk)

+ type Bulk struct

+ Response []Response

+ func (b *Bulk) Browse(addresses ...string) Result

+ func (b *Bulk) BrowseAsync(cb ResponseBulkCallback, addresses ...string) Result

+ func (b *Bulk) Create(args ...BulkCreateArg) Result

+ func (b *Bulk) CreateAsync(cb ResponseBulkCallback, args ...BulkCreateArg) Result

+ func (b *Bulk) Delete(addresses ...string) Result

+ func (b *Bulk) DeleteAsync(cb ResponseBulkCallback, addresses ...string) Result

+ func (b *Bulk) Metadata(addresses ...string) Result

+ func (b *Bulk) MetadataAsync(cb ResponseBulkCallback, addresses ...string) Result

+ func (b *Bulk) Read(args ...BulkReadArg) Result

+ func (b *Bulk) ReadAsync(cb ResponseBulkCallback, args ...BulkReadArg) Result

+ func (b *Bulk) Write(args ...BulkWriteArg) Result

+ func (b *Bulk) WriteAsync(cb ResponseBulkCallback, args ...BulkWriteArg) Result

+ type BulkCreateArg struct

+ Address string

+ Data *Variant

+ type BulkReadArg struct

+ Address string

+ Argument *Variant

+ type BulkWriteArg struct

+ Address string

+ Data *Variant

type Client

+ func (c *Client) CreateBulk() *Bulk

+ func (c *Client) ReadJsonSyncArgs(cv *Converter, address string, indentStep int, data []byte) (Result, []byte)

+ type Response struct

+ Address string

+ Data *Variant

+ Result Result

+ Time time.Time

+ type ResponseBulkCallback = func([]Response)

type Result

+ const ResultCommunicationError

+ const ResultMissingArgument

+ const ResultOkNoContent

+ const ResultPaymentRequired

+ const ResultResourceUnavailable

+ const ResultTooManyArguments

+ const ResultTooManyOperations

+ const ResultWouldBlock

v1.1.0

Jul 28, 2022

Changes in this version

+ var EnumNamesReferenceType = map[ReferenceType]string

+ type AllowedOperation uint

+ const AllowedOperationAll

+ const AllowedOperationBrowse

+ const AllowedOperationCreate

+ const AllowedOperationDelete

+ const AllowedOperationNone

+ const AllowedOperationRead

+ const AllowedOperationWrite

+ type MetaDataBuilder struct

+ func NewMetaDataBuilder(a AllowedOperation, desc string, descurl string) *MetaDataBuilder

+ func (m *MetaDataBuilder) AddExtension(key string, val string) *MetaDataBuilder

+ func (m *MetaDataBuilder) AddReference(r ReferenceType, t string) *MetaDataBuilder

+ func (m *MetaDataBuilder) Build() *Variant

+ func (m *MetaDataBuilder) DisplayFormat(df fbs.DisplayFormat) *MetaDataBuilder

+ func (m *MetaDataBuilder) DisplayName(n string) *MetaDataBuilder

+ func (m *MetaDataBuilder) NodeClass(nc fbs.NodeClass) *MetaDataBuilder

+ func (m *MetaDataBuilder) Operations(a AllowedOperation) *MetaDataBuilder

+ func (m *MetaDataBuilder) Unit(u string) *MetaDataBuilder

+ type ReferenceType uint8

+ const ReferenceTypeCreate

+ const ReferenceTypeHasSave

+ const ReferenceTypeRead

+ const ReferenceTypeReadIn

+ const ReferenceTypeReadOut

+ const ReferenceTypeUses

+ const ReferenceTypeWrite

+ const ReferenceTypeWriteIn

+ const ReferenceTypeWriteOut

type Variant

+ func (v *Variant) GetArrayTime() []time.Time

+ func (v *Variant) GetTime() time.Time

+ func (v *Variant) SetArrayTime(dfs []time.Time)

+ func (v *Variant) SetArrayTimestamp(data []uint64)

+ func (v *Variant) SetTime(df time.Time)

+ func (v *Variant) SetTimestamp(ft uint64)

type VariantType

+ const VariantTypeArrayTimestamp

+ const VariantTypeTimestamp

v1.0.1

Feb 17, 2022

Changes in this version

+ const TimeoutSettingIdle

+ const TimeoutSettingPing

+ func DeleteClient(c *Client)

+ func DeleteProvider(p *Provider)

+ func DeleteProviderNode(n *ProviderNode)

+ func DeleteSystem(d *System)

+ func DeleteVariant(v *Variant)

+ type Client struct

+ func (c *Client) Browse(address string) (Result, []string)

+ func (c *Client) BrowseAsync(address string, onResponse ResponseCallback) Result

+ func (c *Client) BrowseSync(address string) (Result, *Variant)

+ func (c *Client) CreateAsync(address string, data *Variant, onResponse ResponseCallback) Result

+ func (c *Client) CreateSubscription(id string, subscriptionProperties SubscriptionProperties, ...) (*Subscription, Result)

+ func (c *Client) CreateSync(address string, data *Variant) Result

+ func (c *Client) DeleteSubscription(subscription *Subscription)

+ func (c *Client) GetAuthToken() string

+ func (c *Client) IsConnected() bool

+ func (c *Client) Metadata(address string) (Result, *fbs.Metadata)

+ func (c *Client) MetadataAsync(address string, onResponse ResponseCallback) Result

+ func (c *Client) MetadataSync(address string) (Result, *Variant)

+ func (c *Client) PingAsync(onResponse ResponseCallback) Result

+ func (c *Client) PingSync() Result

+ func (c *Client) ReadAsync(address string, data *Variant, onResponse ResponseCallback) Result

+ func (c *Client) ReadJsonSync(cv *Converter, address string, indentStep int) (Result, []byte)

+ func (c *Client) ReadSync(address string) (Result, *Variant)

+ func (c *Client) ReadSyncArgs(address string, args *Variant) Result

+ func (c *Client) RemoveAsync(address string, onResponse ResponseCallback) Result

+ func (c *Client) RemoveSync(address string) Result

+ func (c *Client) SetAuthToken(token string)

+ func (c *Client) SetTimeout(timeout TimeoutSetting, value uint) Result

+ func (c *Client) WriteAsync(address string, data *Variant, onResponse ResponseCallback) Result

+ func (c *Client) WriteJsonSync(cv *Converter, address string, json []byte) (Result, error)

+ func (c *Client) WriteSync(address string, data *Variant) Result

+ type Converter struct

+ func (c *Converter) GenerateJsonComplex(data []byte, ty []byte, indentStep int) (Result, []byte)

+ func (c *Converter) GenerateJsonSimple(data *Variant, indentStep int) (Result, []byte)

+ func (c *Converter) GetSchema(schema Schema) (Result, []byte)

+ func (c *Converter) ParseJsonComplex(json []byte, ty []byte) (Result, []byte, error)

+ func (c *Converter) ParseJsonSimple(json []byte) (Result, *Variant, error)

+ type Factory struct

+ func (f *Factory) CreateClient(remote string) *Client

+ func (f *Factory) CreateProvider(remote string) *Provider

+ type NotifyItem struct

+ Data Variant

+ Info Variant

+ type OnSubscription func(result Result, items map[string]Variant)

+ type Provider struct

+ func (p *Provider) GetToken() *Variant

+ func (p *Provider) IsConnected() bool

+ func (p *Provider) RegisterNode(address string, node *ProviderNode) Result

+ func (p *Provider) RegisterType(address string, pathname string) Result

+ func (p *Provider) RegisterTypeVariant(address string, data *Variant) Result

+ func (p *Provider) SetTimeoutNode(node *ProviderNode, timeoutMS uint) Result

+ func (p *Provider) Start() Result

+ func (p *Provider) Stop() Result

+ func (p *Provider) UnregisterNode(address string) Result

+ func (p *Provider) UnregisterType(address string) Result

+ type ProviderNode struct

+ func NewProviderNode() *ProviderNode

+ func (n *ProviderNode) Channels() *ProviderNodeChannels

+ type ProviderNodeCallback = func(result Result, data *Variant)

+ type ProviderNodeChannels struct

+ Done chan bool

+ OnBrowse chan ProviderNodeEvent

+ OnCreate chan ProviderNodeEventData

+ OnMetadata chan ProviderNodeEvent

+ OnRead chan ProviderNodeEventData

+ OnRemove chan ProviderNodeEvent

+ OnWrite chan ProviderNodeEventData

+ type ProviderNodeEvent struct

+ Address string

+ Callback ProviderNodeCallback

+ type ProviderNodeEventData struct

+ Address string

+ Callback ProviderNodeCallback

+ Data *Variant

+ type ResponseCallback = func(result Result, v *Variant)

+ type Result C.DLR_RESULT

+ const ResultAlreadyExists

+ const ResultClientNotConnected

+ const ResultCommInvalidHeader

+ const ResultCommProtocolError

+ const ResultCreationFailed

+ const ResultDeprecated

+ const ResultFailed

+ const ResultInvalidAddress

+ const ResultInvalidConfiguration

+ const ResultInvalidFloatingpoint

+ const ResultInvalidHandle

+ const ResultInvalidOperationMode

+ const ResultInvalidValue

+ const ResultLimitMax

+ const ResultLimitMin

+ const ResultNotInitialized

+ const ResultOk

+ const ResultOutOfMemory

+ const ResultPermissionDenied

+ const ResultRtInternalError

+ const ResultRtInvalidRetain

+ const ResultRtInvalidmemorymap

+ const ResultRtInvalidobject

+ const ResultRtMemorylocked

+ const ResultRtNotopen

+ const ResultRtNovaliddata

+ const ResultRtWrongrevison

+ const ResultSecInvalidsession

+ const ResultSecInvalidtokencontent

+ const ResultSecNotoken

+ const ResultSecUnauthorized

+ const ResultSizeMismatch

+ const ResultSubmoduleFailure

+ const ResultTimeout

+ const ResultTypeMismatch

+ const ResultUnsupported

+ const ResultVersionMismatch

+ func (r Result) String() string

+ type Schema C.enum_DLR_SCHEMA

+ const SchemaDiagnosis

+ const SchemaMemory

+ const SchemaMemoryMap

+ const SchemaMetadata

+ const SchemaProblem

+ const SchemaReflection

+ const SchemaToken

+ type Subscription struct

+ func (s *Subscription) Addresses() []string

+ func (s *Subscription) Id() string

+ func (s *Subscription) Subscribe(addresses ...string) Result

+ func (s *Subscription) Unsubscribe(addresses ...string) Result

+ type SubscriptionProperties struct

+ BrowseListChange bool

+ CountingSubscriptions bool

+ DataChangeTrigger fbs.DataChangeTrigger

+ DeadBandValue float32

+ ErrorInterval uint32

+ Id string

+ KeepaliveInterval uint32

+ MetaDataChange bool

+ PublishInterval uint32

+ QueueBehaviour fbs.QueueBehaviour

+ QueueSize uint32

+ SamplingInterval uint64

+ func DefaultSubscriptionProperties() SubscriptionProperties

+ func (s SubscriptionProperties) BuildJson() ([]byte, error)

+ type System struct

+ func NewSystem(ipcPath string) *System

+ func (d *System) Factory() *Factory

+ func (d *System) JSONConverter() *Converter

+ func (d *System) SetBfbsPath(path string)

+ func (d *System) Start(boStartBroker bool)

+ func (d *System) Stop(boForceProviderStop bool)

+ type TimeoutSetting C.enum_DLR_TIMEOUT_SETTING

+ type Variant struct

+ func NewVariant() *Variant

+ func (v *Variant) CheckConvert(ty VariantType) Result

+ func (v *Variant) Copy(dest *Variant) Result

+ func (v *Variant) GetArrayBool8() []bool

+ func (v *Variant) GetArrayFloat32() []float32

+ func (v *Variant) GetArrayFloat64() []float64

+ func (v *Variant) GetArrayInt16() []int16

+ func (v *Variant) GetArrayInt32() []int32

+ func (v *Variant) GetArrayInt64() []int64

+ func (v *Variant) GetArrayInt8() []int8

+ func (v *Variant) GetArrayString() []string

+ func (v *Variant) GetArrayUint16() []uint16

+ func (v *Variant) GetArrayUint32() []uint32

+ func (v *Variant) GetArrayUint64() []uint64

+ func (v *Variant) GetArrayUint8() []uint8

+ func (v *Variant) GetBool8() bool

+ func (v *Variant) GetCount() uint64

+ func (v *Variant) GetData() unsafe.Pointer

+ func (v *Variant) GetFlatbuffers() []byte

+ func (v *Variant) GetFloat32() float32

+ func (v *Variant) GetFloat64() float64

+ func (v *Variant) GetInt16() int16

+ func (v *Variant) GetInt32() int32

+ func (v *Variant) GetInt64() int64

+ func (v *Variant) GetInt8() int8

+ func (v *Variant) GetSize() uint64

+ func (v *Variant) GetString() string

+ func (v *Variant) GetType() VariantType

+ func (v *Variant) GetUint16() uint16

+ func (v *Variant) GetUint32() uint32

+ func (v *Variant) GetUint64() uint64

+ func (v *Variant) GetUint8() uint8

+ func (v *Variant) SetArrayBool8(data []bool)

+ func (v *Variant) SetArrayFloat32(data []float32)

+ func (v *Variant) SetArrayFloat64(data []float64)

+ func (v *Variant) SetArrayInt16(data []int16)

+ func (v *Variant) SetArrayInt32(data []int32)

+ func (v *Variant) SetArrayInt64(data []int64)

+ func (v *Variant) SetArrayInt8(data []int8)

+ func (v *Variant) SetArrayString(data []string)

+ func (v *Variant) SetArrayUint16(data []uint16)

+ func (v *Variant) SetArrayUint32(data []uint32)

+ func (v *Variant) SetArrayUint64(data []uint64)

+ func (v *Variant) SetArrayUint8(data []uint8)

+ func (v *Variant) SetBool8(data bool)

+ func (v *Variant) SetFlatbuffers(data []byte)

+ func (v *Variant) SetFloat32(data float32)

+ func (v *Variant) SetFloat64(data float64)

+ func (v *Variant) SetInt16(data int16)

+ func (v *Variant) SetInt32(data int32)

+ func (v *Variant) SetInt64(data int64)

+ func (v *Variant) SetInt8(data int8)

+ func (v *Variant) SetString(data string)

+ func (v *Variant) SetUint16(data uint16)

+ func (v *Variant) SetUint32(data uint32)

+ func (v *Variant) SetUint64(data uint64)

+ func (v *Variant) SetUint8(data uint8)

+ type VariantType C.enum_DLR_VARIANT_TYPE

+ const VariantTypeArrayBool8

+ const VariantTypeArrayFloat32

+ const VariantTypeArrayFloat64

+ const VariantTypeArrayInt16

+ const VariantTypeArrayInt32

+ const VariantTypeArrayInt64

+ const VariantTypeArrayInt8

+ const VariantTypeArrayString

+ const VariantTypeArrayUint16

+ const VariantTypeArrayUint32

+ const VariantTypeArrayUint64

+ const VariantTypeArrayUint8

+ const VariantTypeBool8

+ const VariantTypeFlatbuffers

+ const VariantTypeFloat32

+ const VariantTypeFloat64

+ const VariantTypeInt16

+ const VariantTypeInt32

+ const VariantTypeInt64

+ const VariantTypeInt8

+ const VariantTypeRaw

+ const VariantTypeString

+ const VariantTypeUint16

+ const VariantTypeUint32

+ const VariantTypeUint64

+ const VariantTypeUint8

+ const VariantTypeUnknown

v0

v0.1.0-develop

Feb 26, 2021

Other modules containing this package

github.com/boschrexroth/ctrlx-datalayer-golang/v2

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