model

package
v0.0.0-...-f857062 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDefaultPlcBrowseItem 

func NewDefaultPlcBrowseItem(Tag apiModel.PlcTag, Name string, DataTypeName string, Readable bool, Writable bool, Subscribable bool, Children map[string]apiModel.PlcBrowseItem, Options map[string]apiValues.PlcValue) apiModel.PlcBrowseItem

func NewDefaultPlcBrowseRequestBuilder 

func NewDefaultPlcBrowseRequestBuilder(tagHandler spi.PlcTagHandler, browser spi.PlcBrowser) apiModel.PlcBrowseRequestBuilder

func NewDefaultPlcBrowseRequestResult 

func NewDefaultPlcBrowseRequestResult(Request apiModel.PlcBrowseRequest, Response apiModel.PlcBrowseResponse, Err error) apiModel.PlcBrowseRequestResult

func NewDefaultPlcBrowseResponse 

func NewDefaultPlcBrowseResponse(request apiModel.PlcBrowseRequest, results map[string][]apiModel.PlcBrowseItem, responseCodes map[string]apiModel.PlcResponseCode) apiModel.PlcBrowseResponse

func NewDefaultPlcConsumerRegistration 

func NewDefaultPlcConsumerRegistration(plcSubscriber spi.PlcSubscriber, consumer apiModel.PlcSubscriptionEventConsumer, handles ...apiModel.PlcSubscriptionHandle) apiModel.PlcConsumerRegistration

func NewDefaultPlcDiscoveryItem 

func NewDefaultPlcDiscoveryItem(
	ProtocolCode string,
	TransportCode string,
	TransportUrl url.URL,
	Options map[string][]string,
	Name string,
	Attributes map[string]apiValues.PlcValue,
) apiModel.PlcDiscoveryItem

func NewDefaultPlcReadRequest 

func NewDefaultPlcReadRequest(
	tags map[string]apiModel.PlcTag,
	tagNames []string,
	reader spi.PlcReader,
	readRequestInterceptor interceptors.ReadRequestInterceptor,
) apiModel.PlcReadRequest

func NewDefaultPlcReadRequestBuilder 

func NewDefaultPlcReadRequestBuilder(tagHandler spi.PlcTagHandler, reader spi.PlcReader) apiModel.PlcReadRequestBuilder

func NewDefaultPlcReadRequestBuilderWithInterceptor 

func NewDefaultPlcReadRequestBuilderWithInterceptor(tagHandler spi.PlcTagHandler, reader spi.PlcReader, readRequestInterceptor interceptors.ReadRequestInterceptor) apiModel.PlcReadRequestBuilder

func NewDefaultPlcReadRequestResult 

func NewDefaultPlcReadRequestResult(Request apiModel.PlcReadRequest, Response apiModel.PlcReadResponse, Err error) apiModel.PlcReadRequestResult

func NewDefaultPlcReadResponse 

func NewDefaultPlcReadResponse(request apiModel.PlcReadRequest, responseCodes map[string]apiModel.PlcResponseCode, values map[string]apiValues.PlcValue) apiModel.PlcReadResponse

func NewDefaultPlcSubscriptionEvent 

func NewDefaultPlcSubscriptionEvent(
	defaultPlcSubscriptionEventRequirements DefaultPlcSubscriptionEventRequirements,
	tags map[string]apiModel.PlcTag,
	types map[string]apiModel.PlcSubscriptionType,
	intervals map[string]time.Duration,
	responseCodes map[string]apiModel.PlcResponseCode,
	values map[string]apiValues.PlcValue,
	_options ...options.WithOption,
) apiModel.PlcSubscriptionEvent

func NewDefaultPlcSubscriptionHandle 

func NewDefaultPlcSubscriptionHandle(plcSubscriber spi.PlcSubscriber) apiModel.PlcSubscriptionHandle

NewDefaultPlcSubscriptionHandle can be used when the DefaultPlcSubscriptionHandle is sufficient

func NewDefaultPlcSubscriptionRequest 

func NewDefaultPlcSubscriptionRequest(subscriber spi.PlcSubscriber, tagNames []string, tags map[string]apiModel.PlcSubscriptionTag, types map[string]apiModel.PlcSubscriptionType, intervals map[string]time.Duration, preRegisteredConsumers map[string][]apiModel.PlcSubscriptionEventConsumer) apiModel.PlcSubscriptionRequest

func NewDefaultPlcSubscriptionRequestBuilder 

func NewDefaultPlcSubscriptionRequestBuilder(tagHandler spi.PlcTagHandler, valueHandler spi.PlcValueHandler, subscriber spi.PlcSubscriber) apiModel.PlcSubscriptionRequestBuilder

func NewDefaultPlcSubscriptionRequestResult 

func NewDefaultPlcSubscriptionRequestResult(Request apiModel.PlcSubscriptionRequest, Response apiModel.PlcSubscriptionResponse, Err error) apiModel.PlcSubscriptionRequestResult

func NewDefaultPlcSubscriptionResponse 

func NewDefaultPlcSubscriptionResponse(
	request apiModel.PlcSubscriptionRequest,
	responseCodes map[string]apiModel.PlcResponseCode,
	values map[string]apiModel.PlcSubscriptionHandle,
	_options ...options.WithOption,
) apiModel.PlcSubscriptionResponse

func NewDefaultPlcUnsubscriptionRequestResult 

func NewDefaultPlcUnsubscriptionRequestResult(
	Request apiModel.PlcUnsubscriptionRequest,
	Response apiModel.PlcUnsubscriptionResponse,
	Err error,
) apiModel.PlcUnsubscriptionRequestResult

func NewDefaultPlcWriteRequest 

func NewDefaultPlcWriteRequest(tags map[string]apiModel.PlcTag, tagNames []string, values map[string]apiValues.PlcValue, writer spi.PlcWriter, writeRequestInterceptor interceptors.WriteRequestInterceptor) apiModel.PlcWriteRequest

func NewDefaultPlcWriteRequestBuilder 

func NewDefaultPlcWriteRequestBuilder(tagHandler spi.PlcTagHandler, valueHandler spi.PlcValueHandler, writer spi.PlcWriter) apiModel.PlcWriteRequestBuilder

func NewDefaultPlcWriteRequestBuilderWithInterceptor 

