Documentation
¶
Index ¶
- Variables
- type ErrDestinationServiceIdentNotFound
- type ErrDestinationServiceIdentOutOfRange
- type ErrRelayLinksUnreachable
- type ErrSourceServiceIdentNotFound
- type ErrSourceServiceIdentOutOfRange
- type MessageSwitch
- func (s *MessageSwitch) AddServiceProvider(textIdent string, serviceProvider qabalwrap.ServiceProvider) (err error)
- func (s *MessageSwitch) ReceiveMessage(spanEmitter *qabalwrap.TraceEmitter, m *qabalwrap.EnvelopedMessage) (err error)
- func (s *MessageSwitch) Setup(serviceInstIdent qabalwrap.ServiceInstanceIdentifier, ...) (err error)
- func (s *MessageSwitch) Start(ctx context.Context, waitGroup *sync.WaitGroup, ...) (err error)
- func (s *MessageSwitch) Stop()
- type ServiceReference
Constants ¶
This section is empty.
Variables ¶
var ErrNotHavingMessageSwitchServiceRecord = errors.New("cannot reach message switch service")
ErrNotHavingMessageSwitchServiceRecord indicate service record cannot be reach.
var ErrNotSupportedOperation = errors.New("request operation is not support")
ErrNotSupportedOperation indicate service is not support given request.
Functions ¶
This section is empty.
Types ¶
type ErrDestinationServiceIdentNotFound ¶
type ErrDestinationServiceIdentNotFound int
ErrDestinationServiceIdentNotFound indicate given destination service ident reference to non-existed service.
func (ErrDestinationServiceIdentNotFound) Error ¶
func (e ErrDestinationServiceIdentNotFound) Error() string
type ErrDestinationServiceIdentOutOfRange ¶
type ErrDestinationServiceIdentOutOfRange int
ErrDestinationServiceIdentOutOfRange indicate given destination service ident not in the valid range.
func (ErrDestinationServiceIdentOutOfRange) Error ¶
func (e ErrDestinationServiceIdentOutOfRange) Error() string
type ErrRelayLinksUnreachable ¶
type ErrRelayLinksUnreachable int
ErrRelayLinksUnreachable indicate all relay providers in given service ident not reachable.
func (ErrRelayLinksUnreachable) Error ¶
func (e ErrRelayLinksUnreachable) Error() string
type ErrSourceServiceIdentNotFound ¶
type ErrSourceServiceIdentNotFound int
ErrSourceServiceIdentNotFound indicate given source service ident reference to non-existed service.
func (ErrSourceServiceIdentNotFound) Error ¶
func (e ErrSourceServiceIdentNotFound) Error() string
type ErrSourceServiceIdentOutOfRange ¶
type ErrSourceServiceIdentOutOfRange int
ErrSourceServiceIdentOutOfRange indicate given source service ident not in the valid range.
func (ErrSourceServiceIdentOutOfRange) Error ¶
func (e ErrSourceServiceIdentOutOfRange) Error() string
type MessageSwitch ¶
type MessageSwitch struct {
qabalwrap.ServiceBase
// contains filtered or unexported fields
}
MessageSwitch provide message switching services.
func NewMessageSwitch ¶
func NewMessageSwitch( spanEmitter *qabalwrap.TraceEmitter, stateStore *qabalwrap.StateStore, diag *qabalwrap.DiagnosisEmitter, textIdent, dnCountry, dnOrganization string, primarySwitch bool) (s *MessageSwitch, err error)
NewMessageSwitch create new instance of MessageSwitch.
func (*MessageSwitch) AddServiceProvider ¶
func (s *MessageSwitch) AddServiceProvider(textIdent string, serviceProvider qabalwrap.ServiceProvider) (err error)
AddServiceProvider associate given service provider into message switch instance. Must only invoke at setup stage.
func (*MessageSwitch) ReceiveMessage ¶
func (s *MessageSwitch) ReceiveMessage(spanEmitter *qabalwrap.TraceEmitter, m *qabalwrap.EnvelopedMessage) (err error)
ReceiveMessage deliver message into this instance of service provider. The message should decypted before pass into this method.
func (*MessageSwitch) Setup ¶
func (s *MessageSwitch) Setup( serviceInstIdent qabalwrap.ServiceInstanceIdentifier, diagnosisEmitter *qabalwrap.DiagnosisEmitter, certProvider qabalwrap.CertificateProvider) (err error)
Setup prepare provider for operation. Should only invoke at maintenance thread in setup stage.
func (*MessageSwitch) Start ¶
func (s *MessageSwitch) Start(ctx context.Context, waitGroup *sync.WaitGroup, spanEmitter *qabalwrap.TraceEmitter) (err error)
func (*MessageSwitch) Stop ¶
func (s *MessageSwitch) Stop()
type ServiceReference ¶
type ServiceReference struct {
UniqueIdent uuid.UUID `json:"u"`
SerialIdent int `json:"i"`
TextIdent string `json:"t"`
PublicKey keybinary.ByteArray32 `json:"p"`
PrivateKey keybinary.ByteArray32 `json:"s"`
}
ServiceReference contains service identification and access keys.
func (*ServiceReference) IsNormalSerialIdent ¶
func (ref *ServiceReference) IsNormalSerialIdent() bool
IsNormalSerialIdent check if serial identifier value is located within assignable range.
Source Files
¶
- crossbar.go
- errors.go
- events.go
- keycache.go
- messagedispatcher.go
- messagesender.go
- messageswitch.go
- mhnd_allocate_service_idents_req.go
- mhnd_host_cert_assign.go
- mhnd_host_cert_req.go
- mhnd_known_service_ident_notify.go
- mhnd_root_cert_assign.go
- mhnd_root_cert_req.go
- relayindexset.go
- serviceconnect.go
- serviceref.go
- servicerelay.go