ocppj

package

Go to main page

Versions in this module

v0

v0.16.0

May 10, 2021

Changes in this version

type DefaultServerDispatcher

+ func (d *DefaultServerDispatcher) CreateClient(clientID string)

type ServerDispatcher

+ CreateClient func(clientID string)

v0.14.1

Apr 8, 2021

v0.14.0

Apr 8, 2021

v0.0.4

Apr 21, 2021

Changes in this version

type Client

+ RequestState ClientState

+ type ClientState interface

+ AddPendingRequest func(requestID string, req ocpp.Request)

+ ClearPendingRequests func()

+ DeletePendingRequest func(requestID string)

+ GetPendingRequest func(requestID string) (ocpp.Request, bool)

+ HasPendingRequest func() bool

+ func NewClientState() ClientState

type Server

+ RequestState ServerState

+ type ServerState interface

+ AddPendingRequest func(clientID string, requestID string, req ocpp.Request)

+ ClearAllPendingRequests func()

+ ClearClientPendingRequest func(clientID string)

+ DeletePendingRequest func(clientID string, requestID string)

+ GetClientState func(clientID string) ClientState

+ HasPendingRequest func(clientID string) bool

+ HasPendingRequests func() bool

+ func NewServerState(m *sync.RWMutex) ServerState

v0.0.3

Apr 16, 2021

v0.0.2

Apr 8, 2021

v0.0.1

Apr 8, 2021

Changes in this version

+ const FormationViolation

+ const GenericError

+ const InternalError

+ const MessageTypeNotSupported

+ const NotImplemented

+ const NotSupported

+ const OccurrenceConstraintViolation

+ const PropertyConstraintViolation

+ const ProtocolError

+ const SecurityError

+ const TypeConstraintViolation

+ var Validate = validator.New()

+ func IsErrorCodeValid(fl validator.FieldLevel) bool

+ func ParseJsonMessage(dataJson string) []interface

+ func ParseRawJsonMessage(dataJson []byte) []interface

+ func SetLogger(logger ocpp.Logger)

+ func SetMessageIdGenerator(generator func() string)

+ type Call struct

+ Action string

+ MessageTypeId MessageType

+ Payload ocpp.Request

+ UniqueId string

+ func (call *Call) GetMessageTypeId() MessageType

+ func (call *Call) GetUniqueId() string

+ func (call *Call) MarshalJSON() ([]byte, error)

+ type CallError struct

+ ErrorCode ocpp.ErrorCode

+ ErrorDescription string

+ ErrorDetails interface{}

+ MessageTypeId MessageType

+ UniqueId string

+ func (callError *CallError) GetMessageTypeId() MessageType

+ func (callError *CallError) GetUniqueId() string

+ func (callError *CallError) MarshalJSON() ([]byte, error)

+ type CallResult struct

+ MessageTypeId MessageType

+ Payload ocpp.Response

+ UniqueId string

+ func (callResult *CallResult) GetMessageTypeId() MessageType

+ func (callResult *CallResult) GetUniqueId() string

+ func (callResult *CallResult) MarshalJSON() ([]byte, error)

+ type Client struct

+ Id string

+ func NewClient(id string, wsClient ws.WsClient, dispatcher ClientDispatcher, ...) *Client

+ func (c *Client) SendError(requestId string, errorCode ocpp.ErrorCode, description string, ...) error

+ func (c *Client) SendRequest(request ocpp.Request) error

+ func (c *Client) SendResponse(requestId string, response ocpp.Response) error

+ func (c *Client) SetErrorHandler(handler func(err *ocpp.Error, details interface{}))

+ func (c *Client) SetRequestHandler(handler func(request ocpp.Request, requestId string, action string))

+ func (c *Client) SetResponseHandler(handler func(response ocpp.Response, requestId string))

+ func (c *Client) Start(serverURL string) error

+ func (c *Client) Stop()

+ type ClientDispatcher interface

+ CompleteRequest func(requestID string)

+ IsPaused func() bool

+ IsRunning func() bool

+ Pause func()

+ Resume func()

+ SendRequest func(req interface{}) error

+ SetNetworkClient func(client ws.WsClient)

+ SetOnRequestCanceled func(cb func(string))

+ SetPendingRequestState func(stateHandler PendingRequestState)

+ SetTimeout func(timeout time.Duration)

+ Start func()

+ Stop func()

+ type DefaultClientDispatcher struct

+ func NewDefaultClientDispatcher(queue RequestQueue) *DefaultClientDispatcher

+ func (d *DefaultClientDispatcher) AddPendingRequest(requestID string, req ocpp.Request)

+ func (d *DefaultClientDispatcher) ClearPendingRequests()

+ func (d *DefaultClientDispatcher) CompleteRequest(requestId string)

+ func (d *DefaultClientDispatcher) DeletePendingRequest(requestID string)

+ func (d *DefaultClientDispatcher) GetPendingRequest(requestID string) (ocpp.Request, bool)

+ func (d *DefaultClientDispatcher) HasPendingRequest() bool

+ func (d *DefaultClientDispatcher) IsPaused() bool

+ func (d *DefaultClientDispatcher) IsRunning() bool

+ func (d *DefaultClientDispatcher) Pause()

+ func (d *DefaultClientDispatcher) Resume()

+ func (d *DefaultClientDispatcher) SendRequest(req interface{}) error

+ func (d *DefaultClientDispatcher) SetNetworkClient(client ws.WsClient)

+ func (d *DefaultClientDispatcher) SetOnRequestCanceled(cb func(string))

+ func (d *DefaultClientDispatcher) SetPendingRequestState(_ PendingRequestState)

+ func (d *DefaultClientDispatcher) SetTimeout(timeout time.Duration)

+ func (d *DefaultClientDispatcher) Start()