func NewDefaultPlcWriteRequestBuilderWithInterceptor(tagHandler spi.PlcTagHandler, valueHandler spi.PlcValueHandler, writer spi.PlcWriter, writeRequestInterceptor interceptors.WriteRequestInterceptor) apiModel.PlcWriteRequestBuilder

func NewDefaultPlcWriteRequestResult 

func NewDefaultPlcWriteRequestResult(Request apiModel.PlcWriteRequest, Response apiModel.PlcWriteResponse, Err error) apiModel.PlcWriteRequestResult

func NewDefaultPlcWriteResponse 

func NewDefaultPlcWriteResponse(request apiModel.PlcWriteRequest, responseCodes map[string]apiModel.PlcResponseCode) apiModel.PlcWriteResponse

Types

type DefaultArrayInfo 

type DefaultArrayInfo struct {
	LowerBound uint32
	UpperBound uint32
}

func (*DefaultArrayInfo) GetLowerBound 

func (t *DefaultArrayInfo) GetLowerBound() uint32

func (*DefaultArrayInfo) GetSize 

func (t *DefaultArrayInfo) GetSize() uint32

func (*DefaultArrayInfo) GetUpperBound 

func (t *DefaultArrayInfo) GetUpperBound() uint32

func (*DefaultArrayInfo) Serialize 

func (d *DefaultArrayInfo) Serialize() ([]byte, error)

func (*DefaultArrayInfo) SerializeWithWriteBuffer 

func (d *DefaultArrayInfo) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultArrayInfo) String 

func (d *DefaultArrayInfo) String() string

type DefaultPlcBrowseItem 

type DefaultPlcBrowseItem struct {
	Tag          apiModel.PlcTag
	Name         string
	DataTypeName string
	Readable     bool
	Writable     bool
	Subscribable bool
	Children     map[string]apiModel.PlcBrowseItem
	Options      map[string]apiValues.PlcValue
}

func (*DefaultPlcBrowseItem) GetChildren 

func (d *DefaultPlcBrowseItem) GetChildren() map[string]apiModel.PlcBrowseItem

func (*DefaultPlcBrowseItem) GetDataTypeName 

func (d *DefaultPlcBrowseItem) GetDataTypeName() string

func (*DefaultPlcBrowseItem) GetName 

func (d *DefaultPlcBrowseItem) GetName() string

func (*DefaultPlcBrowseItem) GetOptions 

func (d *DefaultPlcBrowseItem) GetOptions() map[string]apiValues.PlcValue

func (*DefaultPlcBrowseItem) GetTag 

func (d *DefaultPlcBrowseItem) GetTag() apiModel.PlcTag

func (*DefaultPlcBrowseItem) IsReadable 

func (d *DefaultPlcBrowseItem) IsReadable() bool

func (*DefaultPlcBrowseItem) IsSubscribable 

func (d *DefaultPlcBrowseItem) IsSubscribable() bool

func (*DefaultPlcBrowseItem) IsWritable 

func (d *DefaultPlcBrowseItem) IsWritable() bool

func (*DefaultPlcBrowseItem) Serialize 

func (d *DefaultPlcBrowseItem) Serialize() ([]byte, error)

func (*DefaultPlcBrowseItem) SerializeWithWriteBuffer 

func (d *DefaultPlcBrowseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcBrowseItem) String 

func (d *DefaultPlcBrowseItem) String() string

type DefaultPlcBrowseRequest 

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

func NewDefaultPlcBrowseRequest 

func NewDefaultPlcBrowseRequest(queries map[string]apiModel.PlcQuery, queryNames []string, browser spi.PlcBrowser) *DefaultPlcBrowseRequest

func (*DefaultPlcBrowseRequest) Execute 

func (d *DefaultPlcBrowseRequest) Execute() <-chan apiModel.PlcBrowseRequestResult

func (*DefaultPlcBrowseRequest) ExecuteWithContext 

func (d *DefaultPlcBrowseRequest) ExecuteWithContext(ctx context.Context) <-chan apiModel.PlcBrowseRequestResult

func (*DefaultPlcBrowseRequest) ExecuteWithInterceptor 

func (d *DefaultPlcBrowseRequest) ExecuteWithInterceptor(interceptor func(result apiModel.PlcBrowseItem) bool) <-chan apiModel.PlcBrowseRequestResult

func (*DefaultPlcBrowseRequest) ExecuteWithInterceptorWithContext 

func (d *DefaultPlcBrowseRequest) ExecuteWithInterceptorWithContext(ctx context.Context, interceptor func(result apiModel.PlcBrowseItem) bool) <-chan apiModel.PlcBrowseRequestResult

func (*DefaultPlcBrowseRequest) GetQuery 

func (d *DefaultPlcBrowseRequest) GetQuery(queryName string) apiModel.PlcQuery

func (*DefaultPlcBrowseRequest) GetQueryNames 

func (d *DefaultPlcBrowseRequest) GetQueryNames() []string

func (*DefaultPlcBrowseRequest) IsAPlcMessage 

func (d *DefaultPlcBrowseRequest) IsAPlcMessage() bool

func (*DefaultPlcBrowseRequest) Serialize 

func (d *DefaultPlcBrowseRequest) Serialize() ([]byte, error)

func (*DefaultPlcBrowseRequest) SerializeWithWriteBuffer 

func (d *DefaultPlcBrowseRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcBrowseRequest) String 

func (d *DefaultPlcBrowseRequest) String() string

type DefaultPlcBrowseRequestBuilder 

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

func (*DefaultPlcBrowseRequestBuilder) AddQuery 

func (d *DefaultPlcBrowseRequestBuilder) AddQuery(name string, query string) apiModel.PlcBrowseRequestBuilder

func (*DefaultPlcBrowseRequestBuilder) Build 

func (d *DefaultPlcBrowseRequestBuilder) Build() (apiModel.PlcBrowseRequest, error)

func (*DefaultPlcBrowseRequestBuilder) Serialize 

func (d *DefaultPlcBrowseRequestBuilder) Serialize() ([]byte, error)

func (*DefaultPlcBrowseRequestBuilder) SerializeWithWriteBuffer 

func (d *DefaultPlcBrowseRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcBrowseRequestBuilder) String 

