interceptors

Documentation

Index

• type PlcReadRequest
• type PlcReadRequestResult
• type PlcReadResponse
• type PlcWriteRequest
• type PlcWriteRequestResult
• type PlcWriteResponse
• type ReadRequestInterceptor
• type ReadRequestInterceptorExposer
• type ReaderExposer
• type RequestInterceptor
• type SingleItemRequestInterceptor
  • func NewSingleItemRequestInterceptor(readRequestFactory readRequestFactory, writeRequestFactory writeRequestFactory, ...) SingleItemRequestInterceptor
  • func (m SingleItemRequestInterceptor) InterceptReadRequest(ctx context.Context, readRequest apiModel.PlcReadRequest) []apiModel.PlcReadRequest
  • func (m SingleItemRequestInterceptor) InterceptWriteRequest(ctx context.Context, writeRequest apiModel.PlcWriteRequest) []apiModel.PlcWriteRequest
  • func (m SingleItemRequestInterceptor) ProcessReadResponses(ctx context.Context, readRequest apiModel.PlcReadRequest, ...) apiModel.PlcReadRequestResult
  • func (m SingleItemRequestInterceptor) ProcessWriteResponses(ctx context.Context, writeRequest apiModel.PlcWriteRequest, ...) apiModel.PlcWriteRequestResult
• type WriteRequestInterceptor
• type WriteRequestInterceptorExposer
• type WriterExposer

Types

type PlcReadRequest

type PlcReadRequest interface {
	apiModel.PlcReadRequest
	ReaderExposer
	ReadRequestInterceptorExposer
}

Deprecated: don't use it in productive code

type PlcReadRequestResult

type PlcReadRequestResult interface {
	apiModel.PlcReadRequestResult
}

Deprecated: don't use it in productive code

type PlcReadResponse

type PlcReadResponse interface {
	apiModel.PlcReadResponse
}

Deprecated: don't use it in productive code

type PlcWriteRequest

type PlcWriteRequest interface {
	apiModel.PlcWriteRequest
	WriterExposer
	WriteRequestInterceptorExposer
}

Deprecated: don't use it in productive code

type PlcWriteRequestResult

type PlcWriteRequestResult interface {
	apiModel.PlcWriteRequestResult
}

Deprecated: don't use it in productive code

type PlcWriteResponse

type PlcWriteResponse interface {
	apiModel.PlcWriteResponse
}

Deprecated: don't use it in productive code

type ReadRequestInterceptor

type ReadRequestInterceptor interface {
	InterceptReadRequest(ctx context.Context, readRequest apiModel.PlcReadRequest) []apiModel.PlcReadRequest
	ProcessReadResponses(ctx context.Context, readRequest apiModel.PlcReadRequest, readResults []apiModel.PlcReadRequestResult) apiModel.PlcReadRequestResult
}

type ReadRequestInterceptorExposer

type ReadRequestInterceptorExposer interface {
	GetReadRequestInterceptor() ReadRequestInterceptor
}

type ReaderExposer

type ReaderExposer interface {
	GetReader() spi.PlcReader
}

type RequestInterceptor

type RequestInterceptor interface {
	ReadRequestInterceptor
	WriteRequestInterceptor
}

type SingleItemRequestInterceptor

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

func NewSingleItemRequestInterceptor

func NewSingleItemRequestInterceptor(readRequestFactory readRequestFactory, writeRequestFactory writeRequestFactory, readResponseFactory readResponseFactory, writeResponseFactory writeResponseFactory, _options ...options.WithOption) SingleItemRequestInterceptor

func (SingleItemRequestInterceptor) InterceptReadRequest

func (m SingleItemRequestInterceptor) InterceptReadRequest(ctx context.Context, readRequest apiModel.PlcReadRequest) []apiModel.PlcReadRequest

func (SingleItemRequestInterceptor) InterceptWriteRequest

func (m SingleItemRequestInterceptor) InterceptWriteRequest(ctx context.Context, writeRequest apiModel.PlcWriteRequest) []apiModel.PlcWriteRequest

func (SingleItemRequestInterceptor) ProcessReadResponses

func (m SingleItemRequestInterceptor) ProcessReadResponses(ctx context.Context, readRequest apiModel.PlcReadRequest, readResults []apiModel.PlcReadRequestResult) apiModel.PlcReadRequestResult

func (SingleItemRequestInterceptor) ProcessWriteResponses

func (m SingleItemRequestInterceptor) ProcessWriteResponses(ctx context.Context, writeRequest apiModel.PlcWriteRequest, writeResults []apiModel.PlcWriteRequestResult) apiModel.PlcWriteRequestResult

type WriteRequestInterceptor

type WriteRequestInterceptor interface {
	InterceptWriteRequest(ctx context.Context, writeRequest apiModel.PlcWriteRequest) []apiModel.PlcWriteRequest
	ProcessWriteResponses(ctx context.Context, writeRequest apiModel.PlcWriteRequest, writeResults []apiModel.PlcWriteRequestResult) apiModel.PlcWriteRequestResult
}

type WriteRequestInterceptorExposer

type WriteRequestInterceptorExposer interface {
	GetWriteRequestInterceptor() WriteRequestInterceptor
}

type WriterExposer

type WriterExposer interface {
	GetWriter() spi.PlcWriter
}