+ func (d *DefaultClientDispatcher) Stop()

+ type DefaultServerDispatcher struct

+ func NewDefaultServerDispatcher(queueMap ServerQueueMap) *DefaultServerDispatcher

+ func (d *DefaultServerDispatcher) AddPendingRequest(requestID string, req ocpp.Request)

+ func (d *DefaultServerDispatcher) ClearPendingRequests()

+ func (d *DefaultServerDispatcher) CompleteRequest(clientID string, requestID string)

+ func (d *DefaultServerDispatcher) DeleteClient(clientID string)

+ func (d *DefaultServerDispatcher) DeletePendingRequest(requestID string)

+ func (d *DefaultServerDispatcher) GetPendingRequest(requestID string) (ocpp.Request, bool)

+ func (d *DefaultServerDispatcher) HasPendingRequest() bool

+ func (d *DefaultServerDispatcher) IsRunning() bool

+ func (d *DefaultServerDispatcher) SendRequest(clientID string, req RequestBundle) error

+ func (d *DefaultServerDispatcher) SetNetworkServer(server ws.WsServer)

+ func (d *DefaultServerDispatcher) SetOnRequestCanceled(cb func(string, string))

+ func (d *DefaultServerDispatcher) SetPendingRequestState(_ PendingRequestState)

+ func (d *DefaultServerDispatcher) Start()

+ func (d *DefaultServerDispatcher) Stop()

+ type Endpoint struct

+ PendingRequestState PendingRequestState

+ Profiles []*ocpp.Profile

+ func (endpoint *Endpoint) AddProfile(profile *ocpp.Profile)

+ func (endpoint *Endpoint) CreateCall(request ocpp.Request) (*Call, error)

+ func (endpoint *Endpoint) CreateCallError(uniqueId string, code ocpp.ErrorCode, description string, details interface{}) *CallError

+ func (endpoint *Endpoint) CreateCallResult(confirmation ocpp.Response, uniqueId string) (*CallResult, error)

+ func (endpoint *Endpoint) GetProfile(name string) (*ocpp.Profile, bool)

+ func (endpoint *Endpoint) GetProfileForFeature(featureName string) (*ocpp.Profile, bool)

+ func (endpoint *Endpoint) ParseMessage(arr []interface{}) (Message, *ocpp.Error)

+ type FIFOClientQueue struct

+ func NewFIFOClientQueue(capacity int) *FIFOClientQueue

+ func (q *FIFOClientQueue) Init()

+ func (q *FIFOClientQueue) IsEmpty() bool

+ func (q *FIFOClientQueue) IsFull() bool

+ func (q *FIFOClientQueue) Peek() interface{}

+ func (q *FIFOClientQueue) Pop() interface{}

+ func (q *FIFOClientQueue) Push(element interface{}) error

+ func (q *FIFOClientQueue) Size() int

+ type FIFOQueueMap struct

+ func NewFIFOQueueMap(clientQueueCapacity int) *FIFOQueueMap

+ func (f *FIFOQueueMap) Add(clientID string, queue RequestQueue)

+ func (f *FIFOQueueMap) Get(clientID string) (RequestQueue, bool)

+ func (f *FIFOQueueMap) GetOrCreate(clientID string) RequestQueue

+ func (f *FIFOQueueMap) Init()

+ func (f *FIFOQueueMap) Remove(clientID string)

+ type Message interface

+ GetMessageTypeId func() MessageType

+ GetUniqueId func() string

+ type MessageType int

+ const CALL

+ const CALL_ERROR

+ const CALL_RESULT

+ type PendingRequestState interface

+ AddPendingRequest func(requestID string, req ocpp.Request)

+ ClearPendingRequests func()

+ DeletePendingRequest func(requestID string)

+ GetPendingRequest func(requestID string) (ocpp.Request, bool)

+ HasPendingRequest func() bool

+ type RequestBundle struct

+ Call *Call

+ Data []byte

+ type RequestQueue interface

+ Init func()

+ IsEmpty func() bool

+ IsFull func() bool

+ Peek func() interface{}

+ Pop func() interface{}

+ Push func(element interface{}) error

+ Size func() int

+ type Server struct

+ func NewServer(wsServer ws.WsServer, dispatcher ServerDispatcher, ...) *Server

+ func (s *Server) SendError(clientID string, requestId string, errorCode ocpp.ErrorCode, ...) error

+ func (s *Server) SendRequest(clientID string, request ocpp.Request) error

+ func (s *Server) SendResponse(clientID string, requestId string, response ocpp.Response) error

+ func (s *Server) SetDisconnectedClientHandler(handler func(clientID string))

+ func (s *Server) SetErrorHandler(handler func(clientID string, err *ocpp.Error, details interface{}))

+ func (s *Server) SetNewClientHandler(handler func(clientID string))

+ func (s *Server) SetRequestHandler(...)

+ func (s *Server) SetResponseHandler(handler func(clientID string, response ocpp.Response, requestId string))

+ func (s *Server) Start(listenPort int, listenPath string)

+ func (s *Server) Stop()

+ type ServerDispatcher interface

+ CompleteRequest func(clientID string, requestID string)

+ DeleteClient func(clientID string)

+ IsRunning func() bool

+ SendRequest func(clientID string, req RequestBundle) error

+ SetNetworkServer func(server ws.WsServer)

+ SetOnRequestCanceled func(cb func(string, string))

+ SetPendingRequestState func(stateHandler PendingRequestState)

+ Start func()

+ Stop func()

+ type ServerQueueMap interface

+ Add func(clientID string, queue RequestQueue)

+ Get func(clientID string) (RequestQueue, bool)

+ GetOrCreate func(clientID string) RequestQueue

+ Init func()

+ Remove func(clientID string)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL