fanuc

Documentation

Index

• Constants
• func NewService(cfg *fanucService.Config, repo interfaces.Repository, producer *kafka.Producer, ...) interfaces.FanucService
• type Service
  • func (s *Service) CheckConnection(ctx context.Context, id string) (*entities.Machine, error)
  • func (s *Service) CreateConnection(ctx context.Context, req models.ConnectionRequest) (*entities.Machine, error)
  • func (s *Service) DeleteConnection(ctx context.Context, id string) error
  • func (s *Service) GetConnections(ctx context.Context) ([]entities.Machine, error)
  • func (s *Service) GetControlProgram(ctx context.Context, id string) (string, error)
  • func (s *Service) RestoreConnections() error
  • func (s *Service) StartPolling(ctx context.Context, machineID string, intervalMs int) error
  • func (s *Service) StopPolling(ctx context.Context, machineID string) error

Constants

const (
	HardConnectionTimeout = 5 * time.Second
	DefaultTimeout        = 5000
	DefaultUnknown        = "Unknown"
)

Functions

func NewService

func NewService(cfg *fanucService.Config, repo interfaces.Repository, producer *kafka.Producer, logger *logrus.Logger) interfaces.FanucService

Types

type Service

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

func (*Service) CheckConnection

func (s *Service) CheckConnection(ctx context.Context, id string) (*entities.Machine, error)

func (*Service) CreateConnection

func (s *Service) CreateConnection(ctx context.Context, req models.ConnectionRequest) (*entities.Machine, error)

func (*Service) DeleteConnection

func (s *Service) DeleteConnection(ctx context.Context, id string) error

func (*Service) GetConnections

func (s *Service) GetConnections(ctx context.Context) ([]entities.Machine, error)

func (*Service) GetControlProgram

func (s *Service) GetControlProgram(ctx context.Context, id string) (string, error)

func (*Service) RestoreConnections

func (s *Service) RestoreConnections() error

func (*Service) StartPolling

func (s *Service) StartPolling(ctx context.Context, machineID string, intervalMs int) error

func (*Service) StopPolling

func (s *Service) StopPolling(ctx context.Context, machineID string) error