func (d *DefaultPlcBrowseRequestBuilder) String() string

type DefaultPlcBrowseRequestResult 

type DefaultPlcBrowseRequestResult struct {
	Request  apiModel.PlcBrowseRequest
	Response apiModel.PlcBrowseResponse
	Err      error
}

func (*DefaultPlcBrowseRequestResult) GetErr 

func (d *DefaultPlcBrowseRequestResult) GetErr() error

func (*DefaultPlcBrowseRequestResult) GetRequest 

func (d *DefaultPlcBrowseRequestResult) GetRequest() apiModel.PlcBrowseRequest

func (*DefaultPlcBrowseRequestResult) GetResponse 

func (d *DefaultPlcBrowseRequestResult) GetResponse() apiModel.PlcBrowseResponse

func (*DefaultPlcBrowseRequestResult) Serialize 

func (d *DefaultPlcBrowseRequestResult) Serialize() ([]byte, error)

func (*DefaultPlcBrowseRequestResult) SerializeWithWriteBuffer 

func (d *DefaultPlcBrowseRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcBrowseRequestResult) String 

func (d *DefaultPlcBrowseRequestResult) String() string

type DefaultPlcBrowseResponse 

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

func (*DefaultPlcBrowseResponse) GetQueryNames 

func (d *DefaultPlcBrowseResponse) GetQueryNames() []string

func (*DefaultPlcBrowseResponse) GetQueryResults 

func (d *DefaultPlcBrowseResponse) GetQueryResults(queryName string) []apiModel.PlcBrowseItem

func (*DefaultPlcBrowseResponse) GetRequest 

func (d *DefaultPlcBrowseResponse) GetRequest() apiModel.PlcBrowseRequest

func (*DefaultPlcBrowseResponse) GetResponseCode 

func (d *DefaultPlcBrowseResponse) GetResponseCode(name string) apiModel.PlcResponseCode

func (*DefaultPlcBrowseResponse) IsAPlcMessage 

func (d *DefaultPlcBrowseResponse) IsAPlcMessage() bool

func (*DefaultPlcBrowseResponse) Serialize 

func (d *DefaultPlcBrowseResponse) Serialize() ([]byte, error)

func (*DefaultPlcBrowseResponse) SerializeWithWriteBuffer 

func (d *DefaultPlcBrowseResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcBrowseResponse) String 

func (d *DefaultPlcBrowseResponse) String() string

type DefaultPlcBrowseResponseItem 

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

func NewDefaultPlcBrowseResponseItem 

func NewDefaultPlcBrowseResponseItem(code apiModel.PlcResponseCode, results []apiModel.PlcBrowseItem) *DefaultPlcBrowseResponseItem

func (*DefaultPlcBrowseResponseItem) GetCode 

func (d *DefaultPlcBrowseResponseItem) GetCode() apiModel.PlcResponseCode

func (*DefaultPlcBrowseResponseItem) GetResults 

func (d *DefaultPlcBrowseResponseItem) GetResults() []apiModel.PlcBrowseItem

func (*DefaultPlcBrowseResponseItem) Serialize 

func (d *DefaultPlcBrowseResponseItem) Serialize() ([]byte, error)

func (*DefaultPlcBrowseResponseItem) SerializeWithWriteBuffer 

func (d *DefaultPlcBrowseResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcBrowseResponseItem) String 

func (d *DefaultPlcBrowseResponseItem) String() string

type DefaultPlcConsumerRegistration 

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

func (*DefaultPlcConsumerRegistration) GetConsumerId 

func (d *DefaultPlcConsumerRegistration) GetConsumerId() int

func (*DefaultPlcConsumerRegistration) GetSubscriptionHandles 

func (d *DefaultPlcConsumerRegistration) GetSubscriptionHandles() []apiModel.PlcSubscriptionHandle

func (*DefaultPlcConsumerRegistration) Serialize 

func (d *DefaultPlcConsumerRegistration) Serialize() ([]byte, error)

func (*DefaultPlcConsumerRegistration) SerializeWithWriteBuffer 

func (d *DefaultPlcConsumerRegistration) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcConsumerRegistration) String 

func (d *DefaultPlcConsumerRegistration) String() string

func (*DefaultPlcConsumerRegistration) Unregister 

func (d *DefaultPlcConsumerRegistration) Unregister()

type DefaultPlcDiscoveryItem 

type DefaultPlcDiscoveryItem struct {
	ProtocolCode  string
	TransportCode string
	TransportUrl  url.URL `ignore:"true"` // TODO: find a way to render this as string (e.g. stringer annotation or something)
	Options       map[string][]string
	Name          string
	Attributes    map[string]apiValues.PlcValue
}

func (*DefaultPlcDiscoveryItem) GetAttributes 

func (d *DefaultPlcDiscoveryItem) GetAttributes() map[string]apiValues.PlcValue

func (*DefaultPlcDiscoveryItem) GetConnectionUrl 

func (d *DefaultPlcDiscoveryItem) GetConnectionUrl() string

func (*DefaultPlcDiscoveryItem) GetName 

func (d *DefaultPlcDiscoveryItem) GetName() string

func (*DefaultPlcDiscoveryItem) GetOptions 

func (d *DefaultPlcDiscoveryItem) GetOptions() map[string][]string

func (*DefaultPlcDiscoveryItem) GetProtocolCode 

func (d *DefaultPlcDiscoveryItem) GetProtocolCode() string

func (*DefaultPlcDiscoveryItem) GetTransportCode 

func (d *DefaultPlcDiscoveryItem) GetTransportCode() string

func (*DefaultPlcDiscoveryItem) GetTransportUrl 

func (d *DefaultPlcDiscoveryItem) GetTransportUrl() url.URL

func (*DefaultPlcDiscoveryItem) Serialize 

func (d *DefaultPlcDiscoveryItem) Serialize() ([]byte, error)

func (*DefaultPlcDiscoveryItem) SerializeWithWriteBuffer 

func (d *DefaultPlcDiscoveryItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcDiscoveryItem) String 

func (d *DefaultPlcDiscoveryItem) String() string

type DefaultPlcReadRequest 

type DefaultPlcReadRequest struct {
	*DefaultPlcTagRequest
	// contains filtered or unexported fields
}

func (*DefaultPlcReadRequest) Execute 

func (d *DefaultPlcReadRequest) Execute() <-chan apiModel.PlcReadRequestResult

func (*DefaultPlcReadRequest) ExecuteWithContext 

func (d *DefaultPlcReadRequest) ExecuteWithContext(ctx context.Context) <-chan apiModel.PlcReadRequestResult

func (*DefaultPlcReadRequest) ExecuteWithContextAndInterceptor 

func (d *DefaultPlcReadRequest) ExecuteWithContextAndInterceptor(ctx context.Context) <-chan apiModel.PlcReadRequestResult

func (*DefaultPlcReadRequest) GetReadRequestInterceptor 

func (d *DefaultPlcReadRequest) GetReadRequestInterceptor() interceptors.ReadRequestInterceptor

func (*DefaultPlcReadRequest) GetReader 

func (d *DefaultPlcReadRequest) GetReader() spi.PlcReader

func (*DefaultPlcReadRequest) Serialize 

func (d *DefaultPlcReadRequest) Serialize() ([]byte, error)

func (*DefaultPlcReadRequest) SerializeWithWriteBuffer 

func (d *DefaultPlcReadRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcReadRequest) String 

func (d *DefaultPlcReadRequest) String() string

type DefaultPlcReadRequestBuilder 

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

func (*DefaultPlcReadRequestBuilder) AddTag 

func (d *DefaultPlcReadRequestBuilder) AddTag(name string, tag apiModel.PlcTag) apiModel.PlcReadRequestBuilder

func (*DefaultPlcReadRequestBuilder) AddTagAddress 

func (d *DefaultPlcReadRequestBuilder) AddTagAddress(name string, query string) apiModel.PlcReadRequestBuilder

func (*DefaultPlcReadRequestBuilder) Build 

func (d *DefaultPlcReadRequestBuilder) Build() (apiModel.PlcReadRequest, error)

func (*DefaultPlcReadRequestBuilder) Serialize 

func (d *DefaultPlcReadRequestBuilder) Serialize() ([]byte, error)

func (*DefaultPlcReadRequestBuilder) SerializeWithWriteBuffer 

func (d *DefaultPlcReadRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcReadRequestBuilder) String 

func (d *DefaultPlcReadRequestBuilder) String() string

type DefaultPlcReadRequestResult 

type DefaultPlcReadRequestResult struct {
	Request  apiModel.PlcReadRequest
	Response apiModel.PlcReadResponse
	Err      error
}

func (*DefaultPlcReadRequestResult) GetErr 

func (d *DefaultPlcReadRequestResult) GetErr() error

func (*DefaultPlcReadRequestResult) GetRequest 

func (d *DefaultPlcReadRequestResult) GetRequest() apiModel.PlcReadRequest

func (*DefaultPlcReadRequestResult) GetResponse 

func (d *DefaultPlcReadRequestResult) GetResponse() apiModel.PlcReadResponse

func (*DefaultPlcReadRequestResult) Serialize 

func (d *DefaultPlcReadRequestResult) Serialize() ([]byte, error)

func (*DefaultPlcReadRequestResult) SerializeWithWriteBuffer 

func (d *DefaultPlcReadRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcReadRequestResult) String 

func (d *DefaultPlcReadRequestResult) String() string

type DefaultPlcReadResponse 

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

func (*DefaultPlcReadResponse) GetRequest 

func (d *DefaultPlcReadResponse) GetRequest() apiModel.PlcReadRequest

func (*DefaultPlcReadResponse) GetResponseCode 

func (d *DefaultPlcReadResponse) GetResponseCode(name string) apiModel.PlcResponseCode

func (*DefaultPlcReadResponse) GetTagNames 

func (d *DefaultPlcReadResponse) GetTagNames() []string

func (*DefaultPlcReadResponse) GetValue 

func (d *DefaultPlcReadResponse) GetValue(name string) apiValues.PlcValue

func (*DefaultPlcReadResponse) IsAPlcMessage 

func (d *DefaultPlcReadResponse) IsAPlcMessage() bool

func (*DefaultPlcReadResponse) Serialize 

func (d *DefaultPlcReadResponse) Serialize() ([]byte, error)

func (*DefaultPlcReadResponse) SerializeWithWriteBuffer 

func (d *DefaultPlcReadResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcReadResponse) String 

func (d *DefaultPlcReadResponse) String() string

type DefaultPlcSubscriptionEvent 

type DefaultPlcSubscriptionEvent struct {
	DefaultPlcSubscriptionEventRequirements `ignore:"true"` // Avoid recursion
	// contains filtered or unexported fields
}

func (*DefaultPlcSubscriptionEvent) GetAddress 

func (d *DefaultPlcSubscriptionEvent) GetAddress(name string) string

func (*DefaultPlcSubscriptionEvent) GetInterval 

func (d *DefaultPlcSubscriptionEvent) GetInterval(name string) time.Duration

func (*DefaultPlcSubscriptionEvent) GetResponseCode 

func (d *DefaultPlcSubscriptionEvent) GetResponseCode(name string) apiModel.PlcResponseCode

func (*DefaultPlcSubscriptionEvent) GetSource 

func (d *DefaultPlcSubscriptionEvent) GetSource(name string) string

func (*DefaultPlcSubscriptionEvent) GetTag 

func (d *DefaultPlcSubscriptionEvent) GetTag(name string) apiModel.PlcTag

func (*DefaultPlcSubscriptionEvent) GetTagNames 

func (d *DefaultPlcSubscriptionEvent) GetTagNames() []string

func (*DefaultPlcSubscriptionEvent) GetType 

func (d *DefaultPlcSubscriptionEvent) GetType(name string) apiModel.PlcSubscriptionType

func (*DefaultPlcSubscriptionEvent) GetValue 

func (d *DefaultPlcSubscriptionEvent) GetValue(name string) apiValues.PlcValue

func (*DefaultPlcSubscriptionEvent) IsAPlcMessage 

func (d *DefaultPlcSubscriptionEvent) IsAPlcMessage() bool

func (*DefaultPlcSubscriptionEvent) Serialize 

func (d *DefaultPlcSubscriptionEvent) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionEvent) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionEvent) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionEvent) String 

func (d *DefaultPlcSubscriptionEvent) String() string

type DefaultPlcSubscriptionEventItem 

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

func NewDefaultPlcSubscriptionEventItem 

func NewDefaultPlcSubscriptionEventItem(code apiModel.PlcResponseCode, tag apiModel.PlcTag, subscriptionType apiModel.PlcSubscriptionType, interval time.Duration, value apiValues.PlcValue) *DefaultPlcSubscriptionEventItem

func (*DefaultPlcSubscriptionEventItem) GetCode 

func (d *DefaultPlcSubscriptionEventItem) GetCode() apiModel.PlcResponseCode

func (*DefaultPlcSubscriptionEventItem) GetInterval 

func (d *DefaultPlcSubscriptionEventItem) GetInterval() time.Duration

func (*DefaultPlcSubscriptionEventItem) GetSubscriptionType 

func (d *DefaultPlcSubscriptionEventItem) GetSubscriptionType() apiModel.PlcSubscriptionType

func (*DefaultPlcSubscriptionEventItem) GetTag 

func (d *DefaultPlcSubscriptionEventItem) GetTag() apiModel.PlcTag

func (*DefaultPlcSubscriptionEventItem) GetValue 

func (d *DefaultPlcSubscriptionEventItem) GetValue() apiValues.PlcValue

func (*DefaultPlcSubscriptionEventItem) Serialize 

func (d *DefaultPlcSubscriptionEventItem) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionEventItem) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionEventItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionEventItem) String 

func (d *DefaultPlcSubscriptionEventItem) String() string

type DefaultPlcSubscriptionEventRequirements 

type DefaultPlcSubscriptionEventRequirements interface {
	utils.Serializable
	GetAddress(name string) string
}

type DefaultPlcSubscriptionHandle 

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

func NewDefaultPlcSubscriptionHandleWithHandleToRegister 

func NewDefaultPlcSubscriptionHandleWithHandleToRegister(plcSubscriber spi.PlcSubscriber, handleToRegister apiModel.PlcSubscriptionHandle) *DefaultPlcSubscriptionHandle

NewDefaultPlcSubscriptionHandleWithHandleToRegister should be used when an extension of DefaultPlcSubscriptionHandle is used

func (*DefaultPlcSubscriptionHandle) Register 

func (d *DefaultPlcSubscriptionHandle) Register(consumer apiModel.PlcSubscriptionEventConsumer) apiModel.PlcConsumerRegistration

Register registers at the spi.PlcSubscriber

func (*DefaultPlcSubscriptionHandle) Serialize 

func (d *DefaultPlcSubscriptionHandle) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionHandle) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionHandle) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionHandle) String 

func (d *DefaultPlcSubscriptionHandle) String() string

type DefaultPlcSubscriptionRequest 

type DefaultPlcSubscriptionRequest struct {
	*DefaultPlcTagRequest
	// contains filtered or unexported fields
}

func (*DefaultPlcSubscriptionRequest) Execute 

func (d *DefaultPlcSubscriptionRequest) Execute() <-chan apiModel.PlcSubscriptionRequestResult

func (*DefaultPlcSubscriptionRequest) ExecuteWithContext 

func (d *DefaultPlcSubscriptionRequest) ExecuteWithContext(ctx context.Context) <-chan apiModel.PlcSubscriptionRequestResult

func (*DefaultPlcSubscriptionRequest) GetInterval 

func (d *DefaultPlcSubscriptionRequest) GetInterval(name string) time.Duration

func (*DefaultPlcSubscriptionRequest) GetPreRegisteredConsumers 

func (d *DefaultPlcSubscriptionRequest) GetPreRegisteredConsumers(name string) []apiModel.PlcSubscriptionEventConsumer

func (*DefaultPlcSubscriptionRequest) GetTag 

func (d *DefaultPlcSubscriptionRequest) GetTag(name string) apiModel.PlcSubscriptionTag

func (*DefaultPlcSubscriptionRequest) GetType 

func (d *DefaultPlcSubscriptionRequest) GetType(name string) apiModel.PlcSubscriptionType

func (*DefaultPlcSubscriptionRequest) Serialize 

func (d *DefaultPlcSubscriptionRequest) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionRequest) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionRequest) String 

func (d *DefaultPlcSubscriptionRequest) String() string

type DefaultPlcSubscriptionRequestBuilder 

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

func (*DefaultPlcSubscriptionRequestBuilder) AddChangeOfStateTag 

func (d *DefaultPlcSubscriptionRequestBuilder) AddChangeOfStateTag(name string, tag apiModel.PlcSubscriptionTag) apiModel.PlcSubscriptionRequestBuilder

func (*DefaultPlcSubscriptionRequestBuilder) AddChangeOfStateTagAddress 

func (d *DefaultPlcSubscriptionRequestBuilder) AddChangeOfStateTagAddress(name string, tagAddress string) apiModel.PlcSubscriptionRequestBuilder

func (*DefaultPlcSubscriptionRequestBuilder) AddCyclicTag 

func (d *DefaultPlcSubscriptionRequestBuilder) AddCyclicTag(name string, tag apiModel.PlcSubscriptionTag, interval time.Duration) apiModel.PlcSubscriptionRequestBuilder

func (*DefaultPlcSubscriptionRequestBuilder) AddCyclicTagAddress 

func (d *DefaultPlcSubscriptionRequestBuilder) AddCyclicTagAddress(name string, tagAddress string, interval time.Duration) apiModel.PlcSubscriptionRequestBuilder

func (*DefaultPlcSubscriptionRequestBuilder) AddEventTag 

func (d *DefaultPlcSubscriptionRequestBuilder) AddEventTag(name string, tag apiModel.PlcSubscriptionTag) apiModel.PlcSubscriptionRequestBuilder

func (*DefaultPlcSubscriptionRequestBuilder) AddEventTagAddress 

func (d *DefaultPlcSubscriptionRequestBuilder) AddEventTagAddress(name string, tagAddress string) apiModel.PlcSubscriptionRequestBuilder

func (*DefaultPlcSubscriptionRequestBuilder) AddPreRegisteredConsumer 

func (d *DefaultPlcSubscriptionRequestBuilder) AddPreRegisteredConsumer(name string, consumer apiModel.PlcSubscriptionEventConsumer) apiModel.PlcSubscriptionRequestBuilder

