ocpp

Documentation

Index

• Constants
• type CP
  • func NewChargePoint(log *util.Logger, id string, connector int, timeout time.Duration) *CP
  • func (cp *CP) Authorize(request *core.AuthorizeRequest) (*core.AuthorizeConfirmation, error)
  • func (cp *CP) BootNotification(request *core.BootNotificationRequest) (*core.BootNotificationConfirmation, error)
  • func (cp *CP) Connector() int
  • func (cp *CP) CurrentPower() (float64, error)
  • func (cp *CP) Currents() (float64, float64, float64, error)
  • func (cp *CP) DataTransfer(request *core.DataTransferRequest) (*core.DataTransferConfirmation, error)
  • func (cp *CP) DiagnosticStatusNotification(request *firmware.DiagnosticsStatusNotificationRequest) (*firmware.DiagnosticsStatusNotificationConfirmation, error)
  • func (cp *CP) FirmwareStatusNotification(request *firmware.FirmwareStatusNotificationRequest) (*firmware.FirmwareStatusNotificationConfirmation, error)
  • func (cp *CP) HasConnected() <-chan struct{}
  • func (cp *CP) Heartbeat(request *core.HeartbeatRequest) (*core.HeartbeatConfirmation, error)
  • func (cp *CP) ID() string
  • func (cp *CP) Initialized() error
  • func (cp *CP) MeterValues(request *core.MeterValuesRequest) (*core.MeterValuesConfirmation, error)
  • func (cp *CP) RegisterID(id string)
  • func (cp *CP) StartTransaction(request *core.StartTransactionRequest) (*core.StartTransactionConfirmation, error)
  • func (cp *CP) Status() (api.ChargeStatus, error)
  • func (cp *CP) StatusNotification(request *core.StatusNotificationRequest) (*core.StatusNotificationConfirmation, error)
  • func (cp *CP) StopTransaction(request *core.StopTransactionRequest) (*core.StopTransactionConfirmation, error)
  • func (cp *CP) TestClock(clock clock.Clock)
  • func (cp *CP) TotalEnergy() (float64, error)
  • func (cp *CP) TransactionID() (int, error)
  • func (cp *CP) WatchDog(timeout time.Duration)
• type CS
  • func Instance() *CS
  • func (cs *CS) ChargePointDisconnected(chargePoint ocpp16.ChargePointConnection)
  • func (cs *CS) Debug(args ...interface{})
  • func (cs *CS) Debugf(f string, args ...interface{})
  • func (cs *CS) Error(args ...interface{})
  • func (cs *CS) Errorf(f string, args ...interface{})
  • func (cs *CS) Info(args ...interface{})
  • func (cs *CS) Infof(f string, args ...interface{})
  • func (cs *CS) NewChargePoint(chargePoint ocpp16.ChargePointConnection)
  • func (cs *CS) OnAuthorize(id string, request *core.AuthorizeRequest) (*core.AuthorizeConfirmation, error)
  • func (cs *CS) OnBootNotification(id string, request *core.BootNotificationRequest) (*core.BootNotificationConfirmation, error)
  • func (cs *CS) OnDataTransfer(id string, request *core.DataTransferRequest) (*core.DataTransferConfirmation, error)
  • func (cs *CS) OnDiagnosticsStatusNotification(id string, request *firmware.DiagnosticsStatusNotificationRequest) (confirmation *firmware.DiagnosticsStatusNotificationConfirmation, err error)
  • func (cs *CS) OnFirmwareStatusNotification(id string, request *firmware.FirmwareStatusNotificationRequest) (confirmation *firmware.FirmwareStatusNotificationConfirmation, err error)
  • func (cs *CS) OnHeartbeat(id string, request *core.HeartbeatRequest) (*core.HeartbeatConfirmation, error)
  • func (cs *CS) OnMeterValues(id string, request *core.MeterValuesRequest) (*core.MeterValuesConfirmation, error)
  • func (cs *CS) OnStartTransaction(id string, request *core.StartTransactionRequest) (*core.StartTransactionConfirmation, error)
  • func (cs *CS) OnStatusNotification(id string, request *core.StatusNotificationRequest) (*core.StatusNotificationConfirmation, error)
  • func (cs *CS) OnStopTransaction(id string, request *core.StopTransactionRequest) (*core.StopTransactionConfirmation, error)
  • func (cs *CS) Register(id string, cp *CP) error
  • func (cs *CS) TriggerMessageRequest(id string, requestedMessage remotetrigger.MessageTrigger, ...)
  • func (cs *CS) TriggerMeterValuesRequest(id string, connector int)
  • func (cs *CS) TriggerResetRequest(id string, resetType core.ResetType)

