cache

Documentation

Index

• Constants
• type PlcConnectionCache
  • func NewPlcConnectionCache(driverManager plc4go.PlcDriverManager, ...) PlcConnectionCache
• type PlcConnectionCacheCloseResult
• type WithConnectionCacheOption
  • func WithCustomLogger(logger zerolog.Logger) WithConnectionCacheOption
  • func WithLogger(logger zerolog.Logger) WithConnectionCacheOption
  • func WithMaxLeaseTime(duration time.Duration) WithConnectionCacheOption
  • func WithMaxWaitTime(duration time.Duration) WithConnectionCacheOption
  • func WithTracer() WithConnectionCacheOption

Constants

const (
	StateInitialized cachedPlcConnectionState = iota
	StateIdle
	StateInUse
	StateInvalid
)

Types

type PlcConnectionCache

type PlcConnectionCache interface {
	GetConnection(connectionString string) <-chan plc4go.PlcConnectionConnectResult
	GetConnectionWithContext(ctx context.Context, connectionString string) <-chan plc4go.PlcConnectionConnectResult
	Close() <-chan PlcConnectionCacheCloseResult
}

func NewPlcConnectionCache

func NewPlcConnectionCache(driverManager plc4go.PlcDriverManager, withConnectionCacheOptions ...WithConnectionCacheOption) PlcConnectionCache

type PlcConnectionCacheCloseResult

type PlcConnectionCacheCloseResult interface {
	GetConnectionCache() PlcConnectionCache
	GetErr() error
}

type WithConnectionCacheOption

type WithConnectionCacheOption func(plcConnectionCache *plcConnectionCache)

func WithCustomLogger

func WithCustomLogger(logger zerolog.Logger) WithConnectionCacheOption

func WithLogger

func WithLogger(logger zerolog.Logger) WithConnectionCacheOption

Deprecated: use WithCustomLogger

func WithMaxLeaseTime

func WithMaxLeaseTime(duration time.Duration) WithConnectionCacheOption

func WithMaxWaitTime

func WithMaxWaitTime(duration time.Duration) WithConnectionCacheOption

func WithTracer

func WithTracer() WithConnectionCacheOption