func (*DefaultPlcSubscriptionRequestBuilder) Build 

func (d *DefaultPlcSubscriptionRequestBuilder) Build() (apiModel.PlcSubscriptionRequest, error)

func (*DefaultPlcSubscriptionRequestBuilder) Serialize 

func (d *DefaultPlcSubscriptionRequestBuilder) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionRequestBuilder) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionRequestBuilder) String 

func (d *DefaultPlcSubscriptionRequestBuilder) String() string

type DefaultPlcSubscriptionRequestResult 

type DefaultPlcSubscriptionRequestResult struct {
	Request  apiModel.PlcSubscriptionRequest
	Response apiModel.PlcSubscriptionResponse
	Err      error
}

func (*DefaultPlcSubscriptionRequestResult) GetErr 

func (d *DefaultPlcSubscriptionRequestResult) GetErr() error

func (*DefaultPlcSubscriptionRequestResult) GetRequest 

func (d *DefaultPlcSubscriptionRequestResult) GetRequest() apiModel.PlcSubscriptionRequest

func (*DefaultPlcSubscriptionRequestResult) GetResponse 

func (d *DefaultPlcSubscriptionRequestResult) GetResponse() apiModel.PlcSubscriptionResponse

func (*DefaultPlcSubscriptionRequestResult) Serialize 

func (d *DefaultPlcSubscriptionRequestResult) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionRequestResult) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionRequestResult) String 

func (d *DefaultPlcSubscriptionRequestResult) String() string

type DefaultPlcSubscriptionResponse 

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

func (*DefaultPlcSubscriptionResponse) GetRequest 

func (d *DefaultPlcSubscriptionResponse) GetRequest() apiModel.PlcSubscriptionRequest

func (*DefaultPlcSubscriptionResponse) GetResponseCode 

func (d *DefaultPlcSubscriptionResponse) GetResponseCode(name string) apiModel.PlcResponseCode

func (*DefaultPlcSubscriptionResponse) GetSubscriptionHandle 

func (d *DefaultPlcSubscriptionResponse) GetSubscriptionHandle(name string) (apiModel.PlcSubscriptionHandle, error)

func (*DefaultPlcSubscriptionResponse) GetSubscriptionHandles 

func (d *DefaultPlcSubscriptionResponse) GetSubscriptionHandles() []apiModel.PlcSubscriptionHandle

func (*DefaultPlcSubscriptionResponse) GetTagNames 

func (d *DefaultPlcSubscriptionResponse) GetTagNames() []string

func (*DefaultPlcSubscriptionResponse) IsAPlcMessage 

func (d *DefaultPlcSubscriptionResponse) IsAPlcMessage() bool

func (*DefaultPlcSubscriptionResponse) Serialize 

func (d *DefaultPlcSubscriptionResponse) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionResponse) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionResponse) String 

func (d *DefaultPlcSubscriptionResponse) String() string

type DefaultPlcSubscriptionResponseItem 

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

func NewDefaultPlcSubscriptionResponseItem 

func NewDefaultPlcSubscriptionResponseItem(code apiModel.PlcResponseCode, subscriptionHandle apiModel.PlcSubscriptionHandle) *DefaultPlcSubscriptionResponseItem

func (*DefaultPlcSubscriptionResponseItem) GetCode 

func (d *DefaultPlcSubscriptionResponseItem) GetCode() apiModel.PlcResponseCode

func (*DefaultPlcSubscriptionResponseItem) GetSubscriptionHandle 

func (d *DefaultPlcSubscriptionResponseItem) GetSubscriptionHandle() apiModel.PlcSubscriptionHandle

func (*DefaultPlcSubscriptionResponseItem) Serialize 

func (d *DefaultPlcSubscriptionResponseItem) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionResponseItem) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionResponseItem) String 

func (d *DefaultPlcSubscriptionResponseItem) String() string

type DefaultPlcSubscriptionTag 

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

func NewDefaultPlcSubscriptionTag 

func NewDefaultPlcSubscriptionTag(plcSubscriptionType apiModel.PlcSubscriptionType, plcTag apiModel.PlcTag, duration time.Duration) *DefaultPlcSubscriptionTag

func (*DefaultPlcSubscriptionTag) GetAddressString 

func (d *DefaultPlcSubscriptionTag) GetAddressString() string

func (*DefaultPlcSubscriptionTag) GetArrayInfo 

func (d *DefaultPlcSubscriptionTag) GetArrayInfo() []apiModel.ArrayInfo

func (*DefaultPlcSubscriptionTag) GetDuration 

func (d *DefaultPlcSubscriptionTag) GetDuration() time.Duration

func (*DefaultPlcSubscriptionTag) GetPlcSubscriptionType 

func (d *DefaultPlcSubscriptionTag) GetPlcSubscriptionType() apiModel.PlcSubscriptionType

func (*DefaultPlcSubscriptionTag) GetValueType 

func (d *DefaultPlcSubscriptionTag) GetValueType() apiValues.PlcValueType

func (*DefaultPlcSubscriptionTag) Serialize 

func (d *DefaultPlcSubscriptionTag) Serialize() ([]byte, error)

func (*DefaultPlcSubscriptionTag) SerializeWithWriteBuffer 

func (d *DefaultPlcSubscriptionTag) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcSubscriptionTag) String 

func (d *DefaultPlcSubscriptionTag) String() string

type DefaultPlcTagRequest 

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

func NewDefaultPlcTagRequest 

func NewDefaultPlcTagRequest(tags map[string]apiModel.PlcTag, tagNames []string) *DefaultPlcTagRequest

func (*DefaultPlcTagRequest) GetTag 

func (d *DefaultPlcTagRequest) GetTag(name string) apiModel.PlcTag

func (*DefaultPlcTagRequest) GetTagNames 

func (d *DefaultPlcTagRequest) GetTagNames() []string

func (*DefaultPlcTagRequest) IsAPlcMessage 

func (d *DefaultPlcTagRequest) IsAPlcMessage() bool

func (*DefaultPlcTagRequest) Serialize 

func (d *DefaultPlcTagRequest) Serialize() ([]byte, error)

func (*DefaultPlcTagRequest) SerializeWithWriteBuffer 

func (d *DefaultPlcTagRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcTagRequest) String 

func (d *DefaultPlcTagRequest) String() string

type DefaultPlcUnsubscriptionRequest 

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

func NewDefaultPlcUnsubscriptionRequest 

func NewDefaultPlcUnsubscriptionRequest(subscriptionHandles []apiModel.PlcSubscriptionHandle) *DefaultPlcUnsubscriptionRequest

func (*DefaultPlcUnsubscriptionRequest) Execute 

func (d *DefaultPlcUnsubscriptionRequest) Execute() <-chan apiModel.PlcUnsubscriptionRequestResult

func (*DefaultPlcUnsubscriptionRequest) ExecuteWithContext 

func (d *DefaultPlcUnsubscriptionRequest) ExecuteWithContext(ctx context.Context) <-chan apiModel.PlcUnsubscriptionRequestResult

func (*DefaultPlcUnsubscriptionRequest) GetSubscriptionHandles 

func (d *DefaultPlcUnsubscriptionRequest) GetSubscriptionHandles() []apiModel.PlcSubscriptionHandle

func (*DefaultPlcUnsubscriptionRequest) IsAPlcMessage 

func (d *DefaultPlcUnsubscriptionRequest) IsAPlcMessage() bool

func (*DefaultPlcUnsubscriptionRequest) Serialize 

func (d *DefaultPlcUnsubscriptionRequest) Serialize() ([]byte, error)

func (*DefaultPlcUnsubscriptionRequest) SerializeWithWriteBuffer 

func (d *DefaultPlcUnsubscriptionRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcUnsubscriptionRequest) String 

func (d *DefaultPlcUnsubscriptionRequest) String() string

type DefaultPlcUnsubscriptionRequestBuilder 

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

func NewDefaultPlcUnsubscriptionRequestBuilder 

func NewDefaultPlcUnsubscriptionRequestBuilder() *DefaultPlcUnsubscriptionRequestBuilder

func (*DefaultPlcUnsubscriptionRequestBuilder) AddHandles 

func (d *DefaultPlcUnsubscriptionRequestBuilder) AddHandles(subscriptionHandles ...apiModel.PlcSubscriptionHandle) apiModel.PlcUnsubscriptionRequestBuilder

func (*DefaultPlcUnsubscriptionRequestBuilder) Build 

func (d *DefaultPlcUnsubscriptionRequestBuilder) Build() (apiModel.PlcUnsubscriptionRequest, error)

func (*DefaultPlcUnsubscriptionRequestBuilder) Serialize 

func (d *DefaultPlcUnsubscriptionRequestBuilder) Serialize() ([]byte, error)

func (*DefaultPlcUnsubscriptionRequestBuilder) SerializeWithWriteBuffer 

func (d *DefaultPlcUnsubscriptionRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcUnsubscriptionRequestBuilder) String 

func (d *DefaultPlcUnsubscriptionRequestBuilder) String() string

type DefaultPlcUnsubscriptionRequestResult 

type DefaultPlcUnsubscriptionRequestResult struct {
	Request  apiModel.PlcUnsubscriptionRequest
	Response apiModel.PlcUnsubscriptionResponse
	Err      error
}

func (*DefaultPlcUnsubscriptionRequestResult) GetErr 

func (d *DefaultPlcUnsubscriptionRequestResult) GetErr() error

func (*DefaultPlcUnsubscriptionRequestResult) GetRequest 

func (d *DefaultPlcUnsubscriptionRequestResult) GetRequest() apiModel.PlcUnsubscriptionRequest

func (*DefaultPlcUnsubscriptionRequestResult) GetResponse 

func (d *DefaultPlcUnsubscriptionRequestResult) GetResponse() apiModel.PlcUnsubscriptionResponse

func (*DefaultPlcUnsubscriptionRequestResult) Serialize 

func (d *DefaultPlcUnsubscriptionRequestResult) Serialize() ([]byte, error)

func (*DefaultPlcUnsubscriptionRequestResult) SerializeWithWriteBuffer 

func (d *DefaultPlcUnsubscriptionRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcUnsubscriptionRequestResult) String 

func (d *DefaultPlcUnsubscriptionRequestResult) String() string

type DefaultPlcUnsubscriptionResponse 

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

func NewDefaultPlcUnsubscriptionResponse 

func NewDefaultPlcUnsubscriptionResponse(request apiModel.PlcUnsubscriptionRequest) *DefaultPlcUnsubscriptionResponse

func (*DefaultPlcUnsubscriptionResponse) GetRequest 

func (d *DefaultPlcUnsubscriptionResponse) GetRequest() apiModel.PlcUnsubscriptionRequest

func (*DefaultPlcUnsubscriptionResponse) Serialize 

func (d *DefaultPlcUnsubscriptionResponse) Serialize() ([]byte, error)

func (*DefaultPlcUnsubscriptionResponse) SerializeWithWriteBuffer 

func (d *DefaultPlcUnsubscriptionResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcUnsubscriptionResponse) String 

func (d *DefaultPlcUnsubscriptionResponse) String() string

type DefaultPlcWriteRequest 

type DefaultPlcWriteRequest struct {
	*DefaultPlcTagRequest
	// contains filtered or unexported fields
}

func (*DefaultPlcWriteRequest) Execute 

func (d *DefaultPlcWriteRequest) Execute() <-chan apiModel.PlcWriteRequestResult

func (*DefaultPlcWriteRequest) ExecuteWithContext 

func (d *DefaultPlcWriteRequest) ExecuteWithContext(ctx context.Context) <-chan apiModel.PlcWriteRequestResult

func (*DefaultPlcWriteRequest) ExecuteWithContextAndInterceptor 

func (d *DefaultPlcWriteRequest) ExecuteWithContextAndInterceptor(ctx context.Context) <-chan apiModel.PlcWriteRequestResult

func (*DefaultPlcWriteRequest) GetValue 

func (d *DefaultPlcWriteRequest) GetValue(name string) apiValues.PlcValue

func (*DefaultPlcWriteRequest) GetWriteRequestInterceptor 

func (d *DefaultPlcWriteRequest) GetWriteRequestInterceptor() interceptors.WriteRequestInterceptor

func (*DefaultPlcWriteRequest) GetWriter 