Constants

const (
	// Core profile keys
	KeyNumberOfConnectors = "NumberOfConnectors"

	// Meter profile keys
	KeyMeterValuesSampledData   = "MeterValuesSampledData"
	KeyMeterValueSampleInterval = "MeterValueSampleInterval"

	// Smart Charging profile keys
	KeyChargeProfileMaxStackLevel              = "ChargeProfileMaxStackLevel"
	KeyChargingScheduleAllowedChargingRateUnit = "ChargingScheduleAllowedChargingRateUnit"
	KeyChargingScheduleMaxPeriods              = "ChargingScheduleMaxPeriods"
	KeyConnectorSwitch3to1PhaseSupported       = "ConnectorSwitch3to1PhaseSupported"
	KeyMaxChargingProfilesInstalled            = "MaxChargingProfilesInstalled"

	// Alfen specific keys
	KeyAlfenPlugAndChargeIdentifier = "PlugAndChargeIdentifier"
)

Types

type CP

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

func NewChargePoint

func NewChargePoint(log *util.Logger, id string, connector int, timeout time.Duration) *CP

func (*CP) Authorize

func (cp *CP) Authorize(request *core.AuthorizeRequest) (*core.AuthorizeConfirmation, error)

func (*CP) BootNotification

func (cp *CP) BootNotification(request *core.BootNotificationRequest) (*core.BootNotificationConfirmation, error)

func (*CP) Connector

func (cp *CP) Connector() int

func (*CP) CurrentPower

func (cp *CP) CurrentPower() (float64, error)

func (*CP) Currents

func (cp *CP) Currents() (float64, float64, float64, error)

func (*CP) DataTransfer

func (cp *CP) DataTransfer(request *core.DataTransferRequest) (*core.DataTransferConfirmation, error)

func (*CP) DiagnosticStatusNotification

func (cp *CP) DiagnosticStatusNotification(request *firmware.DiagnosticsStatusNotificationRequest) (*firmware.DiagnosticsStatusNotificationConfirmation, error)

func (*CP) FirmwareStatusNotification

func (cp *CP) FirmwareStatusNotification(request *firmware.FirmwareStatusNotificationRequest) (*firmware.FirmwareStatusNotificationConfirmation, error)

func (*CP) HasConnected

func (cp *CP) HasConnected() <-chan struct{}

func (*CP) Heartbeat

func (cp *CP) Heartbeat(request *core.HeartbeatRequest) (*core.HeartbeatConfirmation, error)

func (*CP) ID

func (cp *CP) ID() string

func (*CP) Initialized

func (cp *CP) Initialized() error

func (*CP) MeterValues

func (cp *CP) MeterValues(request *core.MeterValuesRequest) (*core.MeterValuesConfirmation, error)

func (*CP) RegisterID

func (cp *CP) RegisterID(id string)

func (*CP) StartTransaction

func (cp *CP) StartTransaction(request *core.StartTransactionRequest) (*core.StartTransactionConfirmation, error)

func (*CP) Status

func (cp *CP) Status() (api.ChargeStatus, error)

func (*CP) StatusNotification

func (cp *CP) StatusNotification(request *core.StatusNotificationRequest) (*core.StatusNotificationConfirmation, error)

func (*CP) StopTransaction

