pull

Documentation

Index

• type ModbusPuller
  • func NewModbusPuller(client *gorenogymodbus.ModbusClient, ...) *ModbusPuller
  • func (r *ModbusPuller) Close() error
  • func (r *ModbusPuller) Pull(ctx context.Context) error
• type Puller
• type RedisPuller
  • func NewRedisPuller(client *redis.RedisClient, queueName string, ...) *RedisPuller
  • func (r *RedisPuller) Close() error
  • func (r *RedisPuller) Pull(ctx context.Context) error

Types

type ModbusPuller

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

func NewModbusPuller

func NewModbusPuller(client *gorenogymodbus.ModbusClient, outChan chan gorenogymodbus.DynamicControllerInformation) *ModbusPuller

func (*ModbusPuller) Close

func (r *ModbusPuller) Close() error

func (*ModbusPuller) Pull

func (r *ModbusPuller) Pull(ctx context.Context) error

type Puller

type Puller interface {
	Pull(ctx context.Context) error
	Close() error
}

type RedisPuller

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

func NewRedisPuller

func NewRedisPuller(client *redis.RedisClient, queueName string, outChan chan gorenogymodbus.DynamicControllerInformation) *RedisPuller

func (*RedisPuller) Close

func (r *RedisPuller) Close() error

func (*RedisPuller) Pull

func (r *RedisPuller) Pull(ctx context.Context) error