func (d *DefaultPlcWriteRequest) GetWriter() spi.PlcWriter

func (*DefaultPlcWriteRequest) Serialize 

func (d *DefaultPlcWriteRequest) Serialize() ([]byte, error)

func (*DefaultPlcWriteRequest) SerializeWithWriteBuffer 

func (d *DefaultPlcWriteRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcWriteRequest) String 

func (d *DefaultPlcWriteRequest) String() string

type DefaultPlcWriteRequestBuilder 

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

func (*DefaultPlcWriteRequestBuilder) AddTag 

func (m *DefaultPlcWriteRequestBuilder) AddTag(name string, tag apiModel.PlcTag, value any) apiModel.PlcWriteRequestBuilder

func (*DefaultPlcWriteRequestBuilder) AddTagAddress 

func (m *DefaultPlcWriteRequestBuilder) AddTagAddress(name string, tagAddress string, value any) apiModel.PlcWriteRequestBuilder

func (*DefaultPlcWriteRequestBuilder) Build 

func (m *DefaultPlcWriteRequestBuilder) Build() (apiModel.PlcWriteRequest, error)

func (*DefaultPlcWriteRequestBuilder) GetWriteRequestInterceptor 

func (m *DefaultPlcWriteRequestBuilder) GetWriteRequestInterceptor() interceptors.WriteRequestInterceptor

func (*DefaultPlcWriteRequestBuilder) GetWriter 

func (m *DefaultPlcWriteRequestBuilder) GetWriter() spi.PlcWriter

func (*DefaultPlcWriteRequestBuilder) Serialize 

func (d *DefaultPlcWriteRequestBuilder) Serialize() ([]byte, error)

func (*DefaultPlcWriteRequestBuilder) SerializeWithWriteBuffer 

func (d *DefaultPlcWriteRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcWriteRequestBuilder) String 

func (d *DefaultPlcWriteRequestBuilder) String() string

type DefaultPlcWriteRequestResult 

type DefaultPlcWriteRequestResult struct {
	Request  apiModel.PlcWriteRequest
	Response apiModel.PlcWriteResponse
	Err      error
}

func (*DefaultPlcWriteRequestResult) GetErr 

func (d *DefaultPlcWriteRequestResult) GetErr() error

func (*DefaultPlcWriteRequestResult) GetRequest 

func (d *DefaultPlcWriteRequestResult) GetRequest() apiModel.PlcWriteRequest

func (*DefaultPlcWriteRequestResult) GetResponse 

func (d *DefaultPlcWriteRequestResult) GetResponse() apiModel.PlcWriteResponse

func (*DefaultPlcWriteRequestResult) Serialize 

func (d *DefaultPlcWriteRequestResult) Serialize() ([]byte, error)

func (*DefaultPlcWriteRequestResult) SerializeWithWriteBuffer 

func (d *DefaultPlcWriteRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcWriteRequestResult) String 

func (d *DefaultPlcWriteRequestResult) String() string

type DefaultPlcWriteResponse 

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

func (*DefaultPlcWriteResponse) GetRequest 

func (d *DefaultPlcWriteResponse) GetRequest() apiModel.PlcWriteRequest

func (*DefaultPlcWriteResponse) GetResponseCode 

func (d *DefaultPlcWriteResponse) GetResponseCode(name string) apiModel.PlcResponseCode

func (*DefaultPlcWriteResponse) GetTagNames 

func (d *DefaultPlcWriteResponse) GetTagNames() []string

func (*DefaultPlcWriteResponse) IsAPlcMessage 

func (d *DefaultPlcWriteResponse) IsAPlcMessage() bool

func (*DefaultPlcWriteResponse) Serialize 

func (d *DefaultPlcWriteResponse) Serialize() ([]byte, error)

func (*DefaultPlcWriteResponse) SerializeWithWriteBuffer 

func (d *DefaultPlcWriteResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*DefaultPlcWriteResponse) String 

func (d *DefaultPlcWriteResponse) String() string

type PlcBrowseItem deprecated 

type PlcBrowseItem interface {
	apiModel.PlcBrowseItem
}

Deprecated: don't use it in productive code

type PlcBrowser deprecated 

type PlcBrowser interface {
	spi.PlcBrowser
}

Deprecated: don't use it in productive code

type PlcQuery deprecated 

type PlcQuery interface {
	apiModel.PlcQuery
}

Deprecated: don't use it in productive code

type PlcReader deprecated 

type PlcReader interface {
	spi.PlcReader
}

Deprecated: don't use it in productive code

type PlcResponseItem 

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

func NewPlcResponseItem 

func NewPlcResponseItem(code apiModel.PlcResponseCode, value values.PlcValue) *PlcResponseItem

func (*PlcResponseItem) GetCode 

func (r *PlcResponseItem) GetCode() apiModel.PlcResponseCode

func (*PlcResponseItem) GetValue 

func (r *PlcResponseItem) GetValue() values.PlcValue

func (*PlcResponseItem) Serialize 

func (d *PlcResponseItem) Serialize() ([]byte, error)

func (*PlcResponseItem) SerializeWithWriteBuffer 

func (d *PlcResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*PlcResponseItem) String 

func (d *PlcResponseItem) String() string

type PlcSubscriber deprecated 

type PlcSubscriber interface {
	spi.PlcSubscriber
}

Deprecated: don't use it in productive code

type PlcTag deprecated 

type PlcTag interface {
	apiModel.PlcTag
}

Deprecated: don't use it in productive code

type PlcTagHandler deprecated 

type PlcTagHandler interface {
	spi.PlcTagHandler
}

Deprecated: don't use it in productive code

type PlcValueHandler deprecated 

type PlcValueHandler interface {
	spi.PlcValueHandler
}

Deprecated: don't use it in productive code

type PlcWriter deprecated 

type PlcWriter interface {
	spi.PlcWriter
}

Deprecated: don't use it in productive code

type ReadRequestInterceptor deprecated 

type ReadRequestInterceptor interface {
	interceptors.ReadRequestInterceptor
}

Deprecated: don't use it in productive code

type WriteRequestInterceptor deprecated 

type WriteRequestInterceptor interface {
	interceptors.WriteRequestInterceptor
}

Deprecated: don't use it in productive code

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.