func (cp *CP) StopTransaction(request *core.StopTransactionRequest) (*core.StopTransactionConfirmation, error)

func (*CP) TestClock

func (cp *CP) TestClock(clock clock.Clock)

func (*CP) TotalEnergy

func (cp *CP) TotalEnergy() (float64, error)

func (*CP) TransactionID

func (cp *CP) TransactionID() (int, error)

TransactionID returns the current transaction id

func (*CP) WatchDog

func (cp *CP) WatchDog(timeout time.Duration)

WatchDog triggers meter values messages if older than timeout. Must be wrapped in a goroutine.

type CS

type CS struct {
	ocpp16.CentralSystem
	// contains filtered or unexported fields
}

func Instance

func Instance() *CS

func (*CS) ChargePointDisconnected

func (cs *CS) ChargePointDisconnected(chargePoint ocpp16.ChargePointConnection)

func (*CS) Debug

func (cs *CS) Debug(args ...interface{})

func (*CS) Debugf

func (cs *CS) Debugf(f string, args ...interface{})

func (*CS) Error

func (cs *CS) Error(args ...interface{})

func (*CS) Errorf

func (cs *CS) Errorf(f string, args ...interface{})

func (*CS) Info

func (cs *CS) Info(args ...interface{})

func (*CS) Infof

func (cs *CS) Infof(f string, args ...interface{})

func (*CS) NewChargePoint

func (cs *CS) NewChargePoint(chargePoint ocpp16.ChargePointConnection)

func (*CS) OnAuthorize

func (cs *CS) OnAuthorize(id string, request *core.AuthorizeRequest) (*core.AuthorizeConfirmation, error)

func (*CS) OnBootNotification

func (cs *CS) OnBootNotification(id string, request *core.BootNotificationRequest) (*core.BootNotificationConfirmation, error)

func (*CS) OnDataTransfer

func (cs *CS) OnDataTransfer(id string, request *core.DataTransferRequest) (*core.DataTransferConfirmation, error)

func (*CS) OnDiagnosticsStatusNotification

func (cs *CS) OnDiagnosticsStatusNotification(id string, request *firmware.DiagnosticsStatusNotificationRequest) (confirmation *firmware.DiagnosticsStatusNotificationConfirmation, err error)

func (*CS) OnFirmwareStatusNotification

func (cs *CS) OnFirmwareStatusNotification(id string, request *firmware.FirmwareStatusNotificationRequest) (confirmation *firmware.FirmwareStatusNotificationConfirmation, err error)

func (*CS) OnHeartbeat

func (cs *CS) OnHeartbeat(id string, request *core.HeartbeatRequest) (*core.HeartbeatConfirmation, error)

func (*CS) OnMeterValues

func (cs *CS) OnMeterValues(id string, request *core.MeterValuesRequest) (*core.MeterValuesConfirmation, error)

func (*CS) OnStartTransaction

func (cs *CS) OnStartTransaction(id string, request *core.StartTransactionRequest) (*core.StartTransactionConfirmation, error)

func (*CS) OnStatusNotification

func (cs *CS) OnStatusNotification(id string, request *core.StatusNotificationRequest) (*core.StatusNotificationConfirmation, error)

func (*CS) OnStopTransaction

func (cs *CS) OnStopTransaction(id string, request *core.StopTransactionRequest) (*core.StopTransactionConfirmation, error)

func (*CS) Register

func (cs *CS) Register(id string, cp *CP) error

Register registers a chargepoint with the central system. The chargepoint identified by id may already be connected in which case initial connection is triggered.

func (*CS) TriggerMessageRequest

func (cs *CS) TriggerMessageRequest(id string, requestedMessage remotetrigger.MessageTrigger, props ...func(request *remotetrigger.TriggerMessageRequest))

func (*CS) TriggerMeterValuesRequest

func (cs *CS) TriggerMeterValuesRequest(id string, connector int)

func (*CS) TriggerResetRequest

func (cs *CS) TriggerResetRequest(id string, resetType core.ResetType)